summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Basic/Simple.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Basic/Simple.cpp')
-rw-r--r--TAO/orbsvcs/tests/Notify/Basic/Simple.cpp54
1 files changed, 27 insertions, 27 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Basic/Simple.cpp b/TAO/orbsvcs/tests/Notify/Basic/Simple.cpp
index bc5a9d903ea..c41fef13020 100644
--- a/TAO/orbsvcs/tests/Notify/Basic/Simple.cpp
+++ b/TAO/orbsvcs/tests/Notify/Basic/Simple.cpp
@@ -14,7 +14,7 @@ Event_AnyPushConsumer::Event_AnyPushConsumer (Simple_Test *test_client)
}
void
-Event_AnyPushConsumer::push (const CORBA::Any & data, CORBA::Environment &/*ACE_TRY_ENV*/)
+Event_AnyPushConsumer::push (const CORBA::Any & data TAO_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosEventComm::Disconnected
@@ -50,48 +50,48 @@ Simple_Test::~Simple_Test ()
}
void
-Simple_Test::init (int argc, char* argv [], CORBA::Environment &ACE_TRY_ENV)
+Simple_Test::init (int argc, char* argv [] TAO_ENV_ARG_DECL)
{
// init base class
- Notify_Test_Client::init (argc, argv, ACE_TRY_ENV);
+ Notify_Test_Client::init (argc, argv TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
// Create all participents ...
- this->create_EC (ACE_TRY_ENV);
+ this->create_EC (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
CosNotifyChannelAdmin::AdminID adminid;
supplier_admin_ =
- ec_->new_for_suppliers (this->ifgop_, adminid, ACE_TRY_ENV);
+ ec_->new_for_suppliers (this->ifgop_, adminid TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (supplier_admin_.in ()));
consumer_admin_ =
- ec_->new_for_consumers (this->ifgop_, adminid, ACE_TRY_ENV);
+ ec_->new_for_consumers (this->ifgop_, adminid TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (consumer_admin_.in ()));
consumer_ = new Event_AnyPushConsumer (this);
- consumer_->init (root_poa_.in (), ACE_TRY_ENV);
+ consumer_->init (root_poa_.in () TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
- consumer_->connect (this->consumer_admin_.in (), ACE_TRY_ENV);
+ consumer_->connect (this->consumer_admin_.in () TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
Event_AnyPushConsumer* consumer2;
consumer2 = new Event_AnyPushConsumer (this);
- consumer2->init (root_poa_.in (), ACE_TRY_ENV);
+ consumer2->init (root_poa_.in () TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
- consumer2->connect (this->consumer_admin_.in (), ACE_TRY_ENV);
+ consumer2->connect (this->consumer_admin_.in () TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
supplier_ = new Event_AnyPushSupplier (this);
- supplier_->init (root_poa_.in (), ACE_TRY_ENV);
+ supplier_->init (root_poa_.in () TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
- supplier_->connect (this->supplier_admin_.in (), ACE_TRY_ENV);
+ supplier_->connect (this->supplier_admin_.in () TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
// Setup the CA to receive all type of events
@@ -103,7 +103,7 @@ Simple_Test::init (int argc, char* argv [], CORBA::Environment &ACE_TRY_ENV)
added[0].domain_name = CORBA::string_dup ("*");
added[0].type_name = CORBA::string_dup ("*");
- this->consumer_admin_->subscription_change (added, removed, ACE_TRY_ENV);
+ this->consumer_admin_->subscription_change (added, removed TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
}
@@ -141,14 +141,14 @@ Simple_Test::parse_args(int argc, char *argv[])
}
void
-Simple_Test::create_EC (CORBA::Environment &ACE_TRY_ENV)
+Simple_Test::create_EC (TAO_ENV_SINGLE_ARG_DECL)
{
CosNotifyChannelAdmin::ChannelID id;
ec_ = notify_factory_->create_channel (initial_qos_,
initial_admin_,
- id,
- ACE_TRY_ENV);
+ id
+ TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (ec_.in ()));
@@ -163,14 +163,14 @@ Simple_Test::on_event_received (void)
if (this->result_count_ == 2*this->event_count_)
{
- ACE_DECLARE_NEW_CORBA_ENV;
- this->end_test (ACE_TRY_ENV);
+ TAO_ENV_DECLARE_NEW_ENV;
+ this->end_test (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
}
}
void
-Simple_Test::run_test (CORBA::Environment &ACE_TRY_ENV)
+Simple_Test::run_test (TAO_ENV_SINGLE_ARG_DECL)
{
CORBA::Any data;
@@ -178,23 +178,23 @@ Simple_Test::run_test (CORBA::Environment &ACE_TRY_ENV)
{
data <<= (CORBA::Long)i;
- supplier_->send_event (data, ACE_TRY_ENV);
+ supplier_->send_event (data TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
}
}
void
-Simple_Test::end_test (CORBA::Environment &ACE_TRY_ENV)
+Simple_Test::end_test (TAO_ENV_SINGLE_ARG_DECL)
{
- this->shutdown (ACE_TRY_ENV); // break out of run
+ this->shutdown (TAO_ENV_SINGLE_ARG_PARAMETER); // break out of run
}
int
Simple_Test::check_results (void)
{
// Destroy the channel
- ACE_DECLARE_NEW_CORBA_ENV;
- this->ec_->destroy (ACE_TRY_ENV);
+ TAO_ENV_DECLARE_NEW_ENV;
+ this->ec_->destroy (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
if (this->result_count_ == 2*this->event_count_)
@@ -221,11 +221,11 @@ main (int argc, char* argv[])
ACE_TRY_NEW_ENV
{
- events.init (argc, argv,
- ACE_TRY_ENV); //Init the Client
+ events.init (argc, argv
+ TAO_ENV_ARG_PARAMETER); //Init the Client
ACE_TRY_CHECK;
- events.run_test (ACE_TRY_ENV);
+ events.run_test (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
events.ORB_run ();