summaryrefslogtreecommitdiff
path: root/examples/Reactor/Misc/test_signals_1.cpp
blob: efa036facc4ce3a262676b21936cd70464db4f55 (plain)
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
#include "ace/Service_Config.h"
#include "ace/Time_Value.h"

static void 
my_signal_function (int sig)
{
  ACE_DEBUG ((LM_DEBUG, "Executed non-ACE signal handler for sig %S\n", sig));
}

class My_Handler : public ACE_Event_Handler
{
public:
  virtual int handle_signal (int sig,
			     siginfo_t *,
			     ucontext_t *)
  {
    ACE_DEBUG ((LM_DEBUG, "Executed ACE signal handler for sig %S\n", sig));
    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 
main (int, char *argv[])
{
  // The following sets up a service configurator - mostly used to get
  // a reactor for the process.
  ACE_Service_Config my_config (argv[0]);

  // ----- First you need a handler for the timeout -----
  My_Handler my_handler;

  // ----- Now set up the timer -----

  // This is the timeout period in seconds.
  ACE_Time_Value period (2);

  if (my_config.reactor ()->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 (my_config.reactor ()->register_handler (SIGINT, &my_handler) == -1)
    ACE_ERROR_RETURN ((LM_DEBUG, "%p\n", "register_handler"), -1);

  // ----- Set up a non-ACE signal handler -----
  ACE_Sig_Action sig ((ACE_SignalHandler) my_signal_function, SIGQUIT);

  // This just executes the reactor events until my_handler tells us
  // we are finished.
  ACE_DEBUG ((LM_DEBUG, "starting event loop\n"));

  int result = my_config.run_reactor_event_loop ();

  ACE_DEBUG ((LM_DEBUG, "result = %d\n", result));
  return 0;
}