summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Basic/Events_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Basic/Events_Test.cpp')
-rw-r--r--TAO/orbsvcs/tests/Notify/Basic/Events_Test.cpp58
1 files changed, 30 insertions, 28 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Basic/Events_Test.cpp b/TAO/orbsvcs/tests/Notify/Basic/Events_Test.cpp
index 09c7187dc62..7272dfe3f5b 100644
--- a/TAO/orbsvcs/tests/Notify/Basic/Events_Test.cpp
+++ b/TAO/orbsvcs/tests/Notify/Basic/Events_Test.cpp
@@ -14,7 +14,9 @@ Event_StructuredPushConsumer::Event_StructuredPushConsumer (Events_Test *test_cl
}
void
-Event_StructuredPushConsumer::push_structured_event (const CosNotification::StructuredEvent & notification, CORBA::Environment &/*ACE_TRY_ENV*/)
+Event_StructuredPushConsumer::push_structured_event
+ (const CosNotification::StructuredEvent & notification
+ TAO_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosEventComm::Disconnected
@@ -50,48 +52,48 @@ Events_Test::~Events_Test ()
}
void
-Events_Test::init (int argc, char* argv [], CORBA::Environment &ACE_TRY_ENV)
+Events_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_StructuredPushConsumer (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_StructuredPushConsumer* consumer2;
consumer2 = new Event_StructuredPushConsumer (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_StructuredPushSupplier (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 +105,7 @@ Events_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 +143,14 @@ Events_Test::parse_args(int argc, char *argv[])
}
void
-Events_Test::create_EC (CORBA::Environment &ACE_TRY_ENV)
+Events_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;
/****************************************************************/
@@ -166,7 +168,7 @@ Events_Test::create_EC (CORBA::Environment &ACE_TRY_ENV)
admin[1].value <<= (CORBA::Long)2;
- ec_->set_admin (admin, ACE_TRY_ENV);
+ ec_->set_admin (admin TAO_ENV_ARG_PARAMETER);
ACE_CHECK;*/
/****************************************************************/
@@ -182,14 +184,14 @@ Events_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
-Events_Test::run_test (CORBA::Environment &ACE_TRY_ENV)
+Events_Test::run_test (TAO_ENV_SINGLE_ARG_DECL)
{
// operations:
CosNotification::StructuredEvent event;
@@ -235,23 +237,23 @@ Events_Test::run_test (CORBA::Environment &ACE_TRY_ENV)
qos[0].name = CORBA::string_dup (CosNotification::Priority);
qos[0].value <<= (CORBA::Short)prio++;
- supplier_->send_event (event, ACE_TRY_ENV);
+ supplier_->send_event (event TAO_ENV_ARG_PARAMETER);
ACE_CHECK;
}
}
void
-Events_Test::end_test (CORBA::Environment &ACE_TRY_ENV)
+Events_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
Events_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_)
@@ -278,11 +280,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 ();