Function null_transform

tests/tools/plugins/tunnel_transform.cc:194–252

}

static int
null_transform(TSCont contp, TSEvent event, void * /* edata ATS_UNUSED */, bool forward)
{
  /* Check to see if the transformation has been closed by a call to
   * TSVConnClose.
   */
  Dbg(plugin_ctl, "Entering null_transform()");

  if (TSVConnClosedGet(contp)) {
    Dbg(plugin_ctl, "\tVConn is closed");
    my_data_destroy(static_cast<MyData *>(TSContDataGet(contp)));
    TSContDestroy(contp);
    return 0;
  } else {
    switch (event) {
    case TS_EVENT_ERROR: {
      TSVIO input_vio;

      TSStatIntIncrement(stat_error, 1);

      Dbg(plugin_ctl, "\tEvent is TS_EVENT_ERROR");
      /* Get the write VIO for the write operation that was
       * performed on ourself. This VIO contains the continuation of
       * our parent transformation. This is the input VIO.
       */
      input_vio = TSVConnWriteVIOGet(contp);

      /* Call back the write VIO continuation to let it know that we
       * have completed the write operation.
       */
      TSContCall(TSVIOContGet(input_vio), TS_EVENT_ERROR, input_vio);
    } break;
    case TS_EVENT_VCONN_WRITE_COMPLETE:
      Dbg(plugin_ctl, "\tEvent is TS_EVENT_VCONN_WRITE_COMPLETE");
      /* When our output connection says that it has finished
       * reading all the data we've written to it then we should
       * shutdown the write portion of its connection to
       * indicate that we don't want to hear about it anymore.
       */
      TSVConnShutdown(TSTransformOutputVConnGet(contp), 0, 1);
      break;

    /* If we get a WRITE_READY event or any other type of
     * event (sent, perhaps, because we were re-enabled) then
     * we'll attempt to transform more data.
     */
    case TS_EVENT_VCONN_WRITE_READY:
      Dbg(plugin_ctl, "\tEvent is TS_EVENT_VCONN_WRITE_READY");
      handle_transform(contp, forward);
      break;
    default:
      Dbg(plugin_ctl, "\t(event is %d)", event);
      handle_transform(contp, forward);
      break;
    }
  }

  return 0;