summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Basic/Sequence.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Basic/Sequence.cpp')
-rw-r--r--TAO/orbsvcs/tests/Notify/Basic/Sequence.cpp48
1 files changed, 16 insertions, 32 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Basic/Sequence.cpp b/TAO/orbsvcs/tests/Notify/Basic/Sequence.cpp
index dfd1065d18f..67ada03200b 100644
--- a/TAO/orbsvcs/tests/Notify/Basic/Sequence.cpp
+++ b/TAO/orbsvcs/tests/Notify/Basic/Sequence.cpp
@@ -18,7 +18,6 @@ SequencePushConsumer::SequencePushConsumer (Sequence *test_client)
void
SequencePushConsumer::push_structured_events (
const CosNotification::EventBatch &batch
- ACE_ENV_ARG_DECL_NOT_USED
)
ACE_THROW_SPEC ((CORBA::SystemException,
CosEventComm::Disconnected))
@@ -62,8 +61,7 @@ Sequence::~Sequence (void)
int
Sequence::init (int argc,
- char* argv []
- ACE_ENV_ARG_DECL)
+ char* argv [])
{
if (TAO_debug_level)
{
@@ -82,8 +80,7 @@ Sequence::init (int argc,
// Initialize the base class.
Notify_Test_Client::init (argc,
- argv
- ACE_ENV_ARG_PARAMETER);
+ argv);
// Create all participents.
this->create_EC ();
@@ -92,25 +89,21 @@ Sequence::init (int argc,
this->supplier_admin_ =
this->ec_->new_for_suppliers (this->ifgop_,
- adminid
- ACE_ENV_ARG_PARAMETER);
+ adminid);
ACE_ASSERT (!CORBA::is_nil (supplier_admin_.in ()));
this->consumer_admin_ =
this->ec_->new_for_consumers (this->ifgop_,
- adminid
- ACE_ENV_ARG_PARAMETER);
+ adminid);
ACE_ASSERT (!CORBA::is_nil (consumer_admin_.in ()));
ACE_NEW_RETURN (this->consumer_,
SequencePushConsumer (this),
-1);
- this->consumer_->init (root_poa_.in ()
- ACE_ENV_ARG_PARAMETER);
- this->consumer_->connect (this->consumer_admin_.in ()
- ACE_ENV_ARG_PARAMETER);
+ this->consumer_->init (root_poa_.in ());
+ this->consumer_->connect (this->consumer_admin_.in ());
CosNotification::QoSProperties properties (3);
properties.length (3);
@@ -127,11 +120,9 @@ Sequence::init (int argc,
ACE_NEW_RETURN (this->supplier_,
SequencePushSupplier (this),
-1);
- this->supplier_->init (root_poa_.in ()
- ACE_ENV_ARG_PARAMETER);
+ this->supplier_->init (root_poa_.in ());
- this->supplier_->connect (this->supplier_admin_.in ()
- ACE_ENV_ARG_PARAMETER);
+ this->supplier_->connect (this->supplier_admin_.in ());
consumer_start( 0 );
@@ -210,8 +201,7 @@ Sequence::create_EC (void)
this->ec_ = notify_factory_->create_channel (this->initial_qos_,
this->initial_admin_,
- id
- ACE_ENV_ARG_PARAMETER);
+ id);
ACE_ASSERT (!CORBA::is_nil (this->ec_.in ()));
}
@@ -225,7 +215,6 @@ Sequence::on_event_received (void)
if (this->events_received_.value () == this->event_count_)
{
- ACE_DECLARE_NEW_CORBA_ENV;
this->end_test ();
}
}
@@ -291,8 +280,7 @@ Sequence::run_test (void)
if (TAO_debug_level)
ACE_DEBUG ((LM_DEBUG, "Sending batch with %d events\n", batch.length ()));
- this->supplier_->send_events (batch
- ACE_ENV_ARG_PARAMETER);
+ this->supplier_->send_events (batch);
// reset
batch.length (this->supplier_batch_size_);
@@ -305,8 +293,7 @@ Sequence::run_test (void)
{
batch.length (batch_index); // set the correct length
- this->supplier_->send_events (batch
- ACE_ENV_ARG_PARAMETER);
+ this->supplier_->send_events (batch);
}
}
@@ -321,7 +308,6 @@ int
Sequence::check_results (void)
{
// Destroy the channel.
- ACE_DECLARE_NEW_CORBA_ENV;
this->ec_->destroy ();
if (this->events_received_.value () == this->event_count_)
@@ -350,22 +336,20 @@ main (int argc, char* argv[])
return 1;
}
- ACE_TRY_NEW_ENV
+ try
{
events.init (argc,
- argv
- ACE_ENV_ARG_PARAMETER);
+ argv);
events.run_test ();
- events.ORB_run( ACE_ENV_SINGLE_ARG_PARAMETER );
+ events.ORB_run( );
}
- ACE_CATCH (CORBA::Exception, se)
+ catch (const CORBA::Exception& se)
{
- ACE_PRINT_EXCEPTION (se, "Error: ");
+ se._tao_print_exception ("Error: ");
return 1;
}
- ACE_ENDTRY;
return events.check_results ();
}