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
|
// -*- C++ -*-
//=============================================================================
/**
* @file ImR_Activator_i.h
*
* @author Priyanka Gontla <gontla_p@ociweb.com>
* @author Darrell Brunsch <brunsch@cs.wustl.edu>
*/
//=============================================================================
#ifndef IMR_ACTIVATOR_I_H
#define IMR_ACTIVATOR_I_H
#include "activator_export.h"
#include "ImR_ActivatorS.h"
#include "ImR_LocatorC.h"
#include "ace/Process_Manager.h"
#include "ace/Hash_Map_Manager.h"
#include "ace/Null_Mutex.h"
#include "ace/SString.h"
#if defined (ACE_WIN32)
# include "ace/Task.h"
#endif /* ACE_WIN32 */
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class Activator_Options;
// ace/Functor.h doesn't provide functors for every built in integer type.
// Depending on the platform and what pid_t maps to, the functors may be missing.
struct ACE_Hash_pid_t
{
unsigned long operator () (pid_t t) const
{
return t;
}
};
struct ACE_Equal_To_pid_t
{
int operator () (const pid_t lhs, const pid_t rhs) const
{
return lhs == rhs;
}
};
#if (ACE_SIZEOF_VOID_P == 8)
typedef ACE_INT64 Act_token_type;
#else
typedef ACE_INT32 Act_token_type;
#endif
#if defined (ACE_WIN32)
class Active_Pid_Setter;
class Watchdog : public ACE_Task_Base
{
public:
Watchdog (ACE_Process_Manager& procman);
virtual int svc ();
bool start ();
void stop ();
private:
bool stop_;
ACE_Process_Manager &procman_;
};
#endif /* ACE_WIN32 */
/**
* @class ImR_Activator_i
*
* @brief IMR Activator Interface.
*
* This class provides the interface for the various activities
* that can be done by the ImR_Activator.
*
*/
class Activator_Export ImR_Activator_i : public POA_ImplementationRepository::ActivatorExt,
public ACE_Event_Handler
{
public:
friend class Active_Pid_Setter;
ImR_Activator_i (void);
void start_server (const char* name,
const char* cmdline,
const char* dir,
const ImplementationRepository::EnvironmentList & env);
CORBA::Boolean kill_server (const char* name, CORBA::Long pid, CORBA::Short signum);
CORBA::Boolean still_alive (CORBA::Long pid);
void shutdown(void);
/// Initialize the Server state - parsing arguments and waiting.
int init (Activator_Options& opts);
/// Cleans up any state created by init*.
int fini (void);
int handle_timeout (const ACE_Time_Value &, const void *tok);
/// Runs the orb.
int run (void);
/// Shutdown the orb.
void shutdown (bool signaled);
private:
int init_with_orb (CORBA::ORB_ptr orb, const Activator_Options& opts);
void register_with_imr(ImplementationRepository::Activator_ptr activator);
// Handles the death of the child processes of the ImR_Activator.
// Informs the ImR_Locator too.
int handle_exit (ACE_Process * process);
int handle_exit_i (pid_t pid);
bool still_running_i (const char *name, pid_t& pid);
bool in_upcall (void);
private:
typedef ACE_Unbounded_Set<ACE_CString> UniqueServerList;
typedef ACE_Hash_Map_Manager_Ex<pid_t,
ACE_CString,
ACE_Hash_pid_t,
ACE_Equal_To_pid_t,
ACE_Null_Mutex> ProcessMap;
ACE_Process_Manager process_mgr_;
PortableServer::POA_var root_poa_;
PortableServer::POA_var imr_poa_;
PortableServer::Current_var current_;
ImplementationRepository::Locator_var locator_;
/// We're given a token when registering with the locator, which
/// we must use when unregistering.
CORBA::Long registration_token_;
CORBA::ORB_var orb_;
unsigned int debug_;
bool notify_imr_;
unsigned int induce_delay_;
ACE_CString name_;
ProcessMap process_map_;
UniqueServerList running_server_list_;
UniqueServerList dying_server_list_;
/// The default environment buffer length
int env_buf_len_;
/// Maximum number of environment variables
int max_env_vars_;
bool detach_child_;
pid_t active_check_pid_;
#if defined (ACE_WIN32)
Watchdog process_watcher_;
#endif /* ACE_WIN32 */
};
#if defined (ACE_WIN32)
class Active_Pid_Setter
{
public:
Active_Pid_Setter(ImR_Activator_i &owner, pid_t pid);
~Active_Pid_Setter();
ImR_Activator_i &owner_;
};
#endif /* ACE_WIN32 */
#endif /* IMR_ACTIVATOR_I_H */
|
