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
|
// $Id$
#include "EC_ProxyConsumer.h"
#include "EC_Event_Channel.h"
#include "EC_SupplierFiltering.h"
#if ! defined (__ACE_INLINE__)
#include "EC_ProxyConsumer.i"
#endif /* __ACE_INLINE__ */
ACE_RCSID(Event, EC_ProxyConsumer, "$Id$")
TAO_EC_ProxyPushConsumer::
TAO_EC_ProxyPushConsumer (TAO_EC_Event_Channel* ec,
TAO_EC_SupplierFiltering* filtering)
: event_channel_ (ec),
supplier_filtering_ (filtering)
{
this->supplier_filtering_->bind (this);
}
TAO_EC_ProxyPushConsumer::~TAO_EC_ProxyPushConsumer (void)
{
}
void
TAO_EC_ProxyPushConsumer::set_default_POA (PortableServer::POA_ptr poa)
{
this->default_POA_ =
PortableServer::POA::_duplicate (poa);
}
PortableServer::POA_ptr
TAO_EC_ProxyPushConsumer::_default_POA (CORBA::Environment&)
{
return PortableServer::POA::_duplicate (this->default_POA_.in ());
}
void
TAO_EC_ProxyPushConsumer::connected (TAO_EC_ProxyPushSupplier* supplier,
CORBA::Environment &ACE_TRY_ENV)
{
this->supplier_filtering_->connected (supplier, ACE_TRY_ENV);
}
void
TAO_EC_ProxyPushConsumer::disconnected (TAO_EC_ProxyPushSupplier* supplier,
CORBA::Environment &ACE_TRY_ENV)
{
this->supplier_filtering_->disconnected (supplier, ACE_TRY_ENV);
}
void
TAO_EC_ProxyPushConsumer::connected (TAO_EC_ProxyPushConsumer*,
CORBA::Environment &)
{
}
void
TAO_EC_ProxyPushConsumer::disconnected (TAO_EC_ProxyPushConsumer*,
CORBA::Environment &)
{
}
void
TAO_EC_ProxyPushConsumer::connect_push_supplier (
RtecEventComm::PushSupplier_ptr push_supplier,
const RtecEventChannelAdmin::SupplierQOS& qos,
CORBA::Environment &ACE_TRY_ENV)
{
if (this->is_connected ())
ACE_THROW (RtecEventChannelAdmin::AlreadyConnected ());
this->supplier_ =
RtecEventComm::PushSupplier::_duplicate (push_supplier);
this->qos_ = qos;
// Notify the event channel...
this->event_channel_->connected (this, ACE_TRY_ENV);
}
void
TAO_EC_ProxyPushConsumer::push (const RtecEventComm::EventSet& event,
CORBA::Environment &ACE_TRY_ENV)
{
this->supplier_filtering_->push (event, ACE_TRY_ENV);
}
void
TAO_EC_ProxyPushConsumer::disconnect_push_consumer (
CORBA::Environment &ACE_TRY_ENV)
{
this->supplier_ =
RtecEventComm::PushSupplier::_nil ();
PortableServer::POA_var poa =
this->_default_POA (ACE_TRY_ENV);
ACE_CHECK;
PortableServer::ObjectId_var id =
poa->servant_to_id (this, ACE_TRY_ENV);
ACE_CHECK;
poa->deactivate_object (id.in (), ACE_TRY_ENV);
ACE_CHECK;
this->supplier_filtering_->unbind (this);
this->supplier_filtering_ = 0;
this->event_channel_->destroy_proxy_push_consumer (this);
}
|
