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
|
//=============================================================================
/**
* @file Console_Input.cpp
*
* $Id: Console_Input.cpp 93639 2011-03-24 13:32:13Z johnnyw $
*
*
* This application tests the working of WFMO_Reactor when users
* are interested in console input.
*
*
* @author Irfan Pyarali <irfan@cs.wustl.edu>
*/
//=============================================================================
#include "ace/Reactor.h"
#include "ace/OS_NS_unistd.h"
#include "ace/OS_NS_string.h"
#include "ace/OS_main.h"
#include "ace/Log_Msg.h"
class Event_Handler : public ACE_Event_Handler
{
public:
Event_Handler (ACE_Reactor &reactor);
int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0);
int handle_close (ACE_HANDLE handle,
ACE_Reactor_Mask close_mask);
};
Event_Handler::Event_Handler (ACE_Reactor &reactor)
{
this->reactor (&reactor);
if (this->reactor ()->register_handler (this,
ACE_STDIN) != 0)
ACE_ERROR ((LM_ERROR,
"Registration with Reactor could not be done\n"));
}
int
Event_Handler::handle_signal (int, siginfo_t *, ucontext_t *)
{
ACE_TCHAR buffer[BUFSIZ];
int result = ACE_OS::read (ACE_STDIN, buffer, sizeof buffer);
buffer[result] = '\0';
if (result <= 0)
{
this->reactor ()->close ();
ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "ACE_OS::read"), -1);
}
if (ACE_OS::strcmp (ACE_TEXT("quit\r\n"), buffer) == 0)
this->reactor ()->close ();
ACE_DEBUG ((LM_DEBUG, "User input: %s", buffer));
return 0;
}
int
Event_Handler::handle_close (ACE_HANDLE,
ACE_Reactor_Mask)
{
ACE_DEBUG ((LM_DEBUG, "Event_Handler removed from Reactor\n"));
return 0;
}
int
ACE_TMAIN (int, ACE_TCHAR *[])
{
ACE_Reactor reactor;
Event_Handler handler (reactor);
int result = 0;
while (result != -1)
result = reactor.handle_events ();
return 0;
}
|
