summaryrefslogtreecommitdiff
path: root/examples/Reactor/TP_Reactor/server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/Reactor/TP_Reactor/server.cpp')
-rw-r--r--examples/Reactor/TP_Reactor/server.cpp66
1 files changed, 0 insertions, 66 deletions
diff --git a/examples/Reactor/TP_Reactor/server.cpp b/examples/Reactor/TP_Reactor/server.cpp
deleted file mode 100644
index 0c147818424..00000000000
--- a/examples/Reactor/TP_Reactor/server.cpp
+++ /dev/null
@@ -1,66 +0,0 @@
-/*
- * ACE reactor demonstration
- *
- * $Id$
- * Date: 26-Jan-2006
- */
-
-#include <ace/Event_Handler.h>
-#include <ace/Log_Msg.h>
-#include <ace/OS.h>
-#include <ace/Reactor.h>
-#include <ace/Signal.h>
-#include <ace/streams.h>
-#include <ace/Thread_Manager.h>
-#include <ace/TP_Reactor.h>
-
-#include "AcceptHandler.h"
-
-/**
- * This is the function run by all threads in the thread pool.
- *
- * @param arg is expected to be of type (ACE_Reactor *)
- */
-ACE_THR_FUNC_RETURN threadFunc(void *arg) {
- ACE_TRACE("threadFunc(void *)");
-
- ACE_Reactor *reactor = (ACE_Reactor *) arg;
- reactor->run_reactor_event_loop();
-
- return 0;
-}
-
-/**
- * The main function sets up the TP reactor. The code is basically taken from
- * the solution to exercise 4c of the ACE course.
- */
-int ACE_TMAIN(int, ACE_TCHAR **) {
-
- // create a reactor from a TP reactor
- ACE_TP_Reactor tpReactor;
- ACE_Reactor reactor(&tpReactor);
-
- // create a new accept handler using that reactor
- AcceptHandler *acceptHandler = 0;
- ACE_NEW_NORETURN (acceptHandler, AcceptHandler(&reactor));
- if (acceptHandler == 0)
- ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("%N:%l: Failed to allocate ")
- ACE_TEXT ("accept handler. (errno = %i: %m)\n"), errno), -1);
-
- // open the accept handler
- if (acceptHandler->open() == -1) {
- delete acceptHandler;
- ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("%N:%l: Failed to open accept ")
- ACE_TEXT ("handler. Exiting.\n")), -1);
- }
-
- // spawn some threads which run the reactor event loop(s)
- ACE_Thread_Manager::instance()->spawn_n(9, threadFunc, &reactor);
-
- // let the thread manager wait for all threads
- ACE_Thread_Manager::instance()->wait();
-
- ACE_DEBUG((LM_DEBUG, ACE_TEXT("Bye. Bye.\n")));
- return 0;
-}
-