TAO/examples/RTScheduling/Job_i.cpp

   1 #include "Job_i.h"
   2 #include "DT_Creator.h"
   3 #include "Task_Stats.h"
   4
   5 #include "tao/debug.h"
   6
   7 #include "ace/Arg_Shifter.h"
   8 #include "ace/High_Res_Timer.h"
   9 #include "ace/OS_NS_sys_time.h"
  10 #include "ace/Countdown_Time.h"
  11
  12 Job_i::Job_i (DT_Creator* dt_creator)
  13   : dt_creator_ (dt_creator),
  14     guid_ (0)
  15 {
  16   // create the stat object.
  17   ACE_NEW (task_stats_, Task_Stats);
  18   task_stats_->init (100);
  19
  20 }
  21
  22 Job_i::~Job_i (void)
  23 {
  24   delete task_stats_;
  25 }
  26
  27 const ACE_CString&
  28 Job_i::name (void)
  29 {
  30   return job_name_;
  31 }
  32
  33 const ACE_CString&
  34 Job_i::poa (void)
  35 {
  36   return POA_name_;
  37 }
  38
  39 int
  40 Job_i::init (ACE_Arg_Shifter& arg_shifter)
  41 {
  42   // Read the name of the Job
  43   job_name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  44   arg_shifter.consume_arg ();
  45
  46   // Read the name of the POA
  47   POA_name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  48   arg_shifter.consume_arg ();
  49
  50   return 0;
  51 }
  52
  53 void
  54 Job_i::work (CORBA::ULong work,
  55        CORBA::Short importance)
  56 {
  57   static CORBA::ULong prime_number = 9619;
  58
  59   if (TAO_debug_level > 0)
  60     ACE_DEBUG ((LM_DEBUG,
  61     "Job_i::work: %d units of work\n",
  62     work));
  63
  64   CORBA::Object_var object =
  65     this->dt_creator_->orb ()->resolve_initial_references (
  66                                          "RTScheduler_Current");
  67
  68   RTScheduling::Current_var current =
  69     RTScheduling::Current::_narrow (object.in ());
  70   RTScheduling::Current::IdType_var guid = current->id ();
  71
  72   if (guid_ == 0)
  73     ACE_OS::memcpy (&guid_,
  74                     guid->get_buffer (),
  75                     sizeof (guid->length ()));
  76
  77   if (TAO_debug_level > 0)
  78     ACE_DEBUG ((LM_DEBUG,
  79     "%t Guid is %d, Importance is %d\n",
  80     guid_,
  81     importance));
  82
  83   ACE_TCHAR msg [BUFSIZ];
  84   ACE_OS::sprintf (msg,
  85                    ACE_TEXT("Guid is ")
  86                    ACE_SIZE_T_FORMAT_SPECIFIER
  87                    ACE_TEXT("\n"), guid_);
  88
  89   dt_creator_->log_msg (ACE_TEXT_ALWAYS_CHAR(msg));
  90
  91   for (; work != 0; work--)
  92     {
  93       //    ACE_hrtime_t now = ACE_OS::gethrtime ();
  94
  95       ACE_Time_Value *base_time = dt_creator_->base_time ();
  96       if (base_time == 0)
  97         return;
  98
  99       ACE_Time_Value run_time = ACE_OS::gettimeofday () - *(base_time);
 100       TASK_STATS::instance ()->sample (run_time.sec (), guid_);
 101
 102       ACE_Time_Value count_down_time (1);
 103       ACE_Countdown_Time count_down (&count_down_time);
 104
 105       while (count_down_time > ACE_Time_Value::zero)
 106         {
 107           ACE::is_prime (prime_number,
 108             2,
 109             prime_number / 2);
 110           count_down.update ();
 111         }
 112
 113       run_time = ACE_OS::gettimeofday () - *(dt_creator_->base_time ());
 114       TASK_STATS::instance ()->sample (run_time.sec (), guid_);
 115
 116       CORBA::Policy_var sched_param;
 117       sched_param = dt_creator_->sched_param (importance);
 118       const char * name = 0;
 119       current->update_scheduling_segment (name,
 120                 sched_param.in (),
 121                 sched_param.in ());
 122     }
 123 }
 124
 125 void
 126 Job_i::post_work (int /*guid*/,
 127       int /*importance*/)
 128 {
 129 }
 130
 131 int
 132 Job_i::guid (void)
 133 {
 134   return this->guid_;
 135 }
 136
 137 void
 138 Job_i::shutdown (void)
 139 {
 140   dt_creator_->job_ended ();
 141 }
 142
 143 void
 144 Job_i::dump_stats (void)
 145 {
 146   ACE_TCHAR fname [BUFSIZ];
 147   ACE_OS::sprintf (fname,
 148                    ACE_TEXT("Job_")
 149                    ACE_SIZE_T_FORMAT_SPECIFIER
 150                    ACE_TEXT(".dat"),
 151                    guid_);
 152
 153   if (TAO_debug_level > 0)
 154     ACE_DEBUG ((LM_DEBUG,
 155     "File name %s\n",
 156     fname));
 157
 158   ACE_TCHAR msg [BUFSIZ];
 159   ACE_OS::sprintf (msg,
 160                    ACE_TEXT("#Schedule Output for DT ")
 161                    ACE_SIZE_T_FORMAT_SPECIFIER,
 162                    guid_);
 163
 164   task_stats_->dump_samples (fname, msg);
 165 }