Thu Jun 16 20:25:08 UTC 2011 Akshay V. Dabholkar <aky@dre.vanderbilt.edu>DeCoM

        * orbsvcs/LWFT_Service:

        * orbsvcs/LWFT_Service/LWFT_Service.mpc:
        * orbsvcs/LWFT_Service/RMOptions.h:
        * orbsvcs/LWFT_Service/RMOptions.cpp:
        * orbsvcs/LWFT_Service/ReplicationManager_process.cpp:
        * orbsvcs/LWFT_Service/host_monitor.cpp:

        * orbsvcs/orbsvcs/LWFT:

        * orbsvcs/orbsvcs/LWFT/AppInfo.idl:
        * orbsvcs/orbsvcs/LWFT/AppOptions.h:
        * orbsvcs/orbsvcs/LWFT/AppOptions.cpp:
        * orbsvcs/orbsvcs/LWFT/AppSideMonitor_Handler.h:
        * orbsvcs/orbsvcs/LWFT/AppSideMonitor_Handler.cpp:
        * orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h:
        * orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.cpp:
        * orbsvcs/orbsvcs/LWFT/AppSideReg.h:
        * orbsvcs/orbsvcs/LWFT/AppSideReg.cpp:
        * orbsvcs/orbsvcs/LWFT/Barrier_Guard.h:
        * orbsvcs/orbsvcs/LWFT/Barrier_Guard.cpp:
        * orbsvcs/orbsvcs/LWFT/Client_ORBInitializer.h:
        * orbsvcs/orbsvcs/LWFT/Client_ORBInitializer.cpp:
        * orbsvcs/orbsvcs/LWFT/Client_Request_Interceptor.h:
        * orbsvcs/orbsvcs/LWFT/Client_Request_Interceptor.cpp:
        * orbsvcs/orbsvcs/LWFT/CorbaStateUpdate.h:
        * orbsvcs/orbsvcs/LWFT/CorbaStateUpdate.cpp:
        * orbsvcs/orbsvcs/LWFT/DDSFailure.h:
        * orbsvcs/orbsvcs/LWFT/DDSFailure.cpp:
        * orbsvcs/orbsvcs/LWFT/DDSStateReaderListener_T.h:
        * orbsvcs/orbsvcs/LWFT/DDSStateReaderListener_T.cpp:
        * orbsvcs/orbsvcs/LWFT/DDSStateUpdate_T.h:
        * orbsvcs/orbsvcs/LWFT/DDSStateUpdate_T.cpp:
        * orbsvcs/orbsvcs/LWFT/Failure_Handler.h:
        * orbsvcs/orbsvcs/LWFT/Failure_Handler.cpp:
        * orbsvcs/orbsvcs/LWFT/FaultNotification.idl:
        * orbsvcs/orbsvcs/LWFT/ForwardingAgent.h:
        * orbsvcs/orbsvcs/LWFT/ForwardingAgent.cpp:
        * orbsvcs/orbsvcs/LWFT/ForwardingAgent.idl:
        * orbsvcs/orbsvcs/LWFT/HMOptions.h:
        * orbsvcs/orbsvcs/LWFT/HMOptions.cpp:
        * orbsvcs/orbsvcs/LWFT/HostMonitor.idl:
        * orbsvcs/orbsvcs/LWFT/HostMonitorImpl.h:
        * orbsvcs/orbsvcs/LWFT/HostMonitorImpl.cpp:
        * orbsvcs/orbsvcs/LWFT/IOR_Interceptor.h:
        * orbsvcs/orbsvcs/LWFT/IOR_Interceptor.cpp:
        * orbsvcs/orbsvcs/LWFT/LWFT.mpc:
        * orbsvcs/orbsvcs/LWFT/LWFTDataStructures.idl:
        * orbsvcs/orbsvcs/LWFT/LWFT_Client.vcproj:
        * orbsvcs/orbsvcs/LWFT/LWFT_Client_Init.h:
        * orbsvcs/orbsvcs/LWFT/LWFT_Client_Init.cpp:
        * orbsvcs/orbsvcs/LWFT/LWFT_Common.vcproj:
        * orbsvcs/orbsvcs/LWFT/LWFT_ReplicationManager.vcproj:
        * orbsvcs/orbsvcs/LWFT/LWFT_Server.vcproj:
        * orbsvcs/orbsvcs/LWFT/LWFT_Server_Init.h:
        * orbsvcs/orbsvcs/LWFT/LWFT_Server_Init.cpp:
        * orbsvcs/orbsvcs/LWFT/LWFT_StateSyncAgent.vcproj:
        * orbsvcs/orbsvcs/LWFT/Monitor_Manager.h:
        * orbsvcs/orbsvcs/LWFT/Monitor_Manager.inl:
        * orbsvcs/orbsvcs/LWFT/Monitor_Manager.cpp:
        * orbsvcs/orbsvcs/LWFT/Monitor_Thread.h:
        * orbsvcs/orbsvcs/LWFT/Monitor_Thread.cpp:
        * orbsvcs/orbsvcs/LWFT/ObjectReferenceFactory.h:
        * orbsvcs/orbsvcs/LWFT/ObjectReferenceFactory.cpp:
        * orbsvcs/orbsvcs/LWFT/ObjectReferenceFactory.idl:
        * orbsvcs/orbsvcs/LWFT/README:
        * orbsvcs/orbsvcs/LWFT/RM_Proxy.h:
        * orbsvcs/orbsvcs/LWFT/RM_Proxy.cpp:
        * orbsvcs/orbsvcs/LWFT/ReplicatedApplication.idl:
        * orbsvcs/orbsvcs/LWFT/ReplicationManager.h:
        * orbsvcs/orbsvcs/LWFT/ReplicationManager.cpp:
        * orbsvcs/orbsvcs/LWFT/ReplicationManager.idl:
        * orbsvcs/orbsvcs/LWFT/ServerORBInitializer.h:
        * orbsvcs/orbsvcs/LWFT/ServerORBInitializer.cpp:
        * orbsvcs/orbsvcs/LWFT/StateSyncAgentTask.h:
        * orbsvcs/orbsvcs/LWFT/StateSyncAgentTask.cpp:
        * orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent.idl:
        * orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent_i.h:
        * orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent_i.cpp:
        * orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent_i_T.cpp:
        * orbsvcs/orbsvcs/LWFT/StatefulObject.h:
        * orbsvcs/orbsvcs/LWFT/StatefulObject.cpp:
        * orbsvcs/orbsvcs/LWFT/Timer.h:
        * orbsvcs/orbsvcs/LWFT/Timer.cpp:
        * orbsvcs/orbsvcs/LWFT/Utilization_Monitor.h:
        * orbsvcs/orbsvcs/LWFT/Utilization_Monitor.cpp:
        * orbsvcs/orbsvcs/LWFT/host_monitor_export.h:
        * orbsvcs/orbsvcs/LWFT/lwft_client_export.h:
        * orbsvcs/orbsvcs/LWFT/lwft_common_export.h:
        * orbsvcs/orbsvcs/LWFT/lwft_server_export.h:
        * orbsvcs/orbsvcs/LWFT/rm_export.h:
        * orbsvcs/orbsvcs/LWFT/rm_impl_export.h:
        * orbsvcs/orbsvcs/LWFT/ssa_export.h:

        Merged additive orbsvcs of LWFT(FLARE) implementation

