| 409 | -------------------------------------------------------------------------*/ |
| 410 | |
| 411 | void |
| 412 | TransformTerminus::reenable(VIO *vio) |
| 413 | { |
| 414 | ink_assert((vio == &m_read_vio) || (vio == &m_write_vio)); |
| 415 | |
| 416 | if (m_event_count == 0) { |
| 417 | if (ink_atomic_increment(&m_event_count, 1) < 0) { |
| 418 | ink_assert(!"not reached"); |
| 419 | } |
| 420 | Dbg(dbg_ctl_transform, "[TransformTerminus::reenable] event_count %d", m_event_count); |
| 421 | this_ethread()->schedule_imm_local(this); |
| 422 | } else { |
| 423 | Dbg(dbg_ctl_transform, "[TransformTerminus::reenable] skipping due to " |
| 424 | "pending events"); |
| 425 | } |
| 426 | } |
| 427 | |
| 428 | /*------------------------------------------------------------------------- |
| 429 | -------------------------------------------------------------------------*/ |
no test coverage detected