TAO/tests/RTScheduling/Current/test.cpp

   1 #include "Thread_Task.h"
   2 #include "../Scheduler.h"
   3 #include "tao/RTScheduling/RTScheduler_Manager.h"
   4
   5 int
   6 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
   7 {
   8   try
   9     {
  10       CORBA::ORB_var orb =
  11         CORBA::ORB_init (argc,
  12                          argv);
  13
  14       CORBA::Object_var manager_obj = orb->resolve_initial_references ("RTSchedulerManager");
  15
  16       TAO_RTScheduler_Manager_var manager = TAO_RTScheduler_Manager::_narrow (manager_obj.in ());
  17
  18       TAO_Scheduler scheduler (orb.in ());
  19
  20       manager->rtscheduler (&scheduler);
  21
  22       Thread_Task task (orb.in ());
  23
  24       task.activate_task (4);
  25
  26       orb->run ();
  27
  28       // Wait until all threads are ready.
  29       ACE_Thread_Manager::instance ()->wait ();
  30
  31       orb->destroy ();
  32     }
  33   catch (const CORBA::Exception& ex)
  34     {
  35       ex._tao_print_exception ("Caught exception:");
  36       return 1;
  37     }
  38
  39   return 0;
  40 }