Function main_handler

plugins/regex_revalidate/regex_revalidate.cc:673–730

}

static int
main_handler(TSCont cont, TSEvent event, void *edata)
{
  TSHttpTxn       txn = (TSHttpTxn)edata;
  int             status;
  invalidate_t   *iptr   = NULL;
  plugin_state_t *pstate = NULL;

  time_t date = 0, now = 0;
  char  *url     = nullptr;
  int    url_len = 0;

  switch (event) {
  case TS_EVENT_HTTP_CACHE_LOOKUP_COMPLETE:
    if (TSHttpTxnCacheLookupStatusGet(txn, &status) == TS_SUCCESS) {
      if (status == TS_CACHE_LOOKUP_HIT_FRESH) {
        pstate = (plugin_state_t *)TSContDataGet(cont);
        iptr   = pstate->invalidate_list;
        while (iptr) {
          if (!date) {
            date = get_date_from_cached_hdr(txn);
            Dbg(dbg_ctl, "Cached Date header is: %jd", intmax_t(date));
            now = time(nullptr);
          }
          if (date <= iptr->epoch && now < iptr->expiry) {
            if (!url) {
              url = TSHttpTxnEffectiveUrlStringGet(txn, &url_len);
              Dbg(dbg_ctl, "Effective url is is '%.*s'", url_len, url);
            }
            if (pcre_exec(iptr->regex, iptr->regex_extra, url, url_len, 0, 0, nullptr, 0) >= 0) {
              Dbg(dbg_ctl, "Forced revalidate, Match with rule regex: '%s' epoch: %jd, expiry: %jd, result: '%s'", iptr->regex_text,
                  intmax_t(iptr->epoch), intmax_t(iptr->expiry), strForResult(iptr->new_result));
              TSHttpTxnCacheLookupStatusSet(txn, iptr->new_result);
              increment_stat(iptr->new_result);

              if (pstate->match_header) {
                add_header(txn, pstate->match_header, iptr);
              }
              iptr = nullptr;
            }
          }
          if (iptr) {
            iptr = iptr->next;
          }
        }
        if (url) {
          TSfree(url);
        }
      }
    }
    break;
  default:
    break;
  }

  TSHttpTxnReenable(txn, TS_EVENT_HTTP_CONTINUE);
  return 0;
}