ACE/apps/JAWS3/jaws3/Protocol_Handler.cpp

   1 #ifndef JAWS_BUILD_DLL
   2 #define JAWS_BUILD_DLL
   3 #endif
   4
   5 #include "jaws3/Protocol_Handler.h"
   6 #include "jaws3/Concurrency.h"
   7
   8 JAWS_Protocol_State::~JAWS_Protocol_State ()
   9 {
  10 }
  11
  12
  13 JAWS_Protocol_Handler::JAWS_Protocol_Handler ( JAWS_Protocol_State *state
  14                                              , void *data
  15                                              )
  16   : state_ (state)
  17   , data_ (data)
  18   , mb_ (& this->db_)
  19 {
  20   this->db_.base ((char *) this, 0 /* an infinite queue */);
  21 }
  22
  23
  24 JAWS_Protocol_Handler::~JAWS_Protocol_Handler ()
  25 {
  26   this->mb_.replace_data_block (0);
  27 }
  28
  29
  30 int
  31 JAWS_Protocol_Handler::service ()
  32 {
  33   if (this->state_ == 0)
  34     return -1;
  35
  36   return this->state_->service (this, this->data_);
  37 }
  38
  39
  40 void
  41 JAWS_Protocol_Handler::event_complete ( const JAWS_Event_Result &result
  42                                       , void *act
  43                                       )
  44 {
  45   // This call is done in the context of the dispatching
  46   // thread (e.g., by the Reactor thread, or by one of the
  47   // threads in the Proactor, or by the invoker of the IO
  48   // if the IO is synchronous).
  49
  50   this->state_ = this->state_->transition (result, this->data_, act);
  51
  52   // At this point, we need to cue this Handler back into
  53   // the concurrency mechanism.  This probably means the
  54   // Message Queue of some Concurrency Task.
  55
  56   JAWS_Concurrency::instance ()->putq (this);
  57
  58   // Doing it this way is less efficient than calling into
  59   // the service() method of the next state directly from
  60   // here, but it gains the flexibility of a more modular
  61   // concurrency mechanism.
  62 }
  63