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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ace
//
// = FILENAME
// Service_Repository.h
//
// = AUTHOR
// Doug Schmidt
//
// ============================================================================
#if !defined (ACE_SERVICE_REPOSITORY_H)
#define ACE_SERVICE_REPOSITORY_H
#include "ace/Service_Types.h"
class ACE_Export ACE_Service_Repository
{
// = TITLE
// A container for all services offered by a Service
// Configurator-based application. This allows an
// administrative entity to centrally manage and control the
// behavior of application services.
//
// = DESCRIPTION
// This class contains a vector of <ACE_Service_Types> *'s.
public:
friend class ACE_Service_Repository_Iterator;
enum {DEFAULT_SIZE = 50};
// = Initialization and termination methods.
ACE_Service_Repository (void);
// Initialize the repository.
ACE_Service_Repository (int size);
// Initialize the repository.
static ACE_Service_Repository *instance (int size = ACE_Service_Repository::DEFAULT_SIZE);
// Get pointer to a process-wide <ACE_Service_Repository>.
static ACE_Service_Repository *instance (ACE_Service_Repository *);
// Set pointer to a process-wide <ACE_Service_Repository> and return
// existing pointer.
static void close_singleton (void);
// Delete the dynamically allocated Singleton
int open (int size = DEFAULT_SIZE);
// Initialize the repository.
~ACE_Service_Repository (void);
// Terminate the repository.
int close (void);
// Terminate the repository.
// = Search structure operations (all acquire locks as necessary).
int insert (const ACE_Service_Type *);
// Insert a new service record.
int find (const char name[],
const ACE_Service_Type **srp = 0,
int ignore_suspended = 1);
// Locate an entry with <name> in the table. If <ignore_suspended>
// is set then only consider services marked as resumed. If the
// caller wants the located entry, pass back a pointer to the
// located entry via <srp>. If <name> is not found, -1 is returned.
// If <name> is found, but it is suspended and the caller wants to
// ignore suspended services a -2 is returned.
int remove (const char[]);
// Remove an existing service record.
// = Liveness control
int resume (const char[], const ACE_Service_Type ** = 0);
// Resume a service record.
int suspend (const char[], const ACE_Service_Type ** = 0);
// Suspend a service record.
int current_size (void);
// Return the current size of the repository.
int total_size (void);
// Return the total size of the repository.
void dump (void) const;
// Dump the state of an object.
ACE_ALLOC_HOOK_DECLARE;
// Declare the dynamic allocation hooks.
private:
int find_i (const char service_name[],
const ACE_Service_Type ** = 0,
int ignore_suspended = 1);
// Locates <service_name>. Must be called without locks being
// held...
const ACE_Service_Type **service_vector_;
// Contains all the configured services.
int current_size_;
// Current number of services.
int total_size_;
// Maximum number of service.
static ACE_Service_Repository *svc_rep_;
// Pointer to a process-wide <ACE_Service_Repository>.
static int delete_svc_rep_;
// Must delete the <svc_rep_> if non-0.
#if defined (ACE_MT_SAFE) && (ACE_MT_SAFE != 0)
ACE_Thread_Mutex lock_;
// Synchronization variable for the MT_SAFE Repository
#endif /* ACE_MT_SAFE */
};
class ACE_Export ACE_Service_Repository_Iterator
{
public:
// = TITLE
// Iterate through the <ACE_Service_Repository>.
// = Initialization method.
ACE_Service_Repository_Iterator (ACE_Service_Repository &sr,
int ignored_suspended = 1);
// = Iteration methods.
int next (const ACE_Service_Type *&next_item);
// Pass back the <next_item> that hasn't been seen in the set.
// Returns 0 when all items have been seen, else 1.
int done (void) const;
// Returns 1 when all items have been seen, else 0.
int advance (void);
// Move forward by one element in the set. Returns 0 when all the
// items in the set have been seen, else 1.
void dump (void) const;
// Dump the state of an object.
ACE_ALLOC_HOOK_DECLARE;
// Declare the dynamic allocation hooks.
private:
ACE_Service_Repository &svc_rep_;
// Reference to the Service Repository we are iterating over.
int next_;
// Next index location that we haven't yet seen.
int ignore_suspended_;
// Are we ignoring suspended services?
};
#if defined (__ACE_INLINE__)
#include "ace/Service_Repository.i"
#endif /* __ACE_INLINE__ */
#endif /* _SERVICE_REPOSITORY_H */
|
