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
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
|
// -*- C++ -*-
//=============================================================================
/**
* @file RTCosScheduling_ServerScheduler_i.h
*
* $Id$
*
* @author Matt Murphy <murphym@cs.uri.edu>
*/
//=============================================================================
#ifndef SERVER_SCHEDULERI_H
#define SERVER_SCHEDULERI_H
#include /**/ "ace/pre.h"
#include "ace/Map_T.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/SString.h"
#include <orbsvcs/RTCosSchedulingS.h>
#include <orbsvcs/RTCosScheduling/RTCosScheduling_export.h>
#include "RTCosScheduling_PCP_Manager.h"
#include "tao/PortableInterceptorC.h"
#include "tao/CodecFactory/CodecFactory.h"
#include "tao/LocalObject.h"
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable:4250)
#endif /* _MSC_VER */
#if defined (__BORLANDC__)
#pragma option push -w-rvl -w-rch -w-ccc -w-inl
#endif /* __BORLANDC__ */
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
#ifndef RTCOSSCHEDULING_SERVER_CONTAINERS
#define RTCOSSCHEDULING_SERVER_CONTAINERS
/**
* CosSchedulingObjectNameMap
*
* This typedef is used by the RTCORBA 1.0 ServerScheduler to map
* CORBA object references to names
*/
typedef CORBA::Object_var COS_SCHEDULING_OBJECT_NAME_KEY;
typedef ACE_CString COS_SCHEDULING_OBJECT_NAME_VALUE;
template<>
class TAO_RTCosScheduling_Export ACE_Equal_To< COS_SCHEDULING_OBJECT_NAME_KEY >
{
public:
int operator () (const COS_SCHEDULING_OBJECT_NAME_KEY lhs,
const COS_SCHEDULING_OBJECT_NAME_KEY rhs) const;
};
namespace TAO {
class TAO_RTCosScheduling_Export CosSchedulingObjectMap_Hash_Key
{
public:
u_long operator () (const COS_SCHEDULING_OBJECT_NAME_KEY &key) const;
};
typedef ACE_Hash_Map_Manager_Ex_Adapter<
COS_SCHEDULING_OBJECT_NAME_KEY,
COS_SCHEDULING_OBJECT_NAME_VALUE,
CosSchedulingObjectMap_Hash_Key,
ACE_Equal_To<COS_SCHEDULING_OBJECT_NAME_KEY>,
ACE_Noop_Key_Generator<COS_SCHEDULING_OBJECT_NAME_KEY> > CosSchedulingObjectMap;
/**
* This typedef is used in the ServerScheduler to hold a list of
* priority ceiling protocol managers for each active method call
* from a client.
*/
typedef int COS_SCHEDULING_INVOCATION_KEY;
typedef PCP_Manager * COS_SCHEDULING_INVOCATION_VALUE;
class CosSchedulingInvocation_Hash_key
{
public:
u_long operator () (const COS_SCHEDULING_INVOCATION_KEY &key) const;
};
typedef ACE_Hash_Map_Manager_Ex_Adapter<
COS_SCHEDULING_INVOCATION_KEY,
COS_SCHEDULING_INVOCATION_VALUE,
CosSchedulingInvocation_Hash_key,
ACE_Equal_To<COS_SCHEDULING_INVOCATION_KEY>,
ACE_Noop_Key_Generator<COS_SCHEDULING_INVOCATION_KEY> > CosSchedulingInvocationMap;
#endif /* RTCOSSCHEDULING_SERVER_CONTAINERS */
#if TAO_HAS_INTERCEPTORS
/**
* @class RTCosScheduling_ServerScheduler_Interceptor
*
* @brief The RTCosScheduling_ServerScheduler_Interceptor intercepts CORBA
* requests on behalf of the RTCORBA 1.0 scheduling service and
* schedules the requests.
*/
class RTCosScheduling_ServerScheduler_Interceptor
: public PortableInterceptor::ServerRequestInterceptor
{
public :
RTCosScheduling_ServerScheduler_Interceptor(CORBA::ORB_ptr orb,
char *shared_file,
CosSchedulingObjectMap *CosSchedulingObjectMap,
CosSchedulingResourceMap *resourceMap);
virtual ~RTCosScheduling_ServerScheduler_Interceptor();
virtual char* name(ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC((
CORBA::SystemException));
virtual void destroy( ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC((CORBA::SystemException));
virtual void receive_request(
PortableInterceptor::ServerRequestInfo_ptr ri
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC((
CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void receive_request_service_contexts(
PortableInterceptor::ServerRequestInfo_ptr ri
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC((
CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void send_reply(
PortableInterceptor::ServerRequestInfo_ptr ri
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC((CORBA::SystemException));
virtual void send_exception(
PortableInterceptor::ServerRequestInfo_ptr ri
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC((
CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void send_other(
PortableInterceptor::ServerRequestInfo_ptr ri
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC((
CORBA::SystemException,
PortableInterceptor::ForwardRequest));
void finish_execution();
private:
/// The name of the interceptor
const char* name_;
/// reference to set local priority
RTCORBA::Current_var current_;
/// Factory reference to receive PCP_managers
PCP_Manager_Factory * PCP_factory_;
/// Map to match threadIDs with PCP_Managers
CosSchedulingInvocationMap invocation_map_;
//The orb
CORBA::ORB_ptr orb_;
/// Map to match CORBA::Object_vars to names
CosSchedulingObjectMap *object_name_map_;
/// Map to match Resource names to Ceilings
CosSchedulingResourceMap *resource_map_;
// The codec to decode incoming CORBA Priorities
IOP::Codec_var codec_;
// The factory to create the codec
IOP::CodecFactory_var codec_factory_;
};
#endif /* TAO_HAS_INTERCEPTORS */
/**
* @class RTCosScheduling_ServerScheduler_i
*
* @brief The ServerScheduler class handles server side
* scheduling for the RTCORBA 1.0 Scheduling Service.
*/
class TAO_RTCosScheduling_Export RTCosScheduling_ServerScheduler_i
: public virtual RTCosScheduling::ServerScheduler,
public virtual CORBA::LocalObject
{
public:
// Constructor
RTCosScheduling_ServerScheduler_i (char *node,
char *file,
char *shared_file,
int numthreads);
//Destructor
virtual ~RTCosScheduling_ServerScheduler_i (void);
/**
* This creates and returns a RT POA for use on the server.
* It accepts a set of non-RT policies and sets these as
* well as RT policies (threadpooling and Server Declared).
*
* @param parent The poa to base the RT POA upon
* @param adapter_name the adapter name for the poa
* @param a_POAManager the poa_manager
* @param policies the list of non real time policies to be set
*/
virtual ::PortableServer::POA_ptr create_POA (
PortableServer::POA_ptr parent,
const char * adapter_name,
PortableServer::POAManager_ptr a_POAManager,
const CORBA::PolicyList & policies
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((
CORBA::SystemException
, PortableServer::POA::AdapterAlreadyExists
, PortableServer::POA::InvalidPolicy));
/**
* This maps a CORBA::Object_var with a name. The names are
* later associated with priority ceiling stored in the
* scheduling config file.
*
* @param obj the CORBA object reference to associate with a name
* @param name name to associate with the CORBA object reference
*/
virtual void schedule_object (CORBA::Object_ptr obj,
const char * name
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC (( CORBA::SystemException
, RTCosScheduling::UnknownName));
private:
/**
* This sets the orb for the ServerScheduler,
* it also resolves references to RT current and sets
* priority mapping
*/
int configure_ORB(TAO_ORB_Core *orb_core);
/// RT Current, to change the priority of the thread
/// RT Corba Priority Mapping , uses
/// Linear Priority Mapping
RTCORBA::PriorityMapping *pm_;
/// The number of threads in the server threadpool
int num_threads_;
char *shared_file_;
/// The map to match CORBA::Object_vars
/// to names
CosSchedulingObjectMap object_name_map_;
/// The map to match resource names to corba priorities
CosSchedulingResourceMap resource_map_;
/*
* resources populates a string/int map with a list of resources (keys)
* and associated priority ceilings(values)
*
* @param node_name the name of the node the client resides on,
* resources() only retrieves ceilings for the local node
*
* @param map resource_map a reference to the resource map to populate
*
*/
int resources(const char* node_name,
const char* file_name,
CosSchedulingResourceMap * resource_map);
};
}
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "RTCosScheduling_ServerScheduler_i.i"
#endif /* __ACE_INLINE__ */
#if defined(_MSC_VER)
#pragma warning(pop)
#endif /* _MSC_VER */
#if defined (__BORLANDC__)
#pragma option pop
#endif /* __BORLANDC__ */
#include /**/ "ace/post.h"
#endif /* SERVER_SCHEDULERI_H */
|