bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

token_metadata: Add get_pending_ranges_mm

Browse Source 
Helper for get_pending_ranges.
This commit is contained in:
Asias He
2015-10-10 16:37:44 +08:00
parent c96d826fe0
commit b860f6a393
2 changed files with 8 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
locator/token_metadata.cc
View File

@@ -328,6 +328,12 @@ range<token> token_metadata::get_primary_range_for(token right) {
return get_primary_ranges_for({right}).front();
}
std::unordered_multimap<range<token>, inet_address>&
token_metadata::get_pending_ranges_mm(sstring keyspace_name) {
return _pending_ranges[keyspace_name];
}
/////////////////// class topology /////////////////////////////////////////////
inline void topology::clear() {
_dc_endpoints.clear();

15
locator/token_metadata.hh
View File

@@ -653,20 +653,9 @@ public:
range<token> get_primary_range_for(token right);
private:
std::unordered_multimap<range<token>, inet_address>& get_pending_ranges_mm(sstring keyspace_name);
#if 0
private Multimap<Range<Token>, InetAddress> getPendingRangesMM(String keyspaceName)
{
Multimap<Range<Token>, InetAddress> map = _pending_ranges.get(keyspaceName);
if (map == null)
{
map = HashMultimap.create();
Multimap<Range<Token>, InetAddress> priorMap = _pending_ranges.putIfAbsent(keyspaceName, map);
if (priorMap != null)
map = priorMap;
}
return map;
}
/** a mutable map may be returned but caller should not modify it */
public Map<Range<Token>, Collection<InetAddress>> getPendingRanges(String keyspaceName)
{