summaryrefslogtreecommitdiff
path: root/tests/HTBP/Send_Large_Msg/server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/HTBP/Send_Large_Msg/server.cpp')
-rw-r--r--tests/HTBP/Send_Large_Msg/server.cpp103
1 files changed, 0 insertions, 103 deletions
diff --git a/tests/HTBP/Send_Large_Msg/server.cpp b/tests/HTBP/Send_Large_Msg/server.cpp
deleted file mode 100644
index 7b7f51cf1b9..00000000000
--- a/tests/HTBP/Send_Large_Msg/server.cpp
+++ /dev/null
@@ -1,103 +0,0 @@
-// $Id$
-
-#include "tests/test_config.h"
-
-#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"
-
-const size_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_UNUSED_ARG (argc);
- ACE_UNUSED_ARG (argv);
-
- char buffer[1000];
-
- 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 = %x\n"),
- sock[0].get_handle(),sock[1].get_handle(),session));
-
- ssize_t got = 1;
- ssize_t total_recv = 0;
-
- while (got != 0)
- {
- errno = 0;
- got = stream.recv (buffer, sizeof (buffer));
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT("got : %s %d "), buffer, got));
-
- if (got < 0)
- break;
- total_recv += got;
- }
-
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT("received %d, %s\n"),total_recv,buffer));
-
-
- ACE_OS::strcpy (buffer,"I hear you !");
- ssize_t 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));
- return 0;
-
-}