Repo restructuring

1 files changed, 186 insertions, 0 deletions

diff --git a/ACE/tests/UPIPE_SAP_Test.cpp b/ACE/tests/UPIPE_SAP_Test.cpp
new file mode 100644
index 00000000000..24d08fdc5f7
--- /dev/null
+++ b/ACE/tests/UPIPE_SAP_Test.cpp
@@ -0,0 +1,186 @@
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    tests
+//
+// = FILENAME
+//    UPIPE_SAP_Test.cpp
+//
+// = DESCRIPTION
+//      This is a test that uses <ACE_UPIPE_SAP> and <ACE_Thread> for
+//      intra-process communication.
+//
+// = AUTHOR
+//    Gerhard Lenzer <Gerhard.Lenzer@med.siemens.de>,
+//    Douglas C. Schmidt <schmidt@cs.wustl.edu>, and
+//    Prashant Jain <pjain@cs.wustl.edu>
+//
+// ============================================================================
+
+#include "test_config.h"
+#include "ace/Stream.h"
+#include "ace/UPIPE_Acceptor.h"
+#include "ace/UPIPE_Connector.h"
+#include "ace/OS_NS_unistd.h"
+
+ACE_RCSID(tests, UPIPE_SAP_Test, "$Id$")
+
+#if defined (ACE_HAS_THREADS) && (defined (ACE_HAS_STREAM_PIPES) || \
+        (defined (ACE_WIN32) && \
+         defined (ACE_HAS_WINNT4) && (ACE_HAS_WINNT4 != 0)))
+
+// Global pattern
+static ACE_UPIPE_Addr addr (ACE_TEXT ("pattern"));
+
+// connector thread.
+
+static void *
+connector (void *)
+{
+  ACE_UPIPE_Stream c_stream;
+
+  ACE_OS::sleep (5);
+
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) connector starting connect\n")));
+  ACE_UPIPE_Connector con;
+
+  if (con.connect (c_stream, addr) == -1)
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) connector ACE_UPIPE_Connector failed\n")));
+
+  ACE_Message_Block *mb;
+
+  ACE_NEW_RETURN (mb, ACE_Message_Block (sizeof ("hello thanks") * sizeof (char)), 0);
+
+  mb->copy ("hello");
+
+  if (c_stream.send (mb) == -1)
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) error connector send\n")));
+
+  if (c_stream.recv (mb) == -1)
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) error connector recv\n")));
+
+  ACE_ASSERT (ACE_OS::strcmp (mb->rd_ptr (), "thanks") == 0);
+
+  // Free up the memory block.
+  mb->release ();
+
+  // Now try the send()/recv() interface.
+  char mytext[] = "This string is sent by connector as a buffer";
+
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) connector sending text\n")));
+  if (c_stream.send (mytext, sizeof (mytext)) == -1)
+    ACE_DEBUG ((LM_DEBUG,
+                ACE_TEXT ("(%t) buffer send from connector failed\n")));
+
+  char conbuf[BUFSIZ];  // Buffer to receive response.
+
+  int i = 0;
+
+  for (char c = ' '; c != '!'; i++)
+    {
+      if (c_stream.recv (&c, 1) == -1)
+        ACE_DEBUG ((LM_DEBUG,
+                    ACE_TEXT ("(%t) buffer recv from connector failed\n")));
+      else
+        conbuf[i] = c;
+    }
+
+  conbuf[i] = '\0';
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) conbuf = %s\n"), conbuf));
+  ACE_ASSERT (ACE_OS::strcmp (conbuf, "this is the acceptor response!") == 0);
+
+  c_stream.close ();
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) exiting thread\n")));
+  return 0;
+}
+
+static void *
+acceptor (void *args)
+{
+  ACE_UPIPE_Acceptor *acceptor = (ACE_UPIPE_Acceptor *) args;
+  ACE_UPIPE_Stream s_stream;
+
+  if (acceptor->accept (s_stream) == -1)
+    ACE_DEBUG ((LM_DEBUG,
+                ACE_TEXT ("(%t) ACE_UPIPE_Acceptor.accept failed\n")));
+
+  ACE_Message_Block *mb = 0;
+
+  if (s_stream.recv (mb) == -1)
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) acceptor recv failed\n")));
+
+  ACE_ASSERT (ACE_OS::strcmp (mb->rd_ptr (), "hello") == 0);
+
+  mb->wr_ptr (mb->rd_ptr ());
+  mb->copy ("thanks");
+
+  if (s_stream.send (mb) == -1)
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) acceptor send failed\n")));
+
+  char s_buf[BUFSIZ];
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) acceptor sleeping on recv\n")));
+
+  if (s_stream.recv (s_buf, sizeof (s_buf)) == -1)
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) acceptor recv failed\n")));
+  else
+    ACE_ASSERT (ACE_OS::strcmp (s_buf,
+                                "This string is sent by connector as a buffer") == 0);
+
+  const char svr_response[] = "this is the acceptor response!";
+  ACE_OS::strcpy (s_buf, svr_response);
+
+  if (s_stream.send (s_buf, sizeof (svr_response)) == -1)
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) acceptor send failed\n")));
+
+  s_stream.close ();
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) exiting thread\n")));
+  return 0;
+}
+#endif /* ACE_HAS_THREADS && defined ACE_HAS_STREAM_PIPES || (ACE_WIN32&&NT4)*/
+
+int
+run_main (int, ACE_TCHAR *[])
+{
+  ACE_START_TEST (ACE_TEXT ("UPIPE_SAP_Test"));
+
+#if defined (ACE_HAS_THREADS) && (defined (ACE_HAS_STREAM_PIPES) || \
+        (defined (ACE_WIN32) && \
+         defined (ACE_HAS_WINNT4) && (ACE_HAS_WINNT4 != 0)))
+
+  ACE_UPIPE_Acceptor acc (addr);
+
+  // Spawn a acceptor thread.
+  if (ACE_Thread_Manager::instance ()->spawn (ACE_THR_FUNC (acceptor),
+                                              (void *) &acc,
+                                              THR_NEW_LWP,
+                                              0) == -1)
+    ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("spawn")), 1);
+
+  // Spawn a connector thread.
+  if (ACE_Thread_Manager::instance ()->spawn (ACE_THR_FUNC (connector),
+                                              (void *) 0,
+                                              THR_NEW_LWP,
+                                              0) == -1)
+    ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("spawn")), 1);
+
+  ACE_Thread_Manager::instance ()->wait ();
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) joined with acceptor thread\n")));
+
+  // Close the acceptor
+  acc.close ();
+
+#else
+
+#if !defined (ACE_HAS_THREADS)
+  ACE_ERROR ((LM_INFO, ACE_TEXT ("threads not supported on this platform\n")));
+#else
+  ACE_ERROR ((LM_INFO, ACE_TEXT ("UPIPE is not supported on this platform\n")));
+#endif /* !defined (ACE_HAS_THREADS) */
+#endif /* defined (ACE_HAS_THREADS) && (defined (ACE_HAS_STREAM_PIPES) || defined (ACE_WIN32) && NT4) */
+
+  ACE_END_TEST;
+  return 0;
+}
+