summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/LB_ObjectGroup_Map.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/LB_ObjectGroup_Map.h')
-rw-r--r--TAO/orbsvcs/orbsvcs/LB_ObjectGroup_Map.h104
1 files changed, 104 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/LB_ObjectGroup_Map.h b/TAO/orbsvcs/orbsvcs/LB_ObjectGroup_Map.h
new file mode 100644
index 00000000000..bc276fb0567
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/LB_ObjectGroup_Map.h
@@ -0,0 +1,104 @@
+// -*- C++ -*-
+
+//=======================================================================
+/**
+ * @file LB_ObjectGroup_Map.h
+ *
+ * $Id$
+ *
+ * @author Ossama Othman <ossama@uci.edu>
+ */
+//=======================================================================
+
+
+#ifndef TAO_LB_OBJECTGROUP_MAP_H
+#define TAO_LB_OBJECTGROUP_MAP_H
+
+#include "ace/pre.h"
+
+#include "ace/config-all.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ace/Hash_Map_Manager.h"
+#include "LB_Replica_Map.h"
+#include "LB_ObjectGroup_Hash.h"
+#include "LB_ObjectGroup_Equal_To.h"
+#include "orbsvcs/LoadBalancingC.h"
+
+/**
+ * @class TAO_LB_ObjectGroup_Map
+ *
+ * @brief Map of RepositoryId to ObjectGroup reference,
+ * FactoryCreationId, replicas belonging to the ObjectGroup and
+ * corresponding replica-specific information.
+ *
+ * Implementation to be used by the Load Balancer ReplicationManager.
+ */
+class TAO_LB_ObjectGroup_Map
+{
+
+public:
+
+ /**
+ * @class Map_Entry
+ *
+ * @brief Value field of the replica map.
+ *
+ * Mapping from and to all of the following fields:
+ * @param object_group, @param factory_creation_id, @param factory,
+ * and @param factory_creation_id. Therefore, we keep all the
+ * fields together in the map.
+ */
+ struct Map_Entry
+ {
+ /// The RepositoryId corresponding to all Replicas in the
+ /// ObjectGroup.
+ CORBA::String_var type_id;
+
+ /// Reference to the ObjectGroup.
+ TAO_LoadBalancing::ObjectGroup_var object_group;
+
+ /// The FactoryCreationId corresponding to the ObjectGroup created
+ /// by the Load Balancer GenericFactory.
+ TAO_LoadBalancing::FactoryCreationId factory_creation_id;
+
+ /// Hash map containing replica references and all related
+ /// information for each replica.
+ TAO_LB_Replica_Map replica_map;
+ };
+
+ /// type_id hash map.
+ typedef ACE_Hash_Map_Manager_Ex<
+ const char *,
+ Map_Entry *,
+ ACE_Hash<const char *>,
+ ACE_Equal_To<const char *>,
+ ACE_SYNCH_MUTEX> type_id_map;
+
+ /// ObjectGroup hash map.
+ typedef ACE_Hash_Map_Manager_Ex<
+ TAO_LoadBalancing::ObjectGroup_ptr,
+ Map_Entry *,
+ TAO_LB_ObjectGroup_Hash,
+ TAO_LB_ObjectGroup_Equal_To,
+ ACE_SYNCH_MUTEX> ObjectGroup_map;
+
+ /// FactoryCreationId hash map.
+ typedef ACE_Hash_Map_Manager_Ex<
+ TAO_LoadBalancing::FactoryCreationId,
+ Map_Entry *,
+ TAO_LB_FactoryCreationId_Hash,
+ TAO_LB_FactoryCreationId_Equal_To,
+ ACE_SYNCH_MUTEX> FactoryCreationId_map;
+
+ int bind (const char *type_id,
+ TAO_LoadBalancing::ObjectGroup_ptr object_group,
+ TAO_LoadBalancing::FactoryCreationId &factory_creation_id);
+};
+
+#include "ace/post.h"
+
+#endif /* TAO_LB_OBJECTGROUP_MAP_H */