| 364 | -------------------------------------------------------------------------*/ |
| 365 | |
| 366 | void |
| 367 | TransformTerminus::do_io_close(int error) |
| 368 | { |
| 369 | if (ink_atomic_increment(&m_event_count, 1) < 0) { |
| 370 | ink_assert(!"not reached"); |
| 371 | } |
| 372 | |
| 373 | INK_WRITE_MEMORY_BARRIER; |
| 374 | |
| 375 | if (error != -1) { |
| 376 | lerrno = error; |
| 377 | m_closed = TS_VC_CLOSE_ABORT; |
| 378 | } else { |
| 379 | m_closed = TS_VC_CLOSE_NORMAL; |
| 380 | } |
| 381 | |
| 382 | m_read_vio.op = VIO::NONE; |
| 383 | m_read_vio.buffer.clear(); |
| 384 | |
| 385 | m_write_vio.op = VIO::NONE; |
| 386 | m_write_vio.buffer.clear(); |
| 387 | |
| 388 | this_ethread()->schedule_imm_local(this); |
| 389 | } |
| 390 | |
| 391 | /*------------------------------------------------------------------------- |
| 392 | -------------------------------------------------------------------------*/ |
no test coverage detected