diff options
Diffstat (limited to 'tests/HTBP/ping/server.cpp')
-rw-r--r-- | tests/HTBP/ping/server.cpp | 124 |
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; -} |