diff options
author | nanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-07-29 18:05:02 +0000 |
---|---|---|
committer | nanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-07-29 18:05:02 +0000 |
commit | 55ed2880fe3dfe7d429273de0bba35b09711948e (patch) | |
tree | d9c06f29a03dac1db406f6b21ff60dc0d9ccb21b | |
parent | 5a879579e0ccad1ba62205a9c895113fb58d5029 (diff) | |
download | ATCD-55ed2880fe3dfe7d429273de0bba35b09711948e.tar.gz |
*** empty log message ***
-rw-r--r-- | ChangeLog-98b | 9 | ||||
-rw-r--r-- | ace/TP_Reactor.cpp | 26 |
2 files changed, 21 insertions, 14 deletions
diff --git a/ChangeLog-98b b/ChangeLog-98b index 962d3463d3a..fc6086d59b1 100644 --- a/ChangeLog-98b +++ b/ChangeLog-98b @@ -1,3 +1,12 @@ +Wed Jul 29 12:49:09 1998 Nanbor Wang <nanbor@cs.wustl.edu> + + * ace/Makefile (FILES): Added TP_Reactor to the build list. + Updated dependency. + + * ace/TP_Reactor.{h,i} (handle_events,notify_handler): Added two + dummy methods to avoid warnings from SunCC. Thanks to Carlos + for noticing this. + Wed Jul 29 09:41:23 1998 David L. Levine <levine@cs.wustl.edu> * ace/config-linux-common.h: added #define diff --git a/ace/TP_Reactor.cpp b/ace/TP_Reactor.cpp index aa4c00cc9f6..0bfb6608235 100644 --- a/ace/TP_Reactor.cpp +++ b/ace/TP_Reactor.cpp @@ -44,7 +44,7 @@ ACE_TP_Reactor::notify_handle (ACE_EH_Dispatch_Info &dispatch_info) if (event_handler == 0) return -1; - // Upcall + // Upcall int status = (event_handler->*callback) (handle); // If negative, remove from Reactor @@ -81,7 +81,7 @@ ACE_TP_Reactor::dispatch_io_set (int number_of_active_handles, { // ACE_DEBUG ((LM_DEBUG, ASYS_TEXT ("ACE_TP_Reactor::dispatching\n"))); number_dispatched++; - + // Remember this info this->dispatch_info_.set (handle, this->handler_rep_.find (handle), @@ -118,7 +118,7 @@ ACE_TP_Reactor::handle_events (ACE_Time_Value *max_wait_time) ACE_MT (result = this->token_.acquire_read (&ACE_TP_Reactor::no_op_sleep_hook)); if (result == -1) return -1; - + // We got the lock, lets handle some events. Note: this method will // *not* dispatch any handlers. It will dispatch timeouts and // signals. @@ -128,7 +128,7 @@ ACE_TP_Reactor::handle_events (ACE_Time_Value *max_wait_time) ACE_MT (this->token_.release ()); return -1; } - + // If there is any event handler that is ready to be dispatched, the // dispatch information is recorded in this->dispatch_info_. ACE_EH_Dispatch_Info dispatch_info; @@ -143,17 +143,17 @@ ACE_TP_Reactor::handle_events (ACE_Time_Value *max_wait_time) // Suspend the handler so that other thread don't start // dispatching it. - result = this->suspend_i (dispatch_info.handle_); + result = this->suspend_i (dispatch_info.handle_); if (result == -1) { ACE_MT (this->token_.release ()); return -1; - } + } } - + // Release the lock. Others threads can start waiting. ACE_MT (this->token_.release ()); - + // If there was an event handler ready, dispatch it. if (dispatch_info.dispatch ()) return this->notify_handle (dispatch_info); @@ -161,7 +161,7 @@ ACE_TP_Reactor::handle_events (ACE_Time_Value *max_wait_time) return result; } -void +void ACE_TP_Reactor::no_op_sleep_hook (void *) { } @@ -172,7 +172,7 @@ ACE_EH_Dispatch_Info::ACE_EH_Dispatch_Info (void) this->reset (); } -void +void ACE_EH_Dispatch_Info::set (ACE_HANDLE handle, ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask, @@ -186,7 +186,7 @@ ACE_EH_Dispatch_Info::set (ACE_HANDLE handle, this->callback_ = callback; } -void +void ACE_EH_Dispatch_Info::reset (void) { this->dispatch_ = 0; @@ -197,10 +197,8 @@ ACE_EH_Dispatch_Info::reset (void) this->callback_ = 0; } -int +int ACE_EH_Dispatch_Info::dispatch (void) const { return this->dispatch_; } - - |