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 "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)
{
// 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 ();
if (auto_consumer_.get ()->init (consumerqos,
rtec_consumeradmin) == -1)
return -1;
this->consumeradmin_ =
auto_consumer_.get ()->_this ();
// give the ownership to the POA.
auto_consumer_.get ()->_remove_ref ();
RtecEventChannelAdmin::SupplierAdmin_ptr rtec_supplieradmin =
rtec->for_suppliers ();
if (auto_supplier_.get ()->init (supplierqos,
rtec_supplieradmin) == -1)
return -1;
this->supplieradmin_ =
auto_supplier_.get ()->_this ();
// give the ownership to the POA.
auto_supplier_.get ()->_remove_ref ();
this->consumer_admin_ = auto_consumer_.release ();
this->supplier_admin_ = auto_supplier_.release ();
return 0;
}
CosEventChannelAdmin::ConsumerAdmin_ptr
TAO_CosEC_EventChannel_i::for_consumers (void)
{
// @@ 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 (void)
{
// @@ 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 (void)
{
// Deactivate the CosEventChannel
PortableServer::POA_var poa =
this->_default_POA ();
PortableServer::ObjectId_var id = poa->servant_to_id (this);
poa->deactivate_object (id.in ());
this->supplieradmin_ = CosEventChannelAdmin::SupplierAdmin::_nil ();
this->consumeradmin_ = CosEventChannelAdmin::ConsumerAdmin::_nil ();
}
void
TAO_CosEC_EventChannel_i::shutdown (void)
{
this->destroy ();
}
|
