summaryrefslogtreecommitdiff
path: root/TAO/tests/CSD_Strategy_Tests/TP_Test_4/ServerApp.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/CSD_Strategy_Tests/TP_Test_4/ServerApp.cpp')
-rw-r--r--TAO/tests/CSD_Strategy_Tests/TP_Test_4/ServerApp.cpp83
1 files changed, 30 insertions, 53 deletions
diff --git a/TAO/tests/CSD_Strategy_Tests/TP_Test_4/ServerApp.cpp b/TAO/tests/CSD_Strategy_Tests/TP_Test_4/ServerApp.cpp
index 9ce517c4863..00e668c62bc 100644
--- a/TAO/tests/CSD_Strategy_Tests/TP_Test_4/ServerApp.cpp
+++ b/TAO/tests/CSD_Strategy_Tests/TP_Test_4/ServerApp.cpp
@@ -32,28 +32,21 @@ ServerApp::~ServerApp()
int
-ServerApp::run_i(int argc, char* argv[] ACE_ENV_ARG_DECL)
+ServerApp::run_i(int argc, char* argv[])
{
- int result = this->init(argc, argv ACE_ENV_ARG_PARAMETER);
+ int result = this->init(argc, argv);
if (result != 0)
{
return result;
}
- ACE_CHECK_RETURN (-1);
-
- this->poa_setup(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
- this->csd_setup(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
- this->servant_setup(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
+
+ this->poa_setup();
+ this->csd_setup();
+ this->servant_setup();
this->collocated_setup();
- this->poa_activate(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
- this->run_collocated_clients(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
- this->run_orb_event_loop(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
+ this->poa_activate();
+ this->run_collocated_clients();
+ this->run_orb_event_loop();
// Calling wait on ACE_Thread_Manager singleton to avoid the problem
// that the main thread might exit before all CSD Threads exit.
@@ -67,10 +60,9 @@ ServerApp::run_i(int argc, char* argv[] ACE_ENV_ARG_DECL)
int
-ServerApp::init(int argc, char* argv[] ACE_ENV_ARG_DECL)
+ServerApp::init(int argc, char* argv[])
{
- this->orb_ = CORBA::ORB_init(argc, argv, "" ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
+ this->orb_ = CORBA::ORB_init(argc, argv, "");
// Parse the command-line args for this application.
// * Raises -1 if problems are encountered.
@@ -85,47 +77,41 @@ ServerApp::init(int argc, char* argv[] ACE_ENV_ARG_DECL)
unsigned num_clients = this->num_remote_clients_ +
this->num_collocated_clients_;
- TheAppShutdown->init(this->orb_.in(), num_clients ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
+ TheAppShutdown->init(this->orb_.in(), num_clients);
return 0;
}
void
-ServerApp::poa_setup(ACE_ENV_SINGLE_ARG_DECL)
+ServerApp::poa_setup(void)
{
this->poa_ = this->create_poa(this->orb_.in(),
- "ChildPoa"
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ "ChildPoa");
}
void
-ServerApp::csd_setup(ACE_ENV_SINGLE_ARG_DECL)
+ServerApp::csd_setup(void)
{
this->tp_strategy_ = new TAO::CSD::TP_Strategy(this->num_csd_threads_);
- if (!this->tp_strategy_->apply_to(this->poa_.in() ACE_ENV_ARG_PARAMETER))
+ if (!this->tp_strategy_->apply_to(this->poa_.in()))
{
ACE_ERROR((LM_ERROR,
"Failed to apply CSD strategy to poa.\n"));
- ACE_THROW(TestAppException());
+ throw TestAppException();
}
- ACE_CHECK;
}
void
-ServerApp::servant_setup(ACE_ENV_SINGLE_ARG_DECL)
+ServerApp::servant_setup(void)
{
this->servants_.create_and_activate(this->num_servants_,
this->orb_.in (),
this->poa_.in (),
- this->ior_filename_prefix_.c_str()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ this->ior_filename_prefix_.c_str());
}
@@ -157,36 +143,33 @@ ServerApp::collocated_setup()
void
-ServerApp::poa_activate(ACE_ENV_SINGLE_ARG_DECL)
+ServerApp::poa_activate(void)
{
PortableServer::POAManager_var poa_manager
- = this->poa_->the_POAManager(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ = this->poa_->the_POAManager();
- poa_manager->activate(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ poa_manager->activate();
}
void
-ServerApp::run_collocated_clients(ACE_ENV_SINGLE_ARG_DECL)
+ServerApp::run_collocated_clients(void)
{
if (this->num_collocated_clients_ > 0)
{
if (this->collocated_client_task_.open() == -1)
{
- ACE_THROW (TestAppException ());
+ throw TestAppException ();
}
}
}
void
-ServerApp::run_orb_event_loop(ACE_ENV_SINGLE_ARG_DECL)
+ServerApp::run_orb_event_loop(void)
{
OrbRunner orb_runner(this->orb_.in(), this->num_orb_threads_);
- orb_runner.run(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ orb_runner.run();
TheAppShutdown->wait ();
}
@@ -340,20 +323,16 @@ ServerApp::set_arg(unsigned& value,
PortableServer::POA_ptr
ServerApp::create_poa(CORBA::ORB_ptr orb,
- const char* poa_name
- ACE_ENV_ARG_DECL)
+ const char* poa_name)
{
// Get the Root POA.
PortableServer::POA_var root_poa
= RefHelper<PortableServer::POA>::resolve_initial_ref(orb,
- "RootPOA"
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (PortableServer::POA::_nil ());
+ "RootPOA");
// Get the POAManager from the Root POA.
PortableServer::POAManager_var poa_manager
- = root_poa->the_POAManager(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (PortableServer::POA::_nil ());
+ = root_poa->the_POAManager();
// Create the child POA Policies.
CORBA::PolicyList policies(0);
@@ -364,9 +343,7 @@ ServerApp::create_poa(CORBA::ORB_ptr orb,
= AppHelper::create_poa(poa_name,
root_poa.in(),
poa_manager.in(),
- policies
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (PortableServer::POA::_nil ());
+ policies);
// Give away the child POA_ptr from the POA_var variable.
return poa._retn();