summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp
diff options
context:
space:
mode:
authorOssama Othman <ossama-othman@users.noreply.github.com>2001-12-08 21:59:30 +0000
committerOssama Othman <ossama-othman@users.noreply.github.com>2001-12-08 21:59:30 +0000
commit63165b00e2d667e39e15cf084128d94a563d484e (patch)
tree6939cf1ed0a80ce8a3224d33f3d23c0e1b9a517f /TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp
parent6579bccb3a3f22f882ef908ad5f7e1a65b00b133 (diff)
downloadATCD-63165b00e2d667e39e15cf084128d94a563d484e.tar.gz
Merged corba-env-clean branch.
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp')
-rw-r--r--TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp48
1 files changed, 26 insertions, 22 deletions
diff --git a/TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp b/TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp
index 98a33f33ebc..59ae4ad8fe5 100644
--- a/TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp
+++ b/TAO/orbsvcs/tests/Notify/lib/Notify_PushSupplier.cpp
@@ -18,33 +18,34 @@ TAO_Notify_PushSupplier::~TAO_Notify_PushSupplier ()
CosNotifyChannelAdmin::ProxyPushConsumer::_nil ();
}
-void TAO_Notify_PushSupplier::init (PortableServer::POA_ptr poa, CORBA::Environment & /*ACE_TRY_ENV*/)
+void TAO_Notify_PushSupplier::init
+ (PortableServer::POA_ptr poa TAO_ENV_ARG_DECL_NOT_USED)
{
this->default_POA_ = PortableServer::POA::_duplicate (poa);
}
void
-TAO_Notify_PushSupplier::connect (CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin, CORBA::Environment &ACE_TRY_ENV)
+TAO_Notify_PushSupplier::connect (CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin TAO_ENV_ARG_DECL)
{
// Activate the consumer with the default_POA_
- CosNotifyComm::PushSupplier_var objref = this->_this (ACE_TRY_ENV);
+ CosNotifyComm::PushSupplier_var objref = this->_this (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
CosNotifyChannelAdmin::ProxyConsumer_var proxyconsumer =
- supplier_admin->obtain_notification_push_consumer (CosNotifyChannelAdmin::ANY_EVENT, this->my_id_, ACE_TRY_ENV);
+ supplier_admin->obtain_notification_push_consumer (CosNotifyChannelAdmin::ANY_EVENT, this->my_id_ TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxyconsumer.in ()));
// narrow
this->consumer_proxy_ =
- CosNotifyChannelAdmin::ProxyPushConsumer::_narrow (proxyconsumer.in (),
- ACE_TRY_ENV);
+ CosNotifyChannelAdmin::ProxyPushConsumer::_narrow (proxyconsumer.in ()
+ TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (consumer_proxy_.in ()));
- this->consumer_proxy_->connect_any_push_supplier (objref.in (),
- ACE_TRY_ENV);
+ this->consumer_proxy_->connect_any_push_supplier (objref.in ()
+ TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
// give ownership to POA
@@ -52,43 +53,46 @@ TAO_Notify_PushSupplier::connect (CosNotifyChannelAdmin::SupplierAdmin_ptr suppl
}
void
-TAO_Notify_PushSupplier::send_event (const CORBA::Any & data, CORBA::Environment &ACE_TRY_ENV)
+TAO_Notify_PushSupplier::send_event (const CORBA::Any & data TAO_ENV_ARG_DECL)
{
- this->consumer_proxy_->push (data, ACE_TRY_ENV);
+ this->consumer_proxy_->push (data TAO_ENV_ARG_PARAMETER);
}
void
-TAO_Notify_PushSupplier::deactivate (CORBA::Environment &ACE_TRY_ENV)
+TAO_Notify_PushSupplier::deactivate (TAO_ENV_SINGLE_ARG_DECL)
{
PortableServer::POA_var poa =
this->_default_POA ();
PortableServer::ObjectId_var id =
- poa->servant_to_id (this,
- ACE_TRY_ENV);
+ poa->servant_to_id (this
+ TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
- poa->deactivate_object (id.in (),
- ACE_TRY_ENV);
+ poa->deactivate_object (id.in ()
+ TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
}
void
-TAO_Notify_PushSupplier::disconnect (CORBA::Environment &ACE_TRY_ENV)
+TAO_Notify_PushSupplier::disconnect (TAO_ENV_SINGLE_ARG_DECL)
{
- this->consumer_proxy_->disconnect_push_consumer (ACE_TRY_ENV);
+ this->consumer_proxy_->disconnect_push_consumer (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
- this->deactivate (ACE_TRY_ENV);
+ this->deactivate (TAO_ENV_SINGLE_ARG_PARAMETER);
}
PortableServer::POA_ptr
-TAO_Notify_PushSupplier::_default_POA (CORBA::Environment& /* env */)
+TAO_Notify_PushSupplier::_default_POA (TAO_ENV_SINGLE_ARG_DECL_NOT_USED /* env */)
{
return PortableServer::POA::_duplicate (this->default_POA_.in ());
}
void
-TAO_Notify_PushSupplier::subscription_change (const CosNotification::EventTypeSeq &/*added*/, const CosNotification::EventTypeSeq &/*removed*/, CORBA::Environment &/*ACE_TRY_ENV*/)
+TAO_Notify_PushSupplier::subscription_change
+ (const CosNotification::EventTypeSeq &/*added*/,
+ const CosNotification::EventTypeSeq &/*removed*/
+ TAO_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyComm::InvalidEventType
@@ -98,10 +102,10 @@ TAO_Notify_PushSupplier::subscription_change (const CosNotification::EventTypeSe
}
void
-TAO_Notify_PushSupplier::disconnect_push_supplier (CORBA::Environment &ACE_TRY_ENV)
+TAO_Notify_PushSupplier::disconnect_push_supplier (TAO_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((
CORBA::SystemException
))
{
- this->deactivate (ACE_TRY_ENV);
+ this->deactivate (TAO_ENV_SINGLE_ARG_PARAMETER);
}