summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Concurrency/CC_tests.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Concurrency/CC_tests.cpp')
-rw-r--r--TAO/orbsvcs/tests/Concurrency/CC_tests.cpp117
1 files changed, 36 insertions, 81 deletions
diff --git a/TAO/orbsvcs/tests/Concurrency/CC_tests.cpp b/TAO/orbsvcs/tests/Concurrency/CC_tests.cpp
index 5dfccef2eb5..cda1e777953 100644
--- a/TAO/orbsvcs/tests/Concurrency/CC_tests.cpp
+++ b/TAO/orbsvcs/tests/Concurrency/CC_tests.cpp
@@ -39,25 +39,21 @@ CC_Test::create_lock_set (void)
// Create the lock set and return an obj ref corresponding to the
// key.
CosConcurrencyControl::LockSet_ptr lock_set(0);
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
lock_set =
- this->naming_service_->get_lock_set_factory ()->create (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->naming_service_->get_lock_set_factory ()->create ();
if (CORBA::is_nil (lock_set))
ACE_ERROR_RETURN ((LM_ERROR,
"null lock set objref returned by factory\n"),
0);
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
- "CC_Client::create_lock_set");
+ ex._tao_print_exception ("CC_Client::create_lock_set");
return 0;
}
- ACE_ENDTRY;
return lock_set;
}
@@ -103,19 +99,15 @@ Test_Single_Lock_With_Mode::run (int /* times_to_run */)
CosConcurrencyControl::LockSet_ptr cc_lock_set_ = create_lock_set ();
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
- cc_lock_set_->lock (mode_ ACE_ENV_ARG_PARAMETER);
+ cc_lock_set_->lock (mode_);
- ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG,
"%s lock set\n",
get_lock_mode_name (mode_)));
- lock_not_held = cc_lock_set_->try_lock (mode_
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ lock_not_held = cc_lock_set_->try_lock (mode_);
if (lock_not_held)
{
@@ -129,15 +121,12 @@ Test_Single_Lock_With_Mode::run (int /* times_to_run */)
"%s lock held\n",
get_lock_mode_name (mode_)));
- cc_lock_set_->unlock (mode_
- ACE_ENV_ARG_PARAMETER);
+ cc_lock_set_->unlock (mode_);
ACE_DEBUG ((LM_DEBUG,
"%s lock released\n",
get_lock_mode_name (mode_)));
- lock_not_held = cc_lock_set_->try_lock (mode_
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ lock_not_held = cc_lock_set_->try_lock (mode_);
if (lock_not_held)
ACE_DEBUG ((LM_DEBUG,
@@ -152,13 +141,11 @@ Test_Single_Lock_With_Mode::run (int /* times_to_run */)
}
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
- "Test_Single_Lock_With_Mode::run");
+ ex._tao_print_exception ("Test_Single_Lock_With_Mode::run");
return CC_FAIL;
}
- ACE_ENDTRY;
CORBA::release (cc_lock_set_);
@@ -181,32 +168,25 @@ Test_Setup_LockSet::~Test_Setup_LockSet (void)
int
Test_Setup_LockSet::run (int /* times_to_run */)
{
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
CosConcurrencyControl::LockSet_ptr cc_lock_set_ =
create_lock_set ();
- this->naming_service_->bind_name (my_name_, cc_lock_set_
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->naming_service_->bind_name (my_name_, cc_lock_set_);
ACE_DEBUG ((LM_DEBUG,
"Name bound\n"));
- cc_lock_set_->lock (CosConcurrencyControl::read
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ cc_lock_set_->lock (CosConcurrencyControl::read);
ACE_DEBUG ((LM_DEBUG,
"Read lock set\n"));
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
- "Test_Against_Other_LockSet::run");
+ ex._tao_print_exception ("Test_Against_Other_LockSet::run");
return CC_FAIL;
}
- ACE_ENDTRY;
return CC_SUCCESS;
}
@@ -228,32 +208,23 @@ Test_Use_Already_Created_LockSet::~Test_Use_Already_Created_LockSet (void)
int
Test_Use_Already_Created_LockSet::run (int /* times_to_run */)
{
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
CORBA::Object_var ccls_obj =
this->naming_service_->get_obj_from_name (const_cast<char *> (""),
- my_name_
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ my_name_);
CosConcurrencyControl::LockSet_var ccls =
- CosConcurrencyControl::LockSet::_narrow (ccls_obj.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ CosConcurrencyControl::LockSet::_narrow (ccls_obj.in ());
- ccls->lock (CosConcurrencyControl::read
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ ccls->lock (CosConcurrencyControl::read);
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
- "Test_Against_Other_LockSet::run");
+ ex._tao_print_exception ("Test_Against_Other_LockSet::run");
return CC_FAIL;
}
- ACE_ENDTRY;
return CC_SUCCESS;
}
@@ -275,29 +246,21 @@ Test_Unlock_Already_Created_LockSet::~Test_Unlock_Already_Created_LockSet (void)
int
Test_Unlock_Already_Created_LockSet::run (int /* times_to_run */)
{
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
CORBA::Object_var ccls_obj =
- this->naming_service_->get_obj_from_name (const_cast<char *> (""), my_name_
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->naming_service_->get_obj_from_name (const_cast<char *> (""), my_name_);
CosConcurrencyControl::LockSet_var ccls =
- CosConcurrencyControl::LockSet::_narrow (ccls_obj.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ CosConcurrencyControl::LockSet::_narrow (ccls_obj.in ());
- ccls->unlock (CosConcurrencyControl::read
- ACE_ENV_ARG_PARAMETER);
+ ccls->unlock (CosConcurrencyControl::read);
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
- "Test_Unlock_Already_Created_LockSet::run");
+ ex._tao_print_exception ("Test_Unlock_Already_Created_LockSet::run");
return CC_FAIL;
}
- ACE_ENDTRY;
return CC_SUCCESS;
}
@@ -322,20 +285,17 @@ Test_Release_Not_Held_Lock::run (int /* times_to_run */)
// Create the lock set
CosConcurrencyControl::LockSet_ptr cc_lock_set_ = create_lock_set ();
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
// lock the lock
- cc_lock_set_->lock (mode_ ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ cc_lock_set_->lock (mode_);
ACE_DEBUG ((LM_DEBUG,
"%s lock set\n",
get_lock_mode_name (mode_)));
// check to see if the lock is held
- lock_not_held = cc_lock_set_->try_lock (mode_
- ACE_ENV_ARG_PARAMETER);
+ lock_not_held = cc_lock_set_->try_lock (mode_);
if (lock_not_held)
{
@@ -350,23 +310,20 @@ Test_Release_Not_Held_Lock::run (int /* times_to_run */)
get_lock_mode_name (mode_)));
// release the lock
- cc_lock_set_->unlock (mode_
- ACE_ENV_ARG_PARAMETER);
+ cc_lock_set_->unlock (mode_);
ACE_DEBUG ((LM_DEBUG,
"%s lock released\n",
get_lock_mode_name (mode_)));
// release the lock again. this should raise an exception
- cc_lock_set_->unlock (mode_
- ACE_ENV_ARG_PARAMETER);
+ cc_lock_set_->unlock (mode_);
ACE_DEBUG ((LM_DEBUG,
"attemptet to release %s lock\n",
get_lock_mode_name (mode_)));
- ACE_TRY_CHECK;
}
- ACE_CATCH(CosConcurrencyControl::LockNotHeld, userex)
+ catch (const CosConcurrencyControl::LockNotHeld& userex)
{
// We should end here
ACE_UNUSED_ARG (userex);
@@ -374,13 +331,11 @@ Test_Release_Not_Held_Lock::run (int /* times_to_run */)
return CC_SUCCESS;
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
- "Test_Release_Not_Held_Lock::run");
+ ex._tao_print_exception ("Test_Release_Not_Held_Lock::run");
return CC_FAIL;
}
- ACE_ENDTRY;
CORBA::release (cc_lock_set_);