blob: a04949a778818b2a5a800494dc7fbe3829b89f42 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// Leader_Follower.h
//
// = AUTHOR
// Carlos O'Ryan (coryan@cs.wustl.edu)
//
// ============================================================================
#ifndef TAO_LEADER_FOLLOWER_H
#define TAO_LEADER_FOLLOWER_H
#include "tao/ORB_Core.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Containers_T.h"
class TAO_Export TAO_Leader_Follower
{
public:
TAO_Leader_Follower (TAO_ORB_Core *orb_core);
// Constructor
~TAO_Leader_Follower (void);
// Destructor
void set_server_thread (void);
// The current thread has become a server thread (i.e. called
// ORB::run), update any flags and counters.
void reset_server_thread (void);
// The current thread is not a server thread anymore, reset any
// flags and counters.
int leader_available (void) const;
// Is there any thread running as a leader?
void set_client_thread (void);
// A server thread is making a request.
void reset_client_thread (void);
// A server thread has finished is making a request.
void set_leader_thread (void) ;
// The current thread has become the leader thread in the
// client side leader-follower set.
void reset_leader_thread (void) ;
// The current thread is no longer the leader thread in the client
// side leader-follower set.
void set_leader_thread (ACE_thread_t thread_ID);
// sets the thread ID of the leader thread in the leader-follower
// model
int is_leader_thread (void) const;
// checks if we are a leader thread
int elect_new_leader (void);
// A leader thread is relinquishing its role, unless there are more
// leader threads running pick up a follower (if there is any) to
// play the leader role.
int add_follower (ACE_SYNCH_CONDITION *follower_ptr);
// 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 follower_available (void) const;
// checks for the availablity of a follower
// returns 1 on available, 0 else
int remove_follower (ACE_SYNCH_CONDITION *follower_ptr);
// removes a follower from the leader-follower set
// returns 0 on success, -1 on failure
ACE_SYNCH_CONDITION *get_next_follower (void);
// returns randomly a follower from the leader-follower set
// returns follower on success, else 0
ACE_SYNCH_MUTEX &lock (void);
ACE_Reverse_Lock<ACE_SYNCH_MUTEX> &reverse_lock (void);
// Accessors
int has_clients (void) const;
// Check if there are any client threads running
ACE_Reactor *reactor (void);
// Accesor to the reactor
private:
TAO_ORB_Core_TSS_Resources *get_tss_resources (void) const;
// Shortcut to obtain the TSS resources of the orb core.
private:
TAO_ORB_Core *orb_core_;
// The orb core
ACE_SYNCH_MUTEX lock_;
// To synchronize access to the members.
ACE_Reverse_Lock<ACE_SYNCH_MUTEX> reverse_lock_;
// do protect the access to the following three members
ACE_Unbounded_Set<ACE_SYNCH_CONDITION *> follower_set_;
// keep a set of followers around (protected)
int leaders_;
// Count the number of active leaders.
// There could be many leaders in the thread pool (i.e. calling
// ORB::run), and the same leader could show up multiple times as it
// receives nested upcalls and sends more requests.
int clients_;
// Count the number of active clients, this is useful to know when
// to deactivate the reactor
ACE_Reactor *reactor_;
// The reactor
};
#if defined (__ACE_INLINE__)
# include "tao/Leader_Follower.i"
#endif /* __ACE_INLINE__ */
#endif /* TAO_LEADER_FOLLOWER_H */
|
