diff options
Diffstat (limited to 'ACE/tests/HTBP/ping/client.cpp')
-rw-r--r-- | ACE/tests/HTBP/ping/client.cpp | 130 |
1 files changed, 130 insertions, 0 deletions
diff --git a/ACE/tests/HTBP/ping/client.cpp b/ACE/tests/HTBP/ping/client.cpp new file mode 100644 index 00000000000..e7753faab6d --- /dev/null +++ b/ACE/tests/HTBP/ping/client.cpp @@ -0,0 +1,130 @@ +/** + * 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; +} |