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
|
// Exercise the ACE_SOCK_Dgram wrapper along with the ACE_Reactor.
// @(#)Dgram.cpp 1.1 10/18/96
// Typical invocation sequence is:
//
// % Dgram 10000 localhost 10001 &
// % Dgram 10001 localhost 10000
//
// This will start two interacting copies of the Dgram
// application.
#include "ace/Reactor.h"
#include "ace/SOCK_Dgram.h"
#include "ace/INET_Addr.h"
class AAL_CP : public ACE_Event_Handler, public ACE_SOCK_Dgram
{
public:
AAL_CP (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 &local_addr)
: ACE_SOCK_Dgram (local_addr)
{
}
ACE_HANDLE
AAL_CP::get_handle (void) const
{
return ACE_SOCK_Dgram::get_handle ();
}
int
AAL_CP::handle_input (ACE_HANDLE)
{
char buf[BUFSIZ];
int n;
ACE_INET_Addr from_addr;
ACE_DEBUG ((LM_DEBUG, "Activity occurred on handle %d!\n",
ACE_SOCK_Dgram::get_handle ()));
if ((n = ACE_SOCK_Dgram::recv (buf, sizeof buf, from_addr)) == -1)
ACE_ERROR ((LM_ERROR, "%p\n", "handle_input"));
else
ACE_DEBUG ((LM_DEBUG, "got buf = %s\n", buf));
return 0;
}
int
AAL_CP::handle_timeout (const ACE_Time_Value &, const void *)
{
ACE_DEBUG ((LM_DEBUG, "timed out for aa1\n"));
return 0;
}
int
main (int argc, char *argv[])
{
// Estabish call backs, and socket names.
if (argc != 4)
ACE_ERROR_RETURN ((LM_ERROR,
"usage: %s localport remotehost remoteport\n",
argv[0]), -1);
ACE_Reactor reactor;
char buf[128];
u_short localport = ACE_OS::atoi (argv[1]);
u_short remoteport = ACE_OS::atoi (argv[3]);
char *remotehost = argv[2];
ACE_INET_Addr remote_addr (remoteport, remotehost);
ACE_INET_Addr local_addr (localport);
AAL_CP aal (local_addr);
if (localport == 10000) // HACK
{
ACE_OS::memcpy (buf, "Data to transmit", sizeof buf);
ACE_DEBUG ((LM_DEBUG, "sending data\n"));
for (size_t i = 0; i < 20; i++)
{
aal.send (buf, sizeof buf, remote_addr);
ACE_DEBUG ((LM_DEBUG, ".\n"));
ACE_OS::sleep (1);
}
}
// Read data from other side.
if (reactor.register_handler (&aal, ACE_Event_Handler::READ_MASK) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "ACE_Reactor::register_handler"), -1);
if (reactor.schedule_timer (&aal, 0,
ACE_Time_Value (1, 0),
ACE_Time_Value (0, 3500000)) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "ACE_Reactor::schedule_timer"), -1);
ACE_OS::memcpy (buf, "Data to transmit", sizeof buf);
for (;;)
{
// Wait at most two seconds.
ACE_Time_Value tv (2, 0);
reactor.handle_events (tv);
ACE_DEBUG ((LM_DEBUG, "return from handle events\n"));
aal.send (buf, sizeof buf, remote_addr);
ACE_DEBUG ((LM_DEBUG, ".\n"));
}
return 0;
}
|
