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
|
// $Id$
#include "EventChannel_i.h"
#include "ace/Auto_Ptr.h"
TAO_CosEC_EventChannel_i::TAO_CosEC_EventChannel_i (void)
: consumer_admin_ (0),
supplier_admin_ (0),
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 &ACE_TRY_ENV)
{
// Allocate the admins..
TAO_CosEC_ConsumerAdmin_i *consumer_;
ACE_NEW_RETURN (consumer_,
TAO_CosEC_ConsumerAdmin_i (),
-1);
auto_ptr <TAO_CosEC_ConsumerAdmin_i> auto_consumer_ (consumer_);
TAO_CosEC_SupplierAdmin_i *supplier_;
ACE_NEW_RETURN (supplier_,
TAO_CosEC_SupplierAdmin_i (),
-1);
auto_ptr <TAO_CosEC_SupplierAdmin_i> auto_supplier_ (supplier_);
RtecEventChannelAdmin::ConsumerAdmin_ptr rtec_consumeradmin =
rtec->for_consumers (ACE_TRY_ENV);
ACE_CHECK_RETURN (-1);
if (auto_consumer_.get ()->init (consumerqos,
rtec_consumeradmin) == -1)
return -1;
this->consumeradmin_ =
auto_consumer_.get ()->_this (ACE_TRY_ENV);
ACE_CHECK_RETURN (-1);
// give the ownership to the POA.
auto_consumer_.get ()->_remove_ref (ACE_TRY_ENV);
ACE_CHECK_RETURN (-1);
RtecEventChannelAdmin::SupplierAdmin_ptr rtec_supplieradmin =
rtec->for_suppliers (ACE_TRY_ENV);
ACE_CHECK_RETURN (-1);
if (auto_supplier_.get ()->init (supplierqos,
rtec_supplieradmin) == -1)
return -1;
this->supplieradmin_ =
auto_supplier_.get ()->_this (ACE_TRY_ENV);
ACE_CHECK_RETURN (-1);
// give the ownership to the POA.
auto_supplier_.get ()->_remove_ref (ACE_TRY_ENV);
ACE_CHECK_RETURN (-1);
this->consumer_admin_ = auto_consumer_.release ();
this->supplier_admin_ = auto_supplier_.release ();
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 &ACE_TRY_ENV)
{
// Deactivate the CosEventChannel
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->supplieradmin_ = CosEventChannelAdmin::SupplierAdmin::_nil ();
this->consumeradmin_ = CosEventChannelAdmin::ConsumerAdmin::_nil ();
}
void
TAO_CosEC_EventChannel_i::shutdown (CORBA::Environment &ACE_TRY_ENV)
{
this->destroy (ACE_TRY_ENV);
}
#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
template class ACE_Auto_Basic_Ptr<TAO_CosEC_ConsumerAdmin_i>;
template class auto_ptr<TAO_CosEC_ConsumerAdmin_i>;
template class ACE_Auto_Basic_Ptr<TAO_CosEC_SupplierAdmin_i>;
template class auto_ptr<TAO_CosEC_SupplierAdmin_i>;
#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
# pragma instantiate ACE_Auto_Basic_Ptr<TAO_CosEC_ConsumerAdmin_i>
# pragma instantiate auto_ptr<TAO_CosEC_ConsumerAdmin_i>
# pragma instantiate ACE_Auto_Basic_Ptr<TAO_CosEC_SupplierAdmin_i>
# pragma instantiate auto_ptr<TAO_CosEC_SupplierAdmin_i>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
|
