Method state_running

src/proxy/http/PreWarmManager.cc:702–749

}

int
PreWarmQueue::state_running(int event, void * /* data ATS_UNUSED */)
{
  switch (event) {
  case EVENT_INTERVAL: {
    for (auto &[dst, info] : _map) {
      // mentain queues
      _delete_closed_sm(info.init_list);
      _delete_closed_sm(info.open_list);

      // pre-warm new connections
      _prewarm_on_event_interval(dst, info);

      // set prewarmManager.stats
      Dbg(dbg_ctl_v_prewarm_q, "dst=%.*s:%d type=%d alpn=%d miss=%d hit=%d init=%d open=%d", (int)dst->host.size(),
          dst->host.data(), dst->port, (int)dst->type, dst->alpn_index, info.stat.miss, info.stat.hit, (int)info.init_list->size(),
          (int)info.open_list->size());

      auto &[counters, gauges] = *info.stats_ids;

      ts::Metrics::Gauge::store(gauges[static_cast<int>(PreWarm::GaugeStat::INIT_LIST_SIZE)], info.init_list->size());
      ts::Metrics::Gauge::store(gauges[static_cast<int>(PreWarm::GaugeStat::OPEN_LIST_SIZE)], info.open_list->size());
      ts::Metrics::Counter::increment(counters[static_cast<int>(PreWarm::CounterStat::HIT)], info.stat.hit);
      ts::Metrics::Counter::increment(counters[static_cast<int>(PreWarm::CounterStat::MISS)], info.stat.miss);

      // clear PreWarmQueue::Stat
      info.stat.miss = 0;
      info.stat.hit  = 0;
    }
    break;
  }
  case EVENT_IMMEDIATE: {
    _reconfigure();

    // reschedule tick event
    EThread *ethread = this_ethread();
    _tick_event->cancel();
    _tick_event = ethread->schedule_every_local(this, _event_period);

    break;
  }
  default:
    ink_abort("unsupported event=%s (%d)", get_vc_event_name(event), event);
    break;
  }

  return EVENT_DONE;
}

void
PreWarmQueue::push(const PreWarm::SPtrConstDst &dst, PreWarmSM *sm)