Function transform_handler

plugins/experimental/icap/icap_plugin.cc:1062–1118

}

static int
transform_handler(TSCont contp, TSEvent event, void *edata)
{
  /* Check to see if the transformation has been closed by a call to TSVConnClose. */
  if (TSVConnClosedGet(contp)) {
    Dbg(dbg_ctl, "transformation closed");
    transform_destroy(contp);
    return 0;
  } else {
    TransformData *data;

    data = static_cast<TransformData *>(TSContDataGet(contp));
    if (data == nullptr) {
      TSError("[%s] Didn't get Continuation's Data, ignoring event", PLUGIN_NAME);
      return 0;
    }
    Dbg(dbg_ctl, "transform handler event [%d], data->state = [%d]", event, static_cast<int>(data->state));

    switch (data->state) {
    case State::BEGIN:
      transform_connect(contp, data);
      break;
    case State::CONNECT:
      transform_connect_event(contp, data, event, edata);
      break;
    case State::WRITE_HEADER:
      transform_write_header_event(contp, data, event, edata);
      break;
    case State::WRITE_BODY:
      transform_write_event(contp, data, event, edata);
      break;
    case State::READ_ICAP_HEADER:
      transform_read_icap_header_event(contp, data, event, edata);
      break;
    case State::READ_HTTP_HEADER:
      transform_read_http_header_event(contp, data, event, edata);
      break;
    case State::READ_HTTP_BODY:
      transform_read_http_body_event(contp, data, event, edata);
      break;
    case State::SEND_ERROR_MSG:
      transform_send_error_msg_event(contp, data, event, edata);
      break;
    case State::BYPASS:
      transform_bypass_event(contp, data, event, edata);
      break;
    case State::BUFFER_OS_RESP:
      transform_buffer_os_resp_event(contp, data, event, edata);
      break;
    case State::SEND_OS_RESP:
      transform_send_os_resp_event(contp, data, event, edata);
      break;
    }
  }

  return 0;
}