TAO/examples/Kokyu_dsrt_schedulers/MUF_Scheduler.h

   1 #ifndef MUF_SCHEDULER_H
   2 #define MUF_SCHEDULER_H
   3
   4 #include "tao/RTScheduling/RTScheduler.h"
   5 #include "tao/CodecFactory/CodecFactory.h"
   6 #include "MUF_SchedulingC.h"
   7 #include "Kokyu/Kokyu_dsrt.h"
   8 #include "Kokyu_dsrt_schedulers_export.h"
   9 #include "tao/LocalObject.h"
  10
  11 struct MUF_Scheduler_Traits
  12 {
  13   typedef RTScheduling::Current::IdType Guid_t;
  14
  15   typedef TimeBase::TimeT Time_t;
  16   class _Now
  17   {
  18   public:
  19     Time_t operator () ()
  20       {
  21         ACE_Time_Value time = ACE_OS::gettimeofday ();
  22         return 10*time.usec () + 10000000*time.sec ();
  23       }
  24   };
  25
  26   struct _QoSDescriptor_t
  27   {
  28     typedef long Criticality_t;
  29
  30     typedef TimeBase::TimeT Time_t;
  31     typedef _Now Now;
  32
  33     Criticality_t criticality_;
  34     Time_t deadline_;
  35     Time_t exec_time_;
  36   };
  37
  38   typedef _QoSDescriptor_t QoSDescriptor_t;
  39
  40   typedef Kokyu::MUF_Comparator<QoSDescriptor_t> QoSComparator_t;
  41
  42   class _Guid_Hash
  43   {
  44   public:
  45     u_long operator () (const Guid_t& id)
  46       {
  47         return ACE::hash_pjw ((const char *) id.get_buffer (),
  48                               id.length ());
  49       }
  50   };
  51   typedef _Guid_Hash Guid_Hash;
  52 };
  53
  54 class Kokyu_DSRT_Schedulers_Export MUF_Sched_Param_Policy:
  55 public MUF_Scheduling::SchedulingParameterPolicy,
  56        public ::CORBA::LocalObject
  57 {
  58  public:
  59     MUF_Sched_Param_Policy ();
  60     MUF_Sched_Param_Policy (const MUF_Sched_Param_Policy &rhs);
  61
  62     MUF_Scheduling::SchedulingParameter value ();
  63
  64     void value (const MUF_Scheduling::SchedulingParameter & value);
  65
  66      virtual CORBA::Policy_ptr copy ();
  67
  68      virtual CORBA::PolicyType policy_type ();
  69
  70      virtual void destroy ();
  71
  72  private:
  73     MUF_Scheduling::SchedulingParameter value_;
  74 };
  75
  76 class Kokyu_DSRT_Schedulers_Export MUF_Scheduler:
  77 public MUF_Scheduling::Scheduler,
  78 public ::CORBA::LocalObject
  79 {
  80  public:
  81   MUF_Scheduler (CORBA::ORB_ptr orb,
  82                  Kokyu::DSRT_Dispatcher_Impl_t,
  83                  int ace_sched_policy,
  84                  int ace_sched_scope);
  85
  86   ~MUF_Scheduler ();
  87
  88
  89   virtual MUF_Scheduling::SchedulingParameterPolicy_ptr
  90     create_scheduling_parameter (const MUF_Scheduling::SchedulingParameter & value);
  91
  92   void shutdown ();
  93
  94   virtual void begin_new_scheduling_segment (const RTScheduling::Current::IdType & guid,
  95                                              const char * name,
  96                                              CORBA::Policy_ptr sched_param,
  97                                              CORBA::Policy_ptr implicit_sched_param);
  98
  99   virtual void begin_nested_scheduling_segment (const RTScheduling::Current::IdType & guid,
 100                                                 const char * name,
 101                                                 CORBA::Policy_ptr sched_param,
 102                                                 CORBA::Policy_ptr implicit_sched_param);
 103
 104   virtual void update_scheduling_segment (const RTScheduling::Current::IdType & guid,
 105                                           const char * name,
 106                                           CORBA::Policy_ptr sched_param,
 107                                           CORBA::Policy_ptr implicit_sched_param);
 108
 109   virtual void end_scheduling_segment (const RTScheduling::Current::IdType & guid,
 110                                        const char * name);
 111
 112   virtual void end_nested_scheduling_segment (const RTScheduling::Current::IdType & guid,
 113                                               const char * name,
 114                                               CORBA::Policy_ptr outer_sched_param);
 115
 116   virtual void send_request (PortableInterceptor::ClientRequestInfo_ptr ri);
 117
 118   virtual void send_poll (PortableInterceptor::ClientRequestInfo_ptr ri);
 119
 120   virtual void receive_request (PortableInterceptor::ServerRequestInfo_ptr ri,
 121                                 RTScheduling::Current::IdType_out guid,
 122                                 CORBA::String_out name,
 123                                 CORBA::Policy_out sched_param,
 124                                 CORBA::Policy_out implicit_sched_param);
 125
 126   virtual void send_reply (PortableInterceptor::ServerRequestInfo_ptr ri);
 127
 128   virtual void send_exception (PortableInterceptor::ServerRequestInfo_ptr ri);
 129
 130   virtual void send_other (PortableInterceptor::ServerRequestInfo_ptr ri);
 131
 132   virtual void receive_reply (PortableInterceptor::ClientRequestInfo_ptr ri);
 133
 134   virtual void receive_exception (PortableInterceptor::ClientRequestInfo_ptr ri);
 135
 136   virtual void receive_other (PortableInterceptor::ClientRequestInfo_ptr ri);
 137
 138   virtual void cancel (const RTScheduling::Current::IdType & guid);
 139
 140   virtual CORBA::PolicyList * scheduling_policies ();
 141
 142   virtual void scheduling_policies (const CORBA::PolicyList & scheduling_policies);
 143
 144   virtual CORBA::PolicyList * poa_policies ();
 145
 146   virtual char * scheduling_discipline_name ();
 147
 148   virtual RTScheduling::ResourceManager_ptr create_resource_manager (const char * name,
 149                                                                      CORBA::Policy_ptr scheduling_parameter);
 150
 151   virtual void set_scheduling_parameter (PortableServer::Servant & resource,
 152                                          const char * name,
 153                                          CORBA::Policy_ptr scheduling_parameter);
 154
 155  private:
 156   CORBA::ORB_var orb_;
 157   IOP::Codec_var codec_;
 158   RTScheduling::Current_var current_;
 159   Kokyu::DSRT_Dispatcher_Factory<MUF_Scheduler_Traits>::DSRT_Dispatcher_Auto_Ptr
 160     kokyu_dispatcher_;
 161   Kokyu::DSRT_Dispatcher_Impl_t disp_impl_type_;
 162   int ace_sched_policy_;
 163   int ace_sched_scope_;
 164 };
 165
 166 #endif //MUF_SCHEDULER_H