summaryrefslogtreecommitdiff
path: root/tests/HTBP/Send_Large_Msg/client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/HTBP/Send_Large_Msg/client.cpp')
-rw-r--r--tests/HTBP/Send_Large_Msg/client.cpp98
1 files changed, 0 insertions, 98 deletions
diff --git a/tests/HTBP/Send_Large_Msg/client.cpp b/tests/HTBP/Send_Large_Msg/client.cpp
deleted file mode 100644
index 62cd9140da8..00000000000
--- a/tests/HTBP/Send_Large_Msg/client.cpp
+++ /dev/null
@@ -1,98 +0,0 @@
-// $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;
-}