TAO/examples/Kokyu_dsrt_schedulers/EDF_Scheduler.h

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