From 7a52d43a162b23d9e85e7b955e9b2c8e9caf550e Mon Sep 17 00:00:00 2001 From: "William R. Otte" Date: Mon, 24 Jul 2006 15:50:30 +0000 Subject: Repo restructuring --- ACE/ace/Reactor.inl | 101 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 101 insertions(+) create mode 100644 ACE/ace/Reactor.inl (limited to 'ACE/ace/Reactor.inl') diff --git a/ACE/ace/Reactor.inl b/ACE/ace/Reactor.inl new file mode 100644 index 00000000000..9b1344465ba --- /dev/null +++ b/ACE/ace/Reactor.inl @@ -0,0 +1,101 @@ +// -*- C++ -*- +// +// $Id$ + +// Run the event loop until the method +// returns -1 or the method is invoked. + +/* + * Hook to specialize the Reactor with the concrete implementation + * known at compile time. + */ +//@@ REACTOR_SPL_INCLUDE_FORWARD_DECL_ADD_HOOK + +ACE_BEGIN_VERSIONED_NAMESPACE_DECL + +ACE_INLINE int +ACE_Reactor::run_event_loop (void) +{ + ACE_TRACE ("ACE_Reactor::run_event_loop"); + ACE_Reactor *r = ACE_Reactor::instance (); + + if (r == 0) + return -1; + + return r->run_reactor_event_loop (ACE_Reactor::check_reconfiguration); +} + +// Run the event loop until the +// method returns -1, the method +// is invoked, or the expires. + +ACE_INLINE int +ACE_Reactor::run_event_loop (ACE_Time_Value &tv) +{ + ACE_TRACE ("ACE_Reactor::run_event_loop"); + ACE_Reactor *r = ACE_Reactor::instance (); + + if (r == 0) + return -1; + + return r->run_reactor_event_loop + (tv, ACE_Reactor::check_reconfiguration); +} + +// Run the event loop until the method +// returns -1 or the method is invoked. + +ACE_INLINE int +ACE_Reactor::run_alertable_event_loop (void) +{ + ACE_TRACE ("ACE_Reactor::run_alertable_event_loop"); + ACE_Reactor *r = ACE_Reactor::instance (); + + if (r == 0) + return -1; + + return r->run_alertable_reactor_event_loop (ACE_Reactor::check_reconfiguration); +} + +// Run the event loop until the +// method returns -1, the method +// is invoked, or the expires. + +ACE_INLINE int +ACE_Reactor::run_alertable_event_loop (ACE_Time_Value &tv) +{ + ACE_TRACE ("ACE_Reactor::run_alertable_event_loop"); + ACE_Reactor *r = ACE_Reactor::instance (); + + if (r == 0) + return -1; + + return r->run_alertable_reactor_event_loop + (tv, ACE_Reactor::check_reconfiguration); +} + +ACE_INLINE void +ACE_Reactor::reset_event_loop (void) +{ + ACE_TRACE ("ACE_Reactor::reset_event_loop"); + + ACE_Reactor::instance ()->reset_reactor_event_loop (); +} + +ACE_INLINE int +ACE_Reactor::end_event_loop (void) +{ + ACE_TRACE ("ACE_Reactor::end_event_loop"); + ACE_Reactor::instance ()->end_reactor_event_loop (); + + return 0; +} + +ACE_INLINE int +ACE_Reactor::event_loop_done (void) +{ + ACE_TRACE ("ACE_Reactor::event_loop_done"); + return ACE_Reactor::instance ()->reactor_event_loop_done (); +} + +ACE_END_VERSIONED_NAMESPACE_DECL -- cgit v1.2.1