diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1998-03-13 01:40:21 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1998-03-13 01:40:21 +0000 |
| commit | 0482076b9fa3dc13acaca1497f592c56d099b2f1 (patch) | |
| tree | 2c6c83c069065bd1bbf8c3927f1960518b13bcf5 /ace/WFMO_Reactor.cpp | |
| parent | e918ba218ef7473a9e8409dc9b071591b7d30203 (diff) | |
| download | ATCD-0482076b9fa3dc13acaca1497f592c56d099b2f1.tar.gz | |
*** empty log message ***
Diffstat (limited to 'ace/WFMO_Reactor.cpp')
| -rw-r--r-- | ace/WFMO_Reactor.cpp | 58 |
1 files changed, 30 insertions, 28 deletions
diff --git a/ace/WFMO_Reactor.cpp b/ace/WFMO_Reactor.cpp index 3675b1ab8c5..04271a0f43b 100644 --- a/ace/WFMO_Reactor.cpp +++ b/ace/WFMO_Reactor.cpp @@ -1223,45 +1223,47 @@ ACE_WFMO_Reactor::upcall (ACE_Event_Handler *event_handler, { long actual_events = events.lNetworkEvents; - if (interested_events & actual_events & FD_READ) - if (event_handler->handle_input (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK); + if ((interested_events & actual_events & FD_READ) + && event_handler->handle_input (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK); - if (interested_events & actual_events & FD_CLOSE) - if (event_handler->handle_input (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK); + if ((interested_events & actual_events & FD_CLOSE) + && event_handler->handle_input (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK); - if (interested_events & actual_events & FD_WRITE) - if (event_handler->handle_output (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::WRITE_MASK); + if ((interested_events & actual_events & FD_WRITE) + && event_handler->handle_output (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::WRITE_MASK); - if (interested_events & actual_events & FD_OOB) - if (event_handler->handle_exception (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::EXCEPT_MASK); + if ((interested_events & actual_events & FD_OOB) + && event_handler->handle_exception (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::EXCEPT_MASK); - if (interested_events & actual_events & FD_ACCEPT) - if (event_handler->handle_input (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::ACCEPT_MASK); + if ((interested_events & actual_events & FD_ACCEPT) + && event_handler->handle_input (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::ACCEPT_MASK); if (interested_events & actual_events & FD_CONNECT) { if (events.iErrorCode[FD_CONNECT_BIT] == 0) - // Successful connect - if (event_handler->handle_output (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::CONNECT_MASK); - else - // Unsuccessful connect - if (event_handler->handle_input (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::CONNECT_MASK); + { + // Successful connect + if (event_handler->handle_output (io_handle) == -1) + ACE_SET_BITS (problems, + ACE_Event_Handler::CONNECT_MASK); + } + // Unsuccessful connect + else if (event_handler->handle_input (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::CONNECT_MASK); } - if (interested_events & actual_events & FD_QOS) - if (event_handler->handle_qos (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::QOS_MASK); + if ((interested_events & actual_events & FD_QOS) + && event_handler->handle_qos (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::QOS_MASK); - if (interested_events & actual_events & FD_GROUP_QOS) - if (event_handler->handle_group_qos (io_handle) == -1) - ACE_SET_BITS (problems, ACE_Event_Handler::GROUP_QOS_MASK); + if ((interested_events & actual_events & FD_GROUP_QOS) + && event_handler->handle_group_qos (io_handle) == -1) + ACE_SET_BITS (problems, ACE_Event_Handler::GROUP_QOS_MASK); } return problems; |