summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorbala <balanatarajan@users.noreply.github.com>2001-03-22 21:50:17 +0000
committerbala <balanatarajan@users.noreply.github.com>2001-03-22 21:50:17 +0000
commitd117bfc3b547719653dca064f036097a676aefac (patch)
tree8d2734e2ecd52601e7835021b34893fdce13f5d3
parent479aa77fb6bffc5a81f5f883c981d31126885063 (diff)
downloadATCD-d117bfc3b547719653dca064f036097a676aefac.tar.gz
*** empty log message ***
-rw-r--r--TAO/tao/Leader_Follower.h34
1 files changed, 3 insertions, 31 deletions
diff --git a/TAO/tao/Leader_Follower.h b/TAO/tao/Leader_Follower.h
index 472ba426b1c..569133484fd 100644
--- a/TAO/tao/Leader_Follower.h
+++ b/TAO/tao/Leader_Follower.h
@@ -74,23 +74,13 @@ public:
*/
int elect_new_leader (void);
- // Node structure for the queue
- struct TAO_Follower_Node
- {
- TAO_Follower_Node (TAO_SYNCH_CONDITION *follower_ptr);
-
- TAO_SYNCH_CONDITION *follower;
-
- TAO_Follower_Node *next;
-
- };
/**
* adds the a follower to the set of followers in the leader-
* follower model
* returns 0 on success, -1 on failure and 1 if the element is
* already there.
*/
- int add_follower (TAO_Follower_Node* node);
+ int add_follower (TAO_SYNCH_CONDITION *follower_ptr);
/// checks for the availablity of a follower
/// returns 1 on available, 0 else
@@ -98,7 +88,7 @@ public:
/// removes a follower from the leader-follower set
/// returns 0 on success, -1 on failure
- int remove_follower (TAO_Follower_Node* node);
+ int remove_follower (TAO_SYNCH_CONDITION *follower_ptr);
/// returns randomly a follower from the leader-follower set
/// returns follower on success, else 0
@@ -114,8 +104,6 @@ public:
/// Accesor to the reactor
ACE_Reactor *reactor (void);
-
-
private:
/// Shortcut to obtain the TSS resources of the orb core.
TAO_ORB_Core_TSS_Resources *get_tss_resources (void) const;
@@ -140,23 +128,7 @@ private:
/// do protect the access to the following three members
ACE_Reverse_Lock<TAO_SYNCH_MUTEX> reverse_lock_;
- // Queue to store the followers
- struct TAO_Follower_Queue
- {
- TAO_Follower_Queue (void);
-
- int is_empty (void) const;
-
- int remove (TAO_Follower_Node *);
-
- int insert (TAO_Follower_Node *);
-
- TAO_Follower_Node *head;
-
- TAO_Follower_Node *tail;
- };
-
- TAO_Follower_Queue follower_set_;
+ ACE_Unbounded_Set<TAO_SYNCH_CONDITION *> follower_set_;
// keep a set of followers around (protected)
/**