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
|
// $Id$
#include "EventChannel_i.h"
TAO_CosEC_EventChannel_i::TAO_CosEC_EventChannel_i (void)
: consumer_admin_ (),
supplier_admin_ (),
consumeradmin_ (CosEventChannelAdmin::ConsumerAdmin::_nil ()),
supplieradmin_ (CosEventChannelAdmin::SupplierAdmin::_nil ())
{
// No-Op.
}
TAO_CosEC_EventChannel_i::~TAO_CosEC_EventChannel_i (void)
{
//No-Op.
}
int
TAO_CosEC_EventChannel_i::init (const RtecEventChannelAdmin::ConsumerQOS &consumerqos,
const RtecEventChannelAdmin::SupplierQOS &supplierqos,
RtecEventChannelAdmin::EventChannel_ptr rtec,
CORBA::Environment &TAO_IN_ENV)
{
RtecEventChannelAdmin::ConsumerAdmin_ptr rtec_consumeradmin =
rtec->for_consumers (TAO_IN_ENV);
TAO_CHECK_ENV_RETURN (TAO_IN_ENV, -1);
if (this->consumer_admin_.init (consumerqos,
rtec_consumeradmin) == -1)
return -1;
this->consumeradmin_ = consumer_admin_._this (TAO_IN_ENV);
TAO_CHECK_ENV_RETURN (TAO_IN_ENV, -1);
RtecEventChannelAdmin::SupplierAdmin_ptr rtec_supplieradmin =
rtec->for_suppliers (TAO_IN_ENV);
TAO_CHECK_ENV_RETURN (TAO_IN_ENV, -1);
if (this->supplier_admin_.init (supplierqos,
rtec_supplieradmin) == -1)
return -1;
this->supplieradmin_ = supplier_admin_._this (TAO_IN_ENV);
TAO_CHECK_ENV_RETURN (TAO_IN_ENV, -1);
return 0;
}
CosEventChannelAdmin::ConsumerAdmin_ptr
TAO_CosEC_EventChannel_i::for_consumers (CORBA::Environment &)
{
// @@ Pradeep: you must make a copy here, because the caller is
// responsible of removing this object.
return
CosEventChannelAdmin::ConsumerAdmin::_duplicate (this->consumeradmin_.in());
}
CosEventChannelAdmin::SupplierAdmin_ptr
TAO_CosEC_EventChannel_i::for_suppliers (CORBA::Environment &)
{
// @@ Pradeep: you must make a copy here, because the caller is
// responsible of removing this object, same here..
return
CosEventChannelAdmin::SupplierAdmin::_duplicate (this->supplieradmin_.in ());
}
void
TAO_CosEC_EventChannel_i::destroy (CORBA::Environment &TAO_IN_ENV)
{
// Deactivate the CosEventChannel
PortableServer::POA_var poa =
this->_default_POA (TAO_IN_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV);
PortableServer::ObjectId_var id = poa->servant_to_id (this,
TAO_IN_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV);
poa->deactivate_object (id.in (),
TAO_IN_ENV);
TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV);
this->supplieradmin_ = CosEventChannelAdmin::SupplierAdmin::_nil ();
this->consumeradmin_ = CosEventChannelAdmin::ConsumerAdmin::_nil ();
}
void
TAO_CosEC_EventChannel_i::shutdown (CORBA::Environment &TAO_IN_ENV)
{
this->destroy (TAO_IN_ENV);
delete this;
}
|
