Function state_interface_with_server

example/plugins/c-api/protocol/TxnSM.cc:560–633

Call correct handler according to the vio type. */

/* Call correct handler according to the vio type. */
int
state_interface_with_server(TSCont contp, TSEvent event, TSVIO vio)
{
  TxnSM *txn_sm = static_cast<TxnSM *>(TSContDataGet(contp));

  Dbg(dbg_ctl, "enter state_interface_with_server");

  txn_sm->q_pending_action = nullptr;

  switch (event) {
  /* This is returned from cache_vc. */
  case TS_EVENT_VCONN_WRITE_READY:
  case TS_EVENT_VCONN_WRITE_COMPLETE:
    return state_write_to_cache(contp, event, vio);
  /* Otherwise, handle events from server. */
  case TS_EVENT_VCONN_READ_READY:
  /* Actually, we shouldn't get READ_COMPLETE because we set bytes
     count to be INT64_MAX. */
  case TS_EVENT_VCONN_READ_COMPLETE:
    return state_read_response_from_server(contp, event, vio);

  /* all data of the response come in. */
  case TS_EVENT_VCONN_EOS:
    Dbg(dbg_ctl, "get server eos");
    /* There is no more use of server_vc, close it. */
    if (txn_sm->q_server_vc) {
      TSVConnClose(txn_sm->q_server_vc);
      txn_sm->q_server_vc = nullptr;
    }
    txn_sm->q_server_read_vio  = nullptr;
    txn_sm->q_server_write_vio = nullptr;

    /* Check if the response is good */
    if (txn_sm->q_server_response_length == 0) {
      /* This is the bad response. Close client_vc. */
      if (txn_sm->q_client_vc) {
        TSVConnClose(txn_sm->q_client_vc);
        txn_sm->q_client_vc = nullptr;
      }
      txn_sm->q_client_read_vio  = nullptr;
      txn_sm->q_client_write_vio = nullptr;

      /* Close cache_vc as well. */
      if (txn_sm->q_cache_vc) {
        TSVConnClose(txn_sm->q_cache_vc);
        txn_sm->q_cache_vc = nullptr;
      }
      txn_sm->q_cache_write_vio = nullptr;
      return state_done(contp, TS_EVENT_NONE, nullptr);
    }

    if (txn_sm->q_cache_response_length >= txn_sm->q_server_response_length) {
      /* Write is complete, close the cache_vc. */
      TSVConnClose(txn_sm->q_cache_vc);
      txn_sm->q_cache_vc        = nullptr;
      txn_sm->q_cache_write_vio = nullptr;
      TSIOBufferReaderFree(txn_sm->q_cache_response_buffer_reader);