blob: 166168c36cf765fca80996305a543358d8906f3a (
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
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
133
134
135
136
137
138
139
140
141
142
|
// -*- C++ -*-
// $Id$
#include "Notify_StructuredPushSupplier.h"
ACE_RCSID(Notify_Tests, Notify_StructuredPushSupplier, "$Id$")
TAO_Notify_StructuredPushSupplier::TAO_Notify_StructuredPushSupplier (void)
{
}
TAO_Notify_StructuredPushSupplier::~TAO_Notify_StructuredPushSupplier ()
{
// Release all resources.
this->default_POA_ = PortableServer::POA::_nil ();
this->proxy_consumer_ =
CosNotifyChannelAdmin::StructuredProxyPushConsumer::_nil ();
}
void
TAO_Notify_StructuredPushSupplier::init
(PortableServer::POA_ptr poa ACE_ENV_ARG_DECL_NOT_USED)
{
this->default_POA_ = PortableServer::POA::_duplicate (poa);
}
CosNotifyChannelAdmin::StructuredProxyPushConsumer_ptr
TAO_Notify_StructuredPushSupplier::get_proxy_consumer (void)
{
return proxy_consumer_.in ();
}
void
TAO_Notify_StructuredPushSupplier::connect (
CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin
ACE_ENV_ARG_DECL
)
{
CosNotifyComm::StructuredPushSupplier_var supplier_ref =
this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
CosNotifyChannelAdmin::ProxyConsumer_var proxyconsumer =
supplier_admin->obtain_notification_push_consumer (
CosNotifyChannelAdmin::STRUCTURED_EVENT,
proxy_consumer_id_
ACE_ENV_ARG_PARAMETER
);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxyconsumer.in ()));
// Narrow.
this->proxy_consumer_ =
CosNotifyChannelAdmin::StructuredProxyPushConsumer::_narrow (
proxyconsumer.in ()
ACE_ENV_ARG_PARAMETER
);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxy_consumer_.in ()));
proxy_consumer_->connect_structured_push_supplier (supplier_ref.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// Give ownership to POA.
this->_remove_ref ();
}
void
TAO_Notify_StructuredPushSupplier::disconnect (ACE_ENV_SINGLE_ARG_DECL)
{
ACE_ASSERT (!CORBA::is_nil (this->proxy_consumer_.in ()));
this->proxy_consumer_->disconnect_structured_push_consumer (
ACE_ENV_SINGLE_ARG_PARAMETER
);
ACE_CHECK;
this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
}
void
TAO_Notify_StructuredPushSupplier::subscription_change
(const CosNotification::EventTypeSeq & /*added*/,
const CosNotification::EventTypeSeq & /*removed */
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException,
CosNotifyComm::InvalidEventType))
{
//No-Op.
}
PortableServer::POA_ptr
TAO_Notify_StructuredPushSupplier::_default_POA (
ACE_ENV_SINGLE_ARG_DECL_NOT_USED
)
{
return PortableServer::POA::_duplicate (this->default_POA_.in ());
}
void
TAO_Notify_StructuredPushSupplier::deactivate (ACE_ENV_SINGLE_ARG_DECL)
{
PortableServer::POA_var poa = this->_default_POA ();
PortableServer::ObjectId_var id =
poa->servant_to_id (this
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
poa->deactivate_object (id.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
void
TAO_Notify_StructuredPushSupplier::disconnect_structured_push_supplier (
ACE_ENV_SINGLE_ARG_DECL
)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->proxy_consumer_->disconnect_structured_push_consumer (
ACE_ENV_SINGLE_ARG_PARAMETER
);
ACE_CHECK;
this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
}
void
TAO_Notify_StructuredPushSupplier::send_event (
const CosNotification::StructuredEvent& event
ACE_ENV_ARG_DECL
)
{
ACE_ASSERT (!CORBA::is_nil (this->proxy_consumer_.in ()));
this->proxy_consumer_->push_structured_event (event ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
|
