| 234 | } |
| 235 | |
| 236 | void |
| 237 | CacheVC::reenable(VIO *avio) |
| 238 | { |
| 239 | DDbg(dbg_ctl_cache_reenable, "reenable %p", this); |
| 240 | #ifdef DEBUG |
| 241 | ink_assert(avio->mutex->thread_holding); |
| 242 | #endif |
| 243 | if (!trigger) { |
| 244 | #ifndef USELESS_REENABLES |
| 245 | if (vio.op == VIO::READ) { |
| 246 | if (vio.buffer.mbuf->max_read_avail() > vio.get_writer->water_mark) |
| 247 | ink_assert(!"useless reenable of cache read"); |
| 248 | } else if (!vio.get_reader()->read_avail()) |
| 249 | ink_assert(!"useless reenable of cache write"); |
| 250 | #endif |
| 251 | trigger = avio->mutex->thread_holding->schedule_imm_local(this); |
| 252 | } |
| 253 | } |
| 254 | |
| 255 | void |
| 256 | CacheVC::reenable_re(VIO *avio) |