1 files changed, 124 insertions, 0 deletions
diff --git a/ACE/tests/HTBP/ping/server.cpp b/ACE/tests/HTBP/ping/server.cpp
new file mode 100644
index 00000000000..d20d46b8b09
--- /dev/null
+++ b/ACE/tests/HTBP/ping/server.cpp
@@ -0,0 +1,124 @@
+/**
+ * server 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/SOCK_Acceptor.h"
+#include "ace/SOCK_Stream.h"
+
+int
+ACE_TMAIN (int, ACE_TCHAR *[])
+{
+  char buffer[1000];
+  ssize_t n = 0;
+
+  ACE_OS::socket_init (ACE_WSOCK_VERSION);
+
+  ACE_INET_Addr local(8088);
+  ACE_SOCK_Stream sock[2];
+  ACE_SOCK_Acceptor acc(local,1);
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("server is ready\n")));
+
+  acc.accept (sock[0]);
+  ACE::HTBP::Channel channel1(sock[0]);
+  ACE_DEBUG ((LM_DEBUG,
+              ACE_TEXT ("Got sock[0], handle = %d\n"),
+              sock[0].get_handle()));
+  acc.accept (sock[1]);
+  ACE::HTBP::Channel channel2 (sock[1]);
+  ACE_DEBUG ((LM_DEBUG,
+              ACE_TEXT ("Got sock[1], handle = %d\n"),
+              sock[1].get_handle()));
+  int res = 0;
+  while ((res = channel1.pre_recv ()) != 0)
+    {
+      ACE_DEBUG ((LM_DEBUG,
+                  ACE_TEXT ("res = %d. waiting 1 sec. %p\n"),
+                  res,
+                  ACE_TEXT ("stream.pre_recv()")));
+      ACE_OS::sleep (1);
+    }
+
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Read from channel2\n")));
+  while ((res = channel2.pre_recv()) != 0)
+    {
+      ACE_DEBUG ((LM_DEBUG,
+                  ACE_TEXT ("res = %d, waiting 1 sec. %p\n"),
+                  res,
+                  ACE_TEXT ("stream2.pre_recv()")));
+      ACE_OS::sleep (1);
+    }
+
+  ACE::HTBP::Session *session = channel1.session();
+  ACE::HTBP::Stream stream (session);
+
+  ACE_DEBUG ((LM_DEBUG,
+              ACE_TEXT ("using streams %d, %d. Got sesssion = %@\n"),
+              sock[0].get_handle(),
+              sock[1].get_handle(),
+              session));
+
+  for (int i = 0; i >= 0; i++)
+    {
+      int retrycount = 10;
+      while ((n = stream.recv(buffer,1000)) == -1
+             && (errno == EWOULDBLOCK || errno == ETIME)
+             && retrycount > 0)
+        {
+          retrycount--;
+          ACE_DEBUG ((LM_DEBUG,
+                      ACE_TEXT ("waiting for inbound data, %d tries left\n"),
+                      retrycount));
+          ACE_OS::sleep(1);
+        }
+      if (retrycount == 0 || n < 0)
+        break;
+
+      buffer[n] = 0;
+
+      ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Got: \"%C\"\n"), buffer));
+
+      if (ACE_OS::strstr (buffer,"goodbye") != 0)
+        break;
+
+      ACE_OS::sprintf (buffer,"I hear you %d",i);
+      n = stream.send (buffer,ACE_OS::strlen(buffer)+1);
+      if (n == -1)
+        ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
+                           ACE_TEXT ("stream.send")),
+                          -1);
+
+      ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Send returned %d\n"), n));
+
+      int got[2] = {-1,-1};
+      while (got[0] == -1 || got[1] == -1)
+        {
+          if (got[0] == -1)
+            {
+              if ((got[0] = (res =channel1.pre_recv())) == -1)
+                ACE_DEBUG ((LM_DEBUG,
+                            ACE_TEXT ("res = %d, waiting 1 sec. %p\n"),
+                            got[0],
+                            ACE_TEXT ("channel1.pre_recv()")));
+            }
+          if (got[1] == -1)
+            {
+              if ((got[1] = (res =channel2.pre_recv())) == -1)
+                ACE_DEBUG ((LM_DEBUG,
+                            ACE_TEXT ("res = %d, waiting 1 sec. %p\n"),
+                            got[1],
+                            ACE_TEXT ("channel2.pre_recv()")));
+            }
+          if (got[0] == -1 || got[1] == -1)
+            ACE_OS::sleep (1);
+        }
+    }
+  return 0;
+}