1 files changed, 156 insertions, 0 deletions
diff --git a/TAO/orbsvcs/ImplRepo_Service/ImR_Locator_i.h b/TAO/orbsvcs/ImplRepo_Service/ImR_Locator_i.h
new file mode 100644
index 00000000000..03ca0f0e594
--- /dev/null
+++ b/TAO/orbsvcs/ImplRepo_Service/ImR_Locator_i.h
@@ -0,0 +1,156 @@
+// -*- C++ -*-
+// $Id$
+
+#ifndef IMR_LOCATOR_I_H
+#define IMR_LOCATOR_I_H
+#include /**/ "ace/pre.h"
+
+#include "locator_export.h"
+
+#include "Adapter_Activator.h"
+#include "Forwarder.h"
+#include "Locator_Options.h"
+#include "Locator_Repository.h"
+#include "AsyncStartupWaiter_i.h"
+#include "tao/IORTable/IORTable.h"
+
+#include "orbsvcs/IOR_Multicast.h"
+
+#include "ImR_LocatorS.h"
+#include "AsyncStartupWaiterS.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+ACE_BEGIN_VERSIONED_NAMESPACE_DECL
+class ACE_Reactor;
+ACE_END_VERSIONED_NAMESPACE_DECL
+
+class INS_Locator;
+
+// Gets a request from a client and depending on the POA name,
+// requests an activator to take care of activating the
+// corresponding server and raises a forward exception to the
+// client pointing to the correct server.
+class Locator_Export ImR_Locator_i
+  : public virtual POA_ImplementationRepository::Locator
+{
+public:
+  ImR_Locator_i();
+
+  ~ImR_Locator_i (void);
+
+  /// Initialize the service, creating its own orb, poa, etc.
+  int init (Options& opts);
+
+  /// Same as above, but use the given orb
+  int init_with_orb (CORBA::ORB_ptr orb, Options& opts);
+
+  /// Cleans up any state created by init*.
+  int fini (void);
+
+  /// Run using the orb reference created during init()
+  int run (void);
+
+  /// Shutdown the orb.
+  void shutdown (bool wait_for_completion);
+
+  int debug() const;
+  // Note : See the IDL for descriptions of the operations.
+
+  // Activator->Locator
+
+  virtual CORBA::Long register_activator (const char* name,
+    ImplementationRepository::Activator_ptr admin);
+  virtual void unregister_activator (const char* name,
+    CORBA::Long token);
+  virtual void notify_child_death (const char* name);
+
+  // tao_imr->Locator
+
+  virtual void activate_server (const char * name);
+  virtual void add_or_update_server (const char * name,
+    const ImplementationRepository::StartupOptions &options);
+  virtual void remove_server (const char * name);
+  virtual void shutdown_server (const char * name);
+  virtual void find (const char * name,
+    ImplementationRepository::ServerInformation_out info);
+  virtual void list (
+    CORBA::ULong how_many,
+    ImplementationRepository::ServerInformationList_out server_list,
+    ImplementationRepository::ServerInformationIterator_out server_iterator);
+  virtual void shutdown(CORBA::Boolean activators, CORBA::Boolean servers);
+
+  // Server->Locator
+
+  virtual void server_is_running (const char* name,
+    const char* partial_ior,
+    ImplementationRepository::ServerObject_ptr server_object);
+  virtual void server_is_shutting_down (const char * name);
+
+  // Used by the INS_Locator to start a sever given an object name
+  char* activate_server_by_object (const char* object_name);
+
+  char* activate_server_by_name (const char * name, bool manual_start);
+
+private:
+
+  char* activate_server_i (Server_Info& info, bool manual_start);
+
+  char* activate_perclient_server_i (Server_Info info, bool manual_start);
+
+  ImplementationRepository::StartupInfo*
+    start_server(Server_Info& info, bool manual_start, int& waiting_clients);
+
+  bool is_alive(Server_Info& info);
+  int is_alive_i(Server_Info& info);
+
+  // Set up the multicast related if 'm' is passed on the command
+  // line.
+  int setup_multicast (ACE_Reactor *reactor, const char *ior);
+  void teardown_multicast();
+
+  void unregister_activator_i(const char* activator);
+
+  Activator_Info_Ptr get_activator (const ACE_CString& name);
+  void connect_activator (Activator_Info& info);
+
+  void auto_start_servers(void);
+
+  CORBA::Object_ptr set_timeout_policy(CORBA::Object_ptr obj, const ACE_Time_Value& to);
+
+  void connect_server(Server_Info& info);
+
+  PortableServer::POA_ptr findPOA(const char* name);
+private:
+
+  // The class that handles the forwarding.
+  ImR_Forwarder forwarder_;
+
+  // Used for the forwarding of any type of POA.
+  ImR_Adapter adapter_;
+
+  /// The locator interface for the IORTable
+  IORTable::Locator_var ins_locator_;
+
+  CORBA::ORB_var orb_;
+  PortableServer::POA_var root_poa_;
+  PortableServer::POA_var imr_poa_;
+
+  int debug_;
+
+  TAO_IOR_Multicast ior_multicast_;
+
+  Locator_Repository repository_;
+
+  AsyncStartupWaiter_i waiter_svt_;
+  ImplementationRepository::AsyncStartupWaiter_var waiter_;
+
+  bool read_only_;
+  ACE_Time_Value startup_timeout_;
+  ACE_Time_Value ping_interval_;
+};
+
+#include /**/ "ace/post.h"
+#endif /* IMR_LOCATOR_I_H */