TAO/examples/RTCORBA/Activity/Periodic_Task.cpp

   1 #include "Periodic_Task.h"
   2
   3 #include "ace/High_Res_Timer.h"
   4 #include "tao/debug.h"
   5
   6 #include "Task_Stats.h"
   7
   8 Periodic_Task::Periodic_Task (void)
   9   :barrier_ (0),
  10    task_priority_ (0),
  11    period_ (0),
  12    exec_time_ (0),
  13    phase_ (0),
  14    iter_ (0),
  15    load_ (0),
  16    task_stats_ (0)
  17 {
  18 }
  19
  20 Periodic_Task::~Periodic_Task ()
  21 {
  22   delete task_stats_;
  23 }
  24
  25 int
  26 Periodic_Task::init_task (ACE_Arg_Shifter& arg_shifter)
  27 {
  28   const ACE_TCHAR *current_arg = 0;
  29
  30   while (arg_shifter.is_anything_left ())
  31     {
  32       if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-JobName"))))
  33         {
  34           name_ = ACE_TEXT_ALWAYS_CHAR(current_arg);
  35           arg_shifter.consume_arg ();
  36         }
  37       else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-Priority"))))
  38         {
  39           task_priority_ = ACE_OS::atoi (current_arg);
  40           arg_shifter.consume_arg ();
  41         }
  42       else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-Period"))))
  43         {
  44           period_ = ACE_OS::atoi (current_arg);
  45           arg_shifter.consume_arg ();
  46         }
  47       else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-ExecTime"))))
  48         {
  49           exec_time_ = ACE_OS::atoi (current_arg);
  50           arg_shifter.consume_arg ();
  51         }
  52       else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-Phase"))))
  53         {
  54           phase_ = ACE_OS::atoi (current_arg);
  55           arg_shifter.consume_arg ();
  56         }
  57       else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-Iter"))))
  58         {
  59           iter_ = ACE_OS::atoi (current_arg);
  60           arg_shifter.consume_arg ();
  61
  62           // create the stat object.
  63           ACE_NEW_RETURN (task_stats_, Task_Stats (iter_), -1);
  64
  65           if (task_stats_->init () == -1)
  66             return -1;
  67         }
  68       else if (0 != (current_arg = arg_shifter.get_the_parameter (ACE_TEXT("-Load"))))
  69         {
  70           load_ = ACE_OS::atoi (current_arg);
  71           arg_shifter.consume_arg ();
  72
  73           return 0;
  74         }
  75       else
  76         {
  77           ACE_DEBUG ((LM_DEBUG, "parse Task unknown option %s\n",
  78                       arg_shifter.get_current ()));
  79           if (TAO_debug_level > 0)
  80             ACE_DEBUG ((LM_DEBUG, "name %s, priority %d, period %duS, exec_time %duS, phase %duS, iter %d, load %d\n",
  81                         name_.c_str(), task_priority_, period_, exec_time_, phase_, iter_, load_));
  82           break;
  83         }
  84     }
  85   return 0;
  86 }
  87
  88 const char*
  89 Periodic_Task::job (void)
  90 {
  91   return name_.c_str ();
  92 }
  93
  94 void
  95 Periodic_Task::job (Job_ptr job)
  96 {
  97   job_ = Job::_duplicate (job);
  98 }
  99
 100 void
 101 Periodic_Task::dump_stats (ACE_TCHAR* msg)
 102 {
 103   ACE_TCHAR buf[BUFSIZ];
 104   ACE_OS::sprintf (buf, ACE_TEXT("%s%s"), name_.c_str (), ACE_TEXT(".dat"));
 105
 106   ACE_TString fname (buf);
 107
 108   ACE_OS::sprintf (buf,ACE_TEXT("#%s #name %s, priority %d, period %ld, exec_time %ld, phase %ld, iter_ %d , load_ %d"),
 109                    msg, name_.c_str(), task_priority_, period_, exec_time_, phase_, iter_, load_);
 110
 111   task_stats_->dump_samples (fname.c_str (), buf,
 112                              ACE_High_Res_Timer::global_scale_factor ());
 113 }