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
|
// $Id$
#include "tests/test_config.h"
#include "ace/Log_Msg.h"
#include "ace/HTBP/HTBP_Session.h"
#include "ace/HTBP/HTBP_Stream.h"
#include "ace/HTBP/HTBP_Addr.h"
#include "ace/SOCK_Acceptor.h"
#include "ace/SOCK_Stream.h"
const size_t Send_Size = 4*1024;
const size_t Loops = 10;
const size_t Total_Size = Send_Size * Loops;
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
ACE_UNUSED_ARG (argc);
ACE_UNUSED_ARG (argv);
char buffer[1000];
ACE_OS::socket_init (ACE_WSOCK_VERSION);
ACE_INET_Addr local(8088);
ACE_SOCK_Stream sock[2];
ACE_SOCK_Acceptor acc(local,1);
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("server is ready\n")));
acc.accept(sock[0]);
ACE::HTBP::Channel channel1(sock[0]);
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("Got sock[0], handle = %d\n"),
sock[0].get_handle()));
acc.accept(sock[1]);
ACE::HTBP::Channel channel2(sock[1]);
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("Got sock[1], handle = %d\n"),
sock[1].get_handle()));
int res = 0;
while ((res =channel1.pre_recv()) != 0)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("res = %d. waiting 1 sec. %p\n"),
res,
ACE_TEXT("stream.pre_recv()")));
ACE_OS::sleep (1);
}
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("Read from channel2\n")));
while ((res = channel2.pre_recv()) != 0)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("res = %d, waiting 1 sec. %p\n"),
res,
ACE_TEXT("stream2.pre_recv()")));
ACE_OS::sleep (1);
}
ACE::HTBP::Session *session = channel1.session();
ACE::HTBP::Stream stream (session);
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("using streams %d, %d. Got sesssion = %x\n"),
sock[0].get_handle(),sock[1].get_handle(),session));
ssize_t got = 1;
ssize_t total_recv = 0;
while (got != 0)
{
errno = 0;
got = stream.recv (buffer, sizeof (buffer));
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("got : %s %d "), buffer, got));
if (got < 0)
break;
total_recv += got;
}
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("received %d, %s\n"),total_recv,buffer));
ACE_OS::strcpy (buffer,"I hear you !");
ssize_t n = stream.send (buffer,ACE_OS::strlen(buffer)+1);
if (n == -1)
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT("%p\n"),
ACE_TEXT("stream.send")),-1);
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("send returned %d\n"),n));
return 0;
}
|
