ChangeLogTag:Wed Feb 18 17:56:54 1998 Carlos O'Ryan <coryan@cs.wustl.edu>

1 files changed, 76 insertions, 0 deletions

diff --git a/TAO/orbsvcs/orbsvcs/Event/ReactorTask.h b/TAO/orbsvcs/orbsvcs/Event/ReactorTask.h
new file mode 100644
index 00000000000..973d6f82f97
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Event/ReactorTask.h
@@ -0,0 +1,76 @@
+// $Id$
+
+#if !defined ACE_ReactorTask_H
+#define ACE_ReactorTask_H
+
+// BBM, moved this here from UPSingleProcessorOrb.h
+//## begin module.includes preserve=yes
+#include "Fast_Reactor.h"
+#if defined (ACE_OLD_STYLE_REACTOR)
+# define ACE_ORB_REACTOR ACE_ES_Fast_Reactor
+#endif /* ACE_OLD_STYLE_REACTOR */
+//## end module.includes
+
+// Added these.
+#include "ace/Timer_Heap.h"
+#include "ace/Timer_List.h"
+
+#include "Local_ESTypes.h"
+#include "RT_Task.h"
+
+class ACE_ES_Reactor_Task : public ACE_RT_Task
+// = TITLE
+//    Event Service Timer Task
+//
+// = DESCRIPTION
+//    An active object that dispatches timers from its own ReactorEx.
+{
+public:
+  // BBM, added this.
+#if defined (ACE_OLD_STYLE_REACTOR)
+  typedef ACE_ORB_REACTOR Reactor;
+#else
+  typedef ACE_Reactor Reactor;
+#endif /* ACE_OLD_STYLE_REACTOR */
+
+  ACE_ES_Reactor_Task();
+  // Default construction.
+
+  ~ACE_ES_Reactor_Task();
+  // Destruction.
+
+  virtual int svc_hook(RtecScheduler::OS_Priority);
+  // Assume ownership of the reactor_.
+
+  int open_reactor (RtecScheduler::Period &period);
+  // This is a hack for now.
+
+  virtual int svc_one();
+  // Calls reactor_.handle_events until done_ is set.
+
+  void shutdown_task();
+  // Sets done_ and notifies the reactor_.
+
+  Reactor &get_reactor();
+  // ReactorEx accessor.
+
+  virtual void threads_closed();
+  // Deletes this.
+
+private:
+  ACE_Timer_List timer_queue_;
+  // The timer storage mechanism used by reactor_.
+
+#if !defined (ACE_OLD_STYLE_REACTOR)
+  ACE_ES_Fast_Reactor fast_reactor_;
+  // The timer dispatch mechanism.
+#endif /* ! ACE_OLD_STYLE_REACTOR */
+
+  Reactor reactor_;
+  // "Public" handle to fast_reactor_.
+
+  sig_atomic_t done_;
+  // When set, end the event loop.
+};
+
+#endif /* ACE_ReactorTask_H */