summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Event/UDP/Supplier.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Event/UDP/Supplier.cpp')
-rw-r--r--TAO/orbsvcs/tests/Event/UDP/Supplier.cpp44
1 files changed, 16 insertions, 28 deletions
diff --git a/TAO/orbsvcs/tests/Event/UDP/Supplier.cpp b/TAO/orbsvcs/tests/Event/UDP/Supplier.cpp
index 8cdb64a3ca5..b06c957738f 100644
--- a/TAO/orbsvcs/tests/Event/UDP/Supplier.cpp
+++ b/TAO/orbsvcs/tests/Event/UDP/Supplier.cpp
@@ -13,16 +13,13 @@ Supplier::Supplier (bool valuetype) : valuetype_ (valuetype), event_count_ (0)
}
void
-Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin
- ACE_ENV_ARG_DECL)
+Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin)
{
this->proxy_ =
- supplier_admin->obtain_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ supplier_admin->obtain_push_consumer ();
RtecEventComm::PushSupplier_var me =
- this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ this->_this ();
// Simple publication, but usually the helper classes in
// $TAO_ROOT/orbsvcs/Event_Utils.h are a better way to do this.
@@ -35,33 +32,26 @@ Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin
h0.type = ACE_ES_EVENT_UNDEFINED; // first free event type
h0.source = 1; // first free event source
- this->proxy_->connect_push_supplier (me.in (), qos
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ this->proxy_->connect_push_supplier (me.in (), qos);
}
void
-Supplier::disconnect (ACE_ENV_SINGLE_ARG_DECL)
+Supplier::disconnect (void)
{
// Disconnect from the EC
- ACE_TRY
+ try
{
- this->proxy_->disconnect_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->proxy_->disconnect_push_consumer ();
}
- ACE_CATCHANY
+ catch (const CORBA::Exception&)
{
}
- ACE_ENDTRY;
PortableServer::POA_var poa =
- this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ 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;
+ poa->servant_to_id (this);
+ poa->deactivate_object (id.in ());
}
void
@@ -71,9 +61,9 @@ Supplier::insert_into_any (CORBA::Any& any, Components::EventBase* vb)
}
void
-Supplier::perform_push (ACE_ENV_SINGLE_ARG_DECL)
+Supplier::perform_push (void)
{
- ACE_TRY
+ try
{
// The event type and source must match our publications
++event_count_;
@@ -97,17 +87,15 @@ Supplier::perform_push (ACE_ENV_SINGLE_ARG_DECL)
event[0].data.any_value <<= CORBA::string_dup( "ACE/TAO/CIAO");
}
- this->proxy_->push (event ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->proxy_->push (event);
}
- ACE_CATCHANY
+ catch (const CORBA::Exception&)
{
}
- ACE_ENDTRY;
}
void
-Supplier::disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+Supplier::disconnect_push_supplier (void)
ACE_THROW_SPEC ((CORBA::SystemException))
{
}