Method process_read_side

src/proxy/PluginVC.cc:601–639

void PluginVC::process_read_side() This function may only be called while holding this->mutex & while it is ok to callback the read side continuation Closes read state if other side write state is no longer available

//    write state is no longer available
//
void
PluginVC::process_read_side()
{
  ink_assert(!deletable);
  ink_assert(magic == PLUGIN_VC_MAGIC_ALIVE);

  Dbg(dbg_ctl_pvc, "[%u] %s: process_read_side", core_obj->id, PVC_TYPE);
  need_read_process = false;

  // Check read_state
  if (read_state.vio.cont == nullptr || read_state.vio.op != VIO::READ || closed || read_state.shutdown ||
      !read_state.vio.ntodo()) {
    return;
  }

  if (!other_side->closed && !other_side->write_state.shutdown) {
    if (other_side->write_state.vio.op != VIO::WRITE || other_side->write_state.shutdown) {
      // Just return, no touch on `other_side->need_write_process`.
      return;
    }
    // Acquire the lock of the write side continuation
    EThread *my_ethread = mutex->thread_holding;
    ink_assert(my_ethread != nullptr);
    MUTEX_TRY_LOCK(lock, other_side->write_state.vio.mutex, my_ethread);
    if (!lock.is_locked()) {
      Dbg(dbg_ctl_pvc_event, "[%u] %s: process_write_side from other side lock miss, retrying", other_side->core_obj->id,
          ((other_side->vc_type == PLUGIN_VC_ACTIVE) ? "Active" : "Passive"));

      // set need_write_process to enforce the write processing
      other_side->need_write_process = true;
      other_side->setup_event_cb(PVC_LOCK_RETRY_TIME, &other_side->core_lock_retry_event);
      return;
    }
    other_side->process_write_side();
  } else {
    Dbg(dbg_ctl_pvc, "[%u] %s: write_state of other side is not available", core_obj->id, PVC_TYPE);
    read_state.vio.cont->handleEvent(VC_EVENT_EOS, &read_state.vio);
  }
}

// void PluginVC::process_read_close()
//