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