summaryrefslogtreecommitdiff
path: root/tests/CLASSIX/CLASSIX_Stream_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/CLASSIX/CLASSIX_Stream_Test.cpp')
-rw-r--r--tests/CLASSIX/CLASSIX_Stream_Test.cpp111
1 files changed, 0 insertions, 111 deletions
diff --git a/tests/CLASSIX/CLASSIX_Stream_Test.cpp b/tests/CLASSIX/CLASSIX_Stream_Test.cpp
deleted file mode 100644
index 4956339f41c..00000000000
--- a/tests/CLASSIX/CLASSIX_Stream_Test.cpp
+++ /dev/null
@@ -1,111 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// tests
-//
-// = FILENAME
-// Stream_Test.cpp
-//
-// = DESCRIPTION
-// This is a test of the <IPP_CLASSIX_Addr> class.
-//
-// = AUTHOR
-// Wei Chiang
-//
-// ============================================================================
-
-#include "ace/CLASSIX/CLASSIX_Stream.h"
-
-#include "tests/test_config.h"
-
-#define RCV_DELAY 1000 /* We should NOT wait in ipcReceive */
-
-static char sndBody[] = "The sea is calm, the tide is full ...\n";
-static char rcvAnnex[K_CMSGANNEXSIZE];
-static char rcvBody[1000];
-
-int
-main (int, char *[])
-{
- ACE_START_TEST ("Stream_Test");
-
- /* ================================================================== */
- ACE_CLASSIX_Port_Core remote_port;
-
- // Sender's socket
- // Use my default port as the sending address
- ACE_CLASSIX_Stream send(remote_port);
-
- ACE_CLASSIX_Stream rcv(send.local_sap().get_addr(),
- ACE_CLASSIX_Port(remote_port));
- // make the rcv's port be one of the multiple receive ports
- if (rcv.selectable() < 0)
- ACE_DEBUG((LM_DEBUG, "failed to make the port selectable\n"));
-
- send.open_writer();
-
- ACE_DEBUG((LM_DEBUG, "send and block on receive....\n"));
- if (send.send_n(&sndBody[0], sizeof(sndBody)) == sizeof(sndBody))
- {
- // Receiver's Socket
- int rslt = rcv.ipcRecv(rcvBody, 1000);
- if (rslt == sizeof (sndBody))
- ACE_DEBUG((LM_DEBUG, "received %s\n", rcvBody));
- else
- ACE_DEBUG((LM_ERROR, "???? Error in ipcReceive():%d\n", rslt));
- }
- else
- {
- ACE_ERROR((LM_ERROR, "(%t)|%p\n", "???? Error in send_n()\n"));
- }
-
- ACE_DEBUG((LM_DEBUG, "send, peek then block on receive....\n"));
- if (send.send_n(&sndBody[0], sizeof(sndBody)) == sizeof(sndBody))
- {
- // Receiver's Socket
- // int rslt = rcv.recv(rcvBody, 1000, MSG_PEEK);
- // Equivalent to rcv.peek()
- int rslt = rcv.peek();
- if (rslt < 0)
- ACE_DEBUG((LM_ERROR, "???? Error while peeking :%d\n", rslt));
- else
- {
- char *buf = new char(rslt);
- if (int n = rcv.recv(buf, rslt) == rslt)
- ACE_DEBUG((LM_DEBUG, "received %s\n", buf));
- else
- ACE_DEBUG((LM_ERROR, "???? Error in ipcReceive(): %d\n", n));
- delete buf;
- }
- }
- else
- {
- ACE_DEBUG((LM_ERROR, "???? Error in send_n()\n"));
- }
-
- ACE_DEBUG((LM_DEBUG, "test recv_n()....\n"));
- if (send.send_n(&sndBody[0], sizeof(sndBody)) == sizeof(sndBody) &&
- send.send_n(&sndBody[0], sizeof(sndBody)) == sizeof(sndBody))
- {
- // Receiver's Socket
-
- int rslt = rcv.ipcRecv_n(rcvBody, 2*sizeof (sndBody) - 10);
- if (rslt == (2 * sizeof (sndBody) -10))
- {
- rcvBody[rslt] = '\0'; // For %s printout format
- ACE_DEBUG((LM_DEBUG, "received %d byte: %s + %s\n", rslt,
- rcvBody, rcvBody + sizeof(sndBody)));
- }
- else
- ACE_DEBUG((LM_ERROR, "???(%P|%t) %p\n", "ipcRecv_n()"));
- }
- else
- ACE_DEBUG((LM_ERROR, "???(%P|%t) %p\n", "ipcRecv_n()"));
-
- ACE_END_TEST;
- return 0;
-}
-