TAO/examples/Kokyu_dsrt_schedulers/FP_Scheduler.h

   1 #ifndef FIXED_PRIORITY_SCHEDULER_H
   2 #define FIXED_PRIORITY_SCHEDULER_H
   3
   4 #include "tao/RTScheduling/RTScheduler.h"
   5 #include "tao/CodecFactory/CodecFactory.h"
   6 #include "tao/LocalObject.h"
   7 #include "FP_SchedulingC.h"
   8 #include "Kokyu/Kokyu_dsrt.h"
   9 #include "Kokyu_dsrt_schedulers_export.h"
  10
  11 struct FP_Scheduler_Traits
  12 {
  13   typedef RTScheduling::Current::IdType Guid_t;
  14
  15   struct _QoSDescriptor_t
  16   {
  17     typedef long Priority_t;
  18     Priority_t priority_;
  19   };
  20
  21   typedef _QoSDescriptor_t QoSDescriptor_t;
  22
  23   typedef Kokyu::Fixed_Priority_Comparator<QoSDescriptor_t> QoSComparator_t;
  24
  25   class _Guid_Hash
  26   {
  27   public:
  28     u_long operator () (const Guid_t& id)
  29       {
  30         return ACE::hash_pjw ((const char *) id.get_buffer (),
  31                               id.length ());
  32       }
  33   };
  34
  35   typedef _Guid_Hash Guid_Hash;
  36 };
  37
  38 class Kokyu_DSRT_Schedulers_Export FP_Segment_Sched_Param_Policy:
  39 public FP_Scheduling::SegmentSchedulingParameterPolicy,
  40        public ::CORBA::LocalObject
  41 {
  42  public:
  43      FP_Segment_Sched_Param_Policy ();
  44      FP_Segment_Sched_Param_Policy (const FP_Segment_Sched_Param_Policy &rhs);
  45
  46      FP_Scheduling::SegmentSchedulingParameter value (
  47       );
  48
  49      void value (
  50         const FP_Scheduling::SegmentSchedulingParameter & value
  51       );
  52
  53      virtual CORBA::Policy_ptr copy ();
  54
  55      virtual CORBA::PolicyType policy_type ();
  56
  57      virtual void destroy ();
  58
  59  private:
  60   FP_Scheduling::SegmentSchedulingParameter value_;
  61 };
  62
  63 class Kokyu_DSRT_Schedulers_Export Fixed_Priority_Scheduler:
  64 public FP_Scheduling::FP_Scheduler,
  65 public ::CORBA::LocalObject
  66 {
  67  public:
  68   Fixed_Priority_Scheduler (CORBA::ORB_ptr orb,
  69                  Kokyu::DSRT_Dispatcher_Impl_t,
  70                  int ace_sched_policy,
  71                  int ace_sched_scope);
  72
  73   ~Fixed_Priority_Scheduler ();
  74
  75   void shutdown ();
  76
  77   virtual FP_Scheduling::SegmentSchedulingParameterPolicy_ptr
  78     create_segment_scheduling_parameter (
  79         const FP_Scheduling::SegmentSchedulingParameter & value
  80       );
  81
  82   virtual void begin_new_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 begin_nested_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 update_scheduling_segment (const RTScheduling::Current::IdType & guid,
  93                                           const char * name,
  94                                           CORBA::Policy_ptr sched_param,
  95                                           CORBA::Policy_ptr implicit_sched_param);
  96
  97   virtual void end_scheduling_segment (const RTScheduling::Current::IdType & guid,
  98                                        const char * name);
  99
 100   virtual void end_nested_scheduling_segment (const RTScheduling::Current::IdType & guid,
 101                                               const char * name,
 102                                               CORBA::Policy_ptr outer_sched_param);
 103
 104   virtual void send_request (PortableInterceptor::ClientRequestInfo_ptr ri);
 105
 106   virtual void receive_request (PortableInterceptor::ServerRequestInfo_ptr ri,
 107                                 RTScheduling::Current::IdType_out guid,
 108                                 CORBA::String_out name,
 109                                 CORBA::Policy_out sched_param,
 110                                 CORBA::Policy_out implicit_sched_param);
 111
 112   virtual void send_reply (PortableInterceptor::ServerRequestInfo_ptr ri);
 113
 114   virtual void send_poll (PortableInterceptor::ClientRequestInfo_ptr ri);
 115
 116   virtual void send_exception (PortableInterceptor::ServerRequestInfo_ptr ri);
 117
 118   virtual void send_other (PortableInterceptor::ServerRequestInfo_ptr ri);
 119
 120   virtual void receive_reply (PortableInterceptor::ClientRequestInfo_ptr ri);
 121
 122   virtual void receive_exception (PortableInterceptor::ClientRequestInfo_ptr ri);
 123
 124   virtual void receive_other (PortableInterceptor::ClientRequestInfo_ptr ri);
 125
 126   virtual void cancel (const RTScheduling::Current::IdType & guid);
 127
 128   virtual CORBA::PolicyList * scheduling_policies ();
 129
 130   virtual void scheduling_policies (const CORBA::PolicyList & scheduling_policies);
 131
 132   virtual CORBA::PolicyList * poa_policies ();
 133
 134   virtual char * scheduling_discipline_name ();
 135
 136   virtual RTScheduling::ResourceManager_ptr create_resource_manager (const char * name,
 137                                                                      CORBA::Policy_ptr scheduling_parameter);
 138
 139   virtual void set_scheduling_parameter (PortableServer::Servant & resource,
 140                                          const char * name,
 141                                          CORBA::Policy_ptr scheduling_parameter);
 142
 143  private:
 144   CORBA::ORB_var orb_;
 145   IOP::Codec_var codec_;
 146   RTScheduling::Current_var current_;
 147   Kokyu::DSRT_Dispatcher_Factory<FP_Scheduler_Traits>::DSRT_Dispatcher_Auto_Ptr
 148   kokyu_dispatcher_;
 149   Kokyu::DSRT_Dispatcher_Impl_t disp_impl_type_;
 150   int ace_sched_policy_;
 151   int ace_sched_scope_;
 152 };
 153
 154 #endif //FIXED_PRIORITY_SCHEDULER_H