blob: 259919ec60444792dbd419d5d535f93b3b0faef5 (
plain)
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
|
// $Id$
// ============================================================================
//
// = FILENAME
// DOVE_Supplier.h
//
// = DESCRIPTION
// A wrapper around the event service initialization and marshalling.
//
// = AUTHORS
// Michael Kircher (mk1@cs.wustl.edu)
// Chris Gill (cdgill@cs.wustl.edu)
// ============================================================================
#include "ace/OS.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/corba.h"
#include "orbsvcs/RtecEventChannelAdminC.h"
#include "orbsvcs/RtecEventCommS.h"
#include "orbsvcs/Event_Utilities.h"
#include "orbsvcs/Event_Service_Constants.h"
#include "orbsvcs/Scheduler_Factory.h"
#ifndef DOVE_SUPPLIER_H
#define DOVE_SUPPLIER_H
#define SOURCE_ID 123
class DOVE_Supplier
{
public:
DOVE_Supplier ();
// Constructor.
~DOVE_Supplier (void);
// Destructor.
int init (void);
// Initialize the ORB and the connection to the Name Service
int connect (const char * MIB_name = 0,
const char* es_name = 0,
const char * ss_name = 0,
ACE_Scheduler_Factory::POD_RT_Info * pod_rt_info = 0);
// Connect to the event service.
void connected ();
// Perform all post-connection-establishment processing.
void disconnect ();
// Disconnect from the event service.
void notify (CORBA::Any& message);
// Notify the consumer proxy that we have events
void use_next_connection ();
// Use the next connection in the list of established connections.
void use_prev_connection ();
// Use the previous connection in the list of established connections.
private:
// The following Supplier is needed because DOVE_Supplier has not
// inherited from PushSupplier.
class Internal_DOVE_Supplier : public POA_RtecEventComm::PushSupplier
{
friend class DOVE_Supplier;
public:
virtual void disconnect_push_supplier (TAO_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException))
{
}
private:
Internal_DOVE_Supplier (DOVE_Supplier* impl_ptr);
DOVE_Supplier* impl_ptr_;
};
private:
struct Connection_Params
{
const char * es_name_;
const char * ss_name_;
RtecEventChannelAdmin::EventChannel_var eventChannel_var_;
RtecEventChannelAdmin::SupplierAdmin_var supplierAdmin_var_;
RtecEventChannelAdmin::ProxyPushConsumer_var proxyPushConsumer_var_;
RtecScheduler::Scheduler_var scheduler_var_;
RtecScheduler::handle_t rt_info_;
ACE_Scheduler_Factory::POD_RT_Info pod_rt_info_;
};
int get_EventChannel ();
// Get the event channel reference.
int get_Scheduler ();
// Get the scheduler reference.
int connect_Supplier ();
// Connect the the supplier with the event channel.
static ACE_Scheduler_Factory::POD_RT_Info * pod_rt_info_instance ();
// Access the default rt_info singleton.
static ACE_Scheduler_Factory::POD_RT_Info * pod_rt_info_instance_;
// Object initialization flags
int initialized_;
int connected_;
Connection_Params ** connection_params_list_;
Connection_Params * current_connection_params_;
int connection_count_;
int current_connection_index_;
// = ORB, ORB Services adminstration references.
CosNaming::NamingContext_var namingContext_var_;
PortableServer::POA_var root_POA_var_;
PortableServer::POAManager_var poa_manager_;
Internal_DOVE_Supplier* internal_DOVE_Supplier_ptr_;
const char * MIB_name_;
// Keep the name of the MIB around.
};
#endif /* DOVE_SUPPLIER_H */
|
