| 315 | } |
| 316 | |
| 317 | void |
| 318 | PluginVC::reenable(VIO *vio) |
| 319 | { |
| 320 | ink_assert(!closed); |
| 321 | ink_assert(magic == PLUGIN_VC_MAGIC_ALIVE); |
| 322 | ink_assert(vio->mutex->thread_holding == this_ethread()); |
| 323 | |
| 324 | Ptr<ProxyMutex> sm_mutex = vio->mutex; |
| 325 | SCOPED_MUTEX_LOCK(lock, sm_mutex, this_ethread()); |
| 326 | |
| 327 | Dbg(dbg_ctl_pvc, "[%u] %s: reenable %s", core_obj->id, PVC_TYPE, (vio->op == VIO::WRITE) ? "Write" : "Read"); |
| 328 | |
| 329 | if (vio->op == VIO::WRITE) { |
| 330 | ink_assert(vio == &write_state.vio); |
| 331 | need_write_process = true; |
| 332 | } else if (vio->op == VIO::READ) { |
| 333 | need_read_process = true; |
| 334 | } else { |
| 335 | ink_release_assert(0); |
| 336 | } |
| 337 | setup_event_cb(0, &sm_lock_retry_event); |
| 338 | } |
| 339 | |
| 340 | void |
| 341 | PluginVC::reenable_re(VIO *vio) |
no test coverage detected