diff options
Diffstat (limited to 'tests/HTBP/ping/client.cpp')
-rw-r--r-- | tests/HTBP/ping/client.cpp | 130 |
1 files changed, 0 insertions, 130 deletions
diff --git a/tests/HTBP/ping/client.cpp b/tests/HTBP/ping/client.cpp deleted file mode 100644 index e7753faab6d..00000000000 --- a/tests/HTBP/ping/client.cpp +++ /dev/null @@ -1,130 +0,0 @@ -/** - * client for a basic connection establishment test using HTBP - * - * $Id$ - */ - - -#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/HTBP/HTBP_ID_Requestor.h" -#include "ace/HTBP/HTBP_Environment.h" - -int -ACE_TMAIN(int argc, ACE_TCHAR *argv[]) -{ - - 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 (&session); - - char buffer[1000]; - ssize_t n = 0; - int retrycount = 10; - for (int i = 0; i < 3; i++) - { - ACE_OS::sprintf (buffer,"Do you hear me? %d",i); - ACE::HTBP::Channel *ob = session.outbound(); - n = stream.send (buffer,ACE_OS::strlen(buffer)+1); - if (n == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n","stream send"),-1); - - ACE_DEBUG ((LM_DEBUG, "send returned %d\n",n)); - - retrycount = 10; - ACE_DEBUG ((LM_DEBUG,"after send, outbound = %x, ob = %x\n", - session.outbound(), ob)); - while ((n = ob->recv_ack()) == -1 - && (errno == EWOULDBLOCK || errno == ETIME) - && retrycount > 0) - { - retrycount--; - ACE_DEBUG ((LM_DEBUG,"waiting for ack, %d tries left\n", - retrycount)); - ACE_OS::sleep (1); - } - ACE_DEBUG ((LM_DEBUG,"After wait for ack, n = %d, retry = %d\n", - n,retrycount,errno)); - - retrycount = 10; - while ((n = stream.recv(buffer,1000)) == -1 - && (errno == EWOULDBLOCK || errno == ETIME) - && retrycount > 0) - { - retrycount--; - ACE_DEBUG ((LM_DEBUG,"waiting for inbound data, %d tries left\n", - retrycount)); - ACE_OS::sleep(1); - } - if (retrycount == 0 || n < 0) - { - ACE_DEBUG ((LM_DEBUG,"bailing after wait, %p\n","recv")); - break; - } - - buffer[n] = 0; - - ACE_DEBUG ((LM_DEBUG,"Got: \"%s\"\n",buffer)); - } - - ACE::HTBP::Channel *ob = session.outbound(); - n = stream.send ("goodbye",7); - if (n == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n","stream send"),-1); - - ACE_DEBUG ((LM_DEBUG, "send returned %d\n",n)); - - retrycount = 10; - while ((n = ob->recv_ack()) == -1 - && (errno == EWOULDBLOCK || errno == ETIME) - && retrycount > 0) - { - retrycount--; - ACE_DEBUG ((LM_DEBUG,"waiting for ack, %d tries left\n", - retrycount)); - ACE_OS::sleep (1); - } - ACE_DEBUG ((LM_DEBUG,"After wait for ack, n = %d, retry = %d\n", - n,retrycount,errno)); - - return 0; -} |