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
115
116
117
|
// This is a simple example of using the ACE_IOStream and
// ACE_Streambuf_T templates to create an object based on ACE_*_Stream
// classes, which mimic a C++ iostream.
#include "ace/Acceptor.h"
#include "ace/SOCK_Acceptor.h"
#include "ace/Service_Config.h"
#include "ace/Signal.h"
#include "ace/Sig_Adapter.h"
#include "iostream_server.h"
#include "ace/OS_NS_unistd.h"
#if !defined (ACE_LACKS_ACE_IOSTREAM)
int
Handler::open (void *)
{
if (this->reactor ()->register_handler (this,
ACE_Event_Handler::READ_MASK) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"registering connection handler with ACE_Reactor\n"),
-1);
return 0;
}
Handler::Handler (void)
{
ACE_DEBUG ((LM_DEBUG, "(%P) starting handler %x\n", this));
}
Handler::~Handler (void)
{
ACE_DEBUG ((LM_DEBUG, "(%P) shutting down handler %x\n", this));
ACE_Reactor::end_event_loop ();
}
int
Handler::handle_input (ACE_HANDLE)
{
int i;
float f;
// Check to see if the socket is closed down.
if (this->peer ().eof ())
ACE_ERROR_RETURN ((LM_ERROR, "(%P) connection closed\n"), -1);
ACE_IOStream_String s;
if (!(this->peer () >> i >> f >> s))
ACE_ERROR_RETURN ((LM_ERROR, "(%P) %p\n", "error getting data"), -1);
cerr << "(" << ACE_OS::getpid () << ") Client sent:\n\t";
cerr << "(" << i << ") (" << f << ") (" << s << ")" << endl ;
if (!(this->peer () << "Received: " << i << " " << f << " " << s << endl))
ACE_ERROR_RETURN ((LM_ERROR, "(%P) %p\n", "error sending data"), -1);
// In order to flush the output to the peer, we have to use the sync
// () function. Some iostreams implementations let us use a 'flush'
// function much like the 'endl' function.
// this->peer ().sync ();
return 0;
}
// Create a factory object that will accept new connection requests
// and create handler objects for us.
typedef ACE_Acceptor<Handler, ACE_SOCK_ACCEPTOR> IOStream_Acceptor;
#endif /* !ACE_LACKS_ACE_IOSTREAM */
int
ACE_TMAIN (int argc, ACE_TCHAR *argv [])
{
#if !defined (ACE_LACKS_ACE_IOSTREAM)
ACE_Service_Config daemon;
// Create an adapter to end the event loop.
ACE_Sig_Adapter sa ((ACE_Sig_Handler_Ex) ACE_Reactor::end_event_loop);
ACE_Sig_Set sig_set;
sig_set.sig_add (SIGINT);
sig_set.sig_add (SIGQUIT);
// Register ourselves to receive SIGINT and SIGQUIT so we can shut
// down gracefully via signals.
if (ACE_Reactor::instance ()->register_handler (sig_set,
&sa) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "%p\n"), -1);
IOStream_Acceptor peer_acceptor;
ACE_INET_Addr addr (argc > 1 ? ACE_OS::atoi (argv[1]) : ACE_DEFAULT_SERVER_PORT);
if (peer_acceptor.open (addr) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"%p\n",
"open"),
-1);
ACE_DEBUG ((LM_DEBUG,
"(%P) starting up daemon\n"));
ACE_Reactor::run_event_loop ();
ACE_DEBUG ((LM_DEBUG,
"(%P) shutting down server daemon\n"));
#else
ACE_UNUSED_ARG (argc);
ACE_UNUSED_ARG (argv);
ACE_ERROR ((LM_ERROR, "ACE_IOSTREAM not supported on this platform\n"));
#endif /* !ACE_LACKS_ACE_IOSTREAM */
return 0;
}
|
