| 311 | } |
| 312 | |
| 313 | int ReactorTask::close(u_long flags) |
| 314 | { |
| 315 | ACE_UNUSED_ARG(flags); |
| 316 | // This is called after the reactor threads exit. |
| 317 | // We should not set state here since we are not |
| 318 | // sure how many reactor threads we will use. |
| 319 | // If there is one reactor thread then we should |
| 320 | // set the state so the stop will not call |
| 321 | // end_reactor_event_loop. |
| 322 | // If there are multiple reactor threads, we still |
| 323 | // need call end_reactor_event_loop in stop() while |
| 324 | // one reactor thread already exited. |
| 325 | //MJM: Right. |
| 326 | |
| 327 | _remove_ref(); |
| 328 | return 0; |
| 329 | } |
| 330 | |
| 331 | void ReactorTask::stop() |
| 332 | { |
no test coverage detected