Function DoRemap

plugins/multiplexer/ats-multiplexer.cc:105–175

}

void
DoRemap(const Instance &i, TSHttpTxn t)
{
  assert(t != nullptr);
  /*
  if (POST || PUT) {
    transformRequest
  }
  */
  TSMBuffer buffer;
  TSMLoc    location;

  CHECK(TSHttpTxnClientReqGet(t, &buffer, &location));

  assert(buffer != nullptr);
  assert(location != nullptr);

  int               method_length;
  const char *const method = TSHttpHdrMethodGet(buffer, location, &method_length);

  Dbg(dbg_ctl, "Method is %s.", std::string(method, method_length).c_str());

  // A value of -1 is used to indicate there was no Content-Length header.
  int content_length = -1;
  // Retrieve the value of the Content-Length header.
  auto field_loc = TSMimeHdrFieldFind(buffer, location, TS_MIME_FIELD_CONTENT_LENGTH, TS_MIME_LEN_CONTENT_LENGTH);
  if (field_loc != TS_NULL_MLOC) {
    content_length = TSMimeHdrFieldValueUintGet(buffer, location, field_loc, -1);
    TSHandleMLocRelease(buffer, location, field_loc);
  }
  bool const is_post_or_put = (method_length == TS_HTTP_LEN_POST && memcmp(TS_HTTP_METHOD_POST, method, TS_HTTP_LEN_POST) == 0) ||
                              (method_length == TS_HTTP_LEN_PUT && memcmp(TS_HTTP_METHOD_PUT, method, TS_HTTP_LEN_PUT) == 0);
  if (i.skipPostPut && is_post_or_put) {
    Dbg(dbg_ctl, "skip_post_put: skipping a POST or PUT request.");
  } else if (content_length < 0 && is_post_or_put) {
    // HttpSM would need an update for POST request transforms to support
    // chunked request bodies. It currently does not support this.
    Dbg(dbg_ctl, "Skipping a non-Content-Length POST or PUT request.");
  } else {
    {
      TSMLoc field;

      CHECK(TSMimeHdrFieldCreateNamed(buffer, location, "X-Multiplexer", 13, &field));
      assert(field != nullptr);

      CHECK(TSMimeHdrFieldValueStringSet(buffer, location, field, -1, "original", 8));

      CHECK(TSMimeHdrFieldAppend(buffer, location, field));

      CHECK(TSHandleMLocRelease(buffer, location, field));
    }

    Requests requests;
    generateRequests(i.origins, buffer, location, requests);
    assert(requests.size() == i.origins.size());

    if (is_post_or_put || content_length > 0) {
      const TSVConn vconnection = TSTransformCreate(handlePost, t);