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
|
// $Id$
#include "tests/test_config.h"
#include "ace/HTBP/HTBP_Session.h"
#include "ace/HTBP/HTBP_Stream.h"
#include "ace/HTBP/HTBP_Addr.h"
#include "ace/HTBP/HTBP_ID_Requestor.h"
#include "ace/HTBP/HTBP_Environment.h"
#include "ace/Log_Msg.h"
const ssize_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_START_TEST (ACE_TEXT ("HTBP_Send_Large_Msg_client"));
ACE_OS::socket_init (ACE_WSOCK_VERSION);
if (argc < 2)
ACE_ERROR_RETURN ((LM_ERROR,
"Usage: client <remote host>\n"),
0);
ACE::HTBP::Environment env;
#if 0 // this should be a taken from a command line argument
env.import_config (ACE_TEXT("../HTBP_Config.conf"));
#endif /* 0 */
ACE::HTBP::ID_Requestor req (&env);
ACE::HTBP::Addr local(ACE_TEXT_ALWAYS_CHAR(req.get_HTID()));
unsigned remote_port = 8088;
const ACE_TCHAR * remote_host = argv[1];
unsigned proxy_port = 0;
ACE_TString proxy_host;
if (env.get_proxy_port(proxy_port) != 0 ||
env.get_proxy_host(proxy_host) != 0)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("no proxy address in ")
ACE_TEXT("config, using direct connect\n")));
proxy_port = remote_port;
proxy_host = remote_host;
}
ACE_INET_Addr proxy(proxy_port,proxy_host.c_str());
ACE::HTBP::Addr remote (remote_port,ACE_TEXT_ALWAYS_CHAR(remote_host));
ACE::HTBP::Session session(remote,
local,
ACE::HTBP::Session::next_session_id(),
&proxy);
ACE::HTBP::Stream *stream = new ACE::HTBP::Stream(&session);
ACE_DEBUG ((LM_DEBUG,ACE_TEXT("Sending message\n")));
char buffer[Send_Size];
ACE_OS::memset (buffer,'a',Send_Size);
ssize_t n = 0;
for (size_t i = 0; i < Loops ; ++i)
{
errno = 0;
while (n < Send_Size)
{
n += stream->send (buffer+n,Send_Size);
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT("Sending %d of %d\n"), n, Send_Size));
}
if (n == -1 && errno != 0)
{
ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT("%p\n %d"),
ACE_TEXT("stream send"), errno), -1);
}
ACE_DEBUG ((LM_DEBUG, ACE_TEXT("In round %d, send returned %d\n"), i, n));
}
buffer[0] = 0;
n = stream->recv (buffer,1000);
while (n == -1)
{
if (errno == EWOULDBLOCK)
n = stream->recv (buffer,1000);
else
ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT("%p\n"),
ACE_TEXT("stream.recv")),-1);
}
ACE_DEBUG ((LM_DEBUG, ACE_TEXT("received %d, %s\n"),n,buffer));
ACE_END_TEST;
return 0;
}
|
