TAO/examples/RTScheduling/Thread_Task.cpp

   1 #include "Thread_Task.h"
   2 #include "DT_Creator.h"
   3 #include "Task_Stats.h"
   4
   5 #include "tao/ORB_Core.h"
   6
   7 #include "ace/High_Res_Timer.h"
   8 #include "ace/Atomic_Op.h"
   9
  10 Thread_Task::Thread_Task (void)
  11  : start_time_ (0),
  12    load_ (0),
  13    iter_ (0),
  14    count_ (0),
  15    importance_ (0),
  16    dt_creator_ (0),
  17    base_time_ (0),
  18    dist_ (0),
  19    job_name_ (),
  20    task_stats_ (0)
  21 {
  22 }
  23
  24 int
  25 Thread_Task::svc (void)
  26 {
  27   try
  28     {
  29       if (TAO_debug_level > 0)
  30         {
  31           ACE_DEBUG ((LM_DEBUG,
  32                       "Thread_Task::svc %d\n",
  33                       importance_));
  34         }
  35
  36       const char * name = 0;
  37       CORBA::Policy_var implicit_sched_param = CORBA::Policy::_duplicate (sched_param_.in ());;
  38       this->current_->begin_scheduling_segment (name,
  39                                                 sched_param_.in (),
  40                                                 implicit_sched_param.in ());
  41
  42       RTScheduling::Current::IdType_var guid = this->current_->id ();
  43       ACE_OS::memcpy (&count_,
  44                       guid->get_buffer (),
  45                       guid->length ());
  46
  47       ACE_TCHAR msg [BUFSIZ];
  48       ACE_OS::sprintf (msg,
  49                        ACE_TEXT("Thread_Task::svc Imp=%d Guid=")
  50                        ACE_SIZE_T_FORMAT_SPECIFIER
  51                        ACE_TEXT("\n"),
  52                        importance_,
  53                        count_);
  54
  55       dt_creator_->log_msg (ACE_TEXT_ALWAYS_CHAR(msg));
  56
  57       this->perform_task ();
  58
  59       this->current_->end_scheduling_segment (name);
  60
  61       dt_creator_->dt_ended () ;
  62     }
  63   catch (const CORBA::THREAD_CANCELLED &)
  64     {
  65       // Threads can be cancelled.
  66     }
  67   catch (const CORBA::Exception& ex)
  68     {
  69       ex._tao_print_exception ("Caught exception:");
  70     }
  71   return 0;
  72 }
  73
  74 int
  75 Thread_Task::importance (void)
  76 {
  77   return this->importance_;
  78 }
  79
  80 time_t
  81 Thread_Task::start_time (void)
  82 {
  83   return this->start_time_;
  84 }
  85
  86 int
  87 Thread_Task::perform_task (void)
  88 {
  89   return 0;
  90 }
  91
  92
  93 const char*
  94 Thread_Task::job (void)
  95 {
  96   return job_name_.in ();
  97 }
  98
  99 void
 100 Thread_Task::job (Job_ptr job)
 101 {
 102   job_ = Job::_duplicate (job);
 103 }
 104
 105 int
 106 Thread_Task::dist (void)
 107 {
 108   return this->dist_;
 109 }
 110
 111 void
 112 Thread_Task::dump_stats (void)
 113 {
 114   ACE_TCHAR fname [BUFSIZ];
 115   ACE_OS::sprintf (fname,
 116                    ACE_TEXT("DT_")
 117                    ACE_SIZE_T_FORMAT_SPECIFIER
 118                    ACE_TEXT(".dat"),
 119                    count_);
 120
 121   if (TAO_debug_level > 0)
 122     ACE_DEBUG ((LM_DEBUG,
 123     "File name %s\n",
 124     fname));
 125
 126   ACE_TCHAR msg [BUFSIZ];
 127   ACE_OS::sprintf (msg,
 128                    ACE_TEXT("#Schedule Output for DT ")
 129                    ACE_SIZE_T_FORMAT_SPECIFIER,
 130                    count_);
 131
 132   task_stats_->dump_samples (fname, msg);
 133 }