diff options
Diffstat (limited to 'TAO/orbsvcs/examples/FaultTolerance/FLARe/ReplicationManager.h')
| -rw-r--r-- | TAO/orbsvcs/examples/FaultTolerance/FLARe/ReplicationManager.h | 231 |
1 files changed, 5 insertions, 226 deletions
diff --git a/TAO/orbsvcs/examples/FaultTolerance/FLARe/ReplicationManager.h b/TAO/orbsvcs/examples/FaultTolerance/FLARe/ReplicationManager.h index b61659ae65a..c0bb70ee262 100644 --- a/TAO/orbsvcs/examples/FaultTolerance/FLARe/ReplicationManager.h +++ b/TAO/orbsvcs/examples/FaultTolerance/FLARe/ReplicationManager.h @@ -99,26 +99,16 @@ public: const char *host_name, const char *process_id, CORBA::Short role, - CORBA::Object_ptr server_reference - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); + CORBA::Object_ptr server_reference); void util_update (const char *host_id, - double util - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); + double util); - virtual void proc_failure (const char *process_id - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); + virtual void proc_failure (const char *process_id); - virtual RankList * register_agent (CORBA::Object_ptr agent_reference - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); + virtual RankList * register_agent (CORBA::Object_ptr agent_reference); - virtual CORBA::Object_ptr get_next (const char * object_id - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); + virtual CORBA::Object_ptr get_next (const char * object_id); bool replica_selection_algo (); @@ -245,215 +235,4 @@ private: // RankList * rank_list_clone (); }; -/* -class ReplicationManager_i : public virtual POA_ReplicationManager, - protected Timer -{ -public: - - using Timer::start; - using Timer::stop; - using Timer::hertz; - - ReplicationManager_i (CORBA::ORB_ptr orb); - - ~ReplicationManager_i (void); - -// ************************************************************************* - - virtual void register_application (const char *object_id, - CORBA::Long load, - const char *host_name, - const char *process_id, - CORBA::Short role, - CORBA::Object_ptr server_reference - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); - - virtual void register_agent (CORBA::Object_ptr agent_reference - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); - - virtual CORBA::Long next_member (const char * - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); - - virtual void util_update (const char *host_id, double utilization - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); - - virtual void proc_failure (const char *process_id - ACE_ENV_ARG_DECL_WITH_DEFAULTS) - ACE_THROW_SPEC ((::CORBA::SystemException)); - - -// ************************************************************************* - - virtual int pulse (void); - - void update_replica_group_map (const char *object_id, - const char *host_name, - const char *process_id, - CORBA::Object_ptr server_reference); - - void update_replica_list (CORBA::Object_ptr server_reference, - const char *object_id); - - void update_replicas_list (CORBA::Object_ptr server_reference, - const char *object_id); - - void update_primary_map (const char *process_id, const char *object_id); - - void update_failover_map (const char *process_id, const char *object_id); - - void update_secondary_map (const char *process_id, const char *object_id); - - void update_host_list (const char *object_id, const char *host_id); - - void update_object_primary_map (const char *process_id, - const char *host_id, - const char *object_id); - - void update_object_failover_map (const char *process_id, - const char *host_id, - const char *object_id); - - void update_object_secondary_map (const char *process_id, - const char *host_id, - const char *object_id); - -// *************************************************************************** - - typedef ACE_Unbounded_Set<ACE_CString> PRIMARY_LIST; - typedef ACE_Unbounded_Set<ACE_CString> FAILOVER_LIST; - typedef ACE_Unbounded_Set<ACE_CString> SECONDARY_LIST; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - PRIMARY_LIST, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> PRIMARY_MAP; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - FAILOVER_LIST, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> FAILOVER_MAP; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - SECONDARY_LIST, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> SECONDARY_MAP; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - ACE_CString, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> PROCESS_MAP; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - CORBA::Object_var, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> REF_MAP; - - typedef ACE_Unbounded_Set<ACE_CString> HOST_LIST; - - typedef ACE_Unbounded_Set<CORBA::Object_ptr> AGENT_LIST; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - HOST_LIST, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> REPLICA_HOST_MAP; - - struct Replica_Group_Entry - { - PROCESS_MAP process_map; - REF_MAP ref_map; - HOST_LIST host_list; - }; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - Replica_Group_Entry *, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> REPLICA_GROUP_MAP; - - typedef ACE_Hash_Map_Iterator_Ex < - ACE_CString, - Replica_Group_Entry *, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> REPLICA_GROUP_MAP_ITERATOR; - - struct Object_Info - { - ACE_CString process_id; - ACE_CString host_id; - }; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - Object_Info, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> OBJECT_PRIMARY_MAP; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - Object_Info, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> OBJECT_FAILOVER_MAP; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - Object_Info, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> OBJECT_SECONDARY_MAP; - - typedef ACE_Hash_Map_Manager_Ex< - ACE_CString, - double, - ACE_Hash<ACE_CString>, - ACE_Equal_To<ACE_CString>, - ACE_Null_Mutex> HOST_UTIL_MAP; - -private: - - CORBA::ORB_var orb_; - TAO_SYNCH_MUTEX lock_; - TAO_SYNCH_MUTEX primary_map_lock_; - TAO_SYNCH_MUTEX failover_map_lock_; - TAO_SYNCH_MUTEX secondary_map_lock_; - TAO_SYNCH_MUTEX replica_group_map_lock_; - TAO_SYNCH_MUTEX replica_host_map_lock_; - TAO_SYNCH_MUTEX object_primary_map_lock_; - TAO_SYNCH_MUTEX object_failover_map_lock_; - TAO_SYNCH_MUTEX object_secondary_map_lock_; - ReplicaList replica_list_; - ReplicasList replicas_list_; - PRIMARY_MAP primary_map_; - FAILOVER_MAP failover_map_; - SECONDARY_MAP secondary_map_; - REPLICA_GROUP_MAP replica_group_map_; - REPLICA_HOST_MAP replica_host_map_; - OBJECT_PRIMARY_MAP object_primary_map_; - OBJECT_FAILOVER_MAP object_failover_map_; - OBJECT_SECONDARY_MAP object_secondary_map_; - HOST_UTIL_MAP host_util_map_; - AGENT_LIST agent_list_; - -}; -*/ #endif /* REPLICATION_MANAGER_H */ |