1 files changed, 117 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.h b/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.h
new file mode 100644
index 00000000000..1ecc90efa4d
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/PortableGroup/PortableGroup_Acceptor_Registry.h
@@ -0,0 +1,117 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file     PortableGroup_Acceptor_Registry.h
+ *
+ *  $Id$
+ *
+ *  Registry for dynamically created acceptors.
+ *
+ *  @author Frank Hunleth <fhunleth@cs.wustl.edu>
+ */
+//=============================================================================
+
+#ifndef TAO_PORTABLEGROUP_ACCEPTOR_REGISTRY_H
+#define TAO_PORTABLEGROUP_ACCEPTOR_REGISTRY_H
+
+#include /**/ "ace/pre.h"
+
+#include "ace/Unbounded_Queue.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ace/CORBA_macros.h"
+
+#include "orbsvcs/PortableGroup/portablegroup_export.h"
+
+#include "tao/Transport_Acceptor.h"
+#include "tao/Resource_Factory.h"
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+class TAO_Profile;
+
+namespace CORBA
+{
+  class Environment;
+}
+
+/**
+ * @class TAO_PortableGroup_Acceptor_Registry
+ *
+ * @brief .
+ *
+ * There is one TAO_PortableGroup_Acceptor_Registry per ORB_Core.
+ */
+class TAO_PortableGroup_Export TAO_PortableGroup_Acceptor_Registry
+{
+public:
+
+  /**
+   * @struct Entry
+   *
+   * @brief Value field of the portable group acceptor registry.
+   */
+  struct Entry
+  {
+    /// Pointer to the acceptor for this GroupId.
+    TAO_Acceptor *acceptor;
+
+    /// Cached endpoint that the acceptor is listening on.
+    TAO_Endpoint *endpoint;
+
+    /// Count of times that this GroupId has been opened.
+    int cnt;
+  };
+
+
+  // = Initialization and termination methods.
+  ///  Default constructor.
+  TAO_PortableGroup_Acceptor_Registry (void);
+
+  ///  Default destructor.
+  ~TAO_PortableGroup_Acceptor_Registry (void);
+
+  /// Open an acceptor based on a tagged profile.
+  void open (const TAO_Profile* profile,
+             TAO_ORB_Core &orb_core
+             ACE_ENV_ARG_DECL);
+
+  /// Close all open acceptors.
+  int close_all (void);
+
+  typedef ACE_Unbounded_Queue<Entry> Acceptor_Registry;
+  typedef ACE_Unbounded_Queue_Iterator<Entry> Acceptor_Registry_Iterator;
+
+protected:
+
+  /// Helper function to open a group acceptor.
+  void open_i (const TAO_Profile* profile,
+               TAO_ORB_Core &orb_core,
+               TAO_ProtocolFactorySetItor &factory
+               ACE_ENV_ARG_DECL);
+
+  /// Find an acceptor by using a profile.
+  int find (const TAO_Profile* profile,
+            Entry *&entry);
+
+private:
+
+  // The acceptor registry should not be copied.
+  TAO_PortableGroup_Acceptor_Registry (
+    const TAO_PortableGroup_Acceptor_Registry&);
+  void operator= (const TAO_PortableGroup_Acceptor_Registry&);
+
+private:
+  /// List of acceptors that are currently open.
+  Acceptor_Registry registry_;
+};
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#include /**/ "ace/post.h"
+
+#endif /* TAO_PORTABLEGROUP_ACCEPTOR_REGISTRY_H */