Function add_header

plugins/regex_revalidate/regex_revalidate.cc:621–671

}

static void
add_header(TSHttpTxn txn, const char *const header, invalidate_t *const rule)
{
  TSMBuffer bufp     = NULL;
  TSMLoc    lochdr   = TS_NULL_MLOC;
  TSMLoc    locfield = TS_NULL_MLOC;
  char      rulestr[LINE_MAX];
  int       rulelen = 0;
  char      encstr[LINE_MAX];
  size_t    enclen = 0;

  TSReleaseAssert(header && rule);

  if (TS_SUCCESS != TSHttpTxnClientReqGet(txn, &bufp, &lochdr)) {
    Dbg(dbg_ctl, "Unable to get client request from transaction");
  }

  rulelen =
    snprintf(rulestr, sizeof(rulestr), "%s %jd %s", rule->regex_text, (intmax_t)rule->expiry, strForResult(rule->new_result));

  if (TS_SUCCESS != TSStringPercentEncode(rulestr, rulelen, encstr, sizeof(encstr), &enclen, NULL)) {
    Dbg(dbg_ctl, "Unable to get encode matching rule '%s'", rulestr);
    return;
  }

  locfield = TSMimeHdrFieldFind(bufp, lochdr, header, strlen(header));

  if (TS_NULL_MLOC == locfield) { // create header
    if (TS_SUCCESS == TSMimeHdrFieldCreateNamed(bufp, lochdr, header, strlen(header), &locfield)) {
      if (TS_SUCCESS == TSMimeHdrFieldValueStringSet(bufp, lochdr, locfield, -1, encstr, enclen)) {
        TSMimeHdrFieldAppend(bufp, lochdr, locfield);
        Dbg(dbg_ctl, "Added header %s: '%.*s'", header, (int)enclen, encstr);
      }
    }
    TSHandleMLocRelease(bufp, lochdr, locfield);
  } else { // replace header
    bool first = true;
    while (locfield) {
      const TSMLoc tmp = TSMimeHdrFieldNextDup(bufp, lochdr, locfield);
      if (first) {
        first = false;
        TSMimeHdrFieldValueStringSet(bufp, lochdr, locfield, -1, encstr, enclen);
        Dbg(dbg_ctl, "Added header '%s': '%.*s'", header, (int)enclen, encstr);
      } else {
        TSMimeHdrFieldDestroy(bufp, lochdr, locfield);
      }
      TSHandleMLocRelease(bufp, lochdr, locfield);
      locfield = tmp;
    }
  }
}

static int
main_handler(TSCont cont, TSEvent event, void *edata)