1 files changed, 121 insertions, 0 deletions
diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/AppSideReg.cpp b/TAO/orbsvcs/examples/FaultTolerance/FLARe/AppSideReg.cpp
new file mode 100644
index 00000000000..d2f9bc3fca4
--- /dev/null
+++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/AppSideReg.cpp
@@ -0,0 +1,121 @@
+/**
+ *  @file  C++ Implementation: AppSideReg
+ *
+ *  @brief Defines implementation of AppSideReg.
+ *
+ */
+
+#include "AppSideReg.h"
+#include "AppOptions.h"
+#include "monitorC.h"
+#include "ArgPair.h"
+#include "ace/Barrier.h"
+
+#include <sstream>
+#include <stdexcept>
+#include <algorithm>
+
+AppSideReg::AppSideReg(ACE_Barrier *ext_barrier, CORBA::ORB_ptr orb)
+  : HM_ior_ (AppOptions::instance ()->host_monitor_ior()),
+    orb_ (CORBA::ORB::_duplicate (orb)),
+    external_barrier_ (ext_barrier)
+{
+}
+
+
+AppSideReg::~AppSideReg()
+{
+  monitor_->stop ();
+  orb_->destroy ();
+}
+
+void AppSideReg::unregister_process (void)
+{
+  hmvar_->unregister_process (AppOptions::instance()->process_id().c_str());
+}
+
+int AppSideReg::svc(void)
+{
+  try
+  {
+      //ACE_DEBUG ((LM_DEBUG, "Entering svc ()\n"));
+      //ArgPair arg_pair = AppOptions::instance()->arg_pair ();
+      //std::copy (arg_pair.argv, arg_pair.argv + arg_pair.argc,
+      //           std::ostream_iterator<std::string> (std::cout,"\n"));
+      //this->orb_ =  CORBA::ORB_init (arg_pair.argc, arg_pair.argv, "ORB");
+      //std::copy (arg_pair.argv, arg_pair.argv + arg_pair.argc,
+      //           std::ostream_iterator<std::string> (std::cout,"\n"));
+      CORBA::Object_var obj = orb_->string_to_object (HM_ior_.c_str());
+
+      //ACE_DEBUG ((LM_DEBUG, "Obtained HM IOR\n"));
+
+      if (CORBA::is_nil (obj))
+      {
+        ACE_DEBUG((LM_ERROR, "Nil Reference\n"));
+        return 1;
+      }
+
+      /// Downcast the object reference to a reference of type HostMonitor.
+      this->hmvar_ = HostMonitor::_narrow (obj);
+      if (CORBA::is_nil (hmvar_))
+      {
+        ACE_DEBUG((LM_ERROR, "Argument is not a HostMonitor reference.\n"));
+        return 1;
+      }
+
+      //ACE_DEBUG ((LM_DEBUG, "Creating the monitor\n"));
+
+      ACE_Barrier internal_thread_barrier (2);
+      monitor_ = std::auto_ptr <AppSideMonitor_Thread> 
+        (new AppSideMonitor_Thread (&internal_thread_barrier));
+      monitor_->activate ();
+
+      //ACE_DEBUG ((LM_DEBUG, "Monitor activated\n"));
+
+      internal_thread_barrier.wait (); 
+      /// Waiting for the AppSideMonitor_Thread to finish its socket stuff.
+      try {
+        hmvar_->dump ();
+      } catch (CORBA::Exception & ex) {
+        ACE_DEBUG((LM_DEBUG,"exception from dump.\n"));
+        throw;
+      }
+
+
+      //ACE_DEBUG ((LM_DEBUG, "Registering process\n"));
+      try {
+          if (hmvar_->register_process (
+                     AppOptions::instance()->process_id().c_str(),
+                     AppOptions::instance()->host_id().c_str(),
+                     AppOptions::instance()->get_port()))
+          {
+            ACE_DEBUG((LM_DEBUG, "Registered successfully %s with host monitor.\n", 
+                       AppOptions::instance()->process_id().c_str()));
+          }
+          else
+          {
+            ACE_DEBUG((LM_ERROR, "Registeration with the monitor failed.\n"));
+          }
+      } catch (CORBA::Exception & ex) {
+        ACE_DEBUG((LM_DEBUG,"exception from register_process.\n"));
+        throw;
+      }
+
+
+      //ACE_DEBUG ((LM_DEBUG, "Registering process\n"));
+  }
+  catch (CORBA::Exception &ex)
+  {
+    ACE_PRINT_EXCEPTION (ex, "A CORBA exception was raised:");
+    return -1;
+  }
+  catch (...)
+  {
+    ACE_DEBUG((LM_ERROR, "Unknown exception raised!"));
+    return -1;
+  }
+
+  external_barrier_->wait ();
+  return 0;
+}
+