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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
// $Id: test_signals_1.cpp 91671 2010-09-08 18:39:23Z johnnyw $
// This simple program illustrates the difference between handling
// signals via the Reactor (which doesn't cause the event loop to
// terminate) and signals that aren't handled via the Reactor (which
// do).
#include "ace/Service_Config.h"
#include "ace/Reactor.h"
#include "ace/Log_Msg.h"
#include "ace/Signal.h"
// Number of times to allow signal to execute until we quit.
static size_t signal_count = 10;
static void
my_signal_function (int sig)
{
ACE_DEBUG ((LM_DEBUG,
"Executed non-ACE signal handler for signal %S\n",
sig));
}
class My_Handler : public ACE_Event_Handler
{
public:
virtual int handle_signal (int sig,
siginfo_t *,
ucontext_t *)
{
// @@ Note that this code is not portable to all OS platforms
// since it uses print statements within signal handler context.
ACE_DEBUG ((LM_DEBUG,
"Executed ACE signal handler for signal %S, count = %d\n",
sig,
signal_count));
--signal_count;
if (signal_count == 0)
ACE_Reactor::end_event_loop ();
return 0;
}
virtual int handle_timeout (const ACE_Time_Value &,
const void *arg)
{
ACE_DEBUG ((LM_DEBUG,
"%s\n",
(const char *) arg));
return 0;
}
};
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
// First you need a handler for the timeout.
My_Handler my_handler;
// This is the timeout period in seconds.
ACE_Time_Value period (ACE_DEFAULT_TIMEOUT);
if (argc > 1)
period.set (ACE_OS::atoi (argv[1]), 0);
// Set up the periodic interval timer.
if (ACE_Reactor::instance ()->schedule_timer
(&my_handler,
"hello",
period,
period) == -1)
ACE_ERROR_RETURN ((LM_DEBUG,
"%p\n",
"schedule_timer"),
-1);
// Set up an ACE signal handler.
if (ACE_Reactor::instance ()->register_handler
(SIGINT,
&my_handler) == -1)
ACE_ERROR_RETURN ((LM_DEBUG,
"%p\n",
"register_handler"),
-1);
// Set up a non-ACE signal handler. When this goes off, the Reactor
// should return from its <run_event_loop> method.
ACE_Sig_Action sig ((ACE_SignalHandler) my_signal_function,
SIGQUIT);
ACE_UNUSED_ARG (sig);
ACE_DEBUG ((LM_DEBUG,
"starting event loop that runs until you've typed ^C a total of 10 times or ^\\ once.\n"));
// This call executes the reactor events until we're finished.
int result = ACE_Reactor::run_event_loop ();
ACE_DEBUG ((LM_DEBUG,
"result = %d\n",
result));
// Make sure to remove my_handler before exiting main() since
// otherwise weird things can happen...
if (ACE_Reactor::instance ()->cancel_timer (&my_handler) == -1)
ACE_ERROR_RETURN ((LM_DEBUG,
"%p\n",
"cancel_timer"),
-1);
return 0;
}
|
