TAO/tests/RTScheduling/Scheduler.cpp

   1 #include "Scheduler.h"
   2 #include "tao/ORB.h"
   3 #include "ace/Atomic_Op.h"
   4 #include "tao/RTScheduling/Request_Interceptor.h"
   5
   6 TAO_Scheduler::TAO_Scheduler (CORBA::ORB_ptr orb)
   7 {
   8   CORBA::Object_var current_obj =
   9     orb->resolve_initial_references ("RTScheduler_Current");
  10
  11   current_ = RTScheduling::Current::_narrow (current_obj.in ());
  12 }
  13
  14 TAO_Scheduler::~TAO_Scheduler ()
  15 {
  16 }
  17
  18 CORBA::PolicyList*
  19 TAO_Scheduler::scheduling_policies ()
  20 {
  21   return 0;
  22 }
  23
  24 void
  25 TAO_Scheduler::scheduling_policies (const CORBA::PolicyList &)
  26 {
  27 }
  28
  29 CORBA::PolicyList*
  30 TAO_Scheduler::poa_policies ()
  31 {
  32   return 0;
  33 }
  34
  35 char *
  36 TAO_Scheduler::scheduling_discipline_name ()
  37 {
  38   return 0;
  39 }
  40
  41 RTScheduling::ResourceManager_ptr
  42 TAO_Scheduler::create_resource_manager (const char *,
  43                                         CORBA::Policy_ptr)
  44 {
  45   return 0;
  46 }
  47
  48 void
  49 TAO_Scheduler::set_scheduling_parameter (PortableServer::Servant &,
  50                                          const char *,
  51                                          CORBA::Policy_ptr)
  52 {
  53 }
  54
  55 void
  56 TAO_Scheduler::begin_new_scheduling_segment (const RTScheduling::Current::IdType &,
  57                                              const char *,
  58                                              CORBA::Policy_ptr,
  59                                              CORBA::Policy_ptr)
  60 {
  61 }
  62
  63 void
  64 TAO_Scheduler::begin_nested_scheduling_segment (const RTScheduling::Current::IdType &,
  65                                                 const char *,
  66                                                 CORBA::Policy_ptr,
  67                                                 CORBA::Policy_ptr)
  68 {
  69 }
  70
  71 void
  72 TAO_Scheduler::update_scheduling_segment (const RTScheduling::Current::IdType &,
  73                                           const char *,
  74                                           CORBA::Policy_ptr,
  75                                           CORBA::Policy_ptr)
  76 {
  77 }
  78
  79 void
  80 TAO_Scheduler::end_scheduling_segment (const RTScheduling::Current::IdType &,
  81                                        const char *)
  82 {
  83 }
  84
  85 void
  86 TAO_Scheduler::end_nested_scheduling_segment (const RTScheduling::Current::IdType &,
  87                                               const char *,
  88                                               CORBA::Policy_ptr)
  89 {
  90 }
  91
  92
  93 void
  94 TAO_Scheduler::send_request (PortableInterceptor::ClientRequestInfo_ptr request_info)
  95 {
  96   IOP::ServiceContext srv_con;
  97   srv_con.context_id = Client_Interceptor::SchedulingInfo;
  98   srv_con.context_data.length (sizeof (size_t));
  99   RTScheduling::Current::IdType_var id = this->current_->id ();
 100   ACE_OS::memcpy (srv_con.context_data.get_buffer (),
 101                   id->get_buffer (),
 102                   sizeof (size_t));
 103   request_info->add_request_service_context (srv_con,
 104                                              0);
 105 }
 106
 107 void
 108 TAO_Scheduler::receive_request (PortableInterceptor::ServerRequestInfo_ptr request_info,
 109                                 RTScheduling::Current::IdType_out guid_out,
 110                                 CORBA::String_out /*name*/,
 111                                 CORBA::Policy_out /*sched_param*/,
 112                                 CORBA::Policy_out /*implicit_sched_param*/)
 113 {
 114   IOP::ServiceContext_var serv_cxt;
 115
 116   try
 117     {
 118       serv_cxt = request_info->get_request_service_context (Server_Interceptor::SchedulingInfo);
 119
 120       size_t gu_id;
 121       ACE_OS::memcpy (&gu_id,
 122                       serv_cxt->context_data.get_buffer (),
 123                       serv_cxt->context_data.length ());
 124
 125       ACE_DEBUG ((LM_DEBUG,
 126                   "The Guid is %d\n",
 127                   gu_id));
 128
 129       RTScheduling::Current::IdType* guid;
 130       ACE_NEW (guid,
 131                RTScheduling::Current::IdType);
 132
 133       guid->length (sizeof (size_t));
 134       ACE_OS::memcpy (guid->get_buffer (),
 135                       serv_cxt->context_data.get_buffer (),
 136                       sizeof (size_t));
 137
 138       guid_out = guid;
 139     }
 140   catch (const CORBA::Exception&)
 141     {
 142       ACE_DEBUG ((LM_DEBUG,
 143                   "Invalid Service Context\n"));
 144     }
 145 }
 146
 147 void
 148 TAO_Scheduler::send_reply (PortableInterceptor::ServerRequestInfo_ptr)
 149 {
 150 }
 151
 152 void
 153 TAO_Scheduler::send_exception (PortableInterceptor::ServerRequestInfo_ptr)
 154 {
 155 }
 156
 157 void
 158 TAO_Scheduler::send_other (PortableInterceptor::ServerRequestInfo_ptr)
 159 {
 160 }
 161
 162 void
 163 TAO_Scheduler::send_poll (PortableInterceptor::ClientRequestInfo_ptr)
 164 {
 165 }
 166
 167 void
 168 TAO_Scheduler::receive_reply (PortableInterceptor::ClientRequestInfo_ptr)
 169 {
 170 }
 171
 172 void
 173 TAO_Scheduler::receive_exception (PortableInterceptor::ClientRequestInfo_ptr)
 174 {
 175 }
 176
 177 void
 178 TAO_Scheduler::receive_other (PortableInterceptor::ClientRequestInfo_ptr)
 179 {
 180 }
 181
 182 void
 183 TAO_Scheduler::cancel (const RTScheduling::Current::IdType &)
 184 {
 185 }