diff options
Diffstat (limited to 'TAO/examples/RTScheduling/MIF_Scheduler/test.cpp')
-rw-r--r-- | TAO/examples/RTScheduling/MIF_Scheduler/test.cpp | 51 |
1 files changed, 25 insertions, 26 deletions
diff --git a/TAO/examples/RTScheduling/MIF_Scheduler/test.cpp b/TAO/examples/RTScheduling/MIF_Scheduler/test.cpp index f290a52e718..8ef6d268b8d 100644 --- a/TAO/examples/RTScheduling/MIF_Scheduler/test.cpp +++ b/TAO/examples/RTScheduling/MIF_Scheduler/test.cpp @@ -1,14 +1,13 @@ //$Id$ #include "test.h" -#include "../Thread_Task.h" -#include "../Task_Stats.h" -#include "../Synch_i.h" - #include "tao/RTScheduling/RTScheduler_Manager.h" #include "tao/ORB_Core.h" - #include "ace/Arg_Shifter.h" +//#include "MIF_DT_Creator.h" +#include "../Thread_Task.h" +#include "../Task_Stats.h" +#include "../Synch_i.h" DT_Test::DT_Test (void) { @@ -16,33 +15,33 @@ DT_Test::DT_Test (void) int DT_Test::init (int argc, char *argv [] - ACE_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { orb_ = CORBA::ORB_init (argc, - argv, - "" - ACE_ENV_ARG_PARAMETER); + argv, + "" + ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); dt_creator_->orb (orb_.in ()); CORBA::Object_ptr manager_obj = orb_->resolve_initial_references ("RTSchedulerManager" - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); TAO_RTScheduler_Manager_var manager = TAO_RTScheduler_Manager::_narrow (manager_obj - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); ACE_NEW_RETURN (scheduler_, - MIF_Scheduler (orb_.in ()), -1); + MIF_Scheduler (orb_.in ()), -1); manager->rtscheduler (scheduler_); CORBA::Object_var object = orb_->resolve_initial_references ("RTScheduler_Current" - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); current_ = @@ -54,10 +53,10 @@ DT_Test::init (int argc, char *argv [] void DT_Test::run (int argc, char* argv [] - ACE_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { init (argc,argv - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; TASK_STATS::instance ()->init (this->dt_creator_->total_load ()); @@ -80,16 +79,16 @@ DT_Test::run (int argc, char* argv [] ACE_CHECK; ACE_DEBUG ((LM_DEBUG, - "Registered Synch Object\n")); + "Registered Synch Object\n")); dt_creator_->create_distributable_threads (current_.in () - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; orb_->destroy (); ACE_DEBUG ((LM_DEBUG, - "Test Terminating......\n")); + "Test Terminating......\n")); } @@ -117,12 +116,12 @@ long flags; orb_->orb_core ()->orb_params ()->sched_policy (); if (this->activate (flags, - 1) == -1) + 1) == -1) { if (ACE_OS::last_error () == EPERM) - ACE_ERROR_RETURN ((LM_ERROR, - ACE_TEXT ("Insufficient privilege to run this test.\n")), - -1); + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("Insufficient privilege to run this test.\n")), + -1); } return 0; } @@ -133,7 +132,7 @@ DT_Test::svc (void) ACE_TRY_NEW_ENV { dt_creator_->create_distributable_threads (current_.in () - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } @@ -162,10 +161,10 @@ main (int argc, char* argv []) { ACE_Service_Config::static_svcs ()->insert (&ace_svc_desc_MIF_DT_Creator); - ACE_DEBUG ((LM_DEBUG, - "%t\n")); + ACE_DEBUG ((LM_DEBUG, + "%t\n")); DT_TEST::instance ()->run (argc, argv - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } |