ACE/apps/JAWS3/jaws3/Protocol_Handler.h

   1 #ifndef JAWS_PROTOCOL_HANDLER_H
   2 #define JAWS_PROTOCOL_HANDLER_H
   3
   4 #include "ace/Message_Block.h"
   5
   6 #include "jaws3/Export.h"
   7 #include "jaws3/Event_Completer.h"
   8
   9
  10 class JAWS_Export JAWS_Protocol_State
  11 {
  12   friend class JAWS_Protocol_Handler;
  13
  14 public:
  15   virtual ~JAWS_Protocol_State ();
  16
  17 protected:
  18   virtual int service (JAWS_Event_Completer *, void *data) = 0;
  19
  20   virtual JAWS_Protocol_State * transition ( const JAWS_Event_Result &
  21                                            , void *data
  22                                            , void *act
  23                                            ) = 0;
  24 };
  25
  26 class JAWS_Export JAWS_Protocol_Handler
  27   : public JAWS_Event_Completer
  28 // = TITLE
  29 //     Abstraction that interacts with concurrency dispatching.
  30 {
  31   friend class JAWS_TPOOL_Concurrency;
  32   friend class JAWS_TPR_Concurrency;
  33   friend class JAWS_THYBRID_Concurrency;
  34
  35 public:
  36   JAWS_Protocol_Handler (JAWS_Protocol_State *state = 0, void *data = 0);
  37
  38   virtual int service ();
  39
  40   virtual void dismiss ()
  41   {
  42     delete this;
  43   }
  44
  45 protected:
  46   virtual ~JAWS_Protocol_Handler ();
  47   // Try to guarantee this class will be created dynamically.
  48
  49 protected:
  50   void event_complete (const JAWS_Event_Result &result, void *act);
  51   // The event completion routine that triggers the transition
  52   // to the next Protocol State.
  53
  54   void default_complete (const JAWS_Event_Result &result, void *act)
  55   {
  56     this->event_complete (result, act);
  57   }
  58
  59 private:
  60   JAWS_Protocol_State *state_;
  61
  62   void *data_;
  63
  64   ACE_Data_Block db_;
  65   ACE_Message_Block mb_;
  66 };
  67
  68
  69 #endif /* JAWS_PROTOCOL_HANDLER_H */