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
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
|
/* -*- C++ -*- */
// $Id$
/*-*- C++ -*- */
// ============================================================================
//
// = LIBRARY
// ACE
//
// = FILENAME
// ACE_Local_Name_Space_T.h
//
// = AUTHOR
// Prashant Jain (pjain@cs.wustl.edu), Irfan Pyarali
// (irfan@wuerl.wustl.edu), and Douglas C. Schmidt
// (schmidt@cs.wustl.edu).
//
// ============================================================================
#if !defined (ACE_LOCAL_NAME_SPACE_T_H)
#define ACE_LOCAL_NAME_SPACE_T_H
#include "ace/Name_Space.h"
#include "ace/Naming_Context.h"
#include "ace/SString.h"
#include "ace/Local_Name_Space.h"
// A short-hand name for our set of name/value/type tuples passed back
// to callers.
typedef ACE_Unbounded_Set<ACE_WString> ACE_WSTRING_SET;
// Simplify later usage by defining typedefs.
typedef ACE_Map_Manager<ACE_NS_String, ACE_NS_Internal, ACE_Null_Mutex> MAP_MANAGER;
typedef ACE_Map_Iterator<ACE_NS_String, ACE_NS_Internal, ACE_Null_Mutex> MAP_ITERATOR;
typedef ACE_Map_Entry <ACE_NS_String, ACE_NS_Internal> MAP_ENTRY;
template <class ALLOCATOR>
class ACE_Name_Space_Map : public MAP_MANAGER
{
// = TITLE
// This class serves as a Proxy that ensures our process always
// has the appropriate allocator in place for every operation
// that accesses or updates the Map Manager.
//
// = DESCRIPTION
// We need this class because otherwise the SHARED_MALLOC
// pointer will be stored in the Map_Manager that resides within
// shared memory. Naturally, this will cause horrible problems
// since only the first process to set that pointer will be
// guaranteed the address of the SHARED_MALLOC allocator is
// meaningful!
public:
ACE_Name_Space_Map (ALLOCATOR *allocator);
// Constructor.
// = The following methods are Proxies to the underlying methods
// provided by <ACE_Map_Manager>. When they are called, they
// acquire the lock, set the allocator to the one specific to this
// process, and then call down to perform the intended operation.
int bind (const ACE_NS_String &,
const ACE_NS_Internal &,
ALLOCATOR *allocator);
int unbind (const ACE_NS_String &,
ACE_NS_Internal &,
ALLOCATOR *allocator);
int rebind (const ACE_NS_String &,
const ACE_NS_Internal &,
ACE_NS_String &,
ACE_NS_Internal &,
ALLOCATOR *allocator);
int find (const ACE_NS_String &,
ACE_NS_Internal &,
ALLOCATOR *allocator);
int close (ALLOCATOR* allocator);
private:
};
template <ACE_MEM_POOL_1, class LOCK>
class ACE_Local_Name_Space : public ACE_Name_Space
// = TITLE
// Maintaining accesses Local Name Server Database. Allows to
// add NameBindings, change them, remove them and resolve
// NameBindings.
//
// = DESCRIPTION
// Manages a Naming Service for a local name space which includes
// bindings for node_local and host_local naming contexts.
// All strings are stored in wide character format.
// A Name Binding consists of a name (that's the key), a value
// string and an optional type string (no wide chars).
{
public:
// = Initialization and termination methods.
ACE_Local_Name_Space (void);
// "Do-nothing" constructor.
ACE_Local_Name_Space (ACE_Naming_Context::Context_Scope_Type scope_in,
ACE_Name_Options *name_options);
// Specifies the scope of this namespace, opens and memory-maps the
// associated file (if accessible) or contacts the dedicated name
// server process for NET_LOCAL namespace.
int open (ACE_Naming_Context::Context_Scope_Type scope_in);
// Specifies the scope of this namespace, opens and memory-maps the
// associated file (if accessible) or contacts the dedicated name
// server process for NET_LOCAL namespace.
~ACE_Local_Name_Space (void);
// destructor, do some cleanup :TBD: last dtor should "compress"
// file
virtual int bind (const ACE_WString &name,
const ACE_WString &value,
const char *type = "");
// Bind a new name to a naming context (Wide character strings).
virtual int rebind (const ACE_WString &name,
const ACE_WString &value,
const char *type = "");
// Overwrite the value or type of an existing name in a
// ACE_Local_Name_Space or bind a new name to the context, if it
// didn't exist yet. (Wide charcter strings interface).
virtual int unbind (const ACE_WString &name);
virtual int unbind_i (const ACE_WString &name);
// Delete a name from a ACE_Local_Name_Space (Wide charcter strings
// Interface).
virtual int resolve (const ACE_WString &name,
ACE_WString &value,
char *&type);
virtual int resolve_i (const ACE_WString &name,
ACE_WString &value,
char *&type);
// Get value and type of a given name binding (Wide chars). The
// caller is responsible for deleting <type>!
virtual int list_names (ACE_WSTRING_SET &set,
const ACE_WString &pattern);
// Get a set of names matching a specified pattern (wchars). Matching
// means the names must begin with the pattern string.
virtual int list_values (ACE_WSTRING_SET &set,
const ACE_WString &pattern);
// Get a set of values matching a specified pattern (wchars). Matching
// means the values must begin with the pattern string.
virtual int list_types (ACE_WSTRING_SET &set,
const ACE_WString &pattern);
// Get a set of types matching a specified pattern (wchars). Matching
// means the types must begin with the pattern string.
virtual int list_name_entries (ACE_BINDING_SET &set,
const ACE_WString &pattern);
// Get a set of names matching a specified pattern (wchars). Matching
// means the names must begin with the pattern string. Returns the
// complete binding associated each pattern match.
virtual int list_value_entries (ACE_BINDING_SET &set,
const ACE_WString &pattern);
// Get a set of values matching a specified pattern (wchars). Matching
// means the values must begin with the pattern string. Returns the
// complete binding associated each pattern match.
virtual int list_type_entries (ACE_BINDING_SET &set,
const ACE_WString &pattern);
// Get a set of types matching a specified pattern (wchars). Matching
// means the types must begin with the pattern string. Returns the
// complete binding associated each pattern match.
virtual void dump (void) const;
// Dump the state of the object
private:
#if defined (ACE_WIN32)
int remap (EXCEPTION_POINTERS *ep);
// Remap the backing store
#endif /* ACE_WIN32 */
int shared_bind (const ACE_WString &name, const ACE_WString &value,
const char *type, int rebind);
int shared_bind_i (const ACE_WString &name, const ACE_WString &value,
const char *type, int rebind);
// Factor out code from bind() and rebind().
int create_manager (void);
int create_manager_i (void);
// Allocate the appropriate type of map manager that stores the
// key/value binding.
// = I just know this is going to cause problems on some platform...
typedef ACE_Allocator_Adapter <ACE_Malloc <ACE_MEM_POOL_2, LOCK> > ALLOCATOR;
ALLOCATOR *allocator_;
// Pointer to the allocator
ACE_Name_Space_Map <ALLOCATOR> *name_space_map_;
// Pointer to the allocated map manager.
ACE_Naming_Context::Context_Scope_Type ns_scope_;
// Scope of this naming context (e.g., PROC_LOCAL, NODE_LOCAL, or NET_LOCAL).
ACE_Name_Options *name_options_;
// Keep track of the options such as database name etc
TCHAR context_file_[MAXNAMELEN];
// Name of the file used as the backing store.
LOCK *lock_;
// Synchronization variable.
};
#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
#include "ace/Local_Name_Space_T.cpp"
#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */
#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
#pragma implementation ("Local_Name_Space_T.cpp")
#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */
#endif /* ACE_LOCAL_NAME_SPACE_T_H */
|
