summaryrefslogtreecommitdiff
path: root/tests/HTBP/ping/server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/HTBP/ping/server.cpp')
-rw-r--r--tests/HTBP/ping/server.cpp124
1 files changed, 0 insertions, 124 deletions
diff --git a/tests/HTBP/ping/server.cpp b/tests/HTBP/ping/server.cpp
deleted file mode 100644
index d20d46b8b09..00000000000
--- a/tests/HTBP/ping/server.cpp
+++ /dev/null
@@ -1,124 +0,0 @@
-/**
- * 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;
-}