| 83 | } |
| 84 | |
| 85 | void ReactorTask::cleanup() |
| 86 | { |
| 87 | reactor_wrapper_.close(); |
| 88 | #if defined (ACE_HAS_WIN32_OVERLAPPED_IO) || defined (ACE_HAS_AIO_CALLS) |
| 89 | if (proactor_) { |
| 90 | reactor_->remove_handler( |
| 91 | proactor_->implementation()->get_handle(), |
| 92 | ACE_Event_Handler::DONT_CALL); |
| 93 | delete proactor_; |
| 94 | proactor_ = 0; |
| 95 | } |
| 96 | #endif |
| 97 | |
| 98 | job_queue(JobQueue_rch()); |
| 99 | delete reactor_; |
| 100 | reactor_ = 0; |
| 101 | delete timer_queue_; |
| 102 | timer_queue_ = 0; |
| 103 | } |
| 104 | |
| 105 | int ReactorTask::init_reactor_task(ThreadStatusManager* thread_status_manager, |
| 106 | const String& name, |
nothing calls this directly
no test coverage detected