Method response_buffer_handler

plugins/traffic_dump/transaction_data.cc:51–105

};

int
TransactionData::response_buffer_handler(TSCont contp, TSEvent event, void * /* edata ATS_UNUSED */)
{
  auto *txnData = reinterpret_cast<TransactionData *>(TSContDataGet(contp));
  // This should always have been set by the TransactionData creator of this Transform.
  TSAssert(txnData != nullptr);

  // If the virtual connection is closed, we're done.
  if (TSVConnClosedGet(contp)) {
    TSContDestroy(contp);
    return 0;
  }

  TSVIO input_vio = TSVConnWriteVIOGet(contp);

  switch (event) {
  case TS_EVENT_ERROR:
    Dbg(dbg_ctl, "Received an error event reading body data");
    TSContCall(TSVIOContGet(input_vio), TS_EVENT_ERROR, input_vio);
    break;
  case TS_EVENT_VCONN_READ_COMPLETE:
    break;
  case TS_EVENT_VCONN_READ_READY:
  case TS_EVENT_IMMEDIATE:
    // Look for data and if we find any, consume.
    if (TSVIOBufferGet(input_vio)) {
      TSIOBufferReader reader     = TSVIOReaderGet(input_vio);
      int64_t          read_avail = TSIOBufferReaderAvail(reader);
      if (read_avail > 0) {
        char response_buffer[read_avail];
        TSIOBufferReaderCopy(reader, response_buffer, read_avail);
        std::string_view response_bytes{response_buffer, (size_t)read_avail};
        txnData->_response_body.append(response_bytes);

        TSIOBufferReaderConsume(reader, read_avail);
        TSVIONDoneSet(input_vio, TSVIONDoneGet(input_vio) + read_avail);
        Dbg(dbg_ctl, "Consumed %" PRId64 " bytes of response body data", read_avail);
      }
      if (TSVIONTodoGet(input_vio) > 0) {
        // signal that we can accept more data.
        TSContCall(TSVIOContGet(input_vio), TS_EVENT_VCONN_WRITE_READY, input_vio);
      } else {
        TSContCall(TSVIOContGet(input_vio), TS_EVENT_VCONN_WRITE_COMPLETE, input_vio);
      }
    } else { // There is no buffer.
      TSError("[%s] upstream buffer disappeared while reading the response body.", debug_tag);
    }
    break;
  default:
    Dbg(dbg_ctl, "unhandled event %d", event);
    break;
  }

  return 0;
}

void
TransactionData::initialize_default_sensitive_field()