Function globalHookHandler

plugins/esi/esi.cc:1518–1578

}

static int
globalHookHandler(TSCont contp, TSEvent event, void *edata)
{
  TSHttpTxn          txnp             = static_cast<TSHttpTxn>(edata);
  bool               intercept_header = false;
  bool               head_only        = false;
  bool               intercept_req    = isInterceptRequest(txnp);
  struct OptionInfo *pOptionInfo      = static_cast<OptionInfo *>(TSContDataGet(contp));

  switch (event) {
  case TS_EVENT_HTTP_READ_REQUEST_HDR:
    Dbg(dbg_ctl_local, "[%s] handling read request header event", __FUNCTION__);
    if (intercept_req) {
      if (!setupServerIntercept(txnp)) {
        TSError("[esi][%s] Could not setup server intercept", __FUNCTION__);
      } else {
        Dbg(dbg_ctl_local, "[%s] Setup server intercept", __FUNCTION__);
      }
    } else {
      Dbg(dbg_ctl_local, "[%s] Not setting up intercept", __FUNCTION__);
    }
    break;

  case TS_EVENT_HTTP_READ_RESPONSE_HDR:
  case TS_EVENT_HTTP_CACHE_LOOKUP_COMPLETE:
    if (!intercept_req) {
      if (event == TS_EVENT_HTTP_READ_RESPONSE_HDR) {
        bool mask_cache_headers = false;
        Dbg(dbg_ctl_local, "[%s] handling read response header event", __FUNCTION__);
        if (isTxnTransformable(txnp, false, pOptionInfo, &intercept_header, &head_only)) {
          addTransform(txnp, true, intercept_header, head_only, pOptionInfo);
          Stats::increment(Stats::N_OS_DOCS);
          mask_cache_headers = true;
        }
        if (pOptionInfo->packed_node_support && mask_cache_headers) {
          // we'll 'mask' OS cache headers so that traffic server will
          // not try to cache this. We cannot outright delete them
          // because we need them in our POST request; hence the 'masking'
          maskOsCacheHeaders(txnp);
        }
      } else {
        Dbg(dbg_ctl_local, "[%s] handling cache lookup complete event", __FUNCTION__);
        if (isCacheObjTransformable(txnp, pOptionInfo, &intercept_header, &head_only)) {
          // we make the assumption above that a transformable cache
          // object would already have a transformation. We should revisit
          // that assumption in case we change the statement below
          addTransform(txnp, false, intercept_header, head_only, pOptionInfo);
          Stats::increment(Stats::N_CACHE_DOCS);
        }
      }
    }
    break;

  default:
    Dbg(dbg_ctl_local, "[%s] Don't know how to handle event type %d", __FUNCTION__, event);
    break;
  }