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
|
/* -*- C++ -*- */
// $Id$
#include "orbsvcs/Event_Utilities.h"
#include "orbsvcs/CosEventChannelAdminC.h"
#include "orbsvcs/CosEventChannelAdminS.h"
#include "orbsvcs/RtecEventCommS.h"
#include "orbsvcs/CosEventCommS.h"
#include "ProxyPushConsumer_i.h"
class TAO_CosEC_PushSupplierWrapper : public POA_RtecEventComm::PushSupplier
{
// = TITLE
// A Wrapper for the Rtec PushSupplier.
//
// = DESCRIPTION
// The Rtec ProxyPushConsumer uses a Rtec PushSupplier. This
// class wraps the Cos PushSupplier to make it look like a Rtec
// PushSupplier.
public:
// = Initialization and termination methods.
TAO_CosEC_PushSupplierWrapper (CosEventComm::PushSupplier_ptr supplier);
// Constructor.
~TAO_CosEC_PushSupplierWrapper (void);
// Destructor.
virtual void disconnect_push_supplier (CORBA::Environment &TAO_TRY_ENV);
// Disconnects the push supplier.
private:
// @@ Pradeep: are you sure you want to go through the CORBA
// interface? Maybe the implementation (ProxyPushConsumer_i) is good
// enough at this point? The tradeoff is flexibility (your scheme
// can use remote CosPushSuppliers), but suffers some performance
// penalty: do you need the extra flexibility? Can you use it? [I
// suspect the answers are "not" for both]
CosEventComm::PushSupplier_var supplier_;
// The Cos PushSupplier that we're proxying for.
};
TAO_CosEC_PushSupplierWrapper::TAO_CosEC_PushSupplierWrapper
(CosEventComm::PushSupplier_ptr supplier)
: supplier_ (CosEventComm::PushSupplier::_duplicate (supplier))
{
// No-Op.
}
TAO_CosEC_PushSupplierWrapper::~TAO_CosEC_PushSupplierWrapper ()
{
// No-Op.
}
void
TAO_CosEC_PushSupplierWrapper::disconnect_push_supplier (CORBA::Environment &TAO_TRY_ENV)
{
this->supplier_->disconnect_push_supplier (TAO_TRY_ENV);
// Deactivate the supplier proxy
PortableServer::POA_var poa =
this->_default_POA (TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV);
PortableServer::ObjectId_var id =
poa->servant_to_id (this,
TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV);
poa->deactivate_object (id.in (),
TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV);
// @@ If we keep a list remember to remove this object from the
// list.
delete this;
}
TAO_CosEC_ProxyPushConsumer_i::TAO_CosEC_ProxyPushConsumer_i (const RtecEventChannelAdmin::SupplierQOS &qos,
RtecEventChannelAdmin::ProxyPushConsumer_ptr ppc)
: qos_ (qos),
ppc_ (RtecEventChannelAdmin::ProxyPushConsumer::_duplicate (ppc)),
wrapper_ (0)
{
// No-Op.
}
TAO_CosEC_ProxyPushConsumer_i::~TAO_CosEC_ProxyPushConsumer_i (void)
{
// No-Op.
}
void
TAO_CosEC_ProxyPushConsumer_i::push (const CORBA::Any &data,
CORBA::Environment &TAO_TRY_ENV)
{
RtecEventComm::Event buffer[1];
// Create an event set that does not own the buffer....
RtecEventComm::EventSet events (1, 1, buffer, 0);
events.length (1);
RtecEventComm::Event &e = events[0];
RtecEventComm::Event eqos =
qos_.publications[0].event;
// @@ what if i initialize the entire <EventSet> with corresponding
// publications entries.
// NOTE: we initialize the <EventHeader> field using the 1st
// <publications> from the <SupplierQOS>.so we assume that
// publications[0] is initialized.
e.header.source = eqos.header.source;
e.header.ttl = eqos.header.ttl;
e.header.type = eqos.header.type;
ACE_hrtime_t t = ACE_OS::gethrtime ();
ORBSVCS_Time::hrtime_to_TimeT (e.header.creation_time,
t);
e.header.ec_recv_time = ORBSVCS_Time::zero;
e.header.ec_send_time = ORBSVCS_Time::zero;
e.data.any_value = data;
this->ppc_->push (events,
TAO_TRY_ENV);
}
void
TAO_CosEC_ProxyPushConsumer_i::disconnect_push_consumer (CORBA::Environment &TAO_TRY_ENV)
{
this->ppc_->disconnect_push_consumer (TAO_TRY_ENV);
// Deactivate the ProxyPushConsumer
PortableServer::POA_var poa =
this->_default_POA (TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV);
PortableServer::ObjectId_var id =
poa->servant_to_id (this,
TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV);
poa->deactivate_object (id.in (),
TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_TRY_ENV);
delete this;
}
void
TAO_CosEC_ProxyPushConsumer_i::connect_push_supplier (CosEventComm::PushSupplier_ptr push_supplier,
CORBA::Environment &TAO_IN_ENV)
{
if (this->connected ())
TAO_THROW (CosEventChannelAdmin::AlreadyConnected ());
ACE_NEW_THROW (this->wrapper_,
TAO_CosEC_PushSupplierWrapper (push_supplier),
CORBA::NO_MEMORY (CORBA::COMPLETED_NO));
this->ppc_->connect_push_supplier (this->wrapper_->_this (TAO_IN_ENV),
this->qos_,
TAO_IN_ENV);
}
int
TAO_CosEC_ProxyPushConsumer_i::connected (void)
{
return this->wrapper_ == 0 ? 0 : 1;
}
|
