summaryrefslogtreecommitdiff
path: root/tests/HTBP/ping/client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/HTBP/ping/client.cpp')
-rw-r--r--tests/HTBP/ping/client.cpp130
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;
-}