Function EventMetricStatSync

src/iocore/eventsystem/UnixEventProcessor.cc:89–156

namespace
{
int
EventMetricStatSync(const char *, RecDataT, RecData *, RecRawStatBlock *rsb, int)
{
  using Graph = EThread::Metrics::Graph;

  int              id = 0;
  EThread::Metrics summary;

  // scan the thread local values
  for (EThread *t : eventProcessor.active_group_threads(ET_CALL)) {
    t->metrics.summarize(summary);
  }

  ink_mutex_acquire(&(rsb->mutex));

  // Update a specific enumerated stat.
  auto slice_stat_update = [=](EThread::Metrics::Slice::STAT_ID stat_id, int stat_idx, size_t value) {
    auto idx    = stat_idx + static_cast<unsigned>(stat_id);
    auto stat   = rsb->global[idx];
    stat->sum   = value;
    stat->count = 1;
    RecRawStatUpdateSum(rsb, idx);
  };

  // Enumerated stats are first - one set for each time scale.
  for (unsigned ts_idx = 0; ts_idx < EThread::Metrics::N_TIMESCALES; ++ts_idx, id += EThread::Metrics::Slice::N_STAT_ID) {
    using ID   = EThread::Metrics::Slice::STAT_ID;
    auto slice = summary._slice.data() + ts_idx;

    slice_stat_update(ID::LOOP_COUNT, id, slice->_count);
    slice_stat_update(ID::LOOP_WAIT, id, slice->_wait);
    slice_stat_update(ID::LOOP_TIME_MIN, id, slice->_duration._min);
    slice_stat_update(ID::LOOP_TIME_MAX, id, slice->_duration._max);
    slice_stat_update(ID::LOOP_EVENTS, id, slice->_events._total);
    slice_stat_update(ID::LOOP_EVENTS_MIN, id, slice->_events._min);
    slice_stat_update(ID::LOOP_EVENTS_MAX, id, slice->_events._max);
    slice_stat_update(ID::LOOP_DRAIN_QUEUE_MAX, id, slice->_duration._max_drain_queue);
    slice_stat_update(ID::LOOP_IO_WAIT_MAX, id, slice->_duration._max_io_wait);
    slice_stat_update(ID::LOOP_IO_WORK_MAX, id, slice->_duration._max_io_work);
  }

  // Next are the event loop histogram buckets.
  for (Graph::raw_type idx = 0; idx < Graph::N_BUCKETS; ++idx, ++id) {
    rsb->global[id]->sum   = summary._loop_timing[idx];
    rsb->global[id]->count = 1;
    RecRawStatUpdateSum(rsb, id);
  }

  // Last are the plugin API histogram buckets.
  for (Graph::raw_type idx = 0; idx < Graph::N_BUCKETS; ++idx, ++id) {
    rsb->global[id]->sum   = summary._api_timing[idx];
    rsb->global[id]->count = 1;
    RecRawStatUpdateSum(rsb, id);
  }

  // Check if it's time to schedule a decay of the histogram data.
  // Done here so that it's (roughly) synchronized across the ET_NET threads.
  // The decay is done in the local threads, this bumps a counter to indicate it should be done.