Function txn_handler

tests/tools/plugins/http2_close_connection.cc:37–73

const int LEN_CLOSE      = 5;

static int
txn_handler(TSCont /* contp */, TSEvent event, void *edata)
{
  Dbg(dbg_ctl_tag, "txn_handler event: %d", event);

  TSHttpTxn txnp = static_cast<TSHttpTxn>(edata);

  TSMBuffer resp_bufp    = nullptr;
  TSMLoc    resp_hdr_loc = nullptr;
  if (TSHttpTxnClientRespGet(txnp, &resp_bufp, &resp_hdr_loc) != TS_SUCCESS) {
    Dbg(dbg_ctl_tag, "TSHttpTxnClientRespGet failed");
  } else {
    Dbg(dbg_ctl_tag, "TSHttpTxnClientRespGet success");
    TSMLoc field_loc = TSMimeHdrFieldFind(resp_bufp, resp_hdr_loc, FIELD_CONNECTION, LEN_CONNECTION);
    if (field_loc) {
      Dbg(dbg_ctl_tag, "Found header %s", FIELD_CONNECTION);
      TSMimeHdrFieldValueStringSet(resp_bufp, resp_hdr_loc, field_loc, 0, VALUE_CLOSE, LEN_CLOSE);
      Dbg(dbg_ctl_tag, "Setting header %s:%s", FIELD_CONNECTION, VALUE_CLOSE);
    } else {
      Dbg(dbg_ctl_tag, "Header %s not found", FIELD_CONNECTION);
      if (TSMimeHdrFieldCreate(resp_bufp, resp_hdr_loc, &field_loc) == TS_SUCCESS) {
        TSMimeHdrFieldNameSet(resp_bufp, resp_hdr_loc, field_loc, FIELD_CONNECTION, LEN_CONNECTION);
        TSMimeHdrFieldAppend(resp_bufp, resp_hdr_loc, field_loc);
        TSMimeHdrFieldValueStringInsert(resp_bufp, resp_hdr_loc, field_loc, 0, VALUE_CLOSE, LEN_CLOSE);
        Dbg(dbg_ctl_tag, "Adding header %s:%s", FIELD_CONNECTION, VALUE_CLOSE);
      } else {
        Dbg(dbg_ctl_tag, "TSMimeHdrFieldCreate failed");
      }
    }
    TSHandleMLocRelease(resp_bufp, resp_hdr_loc, field_loc);
  }
  TSHandleMLocRelease(resp_bufp, TS_NULL_MLOC, resp_hdr_loc);
  resp_bufp = nullptr;

  TSHttpTxnReenable(txnp, TS_EVENT_HTTP_CONTINUE);
  return TS_EVENT_NONE;
}

void
TSPluginInit(int /* argc ATS_UNUSED */, const char ** /* argv ATS_UNUSED */)