Function schedule_handler

plugins/experimental/wasm/wasm_main.cc:300–371

handler for timer event

// handler for timer event
static int
schedule_handler(TSCont contp, TSEvent /*event*/, void * /*data*/)
{
  Dbg(ats_wasm::dbg_ctl, "[%s] Inside schedule_handler", __FUNCTION__);

  auto *c = static_cast<ats_wasm::Context *>(TSContDataGet(contp));

  auto *old_wasm = static_cast<ats_wasm::Wasm *>(c->wasm());
  TSMutexLock(old_wasm->mutex());

  c->onTick(0); // use 0 as  token

  if (wasm_config->configs.empty()) {
    TSError("[wasm][%s] Configuration objects are empty", __FUNCTION__);
    TSMutexUnlock(old_wasm->mutex());
    return 0;
  }

  bool found = false;
  for (auto it = wasm_config->configs.begin(); it != wasm_config->configs.end(); it++) {
    std::shared_ptr<ats_wasm::Wasm> wbp = it->first;
    if (wbp.get() == old_wasm) {
      found                    = true;
      auto    *wasm            = static_cast<ats_wasm::Wasm *>(c->wasm());
      uint32_t root_context_id = c->id();
      if (wasm->existsTimerPeriod(root_context_id)) {
        Dbg(ats_wasm::dbg_ctl, "[%s] reschedule continuation", __FUNCTION__);
        std::chrono::milliseconds period = wasm->getTimerPeriod(root_context_id);
        TSContScheduleOnPool(contp, static_cast<TSHRTime>(period.count()), TS_THREAD_POOL_NET);
      } else {
        Dbg(ats_wasm::dbg_ctl, "[%s] can't find period for root context id: %d", __FUNCTION__, root_context_id);
      }
      break;
    }
  }

  if (!found) {
    std::shared_ptr<ats_wasm::Wasm> temp            = nullptr;
    uint32_t                        root_context_id = c->id();
    old_wasm->removeTimerPeriod(root_context_id);

    if (old_wasm->readyShutdown()) {
      Dbg(ats_wasm::dbg_ctl, "[%s] starting WasmBase Shutdown", __FUNCTION__);
      old_wasm->startShutdown();
      if (!old_wasm->readyDelete()) {
        Dbg(ats_wasm::dbg_ctl, "[%s] not ready to delete WasmBase/PluginBase", __FUNCTION__);
      } else {
        Dbg(ats_wasm::dbg_ctl, "[%s] remove wasm from deleted_configs", __FUNCTION__);
        bool advance = true;
        for (auto it = wasm_config->deleted_configs.begin(); it != wasm_config->deleted_configs.end(); advance ? it++ : it) {
          advance = true;
          Dbg(ats_wasm::dbg_ctl, "[%s] looping through deleted_configs", __FUNCTION__);
          std::shared_ptr<ats_wasm::Wasm> wbp = it->first;
          temp                                = wbp;
          if (wbp.get() == old_wasm) {
            Dbg(ats_wasm::dbg_ctl, "[%s] found matching WasmBase", __FUNCTION__);
            it      = wasm_config->deleted_configs.erase(it);
            advance = false;