| 1100 | } |
| 1101 | |
| 1102 | void Coordinator::BackendState::InstanceStatsToJson(Value* value, Document* document) { |
| 1103 | Value instance_stats(kArrayType); |
| 1104 | { |
| 1105 | lock_guard<mutex> l(lock_); |
| 1106 | DCHECK(exec_done_) << "May only be called after WaitOnExecRpc() completes."; |
| 1107 | for (const auto& elem : instance_stats_map_) { |
| 1108 | Value val(kObjectType); |
| 1109 | elem.second->ToJson(&val, document); |
| 1110 | instance_stats.PushBack(val, document->GetAllocator()); |
| 1111 | } |
| 1112 | } |
| 1113 | value->AddMember("instance_stats", instance_stats, document->GetAllocator()); |
| 1114 | |
| 1115 | // impalad_address is not protected by lock_. The lifetime of the backend state is |
| 1116 | // protected by Coordinator::lock_. |
| 1117 | Value val( |
| 1118 | NetworkAddressPBToString(impalad_address()), document->GetAllocator()); |
| 1119 | value->AddMember("host", val, document->GetAllocator()); |
| 1120 | } |
| 1121 | |
| 1122 | void Coordinator::BackendState::VLogForBackend(const string& msg) { |
| 1123 | VLOG_QUERY << "query_id=" << PrintId(query_id_) << " target backend=" << krpc_host_ |
no test coverage detected