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
|
// $Id$
#ifndef IMR_LOCATOR_I_H
#define IMR_LOCATOR_I_H
#include /**/ "ace/pre.h"
#include "locator_export.h"
#include "Adapter_Activator.h"
#include "Forwarder.h"
#include "Locator_Options.h"
#include "Locator_Repository.h"
#include "AsyncStartupWaiter_i.h"
#include "tao/IORTable/IORTable.h"
#include "orbsvcs/IOR_Multicast.h"
#include "ImR_LocatorS.h"
#include "AsyncStartupWaiterS.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class ACE_Reactor;
class INS_Locator;
// Gets a request from a client and depending on the POA name,
// requests an activator to take care of activating the
// corresponding server and raises a forward exception to the
// client pointing to the correct server.
class Locator_Export ImR_Locator_i
: public virtual POA_ImplementationRepository::Locator
{
public:
ImR_Locator_i();
~ImR_Locator_i (void);
/// Initialize the service, creating its own orb, poa, etc.
int init (Options& opts ACE_ENV_ARG_DECL);
/// Same as above, but use the given orb
int init_with_orb (CORBA::ORB_ptr orb, Options& opts ACE_ENV_ARG_DECL);
/// Cleans up any state created by init*.
int fini (ACE_ENV_SINGLE_ARG_DECL);
/// Run using the orb reference created during init()
int run (ACE_ENV_SINGLE_ARG_DECL);
/// Shutdown the orb.
void shutdown (bool wait_for_completion ACE_ENV_ARG_DECL);
int debug() const;
// Note : See the IDL for descriptions of the operations.
// Activator->Locator
virtual CORBA::Long register_activator (const char* name,
ImplementationRepository::Activator_ptr admin
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void unregister_activator (const char* name,
CORBA::Long token ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void notify_child_death (const char* name ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
// tao_imr->Locator
virtual void activate_server (const char * name
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
ImplementationRepository::NotFound,
ImplementationRepository::CannotActivate));
virtual void add_or_update_server (const char * name,
const ImplementationRepository::StartupOptions &options ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, ImplementationRepository::NotFound));
virtual void remove_server (const char * name ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, ImplementationRepository::NotFound));
virtual void shutdown_server (const char * name ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, ImplementationRepository::NotFound));
virtual void find (const char * name,
ImplementationRepository::ServerInformation_out info ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void list (
CORBA::ULong how_many,
ImplementationRepository::ServerInformationList_out server_list,
ImplementationRepository::ServerInformationIterator_out server_iterator ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void shutdown(CORBA::Boolean activators, CORBA::Boolean servers ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
// Server->Locator
virtual void server_is_running (const char* name,
const char* partial_ior,
ImplementationRepository::ServerObject_ptr server_object
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, ImplementationRepository::NotFound));
virtual void server_is_shutting_down (const char * name ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException, ImplementationRepository::NotFound));
// Used by the INS_Locator to start a sever given an object name
char* activate_server_by_object (const char* object_name ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
ImplementationRepository::NotFound,
ImplementationRepository::CannotActivate));
char* activate_server_by_name (const char * name, bool manual_start ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
ImplementationRepository::NotFound,
ImplementationRepository::CannotActivate));
private:
char* activate_server_i (Server_Info& info, bool manual_start ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
ImplementationRepository::NotFound,
ImplementationRepository::CannotActivate));
char* activate_perclient_server_i (Server_Info info, bool manual_start ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
ImplementationRepository::NotFound,
ImplementationRepository::CannotActivate));
ImplementationRepository::StartupInfo*
start_server(Server_Info& info, bool manual_start ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
ImplementationRepository::NotFound,
ImplementationRepository::CannotActivate));
bool is_alive(Server_Info& info);
int is_alive_i(Server_Info& info);
// Set up the multicast related if 'm' is passed on the command
// line.
int setup_multicast (ACE_Reactor *reactor, const char *ior);
void teardown_multicast();
void unregister_activator_i(const char* activator);
Activator_Info_Ptr get_activator (const ACE_CString& name);
void connect_activator (Activator_Info& info);
void auto_start_servers(ACE_ENV_SINGLE_ARG_DECL);
CORBA::Object_ptr set_timeout_policy(CORBA::Object_ptr obj, const ACE_Time_Value& to);
void connect_server(Server_Info& info);
PortableServer::POA_ptr findPOA(const char* name);
private:
// The class that handles the forwarding.
ImR_Forwarder forwarder_;
// Used for the forwarding of any type of POA.
ImR_Adapter adapter_;
/// The locator interface for the IORTable
IORTable::Locator_var ins_locator_;
CORBA::ORB_var orb_;
PortableServer::POA_var root_poa_;
PortableServer::POA_var imr_poa_;
int debug_;
TAO_IOR_Multicast ior_multicast_;
Locator_Repository repository_;
AsyncStartupWaiter_i waiter_svt_;
ImplementationRepository::AsyncStartupWaiter_var waiter_;
bool read_only_;
ACE_Time_Value startup_timeout_;
ACE_Time_Value ping_interval_;
};
#include /**/ "ace/post.h"
#endif /* IMR_LOCATOR_I_H */
|
