diff options
Diffstat (limited to 'tests/HTBP/Send_Large_Msg/client.cpp')
-rw-r--r-- | tests/HTBP/Send_Large_Msg/client.cpp | 98 |
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; -} |