1 files changed, 49 insertions, 0 deletions

diff --git a/TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h b/TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h
new file mode 100644
index 00000000000..f18ae892b2d
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h
@@ -0,0 +1,49 @@
+// -*- C++ -*-
+// $Id$
+
+/**
+ *  @file  C++ Interface: AppSideMonitor_Thread
+ *
+ *  @brief Declares interface for AppSideMonitor_Thread.
+ *
+ */
+
+#ifndef __APPSIDEMONITOR_THREAD_H_
+#define __APPSIDEMONITOR_THREAD_H_
+
+#include "ace/Task.h"
+#include "ace/SOCK_Acceptor.h"
+#include "ace/Reactor.h"
+#include "ace/Barrier.h"
+#include "ace/Acceptor.h"
+
+#include "AppSideMonitor_Handler.h"
+
+/**
+ *  @class  AppSideMonitor_Thread
+ *
+ *  @brief Encapsulates AppSideMonitor_Thread
+ */
+
+class AppSideMonitor_Thread : public ACE_Task_Base
+{
+public:
+  AppSideMonitor_Thread (ACE_Barrier &thread_barrier);
+
+  AppSideMonitor_Thread (ACE_Barrier &thread_barrier,
+                         u_short port);
+
+  void stop (void);
+  virtual int svc (void);
+
+private:
+  u_short port_;
+  ACE_SOCK_Acceptor::PEER_ADDR serv_addr_;
+  ACE_Reactor reactor_;
+  ACE_Acceptor<AppSideMonitor_Handler, ACE_SOCK_Acceptor> acceptor_;
+  ACE_Barrier &synchronizer_;
+};
+
+
+
+#endif /// __APPSIDEMONITOR_THREAD_H_