| 1905 | } |
| 1906 | |
| 1907 | void Coordinator::FInstanceStatsToJson(Document* doc) { |
| 1908 | DCHECK(exec_rpcs_complete_.Load()) << "Exec() must be called first"; |
| 1909 | Value states(kArrayType); |
| 1910 | { |
| 1911 | lock_guard<SpinLock> l(backend_states_init_lock_); |
| 1912 | for (BackendState* state : backend_states_) { |
| 1913 | Value val(kObjectType); |
| 1914 | state->InstanceStatsToJson(&val, doc); |
| 1915 | states.PushBack(val, doc->GetAllocator()); |
| 1916 | } |
| 1917 | } |
| 1918 | doc->AddMember("backend_instances", states, doc->GetAllocator()); |
| 1919 | } |
| 1920 | |
| 1921 | const TQueryCtx& Coordinator::query_ctx() const { |
| 1922 | return exec_params_.query_exec_request().query_ctx; |
no test coverage detected