ACE/examples/Reactor/TP_Reactor/ReadHandler.h

   1 /*
   2  * ACE reactor demonstration
   3  *
   4  * Date: 26-Jan-2006
   5  */
   6
   7 #ifndef __READHANDLER_H__
   8 #define __READHANDLER_H__
   9
  10 #include <ace/Event_Handler.h>
  11 #include <ace/SOCK_Stream.h>
  12
  13 /**
  14  * This read handler is created by the accept handler and handles all the data
  15  * exchange between client and server. The client makes two requests to the
  16  * server. The first asks the server to create a buffer which will hold the
  17  * data sent in the second call.
  18  */
  19 class ReadHandler : public ACE_Event_Handler {
  20     private:
  21         /**
  22          * The stream socket used for data exchange.
  23          */
  24         ACE_SOCK_Stream mStream;
  25
  26         /**
  27          * The size of the data array.
  28          */
  29         int mDataSize;
  30
  31         /**
  32          * The array containing the client's data.
  33          */
  34         char *mData;
  35
  36         /**
  37          * The call counter to distinguish between first and second call.
  38          */
  39         int mCallCounter;
  40
  41         /**
  42          * Count the numer of invocations of handle_*(). According to the
  43          * docs, there should be only one invocation at any given time.
  44          */
  45         int mInvocationCounter;
  46
  47     public:
  48         /**
  49          * Initialization.
  50          */
  51         ReadHandler();
  52
  53         /**
  54          * Clean up data.
  55          */
  56         virtual ~ReadHandler();
  57
  58         /**
  59          * Provide access to the internal stream socket.
  60          */
  61         ACE_SOCK_Stream &getStream();
  62
  63         /**
  64          * @name Overridden methods from the ACE_Event_Handler
  65          */
  66         // @{
  67         /**
  68          * Provides the handle of mStream;
  69          */
  70         virtual ACE_HANDLE get_handle() const;
  71
  72         /**
  73          * Handles the data excahnge between client and server. On the first
  74          * invocation, mData is allocated to the requested size and on the
  75          * second invocation, that buffer is filled with the client's data.
  76          */
  77         virtual int handle_input(ACE_HANDLE = ACE_INVALID_HANDLE);
  78
  79         /**
  80          * Deletes this instance of the read handler.
  81          */
  82         virtual int handle_close(ACE_HANDLE, ACE_Reactor_Mask);
  83         // @}
  84 };
  85
  86 #endif /* __READHANDLER_H__ */
  87