Method httpConnect

src/proxy/FetchSM.cc:76–122

}

void
FetchSM::httpConnect()
{
  PluginIdentity *pi  = dynamic_cast<PluginIdentity *>(contp);
  const char     *tag = pi ? pi->getPluginTag() : "fetchSM";
  int64_t         id  = pi ? pi->getPluginId() : 0;

  Dbg(dbg_ctl, "[%s] calling httpconnect write pi=%p tag=%s id=%" PRId64, __FUNCTION__, pi, tag, id);
  TSHttpConnectOptions options{.connect_type      = TS_CONNECT_PLUGIN,
                               .addr              = &_addr.sa,
                               .tag               = tag,
                               .id                = id,
                               .buffer_index      = TS_IOBUFFER_SIZE_INDEX_32K,
                               .buffer_water_mark = TS_IOBUFFER_WATER_MARK_PLUGIN_VC_DEFAULT};
  http_vc = PluginHttpConnectInternal(&options);
  if (http_vc == nullptr) {
    Dbg(dbg_ctl, "Not ready to use");
    if (contp) {
      if (fetch_flags & TS_FETCH_FLAGS_STREAM) {
        return InvokePluginExt(TS_EVENT_ERROR);
      }
      InvokePlugin(callback_events.failure_event_id, nullptr);
    }
    cleanUp();
    return;
  }

  /*
   * TS-2906: We need a way to unset internal request when using FetchSM, the use case for this
   * is H2 when it creates outgoing requests it uses FetchSM and the outgoing requests
   * are spawned via H2 SYN packets which are definitely not internal requests.
   */
  if (!is_internal_request) {
    PluginVC *other_side = reinterpret_cast<PluginVC *>(http_vc)->get_other_side();
    if (other_side != nullptr) {
      other_side->set_is_internal_request(false);
    }
  }

  if (fetch_flags & TS_FETCH_FLAGS_SKIP_REMAP) {
    PluginVC *other_side = reinterpret_cast<PluginVC *>(http_vc)->get_other_side();
    other_side->set_is_unmanaged_request(true);
  }

  read_vio  = http_vc->do_io_read(this, INT64_MAX, resp_buffer);
  write_vio = http_vc->do_io_write(this, getReqLen() + req_content_length, req_reader);
}

char *
FetchSM::resp_get(int *length)