blob: ddd2858b63185aea3393f4f78d7e627c3f559628 (
plain)
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
|
// $Id$
#include "EventChannel_i.h"
EventChannel_i::EventChannel_i(const RtecEventChannelAdmin::ConsumerQOS &consumerqos,
const RtecEventChannelAdmin::SupplierQOS &supplierqos,
RtecEventChannelAdmin::ConsumerAdmin_ptr rtec_consumeradmin,
RtecEventChannelAdmin::SupplierAdmin_ptr rtec_supplieradmin)
: consumer_admin_ (consumerqos, rtec_consumeradmin),
supplier_admin_ (supplierqos, rtec_supplieradmin),
consumeradmin_ (0),
supplieradmin_ (0)
{
}
EventChannel_i::~EventChannel_i ()
{
//No-Op.
}
int
EventChannel_i::init (CORBA::Environment &TAO_TRY_ENV)
{
this->consumeradmin_ = consumer_admin_._this (TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1);
this->supplieradmin_ = supplier_admin_._this (TAO_TRY_ENV);
TAO_CHECK_ENV_RETURN (TAO_TRY_ENV, -1);
return 0;
}
CosEventChannelAdmin::ConsumerAdmin_ptr
EventChannel_i::for_consumers (CORBA::Environment &TAO_TRY_ENV)
{
return this->consumeradmin_;
}
CosEventChannelAdmin::SupplierAdmin_ptr
EventChannel_i::for_suppliers (CORBA::Environment &TAO_TRY_ENV)
{
return this->supplieradmin_;
}
void
EventChannel_i::destroy (CORBA::Environment &TAO_TRY_ENV)
{
// Deactivate the CosEventChannel
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;
}
|
