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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file RTCosScheduling_ClientScheduler_i.h
*
* $Id$
*
* @author Matt Murphy <murphym@cs.uri.edu>
*/
//=============================================================================
#ifndef CLIENT_SCHEDULER_I_H
#define CLIENT_SCHEDULER_I_H
#include /**/ "ace/pre.h"
/**
* Note - Before making this file with Makefile.RTCosScheduling, please make
* sure that you first comment out the following line from the
* RTCosSchedulingS.h file:
* //#include "tao/PortableServer/PortableServerS.h"
*/
#include "ace/Map_T.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (__BORLANDC__)
#pragma option push -w-rvl -w-rch -w-ccc -w-inl
#endif /* __BORLANDC__ */
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
#include "ace/SString.h"
#include <orbsvcs/RTCosSchedulingC.h>
#include <orbsvcs/RTCosScheduling/RTCosScheduling_export.h>
#include "tao/RTCORBA/Priority_Mapping_Manager.h"
#include "tao/PortableInterceptorC.h"
#include "tao/RTCORBA/Linear_Priority_Mapping.h"
namespace TAO {
#ifndef COS_SCHEDULER_ACTIVITY_MAP
#define COS_SCHEDULER_ACTIVITY_MAP
/**
* This typedef is used in RTCosScheduling_ClientScheduler
* to map activity names,stored as an ACE_CString,
* to CORBA priorities
*/
typedef ACE_CString COS_SCHEDULER_ACTIVITY_KEY;
typedef CORBA::Long COS_SCHEDULER_ACTIVITY_VALUE;
typedef ACE_Map_Manager_Adapter<
COS_SCHEDULER_ACTIVITY_KEY,
COS_SCHEDULER_ACTIVITY_VALUE,
ACE_Noop_Key_Generator<COS_SCHEDULER_ACTIVITY_KEY> >
CosSchedulerActivityMap;
#endif /* ACTIVITY_MAP */
#if TAO_HAS_INTERCEPTORS
/**
* @class ClientRequestInterceptor
*
* @brief Simple concrete client request interceptor.
*/
class RTCosScheduling_ClientScheduler_Interceptor
: public PortableInterceptor::ClientRequestInterceptor
{
public:
RTCosScheduling_ClientScheduler_Interceptor();
RTCosScheduling_ClientScheduler_Interceptor(const CORBA::ORB_var orb);
virtual ~RTCosScheduling_ClientScheduler_Interceptor() { }
/**
* @name Methods Required by the Client Request Interceptor
* Interface
*
* These are methods that must be implemented since they are pure
* virtual in the abstract base class. They are the canonical
* methods required for all client request interceptors.
*/
//@{
/// Return the name of this ClientRequestInterceptor.
//
virtual char * name (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void send_request (
PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL_WITH_DEFAULTS)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void send_poll (
PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void receive_reply (
PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void receive_exception (
PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void receive_other (
PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
//@}
private:
/// The name of the interceptor
const char* name_;
/// reference to set local priority
RTCORBA::Current_var current_;
IOP::Codec_var codec_;
};
#endif /* TAO_HAS_INTERCEPTORS */
/**
* @class RTCosScheduling_ClientScheduler
*
* @brief Used in conjunction with the class ServerScheduler to
* provide RTCORBA 1.0 compliant scheduling
*
* This class provides the framework necessary for a client node
* to retrieve scheduling information from a config file and set
* the local OS priority.
*
*/
class TAO_RTCosScheduling_Export RTCosScheduling_ClientScheduler_i :
public virtual RTCosScheduling::ClientScheduler,
public virtual CORBA::LocalObject
{
public:
//@{
/*
* Constructs a new ClientScheduler object for use on a client
* that wishes to use the RTCORBA 1.0 Scheduling Service.
*
* @param orb The orb
* @param node The name of the node the client resides on
*/
RTCosScheduling_ClientScheduler_i (CORBA::ORB_var orb,
char* node,
char* file);
///Destructor
virtual ~RTCosScheduling_ClientScheduler_i (void);
/**
* Called by clients to set the local thread priority to
* that specified in the scheduling config file
*
* @param activity_name the name of the activity that signifies
* the desired priority
*/
virtual void schedule_activity (
const char *activity_name
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((
CORBA::SystemException,
RTCosScheduling::UnknownName));
//@}
private:
/// The map to match activity names with corba priorities
CosSchedulerActivityMap activity_map_;
/// RT Current, to change the priority of the thread
RTCORBA::Current_var current_;
/// RT Corba Priority Mapping
RTCORBA::PriorityMapping *pm_;
#if TAO_HAS_INTERCEPTORS
/// The Server Interceptor that handles the PCP control
RTCosScheduling_ClientScheduler_Interceptor *client_interceptor_;
#endif /* TAO_HAS_INTERCEPTORS */
int tasks(const char *node_name,
const char *file_name,
CosSchedulerActivityMap *activity_map);
};
}
#if defined (__ACE_INLINE__)
#include "RTCosScheduling_ClientScheduler_i.i"
#endif /* __ACE_INLINE__ */
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */
#if defined (__BORLANDC__)
#pragma option pop
#endif /* __BORLANDC__ */
#include /**/ "ace/post.h"
#endif /* CLIENT_SCHEDULER_I */
|
