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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = FILENAME
// CosEvent_Service.h
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
//
// = DESCRIPTION
// The COS Event Channel service.
//
// ============================================================================
#ifndef COSEVENT_SERVICE_H
#define COSEVENT_SERVICE_H
#include "orbsvcs/Naming/Naming_Utils.h"
#include "orbsvcs/CosNamingC.h"
#include "orbsvcs/Event_Utilities.h"
#include "orbsvcs/Event_Service_Constants.h"
#include "orbsvcs/Scheduler_Factory.h"
#include "orbsvcs/Time_Utilities.h"
#include "orbsvcs/RtecEventChannelAdminC.h"
#include "orbsvcs/Sched/Config_Scheduler.h"
#include "orbsvcs/Runtime_Scheduler.h"
#include "orbsvcs/Event/Event_Channel.h"
#include "orbsvcs/Event/Module_Factory.h"
#include "orbsvcs/CosEvent/EventChannel_i.h"
class CosEvent_Service
{
// = TITLE
// CosEvent_Service
//
// = DESCRIPTION
// Implementation of the COS Event Service.
public:
// = Initialization and termination methods.
CosEvent_Service (void);
// Constructor.
~CosEvent_Service (void);
// Destructor.
int startup (int argc, char *argv[]);
// Initializes the COS Event Service.
// Returns 0 on success, -1 on error.
int run (void);
// run the COS Event Service.
// Returns 0 on success, -1 on error.
int shutdown (void);
// Shutdown the COS Event Service.
// Returns 0 on success, -1 on error.
private:
int init_ORB (int argc, char *argv []);
// initialize the ORB.
int parse_args (int argc, char *argv []);
// Parses the command line arguments.
int init_NamingService (void);
// Initializes the Naming Client.
// Returns 0 on success, -1 on error.
int get_Rtec_viaNamingService (void);
// Gets a reference to a Rtec via the naming service.
// Returns 0 on success, -1 on error.
int start_Scheduler (void);
// start the Scheduler used ny the RtEC.
// Returns 0 on success, -1 on error.
int create_local_RtecService (void);
// Creates a local Rtec.
// Returns 0 on success, -1 on error.
void init_SupplierQOS (RtecScheduler::handle_t supp_handle);
// Initialize the SupplierQOS Factory.
void init_ConsumerQOS (RtecScheduler::handle_t cons_handle);
// Initialize the ConsumerQOS Factory.
int create_CosEC (void);
// Creates a local CosEC.
// Returns 0 on success, -1 on error.
int register_CosEC (void);
// Registers the Cos EC with the Naming Service.
// Returns 0 on success, -1 on error.
const char* service_name;
// The name we use to register with the Naming Service.
const char* rt_service_name;
// The name of the Real Time Event Service.
const char* schedule_name_;
// The name of the scheduler service.
CORBA::ORB_var orb_;
// The ORB that we use.
TAO_Naming_Client naming_client_;
// An instance of the name client used for resolving the factory
// objects.
TAO_Reactive_Module_Factory module_factory_;
// The Module_Factory required by the Rtec.
ACE_Config_Scheduler scheduler_impl_;
// Scheduler used by the Rtec.
RtecScheduler::Scheduler_var scheduler_;
// Reference to the Scheduler after activating it in the ORB.
ACE_EventChannel ec_impl_;
// The servant object of the Rtec.
RtecEventChannelAdmin::EventChannel_var rtec_;
// Reference to the Rtec returned after activating it in the ORB.
ACE_ConsumerQOS_Factory consumer_qos_;
// The Consumer QOS.
ACE_SupplierQOS_Factory supplier_qos_;
// The Supplier QOS.
TAO_CosEC_EventChannel_i ec_i_;
// The servant object of the COS Event Channel.
CosEventChannelAdmin::EventChannel_ptr cos_ec_;
// Reference to the CosEC returned after activating it in the ORB.
int global_scheduler_;
// Flag to indicate if the scheduler is local/global,
// 0 => local, 1 => global, default is local.
int remote_Rtec_;
// Flag to indicate if the RtEC is local/remote,
// 0 => local, 1 => remote, default is remote.\
char* eventTypeIds_;
// The list of EventTypeIDs (for ConsumerQOS) seperated by spaces. e.g. "1 2 3 4"
char* eventSourceIds_;
// The list of EventSourceIDs (for ConsumerQOS) seperated by spaces. e.g. "1 2 3 4"
char *source_type_pairs_;
// The pairs of Source and EventType Ids (for the SupplierQOS).
};
#endif /* COSEVENT_SERVICE_H */
|
