Method do_io_read

src/proxy/Transform.cc:298–326

  -------------------------------------------------------------------------*/

VIO *
TransformTerminus::do_io_read(Continuation *c, int64_t nbytes, MIOBuffer *buf)
{
  m_read_vio.op = VIO::READ;
  m_read_vio.set_continuation(c);
  m_read_vio.nbytes    = nbytes;
  m_read_vio.ndone     = 0;
  m_read_vio.vc_server = this;

  if (buf != nullptr) {
    _read_disabled = false;
    m_read_vio.set_writer(buf);
    if (ink_atomic_increment(&m_event_count, 1) < 0) {
      ink_assert(!"not reached");
    }
    Dbg(dbg_ctl_transform, "[TransformTerminus::do_io_read] event_count %d", m_event_count);

    _read_event = this_ethread()->schedule_imm_local(this);
  } else {
    _read_disabled = true;
    if (_read_event != nullptr) {
      _read_event->cancel();
      _read_event = nullptr;
    }
    m_read_vio.buffer.clear();
  }

  return &m_read_vio;
}

/*-------------------------------------------------------------------------
  -------------------------------------------------------------------------*/