ACE/tests/Thread_Pool_Reactor_Test.h

   1
   2 //=============================================================================
   3 /**
   4  *  @file    Thread_Pool_Reactor_Test.h
   5  *
   6  *  It is only used by Thread_Pool_Reactor_Test.cpp.
   7  *
   8  *  @author   Irfan Pyarali <irfan@cs.wustl.edu>   Nanbor Wang <nanbor@cs.wustl.edu>
   9  */
  10 //=============================================================================
  11
  12
  13 #ifndef ACE_TESTS_THREAD_POOL_REACTOR_TEST_H
  14 #define ACE_TESTS_THREAD_POOL_REACTOR_TEST_H
  15
  16 #include "ace/SOCK_Stream.h"
  17
  18 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  19 # pragma once
  20 #endif /* ACE_LACKS_PRAGMA_ONCE */
  21
  22 #include "ace/Svc_Handler.h"
  23
  24 /**
  25  * @class Request_Handler
  26  *
  27  * @brief This class is the Svc_Handler used by <Acceptor>.
  28  */
  29 class Request_Handler : public ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_MT_SYNCH>
  30 {
  31 public:
  32   /// The default constructor makes sure the right reactor is used.
  33   Request_Handler (ACE_Thread_Manager *tm = 0);
  34
  35 protected:
  36   virtual int handle_input (ACE_HANDLE fd = ACE_INVALID_HANDLE);
  37   virtual int handle_close (ACE_HANDLE fd, ACE_Reactor_Mask = 0);
  38
  39 private:
  40   size_t  nr_msgs_rcvd_;
  41 };
  42
  43 #endif /* ACE_TESTS_THREAD_POOL_REACTOR_TEST_H */