Method main_event_handler

src/proxy/http3/Http09App.cc:96–153

}

int
Http09App::main_event_handler(int event, Event *data)
{
  Dbg(dbg_ctl_v, "[%s] %s (%d)", this->_qc->cids().data(), get_vc_event_name(event), event);

  VIO                 *vio     = reinterpret_cast<VIO *>(data->cookie);
  QUICStreamVCAdapter *adapter = static_cast<QUICStreamVCAdapter *>(vio->vc_server);

  if (adapter == nullptr) {
    Dbg(dbg_ctl, "[%s] Unknown Stream", this->_qc->cids().data());
    return -1;
  }

  bool is_bidirectional = adapter->stream().is_bidirectional();

  QUICStreamId       stream_id = adapter->stream().id();
  Http09Transaction *txn       = static_cast<Http09Transaction *>(this->_ssn->get_transaction(stream_id));

  switch (event) {
  case VC_EVENT_READ_READY:
  case VC_EVENT_READ_COMPLETE:
    if (!is_bidirectional) {
      // FIXME Ignore unidirectional streams for now
      break;
    }

    if (txn == nullptr) {
      if (auto ret = this->_streams.find(stream_id); ret != this->_streams.end()) {
        txn = new Http09Transaction(this->_ssn, ret->second);
        SCOPED_MUTEX_LOCK(lock, txn->mutex, this_ethread());
        txn->new_transaction();
      } else {
        ink_assert(!"Stream info should exist");
      }
    } else {
      SCOPED_MUTEX_LOCK(lock, txn->mutex, this_ethread());
      txn->handleEvent(event);
    }
    break;
  case VC_EVENT_WRITE_READY:
  case VC_EVENT_WRITE_COMPLETE:
    if (txn != nullptr) {
      SCOPED_MUTEX_LOCK(lock, txn->mutex, this_ethread());
      txn->handleEvent(event);
    }
    break;
  case VC_EVENT_EOS:
  case VC_EVENT_ERROR:
  case VC_EVENT_INACTIVITY_TIMEOUT:
  case VC_EVENT_ACTIVE_TIMEOUT:
    ink_assert(false);
    break;
  default:
    break;
  }

  return EVENT_CONT;
}