1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
/*
* ACE reactor demonstration
*
* $Id: server.cpp 91730 2010-09-13 09:31:11Z johnnyw $
* Date: 26-Jan-2006
*/
#include <ace/Event_Handler.h>
#include <ace/Log_Msg.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"), ACE_ERRNO_GET), -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;
}
|
