TAO/examples/RTScheduling/Fixed_Priority_Scheduler/FP_Task.cpp

   1 #include "FP_Task.h"
   2 #include "test.h"
   3 #include "tao/RTCORBA/Priority_Mapping_Manager.h"
   4 #include "tao/RTCORBA/Priority_Mapping.h"
   5 #include "ace/High_Res_Timer.h"
   6 #include "ace/OS_NS_errno.h"
   7 #include "ace/Countdown_Time.h"
   8
   9 FP_Task::FP_Task (int importance,
  10                   time_t start_time,
  11                   int load,
  12                   int iter,
  13                   int dist,
  14                   char *job_name,
  15                   DT_Creator *dt_creator)
  16 {
  17   this->load_ = load;
  18   this->iter_ = iter;
  19   this->start_time_ = start_time;
  20   this->importance_ = importance;
  21   this->dt_creator_ = dt_creator;
  22   this->dist_ = dist;
  23   this->job_name_ =  CORBA::string_dup (job_name);
  24 }
  25
  26 int
  27 FP_Task::activate_task (RTScheduling::Current_ptr current,
  28                         CORBA::Policy_ptr sched_param,
  29                         long flags,
  30                         ACE_Time_Value* base_time)
  31 {
  32   if (TAO_debug_level > 0)
  33     ACE_DEBUG ((LM_DEBUG,
  34                 "FP_Task::activate %d\n",
  35                 importance_));
  36
  37   char msg [BUFSIZ];
  38   ACE_OS::sprintf (msg, "FP_Task::activate task\n");
  39   dt_creator_->log_msg (msg);
  40
  41   base_time_ = base_time;
  42
  43   current_ = RTScheduling::Current::_narrow (current);
  44
  45   sched_param_ = CORBA::Policy::_duplicate (sched_param);
  46
  47   pre_activate ();
  48
  49   if (this->activate (flags,
  50                       1,
  51                       0,
  52                       this->importance_) == -1)
  53     {
  54       if (ACE_OS::last_error () == EPERM)
  55         ACE_ERROR_RETURN ((LM_ERROR,
  56                            ACE_TEXT ("Insufficient privilege to run this test.\n")),
  57                           -1);
  58     }
  59
  60   return 0;
  61 }
  62
  63 void
  64 FP_Task::pre_activate ()
  65 {
  66   CORBA::Object_var object =
  67     DT_TEST::instance ()->orb ()->resolve_initial_references ("PriorityMappingManager");
  68
  69   RTCORBA::PriorityMappingManager_var mapping_manager =
  70     RTCORBA::PriorityMappingManager::_narrow (object.in ());
  71
  72   RTCORBA::PriorityMapping *pm = mapping_manager->mapping ();
  73
  74   CORBA::Short native_priority;
  75   if (pm->to_native (this->importance_, native_priority) == 0)
  76     ACE_ERROR ((LM_ERROR,
  77                 "Cannot convert native priority %d to corba priority\n",
  78                 native_priority));
  79   if (TAO_debug_level > 0)
  80     ACE_DEBUG ((LM_DEBUG,
  81                 "Native Priority = %d\n",
  82                  native_priority));
  83   char msg [BUFSIZ];
  84   ACE_OS::sprintf (msg, "Native Priority %d\n",
  85                    native_priority);
  86   dt_creator_->log_msg (msg);
  87
  88   this->importance_ = native_priority;
  89 }
  90
  91 int
  92 FP_Task::perform_task ()
  93 {
  94   static CORBA::ULong prime_number = 9619;
  95
  96   for (int j = 0; j < this->iter_; j++)
  97     {
  98       ACE_Time_Value run_time = ACE_OS::gettimeofday () - *base_time_;
  99       TASK_STATS::instance ()->sample (run_time.sec (), count_);
 100
 101       ACE_Time_Value count_down_time (1);
 102       ACE_Countdown_Time count_down (&count_down_time);
 103
 104       while (count_down_time > ACE_Time_Value::zero)
 105         {
 106           ACE::is_prime (prime_number,
 107                          2,
 108                          prime_number / 2);
 109
 110           count_down.update ();
 111         }
 112     }
 113
 114   if (TAO_debug_level > 0)
 115     ACE_DEBUG ((LM_DEBUG,
 116                 "%d\n",
 117                 count_));
 118
 119   if (this->dist_)
 120     {
 121       job_->work (this->load_, this->importance_);
 122
 123
 124       for (int j = 0; j < this->iter_; j++)
 125         {
 126           ACE_Time_Value run_time = ACE_OS::gettimeofday () - *base_time_;
 127           TASK_STATS::instance ()->sample (run_time.sec (), count_);
 128
 129           ACE_Time_Value count_down_time (1);
 130           ACE_Countdown_Time count_down (&count_down_time);
 131
 132           while (count_down_time > ACE_Time_Value::zero)
 133             {
 134               if (TAO_debug_level > 0)
 135                 ACE_DEBUG ((LM_DEBUG,
 136                             "Waiting on count down\n"));
 137
 138
 139               ACE::is_prime (prime_number,
 140                              2,
 141                              prime_number / 2);
 142               count_down.update ();
 143             }
 144         }
 145
 146       if (TAO_debug_level > 0)
 147         ACE_DEBUG ((LM_DEBUG,
 148                     "%d\n",
 149                     count_));
 150     }
 151
 152   if (dist_)
 153     job_->shutdown ();
 154   return 0;
 155 }