diff options
Diffstat (limited to 'TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.cpp')
-rw-r--r-- | TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.cpp | 24 |
1 files changed, 9 insertions, 15 deletions
diff --git a/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.cpp b/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.cpp index 5fc7489897e..20c01a4f80b 100644 --- a/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.cpp +++ b/TAO/orbsvcs/performance-tests/RTEvent/lib/Consumer.cpp @@ -11,8 +11,8 @@ #include "orbsvcs/Event_Service_Constants.h" #include "ace/OS_NS_unistd.h" -ACE_RCSID (TAO_PERF_RTEC, - Consumer, +ACE_RCSID (TAO_PERF_RTEC, + Consumer, "$Id$") Consumer::Consumer (CORBA::Long experiment_id, @@ -35,8 +35,7 @@ Consumer::connect (RtecEventChannelAdmin::EventChannel_ptr ec ACE_ENV_ARG_DECL) { RtecEventChannelAdmin::ConsumerAdmin_var consumer_admin = - ec->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; + ec->for_consumers (); { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_); @@ -44,13 +43,11 @@ Consumer::connect (RtecEventChannelAdmin::EventChannel_ptr ec return; this->proxy_supplier_ = - consumer_admin->obtain_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; + consumer_admin->obtain_push_supplier (); } RtecEventComm::PushConsumer_var consumer = - this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; + this->_this (); RtecEventChannelAdmin::ConsumerQOS consumer_qos; consumer_qos.is_gateway = 0; @@ -68,11 +65,10 @@ Consumer::connect (RtecEventChannelAdmin::EventChannel_ptr ec this->proxy_supplier_->connect_push_consumer (consumer.in (), consumer_qos ACE_ENV_ARG_PARAMETER); - ACE_CHECK; } void -Consumer::disconnect (ACE_ENV_SINGLE_ARG_DECL) +Consumer::disconnect (void) { RtecEventChannelAdmin::ProxyPushSupplier_var proxy; { @@ -84,11 +80,9 @@ Consumer::disconnect (ACE_ENV_SINGLE_ARG_DECL) Implicit_Deactivator deactivator (this ACE_ENV_ARG_PARAMETER); - ACE_CHECK; ACE_TRY { - proxy->disconnect_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + proxy->disconnect_push_supplier (); } ACE_CATCHANY { } ACE_ENDTRY; } @@ -125,7 +119,7 @@ Consumer::push (const RtecEventComm::EventSet &events } void -Consumer::disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) +Consumer::disconnect_push_consumer (void) ACE_THROW_SPEC ((CORBA::SystemException)) { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_); @@ -134,7 +128,7 @@ Consumer::disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) } PortableServer::POA_ptr -Consumer::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) +Consumer::_default_POA (void) ACE_THROW_SPEC ((CORBA::SystemException)) { return PortableServer::POA::_duplicate (this->default_POA_.in ()); |