Function TEST_P

3rdparty/libprocess/src/tests/benchmarks.cpp:790–839

Tests the performance of metrics fetching when there are a large number of metrics.

// Tests the performance of metrics fetching when there
// are a large number of metrics.
TEST_P(Metrics_BENCHMARK_Test, Scalability)
{
  size_t metrics_count = GetParam();

  vector<metrics::Counter> counters;
  counters.reserve(metrics_count);

  for (size_t i = 0; i < metrics_count; ++i) {
    counters.push_back(
        metrics::Counter("metrics/keys/can/be/somewhat/long/"
                         "so/we/use/a/fairly/long/key/here/"
                         "to/test/a/more/pathological/case/" +
                         stringify(i)));
  }

  Stopwatch watch;
  watch.start();
  for (size_t i = 0; i < metrics_count; ++i) {
    metrics::add(counters[i]).get();
  }
  watch.stop();

  std::cout << "Added " << metrics_count << " counters in "
            << watch.elapsed() << std::endl;

  watch.start();
  metrics::snapshot(None()).get();
  watch.stop();

  std::cout << "Snapshot of " << metrics_count << " counters in "
              << watch.elapsed() << std::endl;

  UPID upid("metrics", process::address());

  watch.start();
  http::get(upid, "snapshot").get();
  watch.stop();

  std::cout << "HTTP /snapshot of " << metrics_count << " counters in "
              << watch.elapsed() << std::endl;

  watch.start();
  for (size_t i = 0; i < metrics_count; ++i) {
    metrics::remove(counters[i]).get();
  }
  watch.stop();

  std::cout << "Removed " << metrics_count << " counters in "
            << watch.elapsed() << std::endl;
}


TEST(ProcessTest, Process_BENCHMARK_MpscLinkedQueueEmpty)