| 1892 | } |
| 1893 | |
| 1894 | void Scheduler::AssignmentCtx::PrintAssignment( |
| 1895 | const FragmentScanRangeAssignment& assignment) { |
| 1896 | VLOG_FILE << "Total remote scan volume = " |
| 1897 | << PrettyPrinter::Print(assignment_byte_counters_.remote_bytes, TUnit::BYTES); |
| 1898 | VLOG_FILE << "Total local scan volume = " |
| 1899 | << PrettyPrinter::Print(assignment_byte_counters_.local_bytes, TUnit::BYTES); |
| 1900 | VLOG_FILE << "Total cached scan volume = " |
| 1901 | << PrettyPrinter::Print(assignment_byte_counters_.cached_bytes, TUnit::BYTES); |
| 1902 | |
| 1903 | for (const FragmentScanRangeAssignment::value_type& entry : assignment) { |
| 1904 | VLOG_FILE << "ScanRangeAssignment: server=" << entry.first.DebugString(); |
| 1905 | for (const PerNodeScanRanges::value_type& per_node_scan_ranges : entry.second) { |
| 1906 | stringstream str; |
| 1907 | for (const ScanRangeParamsPB& params : per_node_scan_ranges.second) { |
| 1908 | str << params.DebugString() << " "; |
| 1909 | } |
| 1910 | VLOG_FILE << "node_id=" << per_node_scan_ranges.first << " ranges=" << str.str(); |
| 1911 | } |
| 1912 | } |
| 1913 | } |
| 1914 | |
| 1915 | void Scheduler::AddressableAssignmentHeap::InsertOrUpdate( |
| 1916 | const IpAddr& ip, int64_t assigned_bytes, int rank) { |
no test coverage detected