diff options
author | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-04-01 22:28:20 +0000 |
---|---|---|
committer | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-04-01 22:28:20 +0000 |
commit | cb2e028e51e283c10e8f26374b59e72b00f5b42a (patch) | |
tree | 1c8c16bf94f15353dfebdf885bfb239f8adf33fc /ace | |
parent | f6c79f8e3607098bf55c2f4d782f99dcfab2b554 (diff) | |
download | ATCD-cb2e028e51e283c10e8f26374b59e72b00f5b42a.tar.gz |
added dump () method
Diffstat (limited to 'ace')
-rw-r--r-- | ace/Reactor.cpp | 39 | ||||
-rw-r--r-- | ace/Reactor.h | 99 | ||||
-rw-r--r-- | ace/Reactor_Impl.h | 158 |
3 files changed, 154 insertions, 142 deletions
diff --git a/ace/Reactor.cpp b/ace/Reactor.cpp index 78f8940ae23..4c97be43438 100644 --- a/ace/Reactor.cpp +++ b/ace/Reactor.cpp @@ -39,13 +39,13 @@ ACE_Reactor::ACE_Reactor (ACE_Reactor_Impl *impl) this->delete_implementation_ = 1; } } - + ACE_Reactor::~ACE_Reactor (void) { if (this->delete_implementation_) delete this->implementation (); } - + // Process-wide ACE_Reactor. ACE_Reactor *ACE_Reactor::reactor_ = 0; @@ -65,13 +65,13 @@ ACE_Reactor::instance (void) { // Perform Double-Checked Locking Optimization. ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, - *ACE_Static_Object_Lock::instance (), 0)); - + *ACE_Static_Object_Lock::instance (), 0)); + if (ACE_Reactor::reactor_ == 0) - { - ACE_NEW_RETURN (ACE_Reactor::reactor_, ACE_Reactor, 0); - ACE_Reactor::delete_reactor_ = 1; - } + { + ACE_NEW_RETURN (ACE_Reactor::reactor_, ACE_Reactor, 0); + ACE_Reactor::delete_reactor_ = 1; + } } return ACE_Reactor::reactor_; } @@ -82,7 +82,7 @@ ACE_Reactor::instance (ACE_Reactor *r) ACE_TRACE ("ACE_Reactor::instance"); ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, - *ACE_Static_Object_Lock::instance (), 0)); + *ACE_Static_Object_Lock::instance (), 0)); ACE_Reactor *t = ACE_Reactor::reactor_; // We can't safely delete it since we don't know who created it! ACE_Reactor::delete_reactor_ = 0; @@ -97,7 +97,7 @@ ACE_Reactor::close_singleton (void) ACE_TRACE ("ACE_Reactor::close_singleton"); ACE_MT (ACE_GUARD (ACE_Recursive_Thread_Mutex, ace_mon, - *ACE_Static_Object_Lock::instance ())); + *ACE_Static_Object_Lock::instance ())); if (ACE_Reactor::delete_reactor_) { @@ -121,7 +121,7 @@ ACE_Reactor::run_event_loop (void) #if !defined (ACE_HAS_WINCE) if (ACE_Service_Config::reconfig_occurred ()) - ACE_Service_Config::reconfigure (); + ACE_Service_Config::reconfigure (); else #endif /* !ACE_HAS_WINCE */ @@ -147,8 +147,8 @@ ACE_Reactor::run_event_loop (ACE_Time_Value &tv) #if !defined (ACE_HAS_WINCE) if (ACE_Service_Config::reconfig_occurred ()) - ACE_Service_Config::reconfigure (); - else + ACE_Service_Config::reconfigure (); + else #endif /* !ACE_HAS_WINCE */ if (result <= 0) return result; @@ -172,7 +172,7 @@ ACE_Reactor::run_alertable_event_loop (void) #if !defined (ACE_HAS_WINCE) if (ACE_Service_Config::reconfig_occurred ()) - ACE_Service_Config::reconfigure (); + ACE_Service_Config::reconfigure (); else #endif /* !ACE_HAS_WINCE */ @@ -198,8 +198,8 @@ ACE_Reactor::run_alertable_event_loop (ACE_Time_Value &tv) #if !defined (ACE_HAS_WINCE) if (ACE_Service_Config::reconfig_occurred ()) - ACE_Service_Config::reconfigure (); - else + ACE_Service_Config::reconfigure (); + else #endif /* !ACE_HAS_WINCE */ if (result <= 0) return result; @@ -237,3 +237,10 @@ ACE_Reactor::event_loop_done (void) return ACE_Reactor::end_event_loop_ != 0; } +void +ACE_Reactor::dump (void) const +{ + ACE_TRACE ("ACE_Reactor::dump"); + + implementation_->dump (); +} diff --git a/ace/Reactor.h b/ace/Reactor.h index 527f52a2e46..fc7133d290e 100644 --- a/ace/Reactor.h +++ b/ace/Reactor.h @@ -98,9 +98,9 @@ public: // Close down and release all resources. virtual int open (size_t size, - int restart = 0, - ACE_Sig_Handler *signal_handler = 0, - ACE_Timer_Queue *timer_queue = 0); + int restart = 0, + ACE_Sig_Handler *signal_handler = 0, + ACE_Timer_Queue *timer_queue = 0); // Initialization. virtual int set_sig_handler (ACE_Sig_Handler *signal_handler); @@ -153,19 +153,19 @@ public: // = Register and remove Handlers. virtual int register_handler (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask); + ACE_Reactor_Mask mask); // Register <event_handler> with <mask>. The I/O handle will always // come from <get_handle> on the <event_handler>. virtual int register_handler (ACE_HANDLE io_handle, - ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask); + ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask); // Register <event_handler> with <mask>. The I/O handle is provided // through the <io_handle> parameter. #if defined (ACE_WIN32) virtual int register_handler (ACE_Event_Handler *event_handler, - ACE_HANDLE event_handle = ACE_INVALID_HANDLE); + ACE_HANDLE event_handle = ACE_INVALID_HANDLE); // Register an <event_handler> that will be notified when // <event_handle> is signaled. Since no event mask is passed // through this interface, it is assumed that the <event_handle> @@ -180,56 +180,56 @@ public: #endif /* ACE_WIN32 */ virtual int register_handler (ACE_HANDLE event_handle, - ACE_HANDLE io_handle, - ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask); + ACE_HANDLE io_handle, + ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask); // Register an <event_handler> that will be notified when // <event_handle> is signaled. <mask> specifies the network events // that the <event_handler> is interested in. virtual int register_handler (const ACE_Handle_Set &handles, - ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask); + ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask); // Register <event_handler> with all the <handles> in the <Handle_Set>. virtual int register_handler (int signum, - ACE_Event_Handler *new_sh, - ACE_Sig_Action *new_disp = 0, - ACE_Event_Handler **old_sh = 0, - ACE_Sig_Action *old_disp = 0); + ACE_Event_Handler *new_sh, + ACE_Sig_Action *new_disp = 0, + ACE_Event_Handler **old_sh = 0, + ACE_Sig_Action *old_disp = 0); // Register <new_sh> to handle the signal <signum> using the // <new_disp>. Returns the <old_sh> that was previously registered // (if any), along with the <old_disp> of the signal handler. virtual int register_handler (const ACE_Sig_Set &sigset, - ACE_Event_Handler *new_sh, - ACE_Sig_Action *new_disp = 0); + ACE_Event_Handler *new_sh, + ACE_Sig_Action *new_disp = 0); // Registers <new_sh> to handle a set of signals <sigset> using the // <new_disp>. virtual int remove_handler (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask); + ACE_Reactor_Mask mask); // Removes <event_handler>. Note that the I/O handle will be // obtained using <get_handle> method of <event_handler> . If // <mask> == <ACE_Event_Handler::DONT_CALL> then the <handle_close> // method of the <event_handler> is not invoked. virtual int remove_handler (ACE_HANDLE handle, - ACE_Reactor_Mask mask); + ACE_Reactor_Mask mask); // Removes <handle>. If <mask> == <ACE_Event_Handler::DONT_CALL> // then the <handle_close> method of the associated <event_handler> // is not invoked. virtual int remove_handler (const ACE_Handle_Set &handle_set, - ACE_Reactor_Mask mask); + ACE_Reactor_Mask mask); // Removes all handles in <handle_set>. If <mask> == // <ACE_Event_Handler::DONT_CALL> then the <handle_close> method of // the associated <event_handler>s is not invoked. virtual int remove_handler (int signum, - ACE_Sig_Action *new_disp, - ACE_Sig_Action *old_disp = 0, - int sigkey = -1); + ACE_Sig_Action *new_disp, + ACE_Sig_Action *old_disp = 0, + int sigkey = -1); // Remove the ACE_Event_Handler currently associated with <signum>. // Install the new disposition (if given) and return the previous // disposition (if desired by the caller). Returns 0 on success and @@ -269,9 +269,9 @@ public: // Timer management. virtual long schedule_timer (ACE_Event_Handler *event_handler, - const void *arg, - const ACE_Time_Value &delta, - const ACE_Time_Value &interval = ACE_Time_Value::zero); + const void *arg, + const ACE_Time_Value &delta, + const ACE_Time_Value &interval = ACE_Time_Value::zero); // Schedule an <event_handler> that will expire after <delay> amount // of time. If it expires then <arg> is passed in as the value to // the <event_handler>'s <handle_timeout> callback method. If @@ -287,13 +287,13 @@ public: // valid <timer_id>. virtual int cancel_timer (ACE_Event_Handler *event_handler, - int dont_call_handle_close = 1); + int dont_call_handle_close = 1); // Cancel all Event_Handlers that match the address of // <event_handler>. Returns number of handlers cancelled. virtual int cancel_timer (long timer_id, - const void **arg = 0, - int dont_call_handle_close = 1); + const void **arg = 0, + int dont_call_handle_close = 1); // Cancel the single Event_Handler that matches the <timer_id> value // (which was returned from the schedule method). If arg is // non-NULL then it will be set to point to the ``magic cookie'' @@ -305,28 +305,28 @@ public: // = High-level Event_Handler scheduling operations virtual int schedule_wakeup (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask masks_to_be_added); + ACE_Reactor_Mask masks_to_be_added); // Add <masks_to_be_added> to the <event_handler>'s entry. // <event_handler> must already have been registered. virtual int schedule_wakeup (ACE_HANDLE handle, - ACE_Reactor_Mask masks_to_be_added); + ACE_Reactor_Mask masks_to_be_added); // Add <masks_to_be_added> to the <handle>'s entry. <event_handler> // associated with <handle> must already have been registered. virtual int cancel_wakeup (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask masks_to_be_cleared); + ACE_Reactor_Mask masks_to_be_cleared); // Clear <masks_to_be_cleared> from the <event_handler>'s entry. virtual int cancel_wakeup (ACE_HANDLE handle, - ACE_Reactor_Mask masks_to_be_cleared); + ACE_Reactor_Mask masks_to_be_cleared); // Clear <masks_to_be_cleared> from the <handle>'s entry. // = Notification methods. virtual int notify (ACE_Event_Handler *event_handler = 0, - ACE_Reactor_Mask mask = ACE_Event_Handler::EXCEPT_MASK, - ACE_Time_Value *tv = 0); + ACE_Reactor_Mask mask = ACE_Event_Handler::EXCEPT_MASK, + ACE_Time_Value *tv = 0); // Notify <event_handler> of <mask> event. The <ACE_Time_Value> // indicates how long to blocking trying to notify. If <timeout> == // 0, the caller will block until action is possible, else will wait @@ -349,14 +349,14 @@ public: // <ACE_Message_Queue::dequeue> loop. virtual int handler (ACE_HANDLE handle, - ACE_Reactor_Mask mask, - ACE_Event_Handler **event_handler = 0); + ACE_Reactor_Mask mask, + ACE_Event_Handler **event_handler = 0); // Check to see if <handle> is associated with a valid Event_Handler // bound to <mask>. Return the <event_handler> associated with this // <handler> if <event_handler> != 0. virtual int handler (int signum, - ACE_Event_Handler **event_handler = 0); + ACE_Event_Handler **event_handler = 0); // Check to see if <signum> is associated with a valid Event_Handler // bound to a signal. Return the <event_handler> associated with // this <handler> if <event_handler> != 0. @@ -376,7 +376,7 @@ public: // Wake up all threads in waiting in the event loop virtual int owner (ACE_thread_t new_owner, - ACE_thread_t *old_owner = 0); + ACE_thread_t *old_owner = 0); // Transfers ownership of Reactor to the <new_owner>. virtual int owner (ACE_thread_t *owner); @@ -391,27 +391,27 @@ public: // = Low-level wait_set mask manipulation methods. virtual int mask_ops (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask, - int ops); + ACE_Reactor_Mask mask, + int ops); // GET/SET/ADD/CLR the dispatch mask "bit" bound with the // <event_handler> and <mask>. virtual int mask_ops (ACE_HANDLE handle, - ACE_Reactor_Mask mask, - int ops); + ACE_Reactor_Mask mask, + int ops); // GET/SET/ADD/CLR the dispatch MASK "bit" bound with the <handle> // and <mask>. // = Low-level ready_set mask manipulation methods. virtual int ready_ops (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask, - int ops); + ACE_Reactor_Mask mask, + int ops); // GET/SET/ADD/CLR the ready "bit" bound with the <event_handler> // and <mask>. virtual int ready_ops (ACE_HANDLE handle, - ACE_Reactor_Mask mask, - int ops); + ACE_Reactor_Mask mask, + int ops); // GET/SET/ADD/CLR the ready "bit" bound with the <handle> and <mask>. virtual ACE_Reactor_Impl *implementation (void); @@ -424,6 +424,9 @@ public: ACE_ALLOC_HOOK_DECLARE; // Declare the dynamic allocation hooks. + void dump (void) const; + // Dump the state of an object. + protected: virtual void implementation (ACE_Reactor_Impl *implementation); // Set the implementation class. diff --git a/ace/Reactor_Impl.h b/ace/Reactor_Impl.h index d3a9c18a701..f9ee3799041 100644 --- a/ace/Reactor_Impl.h +++ b/ace/Reactor_Impl.h @@ -1,18 +1,17 @@ /* -*- C++ -*- */ - // $Id$ // ============================================================================ // // = LIBRARY // ace -// +// // = FILENAME // Reactor_Impl.h // // = AUTHOR -// Irfan Pyarali -// +// Irfan Pyarali +// // ============================================================================ #if !defined (ACE_REACTOR_IMPL_H) @@ -39,12 +38,12 @@ class ACE_Export ACE_Reactor_Impl public: virtual ~ACE_Reactor_Impl (void) {}; // Close down and release all resources. - - virtual int open (size_t size, - int restart = 0, - ACE_Sig_Handler * = 0, - ACE_Timer_Queue * = 0) = 0; - // Initialization. + + virtual int open (size_t size, + int restart = 0, + ACE_Sig_Handler * = 0, + ACE_Timer_Queue * = 0) = 0; + // Initialization. virtual int set_sig_handler (ACE_Sig_Handler *signal_handler) = 0; // Use a user specified signal handler instead. @@ -55,7 +54,7 @@ public: virtual int close (void) = 0; // Close down and release all resources. - // = Event loop drivers. + // = Event loop drivers. virtual int handle_events (ACE_Time_Value *max_wait_time = 0) = 0; virtual int alertable_handle_events (ACE_Time_Value *max_wait_time = 0) = 0; @@ -70,7 +69,7 @@ public: // <max_wait_time> will equal 1 second. This can be used if an // application wishes to handle events for some fixed amount of // time. - // + // // Returns the total number of <ACE_Event_Handler>s that were // dispatched, 0 if the <max_wait_time> elapsed without dispatching // any handlers, or -1 if an error occurs. @@ -91,19 +90,19 @@ public: // return when the system queues an I/O completion routine or an // Asynchronous Procedure Call. - // = Register and remove Handlers. + // = Register and remove Handlers. virtual int register_handler (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask) = 0; + ACE_Reactor_Mask mask) = 0; // Register <event_handler> with <mask>. The I/O handle will always // come from <get_handle> on the <event_handler>. - - virtual int register_handler (ACE_HANDLE io_handle, - ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask) = 0; + + virtual int register_handler (ACE_HANDLE io_handle, + ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask) = 0; // Register <event_handler> with <mask>. The I/O handle is provided // through the <io_handle> parameter. - + #if defined (ACE_WIN32) // Originally this interface was available for all platforms, but @@ -113,8 +112,8 @@ public: // register_handler(ACE_Event_Handler*,ACE_HANDLE). Therefore, we // have restricted this method to Win32 only. - virtual int register_handler (ACE_Event_Handler *event_handler, - ACE_HANDLE event_handle = ACE_INVALID_HANDLE) = 0; + virtual int register_handler (ACE_Event_Handler *event_handler, + ACE_HANDLE event_handle = ACE_INVALID_HANDLE) = 0; // Register an <event_handler> that will be notified when // <event_handle> is signaled. Since no event mask is passed // through this interface, it is assumed that the <event_handle> @@ -123,56 +122,56 @@ public: #endif /* ACE_WIN32 */ virtual int register_handler (ACE_HANDLE event_handle, - ACE_HANDLE io_handle, - ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask) = 0; + ACE_HANDLE io_handle, + ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask) = 0; // Register an <event_handler> that will be notified when // <event_handle> is signaled. <mask> specifies the network events // that the <event_handler> is interested in. - + virtual int register_handler (const ACE_Handle_Set &handles, - ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask) = 0; + ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask) = 0; // Register <event_handler> with all the <handles> in the <Handle_Set>. - virtual int register_handler (int signum, - ACE_Event_Handler *new_sh, - ACE_Sig_Action *new_disp = 0, - ACE_Event_Handler **old_sh = 0, - ACE_Sig_Action *old_disp = 0) = 0; + virtual int register_handler (int signum, + ACE_Event_Handler *new_sh, + ACE_Sig_Action *new_disp = 0, + ACE_Event_Handler **old_sh = 0, + ACE_Sig_Action *old_disp = 0) = 0; // Register <new_sh> to handle the signal <signum> using the // <new_disp>. Returns the <old_sh> that was previously registered // (if any), along with the <old_disp> of the signal handler. - virtual int register_handler (const ACE_Sig_Set &sigset, - ACE_Event_Handler *new_sh, - ACE_Sig_Action *new_disp = 0) = 0; + virtual int register_handler (const ACE_Sig_Set &sigset, + ACE_Event_Handler *new_sh, + ACE_Sig_Action *new_disp = 0) = 0; // Registers <new_sh> to handle a set of signals <sigset> using the // <new_disp>. virtual int remove_handler (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask) = 0; + ACE_Reactor_Mask mask) = 0; // Removes <event_handler>. Note that the I/O handle will be // obtained using <get_handle> method of <event_handler> . If // <mask> == <ACE_Event_Handler::DONT_CALL> then the <handle_close> // method of the <event_handler> is not invoked. - virtual int remove_handler (ACE_HANDLE handle, - ACE_Reactor_Mask mask) = 0; + virtual int remove_handler (ACE_HANDLE handle, + ACE_Reactor_Mask mask) = 0; // Removes <handle>. If <mask> == <ACE_Event_Handler::DONT_CALL> // then the <handle_close> method of the associated <event_handler> // is not invoked. virtual int remove_handler (const ACE_Handle_Set &handle_set, - ACE_Reactor_Mask mask) = 0; + ACE_Reactor_Mask mask) = 0; // Removes all handles in <handle_set>. If <mask> == // <ACE_Event_Handler::DONT_CALL> then the <handle_close> method of // the associated <event_handler>s is not invoked. - virtual int remove_handler (int signum, - ACE_Sig_Action *new_disp, - ACE_Sig_Action *old_disp = 0, - int sigkey = -1) = 0; + virtual int remove_handler (int signum, + ACE_Sig_Action *new_disp, + ACE_Sig_Action *old_disp = 0, + int sigkey = -1) = 0; // Remove the ACE_Event_Handler currently associated with <signum>. // Install the new disposition (if given) and return the previous // disposition (if desired by the caller). Returns 0 on success and @@ -181,7 +180,7 @@ public: virtual int remove_handler (const ACE_Sig_Set &sigset) = 0; // Calls <remove_handler> for every signal in <sigset>. - // = Suspend and resume Handlers. + // = Suspend and resume Handlers. virtual int suspend_handler (ACE_Event_Handler *event_handler) = 0; // Suspend <event_handler> temporarily. Use @@ -194,17 +193,17 @@ public: // Suspend all <handles> in handle set temporarily. virtual int suspend_handlers (void) = 0; - // Suspend all <handles> temporarily. + // Suspend all <handles> temporarily. virtual int resume_handler (ACE_Event_Handler *event_handler) = 0; // Resume <event_handler>. Use <event_handler->get_handle()> to get // the handle. virtual int resume_handler (ACE_HANDLE handle) = 0; - // Resume <handle>. + // Resume <handle>. virtual int resume_handler (const ACE_Handle_Set &handles) = 0; - // Resume all <handles> in handle set. + // Resume all <handles> in handle set. virtual int resume_handlers (void) = 0; // Resume all <handles>. @@ -218,9 +217,9 @@ public: // Timer management. virtual long schedule_timer (ACE_Event_Handler *event_handler, - const void *arg, - const ACE_Time_Value &delta, - const ACE_Time_Value &interval = ACE_Time_Value::zero) = 0; + const void *arg, + const ACE_Time_Value &delta, + const ACE_Time_Value &interval = ACE_Time_Value::zero) = 0; // Schedule an <event_handler> that will expire after <delay> amount // of time. If it expires then <arg> is passed in as the value to // the <event_handler>'s <handle_timeout> callback method. If @@ -236,13 +235,13 @@ public: // valid <timer_id>. virtual int cancel_timer (ACE_Event_Handler *event_handler, - int dont_call_handle_close = 1) = 0; + int dont_call_handle_close = 1) = 0; // Cancel all Event_Handlers that match the address of // <event_handler>. Returns number of handlers cancelled. - virtual int cancel_timer (long timer_id, - const void **arg = 0, - int dont_call_handle_close = 1) = 0; + virtual int cancel_timer (long timer_id, + const void **arg = 0, + int dont_call_handle_close = 1) = 0; // Cancel the single Event_Handler that matches the <timer_id> value // (which was returned from the schedule method). If arg is // non-NULL then it will be set to point to the ``magic cookie'' @@ -252,30 +251,30 @@ public: // wasn't found. // = High-level Event_Handler scheduling operations - + virtual int schedule_wakeup (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask masks_to_be_added) = 0; + ACE_Reactor_Mask masks_to_be_added) = 0; // Add <masks_to_be_added> to the <event_handler>'s entry. // <event_handler> must already have been registered. - + virtual int schedule_wakeup (ACE_HANDLE handle, - ACE_Reactor_Mask masks_to_be_added) = 0; + ACE_Reactor_Mask masks_to_be_added) = 0; // Add <masks_to_be_added> to the <handle>'s entry. <event_handler> // associated with <handle> must already have been registered. virtual int cancel_wakeup (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask masks_to_be_cleared) = 0; + ACE_Reactor_Mask masks_to_be_cleared) = 0; // Clear <masks_to_be_cleared> from the <event_handler>'s entry. virtual int cancel_wakeup (ACE_HANDLE handle, - ACE_Reactor_Mask masks_to_be_cleared) = 0; + ACE_Reactor_Mask masks_to_be_cleared) = 0; // Clear <masks_to_be_cleared> from the <handle>'s entry. // = Notification methods. - virtual int notify (ACE_Event_Handler *event_handler = 0, - ACE_Reactor_Mask mask = ACE_Event_Handler::EXCEPT_MASK, - ACE_Time_Value * = 0) = 0; + virtual int notify (ACE_Event_Handler *event_handler = 0, + ACE_Reactor_Mask mask = ACE_Event_Handler::EXCEPT_MASK, + ACE_Time_Value * = 0) = 0; // Notify <event_handler> of <mask> event. The <ACE_Time_Value> // indicates how long to blocking trying to notify. If <timeout> == // 0, the caller will block until action is possible, else will wait @@ -298,14 +297,14 @@ public: // <ACE_Message_Queue::dequeue> loop. virtual int handler (ACE_HANDLE handle, - ACE_Reactor_Mask mask, - ACE_Event_Handler **event_handler = 0) = 0; + ACE_Reactor_Mask mask, + ACE_Event_Handler **event_handler = 0) = 0; // Check to see if <handle> is associated with a valid Event_Handler // bound to <mask>. Return the <event_handler> associated with this // <handler> if <event_handler> != 0. - virtual int handler (int signum, - ACE_Event_Handler ** = 0) = 0; + virtual int handler (int signum, + ACE_Event_Handler ** = 0) = 0; // Check to see if <signum> is associated with a valid Event_Handler // bound to a signal. Return the <event_handler> associated with // this <handler> if <event_handler> != 0. @@ -339,29 +338,32 @@ public: // = Low-level wait_set mask manipulation methods. virtual int mask_ops (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask, - int ops) = 0; + ACE_Reactor_Mask mask, + int ops) = 0; // GET/SET/ADD/CLR the dispatch mask "bit" bound with the // <event_handler> and <mask>. - virtual int mask_ops (ACE_HANDLE handle, - ACE_Reactor_Mask mask, - int ops) = 0; + virtual int mask_ops (ACE_HANDLE handle, + ACE_Reactor_Mask mask, + int ops) = 0; // GET/SET/ADD/CLR the dispatch MASK "bit" bound with the <handle> // and <mask>. // = Low-level ready_set mask manipulation methods. - virtual int ready_ops (ACE_Event_Handler *event_handler, - ACE_Reactor_Mask mask, - int ops) = 0; + virtual int ready_ops (ACE_Event_Handler *event_handler, + ACE_Reactor_Mask mask, + int ops) = 0; // GET/SET/ADD/CLR the ready "bit" bound with the <event_handler> // and <mask>. - virtual int ready_ops (ACE_HANDLE handle, - ACE_Reactor_Mask, - int ops) = 0; + virtual int ready_ops (ACE_HANDLE handle, + ACE_Reactor_Mask, + int ops) = 0; // GET/SET/ADD/CLR the ready "bit" bound with the <handle> and <mask>. + virtual void dump (void) const = 0; + // Dump the state of an object. + ACE_ALLOC_HOOK_DECLARE; // Declare the dynamic allocation hooks. }; |