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
|
/* -*- 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.
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.
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.
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.
};
#endif /* COSEVENT_SERVICE_H */
|
