| 425 | } |
| 426 | |
| 427 | void TAcceptQueueServer::InitMetrics(MetricGroup* metrics, const string& key_prefix) { |
| 428 | DCHECK(metrics != nullptr); |
| 429 | stringstream queue_size_ss; |
| 430 | queue_size_ss << key_prefix << ".connection-setup-queue-size"; |
| 431 | queue_size_metric_ = metrics->AddGauge(queue_size_ss.str(), 0); |
| 432 | stringstream timedout_cnxns_ss; |
| 433 | timedout_cnxns_ss << key_prefix << ".timedout-cnxn-requests"; |
| 434 | timedout_cnxns_metric_ = metrics->AddGauge(timedout_cnxns_ss.str(), 0); |
| 435 | const int max_histogram_value_us = 5 * 60 * MICROS_PER_SEC; |
| 436 | stringstream cnxns_setup_time_ss; |
| 437 | cnxns_setup_time_ss << key_prefix << ".connection-setup-time"; |
| 438 | cnxns_setup_time_us_metric_ = metrics->RegisterMetric(new HistogramMetric( |
| 439 | MetricDefs::Get(cnxns_setup_time_ss.str()), max_histogram_value_us, 1)); |
| 440 | stringstream thread_wait_time_ss; |
| 441 | thread_wait_time_ss << key_prefix << ".svc-thread-wait-time"; |
| 442 | thread_wait_time_us_metric_ = metrics->RegisterMetric(new HistogramMetric( |
| 443 | MetricDefs::Get(thread_wait_time_ss.str()), max_histogram_value_us, 1)); |
| 444 | metrics_enabled_ = true; |
| 445 | } |
| 446 | |
| 447 | } // namespace server |
| 448 | } // namespace thrift |
no test coverage detected