| 431 | } |
| 432 | |
| 433 | void ReactorTask::wait_until_empty() |
| 434 | { |
| 435 | GuardType guard(lock_); |
| 436 | while (reactor_notified_ || processing_) { |
| 437 | condition_.wait(*thread_status_manager_); |
| 438 | } |
| 439 | } |
| 440 | |
| 441 | int ReactorTask::handle_exception(ACE_HANDLE /*fd*/) |
| 442 | { |