1 files changed, 196 insertions, 0 deletions
diff --git a/TAO/orbsvcs/ImplRepo_Service/AsyncAccessManager.h b/TAO/orbsvcs/ImplRepo_Service/AsyncAccessManager.h
new file mode 100644
index 00000000000..358d4efebbd
--- /dev/null
+++ b/TAO/orbsvcs/ImplRepo_Service/AsyncAccessManager.h
@@ -0,0 +1,196 @@
+// -*- C++ -*-
+/*
+ * @file AsyncAccessManager.h
+ *
+ * $Id$
+ *
+ * @author Phil Mesnier <mesnier_p@ociweb.com>
+ */
+
+#ifndef IMR_ASYNCACCESSMANAGER_H_
+#define IMR_ASYNCACCESSMANAGER_H_
+
+#include "locator_export.h"
+
+#include "ImR_ActivatorS.h" // ImR_Activator_AMIS.h
+#include "ace/Vector_T.h"
+#include "ace/SString.h"
+
+#include "Forwarder.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+#pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "LiveCheck.h"
+
+class ImR_Locator_i;
+class ImR_ReplyHandler;
+struct Server_Info;
+
+
+enum AAM_Status
+  {
+    AAM_INIT,
+    AAM_SERVER_STARTED_RUNNING,
+    AAM_ACTIVATION_SENT,
+    AAM_WAIT_FOR_RUNNING,
+    AAM_WAIT_FOR_PING,
+    AAM_WAIT_FOR_ALIVE,
+    AAM_SERVER_READY,
+    AAM_SERVER_DEAD,
+    AAM_NOT_MANUAL,
+    AAM_NO_ACTIVATOR,
+    AAM_NO_COMMANDLINE
+  };
+
+//----------------------------------------------------------------------------
+/*
+ * @class AsyncAccessManager
+ *
+ * @brief manages the state of a request for a server across multiple upcalls
+ *
+ * When a client implicitly or explicitly requests a server reference up to
+ * three distinct actions must occur, each of which involves waiting for
+ * externally triggered events.
+ * 1) if not running, request activation of the server
+ * 2) if activated, wait for server to call in with a ServerObject reference
+ * 3) if not recently pinged, ping the ServerObject to confirm it is alive.
+ *
+ * A single AsyncAccessManager instance is used to track the progress of
+ * an individual server activation. If multiple clients request the same
+ * server instance, then each can be notified when the server is ready. If
+ * a server is configured for per-client activation, each client request
+ * will have its own AAM instance.
+ */
+
+class AsyncAccessManager
+{
+ public:
+  AsyncAccessManager (const Server_Info &info,
+                      bool manual,
+                      ImR_Locator_i &locator);
+
+  ~AsyncAccessManager (void);
+
+  void started_running (void);
+
+  bool has_server (const char *name);
+
+  void add_interest (ImR_ResponseHandler *rh);
+  AAM_Status status (void) const;
+
+  void activator_replied (bool success);
+  void server_is_running (const char *partial_ior,
+                          ImplementationRepository::ServerObject_ptr ref);
+  void server_is_shutting_down (void);
+  void ping_replied (LiveStatus server);
+
+  AsyncAccessManager *add_ref (void);
+  void remove_ref (void);
+
+ private:
+  void final_state (void);
+  void status (AAM_Status s);
+  bool send_start_request (void);
+
+  Server_Info *info_;
+  bool manual_start_;
+  ImR_Locator_i &locator_;
+  PortableServer::POA_var poa_;
+  ACE_Vector<ImR_ResponseHandler *> rh_list_;
+
+  AAM_Status status_;
+
+  int refcount_;
+  TAO_SYNCH_MUTEX lock_;
+};
+
+class AsyncAccessManager_ptr
+{
+public:
+  AsyncAccessManager_ptr (void);
+  AsyncAccessManager_ptr (AsyncAccessManager *aam);
+  AsyncAccessManager_ptr (const AsyncAccessManager_ptr &aam_ptr);
+  ~AsyncAccessManager_ptr (void);
+
+  AsyncAccessManager_ptr &operator = (const AsyncAccessManager_ptr &aam_ptr);
+  AsyncAccessManager_ptr &operator = (AsyncAccessManager *aam);
+  const AsyncAccessManager * operator-> () const;
+  const AsyncAccessManager * operator* () const;
+  AsyncAccessManager * operator-> ();
+  AsyncAccessManager * operator* ();
+  bool operator== (const AsyncAccessManager_ptr &aam_ptr) const;
+  bool operator== (const AsyncAccessManager *aam) const;
+
+  AsyncAccessManager * clone (void) const;
+  AsyncAccessManager * _retn (void);
+
+  void assign (AsyncAccessManager *aam);
+
+private:
+  AsyncAccessManager * val_;
+};
+
+//----------------------------------------------------------------------------
+/*
+ * @class ActivatorReceiver
+ *
+ * @brief callback for handling asynch server startup requests
+ *
+ */
+
+class ActivatorReceiver :
+  public virtual POA_ImplementationRepository::AMI_ActivatorHandler
+{
+public:
+  ActivatorReceiver (AsyncAccessManager *aam,
+                     PortableServer::POA_ptr poa);
+  virtual ~ActivatorReceiver (void);
+
+  void start_server (void);
+  void start_server_excep (Messaging::ExceptionHolder * excep_holder);
+
+  void shutdown (void);
+  void shutdown_excep (Messaging::ExceptionHolder * excep_holder);
+
+private:
+  AsyncAccessManager_ptr aam_;
+  PortableServer::POA_var poa_;
+};
+
+
+//----------------------------------------------------------------------------
+/*
+ */
+
+class AsyncLiveListener : public LiveListener
+{
+ public:
+  AsyncLiveListener (const char * server,
+                     AsyncAccessManager *aam,
+                     LiveCheck &pinger,
+                     ImplementationRepository::ServerObject_ptr ref);
+
+  AsyncLiveListener (const char * server,
+                     AsyncAccessManager *aam,
+                     LiveCheck &pinger);
+
+  virtual ~AsyncLiveListener (void);
+  bool start (void);
+
+  bool status_changed (LiveStatus status);
+
+ private:
+  AsyncAccessManager_ptr aam_;
+  LiveCheck &pinger_;
+  LiveStatus status_;
+  bool per_client_;
+  ImplementationRepository::ServerObject_var srv_ref_;
+};
+
+
+
+
+
+#endif /* IMR_ASYNCACCESSMANGER_H_  */