mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-28 10:41:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

token_metadata: Add print_pending_ranges for debug print

Browse Source 
Signed-off-by: Pekka Enberg <penberg@scylladb.com>
This commit is contained in:
Asias He
2015-11-30 09:26:08 +08:00
committed by Pekka Enberg
parent 2c59e2f81f
commit aaca88a1e7
2 changed files with 17 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
locator/token_metadata.cc
View File

@@ -461,10 +461,23 @@ void token_metadata::calculate_pending_ranges(abstract_replication_strategy& str
_pending_ranges[keyspace_name] = std::move(new_pending_ranges);
if (logger.is_enabled(logging::log_level::debug)) {
// TODO: Enable printPendingRanges
// logger.debug("Pending ranges: {}", (_pending_ranges.empty() ? "<empty>" : printPendingRanges()));
logger.debug("Pending ranges: {}", (_pending_ranges.empty() ? "<empty>" : print_pending_ranges()));
}
}
sstring token_metadata::print_pending_ranges() {
std::stringstream ss;
for (auto& x : _pending_ranges) {
auto& keyspace_name = x.first;
ss << "\nkeyspace_name = " << keyspace_name << " {\n";
for (auto& m : x.second) {
ss << m.second << " : " << m.first << "\n";
}
ss << "}\n";
}
return sstring(ss.str());
}
void token_metadata::add_leaving_endpoint(inet_address endpoint) {
_leaving_endpoints.emplace(endpoint);

18
locator/token_metadata.hh
View File

@@ -865,23 +865,9 @@ public:
return sb.toString();
}
private String printPendingRanges()
{
StringBuilder sb = new StringBuilder();
for (Map.Entry<String, Multimap<Range<Token>, InetAddress>> entry : _pending_ranges.entrySet())
{
for (Map.Entry<Range<Token>, InetAddress> rmap : entry.getValue().entries())
{
sb.append(rmap.getValue()).append(":").append(rmap.getKey());
sb.append(System.getProperty("line.separator"));
}
}
return sb.toString();
}
#endif
sstring print_pending_ranges();
public:
std::vector<gms::inet_address> pending_endpoints_for(const token& token, const sstring& keyspace_name);
#if 0
/**