summaryrefslogtreecommitdiff
path: root/ace
diff options
context:
space:
mode:
authorlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-04-01 22:28:20 +0000
committerlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-04-01 22:28:20 +0000
commitcb2e028e51e283c10e8f26374b59e72b00f5b42a (patch)
tree1c8c16bf94f15353dfebdf885bfb239f8adf33fc /ace
parentf6c79f8e3607098bf55c2f4d782f99dcfab2b554 (diff)
downloadATCD-cb2e028e51e283c10e8f26374b59e72b00f5b42a.tar.gz
added dump () method
Diffstat (limited to 'ace')
-rw-r--r--ace/Reactor.cpp39
-rw-r--r--ace/Reactor.h99
-rw-r--r--ace/Reactor_Impl.h158
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.
};