ACE/ace/QoS/QoS_Decorator.cpp

   1 // QoS_Decorator.cpp
   2 #include "QoS_Decorator.h"
   3
   4 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   5
   6 ACE_ALLOC_HOOK_DEFINE(ACE_QOS_DECORATOR)
   7
   8 // Constructor.
   9 ACE_QoS_Decorator_Base::ACE_QoS_Decorator_Base ()
  10 {}
  11
  12 // Constructor.
  13 ACE_QoS_Decorator_Base::ACE_QoS_Decorator_Base (ACE_Event_Handler
  14                                                 *event_handler)
  15   : event_handler_ (event_handler)
  16 {
  17 }
  18
  19 // Destructor.
  20 ACE_QoS_Decorator_Base::~ACE_QoS_Decorator_Base ()
  21 {
  22 }
  23
  24 // Forward the call to ACE_Event_Handler component.
  25 ACE_HANDLE
  26 ACE_QoS_Decorator_Base::get_handle () const
  27 {
  28  return this->event_handler_->get_handle ();
  29 }
  30
  31 // Forward the call to ACE_Event_Handler component.
  32 int
  33 ACE_QoS_Decorator_Base::handle_input (ACE_HANDLE fd)
  34 {
  35   return this->event_handler_->handle_input (fd);
  36 }
  37
  38 // Forward the call to ACE_Event_Handler component.
  39 int
  40 ACE_QoS_Decorator_Base::handle_qos (ACE_HANDLE fd)
  41 {
  42   return this->event_handler_->handle_qos (fd);
  43 }
  44
  45 // Constructor.
  46 ACE_QoS_Decorator::ACE_QoS_Decorator ()
  47 {}
  48
  49 // Constructor.
  50 ACE_QoS_Decorator::ACE_QoS_Decorator (ACE_Event_Handler *event_handler,
  51                                       ACE_QoS_Session *qos_session,
  52                                       ACE_Reactor *reactor)
  53   : qos_session_ (qos_session),
  54     reactor_ (reactor)
  55 {
  56   ACE_NEW (this->decorator_base_,
  57            ACE_QoS_Decorator_Base (event_handler));
  58
  59   ACE_NEW (this->qos_event_handler_,
  60            ACE_QoS_Event_Handler (this->decorator_base_));
  61 }
  62
  63 // Destructor.
  64 ACE_QoS_Decorator::~ACE_QoS_Decorator ()
  65 {
  66   delete this->decorator_base_;
  67   delete this->qos_event_handler_;
  68 }
  69
  70 // Implements the undecorated functionality. This is sufficient for
  71 // GQoS. RAPI needs additional QoS decoration. This is done by the
  72 // ACE_QoS_Event_Handler class.
  73 ACE_HANDLE
  74 ACE_QoS_Decorator::get_handle () const
  75 {
  76   return this->decorator_base_->get_handle ();
  77 }
  78
  79 // Implements the undecorated functionality. This is sufficient for
  80 // GQoS. RAPI needs additional QoS decoration. This is done by the
  81 // ACE_QoS_Event_Handler class.
  82 int
  83 ACE_QoS_Decorator::handle_input (ACE_HANDLE fd)
  84 {
  85   return this->decorator_base_->handle_input (fd);
  86 }
  87
  88 // Implements the undecorated functionality. This is sufficient for
  89 // GQoS. RAPI needs additional QoS decoration. This is done by the
  90 // ACE_QoS_Event_Handler class.
  91 int
  92 ACE_QoS_Decorator::handle_qos (ACE_HANDLE fd)
  93 {
  94   return this->decorator_base_->handle_qos (fd);
  95 }
  96
  97 // This method registers the RAPI QoS event handler with the reactor
  98 // if the application is using RAPI. Note that it is a no-op for GQoS
  99 // because an extra socket for handling QoS events is not required.
 100 int
 101 ACE_QoS_Decorator::init ()
 102 {
 103 #if defined (ACE_HAS_RAPI)
 104
 105   // Pass the QoS session to QoS Event Handler.
 106   this->qos_event_handler_->qos_session (this->qos_session_);
 107
 108   // Register the QoS Event Handler with the Reactor.
 109   return this->reactor_->register_handler (this->qos_event_handler_,
 110                                            ACE_Event_Handler::READ_MASK);
 111 #endif
 112   return 0;
 113 }
 114
 115 // Constructor.
 116 ACE_QoS_Event_Handler::ACE_QoS_Event_Handler ()
 117 {
 118 }
 119
 120 // Constructor.
 121 ACE_QoS_Event_Handler::ACE_QoS_Event_Handler (ACE_QoS_Decorator_Base
 122                                               *decorator_base)
 123   : decorator_base_ (decorator_base)
 124 {
 125 }
 126
 127 // Destructor.
 128 ACE_QoS_Event_Handler::~ACE_QoS_Event_Handler ()
 129 {
 130 }
 131
 132 // Set the QoS session.
 133 void
 134 ACE_QoS_Event_Handler::qos_session (ACE_QoS_Session *qos_session)
 135 {
 136   this->qos_session_ = qos_session;
 137 }
 138
 139 // Returns the RAPI file descriptor for listening to RAPI evnets.
 140 ACE_HANDLE
 141 ACE_QoS_Event_Handler::get_handle () const
 142 {
 143   return this->qos_session_->rsvp_events_handle ();
 144 }
 145
 146 // Note, here the handle_input () calls the handle_qos () of the
 147 // Decorator Base which then calls handle_qos () of the
 148 // ACE_Event_Handler component within it. This helps to translate the
 149 // normal read events into qos events in case of RAPI so the
 150 // application using the API is oblivious to the fact that in RAPI,
 151 // QoS events are received on a different socket. This helps to
 152 // maintain a uniform design for the application irrespective of
 153 // whether it is using RAPI or GQoS.
 154 int
 155 ACE_QoS_Event_Handler::handle_input (ACE_HANDLE fd)
 156 {
 157   return this->decorator_base_->handle_qos (fd);
 158 }
 159
 160 ACE_END_VERSIONED_NAMESPACE_DECL