1 files changed, 98 insertions, 0 deletions
diff --git a/ACE/tests/HTBP/Send_Large_Msg/client.cpp b/ACE/tests/HTBP/Send_Large_Msg/client.cpp
new file mode 100644
index 00000000000..62cd9140da8
--- /dev/null
+++ b/ACE/tests/HTBP/Send_Large_Msg/client.cpp
@@ -0,0 +1,98 @@
+// $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;
+}