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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
// $Id$
// Exercise the ACE_SOCK_CODgram wrapper along with the ACE_Reactor.
// This test simply ping-pongs datagrams back and forth between the
// parent and child process.
#include "ace/Reactor.h"
#include "ace/SOCK_CODgram.h"
#include "ace/INET_Addr.h"
static u_short port1;
class AAL_CP : public ACE_Event_Handler, public ACE_SOCK_CODgram
{
public:
AAL_CP (const ACE_INET_Addr &remote_addr,
const ACE_INET_Addr &local_addr);
virtual ACE_HANDLE get_handle (void) const;
virtual int handle_input (ACE_HANDLE handle);
virtual int handle_timeout (const ACE_Time_Value & tv,
const void *arg = 0);
};
AAL_CP::AAL_CP (const ACE_INET_Addr &remote_addr,
const ACE_INET_Addr &local_addr)
: ACE_SOCK_CODgram (remote_addr, local_addr)
{
}
ACE_HANDLE
AAL_CP::get_handle (void) const
{
return ACE_SOCK_CODgram::get_handle ();
}
int
AAL_CP::handle_input (ACE_HANDLE)
{
char buf[BUFSIZ];
ACE_DEBUG ((LM_DEBUG, "(%P|%t) activity occurred on handle %d!\n",
ACE_SOCK_CODgram::get_handle ()));
ssize_t n = ACE_SOCK_CODgram::recv (buf, sizeof buf);
if (n == -1)
ACE_ERROR ((LM_ERROR, "%p\n", "handle_input"));
else
ACE_DEBUG ((LM_DEBUG, "(%P|%t) buf of size %d = %*s\n", n, n, buf));
return 0;
}
int
AAL_CP::handle_timeout (const ACE_Time_Value &, const void *)
{
ACE_DEBUG ((LM_DEBUG, "(%P|%t) timed out for aa1\n"));
return 0;
}
static int
run_test (u_short localport,
const char *remotehost,
u_short remoteport)
{
ACE_INET_Addr remote_addr (remoteport,
remotehost);
ACE_INET_Addr local_addr (localport);
AAL_CP aal (remote_addr, local_addr);
// Read data from other side.
if (ACE_Reactor::instance ()->register_handler
(&aal, ACE_Event_Handler::READ_MASK) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"ACE_Reactor::register_handler"),
-1);
char buf[BUFSIZ];
ACE_OS::strcpy (buf, "Data to transmit");
size_t len = ACE_OS::strlen (buf);
if (localport == port1)
{
ACE_DEBUG ((LM_DEBUG, "(%P|%t) sending data\n"));
for (size_t i = 0; i < 20; i++)
{
aal.send (buf, len);
ACE_DEBUG ((LM_DEBUG, "(%P|%t) .\n"));
ACE_OS::sleep (1);
}
}
for (int i = 0; i < 40; i++)
{
// Wait up to 4 seconds for data.
ACE_Time_Value tv (4, 0);
if (ACE_Reactor::instance ()->handle_events (tv) <= 0)
ACE_ERROR_RETURN ((LM_DEBUG,
"(%P|%t) %p\n",
"handle_events"),
-1);
ACE_DEBUG ((LM_DEBUG,
"(%P|%t) return from handle events\n"));
aal.send (buf, len);
ACE_DEBUG ((LM_DEBUG,
"(%P|%t) .\n"));
}
if (ACE_Reactor::instance ()->remove_handler
(&aal, ACE_Event_Handler::READ_MASK) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"ACE_Reactor::remove_handler"),
-1);
ACE_DEBUG ((LM_DEBUG, "(%P|%t) exiting\n"));
return 0;
}
int
main (int argc, char *argv[])
{
// Estabish call backs and socket names.
port1 = argc > 1 ? ACE_OS::atoi (argv[1]) : ACE_DEFAULT_SERVER_PORT;
const char *remotehost = argc > 2 ? argv[2] : ACE_DEFAULT_SERVER_HOST;
const u_short port2 = argc > 3 ? ACE_OS::atoi (argv[3]) : port1 + 1;
ACE_DEBUG ((LM_DEBUG,
"(%P|%t) local port = %d, remote host = %s, remote port = %d\n",
port1, remotehost, port2));
switch (ACE_OS::fork (argv[0]))
{
case -1:
return -1;
case 0:
run_test (port1, remotehost, port2);
break;
default:
run_test (port2, remotehost, port1);
break;
}
return 0;
}
|
