diff --git a/locator/token_metadata.cc b/locator/token_metadata.cc index 59bd298b71..8385c7facc 100644 --- a/locator/token_metadata.cc +++ b/locator/token_metadata.cc @@ -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() ? "" : printPendingRanges())); + logger.debug("Pending ranges: {}", (_pending_ranges.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); diff --git a/locator/token_metadata.hh b/locator/token_metadata.hh index 750ebc4e3e..09fee66a16 100644 --- a/locator/token_metadata.hh +++ b/locator/token_metadata.hh @@ -865,23 +865,9 @@ public: return sb.toString(); } - - private String printPendingRanges() - { - StringBuilder sb = new StringBuilder(); - - for (Map.Entry, InetAddress>> entry : _pending_ranges.entrySet()) - { - for (Map.Entry, 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 pending_endpoints_for(const token& token, const sstring& keyspace_name); #if 0 /**