summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp54
1 files changed, 22 insertions, 32 deletions
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp
index cbbdc1c51d7..26231b016af 100644
--- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp
+++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ProxyPullSupplier.cpp
@@ -43,20 +43,18 @@ TAO_CEC_ProxyPullSupplier::~TAO_CEC_ProxyPullSupplier (void)
void
TAO_CEC_ProxyPullSupplier::activate (
- CosEventChannelAdmin::ProxyPullSupplier_ptr &activated_proxy
- ACE_ENV_ARG_DECL)
+ CosEventChannelAdmin::ProxyPullSupplier_ptr &activated_proxy)
ACE_THROW_SPEC ((CORBA::SystemException))
{
CosEventChannelAdmin::ProxyPullSupplier_var result;
- ACE_TRY
+ try
{
result = this->_this ();
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
result = CosEventChannelAdmin::ProxyPullSupplier::_nil ();
}
- ACE_ENDTRY;
activated_proxy = result._retn ();
}
@@ -64,22 +62,21 @@ void
TAO_CEC_ProxyPullSupplier::deactivate (void)
ACE_THROW_SPEC ((CORBA::SystemException))
{
- ACE_TRY
+ try
{
PortableServer::POA_var poa =
this->_default_POA ();
PortableServer::ObjectId_var id =
- poa->servant_to_id (this ACE_ENV_ARG_PARAMETER);
- poa->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER);
+ poa->servant_to_id (this);
+ poa->deactivate_object (id.in ());
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
// Exceptions here should not be propagated. They usually
// indicate that an object is beign disconnected twice, or some
// race condition, but not a fault that the user needs to know
// about.
}
- ACE_ENDTRY;
}
void
@@ -103,22 +100,20 @@ TAO_CEC_ProxyPullSupplier::shutdown (void)
if (CORBA::is_nil (consumer.in ()))
return;
- ACE_TRY
+ try
{
consumer->disconnect_pull_consumer ();
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
// Ignore exceptions, we must isolate other clients from
// problems on this one.
}
- ACE_ENDTRY;
}
CORBA::Boolean
TAO_CEC_ProxyPullSupplier::consumer_non_existent (
- CORBA::Boolean_out disconnected
- ACE_ENV_ARG_DECL)
+ CORBA::Boolean_out disconnected)
{
CORBA::Object_var consumer;
{
@@ -147,8 +142,7 @@ TAO_CEC_ProxyPullSupplier::consumer_non_existent (
}
void
-TAO_CEC_ProxyPullSupplier::push (const CORBA::Any &event
- ACE_ENV_ARG_DECL_NOT_USED)
+TAO_CEC_ProxyPullSupplier::push (const CORBA::Any &event)
{
if (this->is_connected () == 0)
return;
@@ -183,8 +177,7 @@ TAO_CEC_ProxyPullSupplier::pull (void)
}
CORBA::Any *
-TAO_CEC_ProxyPullSupplier::try_pull (CORBA::Boolean_out has_event
- ACE_ENV_ARG_DECL)
+TAO_CEC_ProxyPullSupplier::try_pull (CORBA::Boolean_out has_event)
ACE_THROW_SPEC ((CORBA::SystemException,CosEventComm::Disconnected))
{
has_event = 0;
@@ -239,8 +232,7 @@ TAO_CEC_ProxyPullSupplier::_decr_refcnt (void)
void
TAO_CEC_ProxyPullSupplier::connect_pull_consumer (
- CosEventComm::PullConsumer_ptr pull_consumer
- ACE_ENV_ARG_DECL)
+ CosEventComm::PullConsumer_ptr pull_consumer)
ACE_THROW_SPEC ((CORBA::SystemException,
CosEventChannelAdmin::AlreadyConnected))
{
@@ -253,7 +245,7 @@ TAO_CEC_ProxyPullSupplier::connect_pull_consumer (
if (this->is_connected_i ())
{
if (this->event_channel_->consumer_reconnect () == 0)
- ACE_THROW (CosEventChannelAdmin::AlreadyConnected ());
+ throw CosEventChannelAdmin::AlreadyConnected ();
// Re-connections are allowed....
this->cleanup_i ();
@@ -269,7 +261,7 @@ TAO_CEC_ProxyPullSupplier::connect_pull_consumer (
CORBA::INTERNAL ());
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
- this->event_channel_->reconnected (this ACE_ENV_ARG_PARAMETER);
+ this->event_channel_->reconnected (this);
}
return;
}
@@ -279,7 +271,7 @@ TAO_CEC_ProxyPullSupplier::connect_pull_consumer (
}
// Notify the event channel...
- this->event_channel_->connected (this ACE_ENV_ARG_PARAMETER);
+ this->event_channel_->connected (this);
}
CosEventComm::PullConsumer_ptr
@@ -311,8 +303,7 @@ TAO_CEC_ProxyPullSupplier::apply_policy (CosEventComm::PullConsumer_ptr pre)
}
void
-TAO_CEC_ProxyPullSupplier::disconnect_pull_supplier (
- ACE_ENV_SINGLE_ARG_DECL)
+TAO_CEC_ProxyPullSupplier::disconnect_pull_supplier ()
ACE_THROW_SPEC ((CORBA::SystemException))
{
CosEventComm::PullConsumer_var consumer;
@@ -324,7 +315,7 @@ TAO_CEC_ProxyPullSupplier::disconnect_pull_supplier (
// @@ CosEventChannelAdmin::EventChannel::SYNCHRONIZATION_ERROR ());
if (this->is_connected_i () == 0)
- ACE_THROW (CORBA::BAD_INV_ORDER ());
+ throw CORBA::BAD_INV_ORDER ();
consumer = this->consumer_._retn ();
@@ -332,25 +323,24 @@ TAO_CEC_ProxyPullSupplier::disconnect_pull_supplier (
}
// Notify the event channel....
- this->event_channel_->disconnected (this ACE_ENV_ARG_PARAMETER);
+ this->event_channel_->disconnected (this);
if (CORBA::is_nil (consumer.in ()))
return;
if (this->event_channel_->disconnect_callbacks ())
{
- ACE_TRY
+ try
{
consumer->disconnect_pull_consumer ();
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
// Ignore exceptions, we must isolate other clients from
// problems on this one.
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+ ACE_PRINT_EXCEPTION (ex,
"ProxySupplier::disconnect_pull_supplier");
}
- ACE_ENDTRY;
}
}