1 files changed, 53 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/LWFT/Monitor_Thread.cpp b/TAO/orbsvcs/orbsvcs/LWFT/Monitor_Thread.cpp
new file mode 100644
index 00000000000..81cb9178934
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/LWFT/Monitor_Thread.cpp
@@ -0,0 +1,53 @@
+// -*- C++ -*-
+// $Id$
+
+/**
+ *  @file  C++ Implementation: Monitor_Thread
+ *
+ *  @brief Defines implementation of Monitor_Thread.
+ *
+ */
+
+#include "Monitor_Thread.h"
+
+#include "ace/TP_Reactor.h"
+#include "tao/Exception.h"
+
+Monitor_Thread::Monitor_Thread (void)
+  : reactor_ (new ACE_TP_Reactor())
+{
+}
+
+int
+Monitor_Thread::svc (void)
+{
+  try
+    {
+      if (reactor_.run_reactor_event_loop() == -1)
+	      {
+	        ACE_ERROR_RETURN ((LM_ERROR,
+			                       "Monitor_Thread: "
+			                       "run_reactor_event_loop failed\n"),
+			                      -1);
+	      }
+    }
+  catch (CORBA::Exception & ex)
+    {
+      ACE_DEBUG ((LM_ERROR,
+                  "Monitor_Thread::svc - caught %s",
+                  ex._info ().c_str ()));
+      return -1;
+    }
+
+  return 0;
+}
+/*
+int Monitor_Thread::register_handler (ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask)
+{
+  return reactor_.register_handler (event_handler, mask);
+}
+*/
+ACE_Reactor * Monitor_Thread::get_reactor (void)
+{
+  return &reactor_;
+}