TAO/tao/RTScheduling/Request_Interceptor.h

   1 // -*- C++ -*-
   2 //
   3 #ifndef TAO_RTSCHEDULING_REQUEST_INTERCEPTOR_H
   4 #define TAO_RTSCHEDULING_REQUEST_INTERCEPTOR_H
   5
   6 #include "tao/RTScheduling/rtscheduler_export.h"
   7 #include "tao/RTScheduling/RTScheduler.h"
   8 #include "ace/Atomic_Op.h"
   9 #include "tao/RTScheduling/Current.h"
  10 #include "tao/LocalObject.h"
  11
  12 #include "tao/PI_Server/PI_Server.h"
  13
  14 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  15
  16 extern std::atomic<long> server_guid_counter;
  17
  18 class TAO_RTScheduler_Export Client_Interceptor:
  19   public PortableInterceptor::ClientRequestInterceptor,
  20   public ::CORBA::LocalObject
  21 {
  22 public:
  23   //  Client_Interceptor (RTScheduling::Current_ptr current);
  24   void send_request (PortableInterceptor::ClientRequestInfo_ptr ri) override;
  25
  26   void send_poll (PortableInterceptor::ClientRequestInfo_ptr ri) override;
  27
  28   void receive_reply (PortableInterceptor::ClientRequestInfo_ptr ri) override;
  29
  30   void receive_exception (PortableInterceptor::ClientRequestInfo_ptr ri) override;
  31
  32   void receive_other (PortableInterceptor::ClientRequestInfo_ptr ri) override;
  33
  34   char* name () override;
  35
  36   void destroy () override;
  37
  38   static const IOP::ServiceId SchedulingInfo;
  39 };
  40
  41 class TAO_RTScheduler_Export Server_Interceptor :
  42   public PortableInterceptor::ServerRequestInterceptor,
  43   public ::CORBA::LocalObject
  44 {
  45 public:
  46   Server_Interceptor (TAO_RTScheduler_Current_ptr current);
  47
  48   void receive_request_service_contexts (PortableInterceptor::ServerRequestInfo_ptr ri) override;
  49
  50   void receive_request (PortableInterceptor::ServerRequestInfo_ptr ri) override;
  51
  52   void send_reply (PortableInterceptor::ServerRequestInfo_ptr ri) override;
  53
  54   void send_exception (PortableInterceptor::ServerRequestInfo_ptr ri) override;
  55
  56   void send_other (PortableInterceptor::ServerRequestInfo_ptr ri) override;
  57
  58   char* name () override;
  59
  60   void destroy () override;
  61
  62   static const IOP::ServiceId SchedulingInfo;
  63
  64  private:
  65   TAO_RTScheduler_Current_var current_;
  66 };
  67
  68 TAO_END_VERSIONED_NAMESPACE_DECL
  69
  70 #endif  /* TAO_RTSCHEDULING_REQUEST_INTERCEPTOR_H */