summaryrefslogtreecommitdiff
path: root/TAO/examples/RTScheduling/MIF_Scheduler/test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/examples/RTScheduling/MIF_Scheduler/test.cpp')
-rw-r--r--TAO/examples/RTScheduling/MIF_Scheduler/test.cpp51
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;
}