1 files changed, 78 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/LWFT/Failure_Handler.h b/TAO/orbsvcs/orbsvcs/LWFT/Failure_Handler.h
new file mode 100644
index 00000000000..05fdb03ff63
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/LWFT/Failure_Handler.h
@@ -0,0 +1,78 @@
+// -*- C++ -*-
+// $Id$
+
+/**
+ *  @file  C++ Interface: Failure_Handler
+ *
+ *  @brief Declares interface for Failure_Handler.
+ *
+ */
+
+#ifndef __FAILURE_HANDLER_H_
+#define __FAILURE_HANDLER_H_
+
+#include <string>
+
+#include "ace/Svc_Handler.h"
+#include "ace/Map_Manager.h"
+#include "ace/SOCK_Connector.h"
+#include "ace/Connector.h"
+
+#include "host_monitor_export.h"
+
+struct ProcessInfo
+{
+  ProcessInfo () {}
+  ProcessInfo (const std::string &pid,
+               const std::string &hn,
+               size_t port);
+
+  std::string process_id;
+  std::string hostname;
+  size_t port;
+};
+
+/**
+ *  @class  Failure_Handler
+ *
+ *  @brief Encapsulates Failure_Handler
+ */
+
+class HostMonitorImpl;
+
+class HostMonitor_Export Failure_Handler
+  : public ACE_Svc_Handler <ACE_SOCK_Connector::PEER_STREAM, ACE_NULL_SYNCH>
+{
+public:
+  typedef ACE_Map_Manager <ACE_HANDLE, ProcessInfo,
+                           ACE_Thread_Mutex>
+    ProcessInfoMap;
+    
+  typedef ACE_Svc_Handler <ACE_SOCK_Connector::PEER_STREAM,
+                           ACE_NULL_SYNCH>
+    super;
+    
+  typedef ACE_Connector <super, ACE_SOCK_Connector> FactoryConnector;
+
+  Failure_Handler (void);
+
+  virtual int handle_input (ACE_HANDLE fd);
+  virtual int open (void *factory);
+
+  void set_host_monitor (HostMonitorImpl *hm);
+  int watch_process (ACE_HANDLE fd,
+                     const std::string &process_id,
+                     const std::string &hostname,
+                     size_t port);
+  int drop_process (ACE_HANDLE fd);
+
+private:
+  static ProcessInfoMap process_map_;
+  FactoryConnector *connector_factory_;
+  HostMonitorImpl *host_monitor_;
+};
+
+
+
+
+#endif /// __FAILURE_HANDLER_H_