summaryrefslogtreecommitdiff
path: root/ACE/tests/Thread_Pool_Reactor_Resume_Test.h
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/tests/Thread_Pool_Reactor_Resume_Test.h')
-rw-r--r--ACE/tests/Thread_Pool_Reactor_Resume_Test.h56
1 files changed, 56 insertions, 0 deletions
diff --git a/ACE/tests/Thread_Pool_Reactor_Resume_Test.h b/ACE/tests/Thread_Pool_Reactor_Resume_Test.h
new file mode 100644
index 00000000000..f3f18a5c712
--- /dev/null
+++ b/ACE/tests/Thread_Pool_Reactor_Resume_Test.h
@@ -0,0 +1,56 @@
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+// tests
+//
+// = FILENAME
+// Thread_Pool_Reactor_Test.h
+//
+// = DESCRIPTION
+// This class gets its own header file to work around AIX C++
+// compiler "features" related to template instantiation... It is
+// only used by Thread_Pool_Reactor_Test.cpp.
+//
+// = AUTHOR
+// Irfan Pyarali <irfan@cs.wustl.edu>
+// Nanbor Wang <nanbor@cs.wustl.edu>
+//
+// ============================================================================
+
+#ifndef ACE_TESTS_THREAD_POOL_REACTOR_RESUME_TEST_H
+#define ACE_TESTS_THREAD_POOL_REACTOR_RESUME_TEST_H
+
+#include "ace/SOCK_Stream.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ace/Svc_Handler.h"
+
+class Request_Handler : public ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_MT_SYNCH>
+{
+ // = TITLE
+ // This class is the Svc_Handler used by <Acceptor>.
+public:
+
+ /// The default constructor makes sure the right reactor is used.
+ Request_Handler (ACE_Thread_Manager *tm = 0);
+
+ /// Dtor..
+ ~Request_Handler (void);
+
+ virtual int open (void * = 0);
+
+protected:
+ virtual int handle_input (ACE_HANDLE fd = ACE_INVALID_HANDLE);
+ virtual int handle_close (ACE_HANDLE fd, ACE_Reactor_Mask = 0);
+ virtual int resume_handler (void);
+
+private:
+ size_t nr_msgs_rcvd_;
+};
+
+#endif /* ACE_TESTS_THREAD_POOL_REACTOR_RESUME_TEST_H */