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
228
|
// -*- C++ -*-
//=============================================================================
/**
* @file PG_FactoryRegistry.h
*
* This file declares the implementation of PortableGroup::FactoryRegistry.
* Eventually this should be folded into the Fault Tolerance ReplicationManager
*
* @author Dale Wilson <wilson_d@ociweb.com>
*/
//=============================================================================
#ifndef TAO_PG_FACTORYREGISTRY_H_
#define TAO_PG_FACTORYREGISTRY_H_
#include /**/ "ace/pre.h"
#include /**/ "ace/ACE.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/Versioned_Namespace.h"
/////////////////////////////////
// Includes needed by this header
#include "orbsvcs/PortableGroup/portablegroup_export.h"
#include "orbsvcs/PortableGroupS.h"
#include "ace/Hash_Map_Manager.h"
#include "ace/SString.h"
#include "ace/Null_Mutex.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
//////////////////////////////////
// Classes declared in this header
namespace TAO
{
class PG_FactoryRegistry;
}
/////////////////////
// Forward references
namespace TAO
{
/**
* Implement the PortableGroup::FactoryRegistry interface
* Note FactoryRegistry is not part of the OMG standard. It was added
* as part of the TAO implementation of Fault Tolerant CORBA
*/
class TAO_PortableGroup_Export PG_FactoryRegistry
: public virtual POA_PortableGroup::FactoryRegistry
{
struct RoleInfo
{
ACE_CString type_id_;
PortableGroup::FactoryInfos infos_;
RoleInfo(size_t estimated_number_entries = 5);
};
typedef ACE_Null_Mutex MapMutex;
typedef ACE_Hash_Map_Manager <ACE_CString, RoleInfo *, MapMutex> RegistryType;
typedef ACE_Hash_Map_Entry <ACE_CString, RoleInfo *> RegistryType_Entry;
typedef ACE_Hash_Map_Iterator <ACE_CString, RoleInfo *, MapMutex> RegistryType_Iterator;
//////////////////////
// non-CORBA interface
public:
/// Constructor
PG_FactoryRegistry (const char * name = "FactoryRegistry");
/// virtual Destructor
virtual ~PG_FactoryRegistry (void);
/**
* Parse command line arguments.
* @param argc traditional C argc
* @param argv traditional C argv
* @return zero for success; nonzero is process return code for failure.
*/
int parse_args (int argc, ACE_TCHAR * argv[]);
/**
* Initialize this object.
* @param orb our ORB -- we keep var to it.
* @return zero for success; nonzero is process return code for failure.
*/
int init (CORBA::ORB_ptr orb);
/**
* alternative init using designated poa
*/
void init (CORBA::ORB_ptr orb, PortableServer::POA_ptr poa);
/**
* Prepare to exit.
* @return zero for success; nonzero is process return code for failure.
*/
int fini (void);
/**
* Processing to happen when the ORB's event loop is idle.
* @param result is a place to return status to be returned by the process
* @returns 0 to continue. 1 to quit.
*/
int idle(int & result);
/**
* Identify this object.
* @return a string to identify this object for logging/console message purposes.
*/
const char * identity () const;
/**
* An object reference to the this object.
* Duplicated by the call so it may (and probably should) be assigned to a _var..
*/
::PortableGroup::FactoryRegistry_ptr reference();
////////////////////////////////
// override servant base methods
virtual void _remove_ref (void);
//////////////////
// CORBA interface
// See IDL for documentation
virtual void register_factory (
const char * role,
const char * type_id,
const PortableGroup::FactoryInfo & factory_info);
virtual void unregister_factory (
const char * role,
const PortableGroup::Location & location);
virtual void unregister_factory_by_role (const char * role);
virtual void unregister_factory_by_location (
const PortableGroup::Location & location);
virtual ::PortableGroup::FactoryInfos * list_factories_by_role (
const char * role,
CORBA::String_out type_id);
virtual ::PortableGroup::FactoryInfos * list_factories_by_location (
const PortableGroup::Location & location);
/////////////////////////
// Implementation methods
private:
/**
* Write this factory's IOR to a file
*/
int write_ior_file (const ACE_TCHAR * outputFile, const char * ior);
///////////////
// Data Members
private:
/**
* A human-readable string to distinguish this from other Notifiers.
*/
ACE_CString identity_;
/**
* The orb
*/
CORBA::ORB_var orb_;
/**
* The POA used to activate this object.
*/
PortableServer::POA_var poa_;
/**
* The CORBA object id assigned to this object.
*/
PortableServer::ObjectId_var object_id_;
/**
* This objects identity as a CORBA object.
*/
CORBA::Object_var this_obj_;
/**
* IOR of this object as assigned by poa.
*/
CORBA::String_var ior_;
/**
* A file to which the factory's IOR should be written.
*/
const ACE_TCHAR * ior_output_file_;
/**
* A name to be used to register the factory with the name service.
*/
ACE_CString ns_name_;
CosNaming::NamingContext_var naming_context_;
CosNaming::Name this_name_;
/**
* Quit on idle flag.
*/
int quit_on_idle_;
/**
* State of the quit process
*/
enum {LIVE, DEACTIVATED, GONE} quit_state_;
int linger_;
RegistryType registry_;
};
} // namespace TAO
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif // TAO_PG_FACTORYREGISTRY_H_
|
