This commit was manufactured by cvs2svn to create tag 'java-1_0_1a'.java-1_0_1a

1 files changed, 0 insertions, 146 deletions

diff --git a/tests/SPIPE_Test.cpp b/tests/SPIPE_Test.cpp
deleted file mode 100644
index ef7fb564f67..00000000000
--- a/tests/SPIPE_Test.cpp
+++ /dev/null
@@ -1,146 +0,0 @@
-// ============================================================================
-// $Id$
-
-//
-// = LIBRARY
-//    tests
-// 
-// = FILENAME
-//    SPIPE_Test.cpp
-//
-// = DESCRIPTION
-//      This is a simple test of Named Pipes that uses
-//      ACE_SPIPE_Acceptor and ACE_SPIPE_Connector classes. The test
-//      forks two processes or spawns two threads (depending upon the
-//      platform) and then executes the client and server allowing
-//      them to use the named pipe to exchange data. No user input is
-//      required as far as command line arguments are concerned.
-//
-// = AUTHOR
-//    Prashant Jain
-// 
-// ============================================================================
-
-#include "ace/OS.h"
-#include "ace/Thread.h"
-#include "ace/Thread_Manager.h"
-#include "ace/SPIPE_Addr.h"
-#include "ace/Time_Value.h"
-#include "ace/SPIPE_Connector.h"
-#include "ace/SPIPE_Acceptor.h"
-#include "test_config.h"
-
-// pipe name to use
-static char *pipe_name = "acepipe";
-
-// Global thread manager.
-static ACE_Thread_Manager thr_mgr;
-
-static void *
-client (void *)
-{
-#if defined (ACE_WIN32)
-  ACE_Thread_Control thread_control (&thr_mgr);  // Insert thread into thr_mgr
-  ACE_NEW_THREAD;
-#endif
-  char *rendezvous = "ace_pipe_name";
-  ACE_SPIPE_Stream cli_stream;
-  ACE_SPIPE_Connector con;
-
-  ACE_OS::sleep (3);
-
-  if (con.connect (cli_stream, ACE_SPIPE_Addr (rendezvous)) == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n", rendezvous));
-
-  for (char c = 'a'; c <= 'z'; c++)
-    if (cli_stream.send (&c, 1) == -1) 
-      ACE_ERROR ((LM_ERROR, "%p\n", "send_n"));
-
-  if (cli_stream.close () == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n", "close"));
-
-#if !defined (ACE_WIN32)
-  ACE_OS::exit (0);
-#endif
-  return 0;
-}
-
-static void *
-server (void *)
-{
-#if defined (ACE_WIN32)
-  ACE_Thread_Control thread_control (&thr_mgr);  // Insert thread into thr_mgr
-  ACE_NEW_THREAD;
-#endif
-  ACE_SPIPE_Acceptor acceptor;
-  ACE_SPIPE_Stream new_stream;
-  char buf[BUFSIZ];
-  int n;
-  char t = 'a';
-
-  char *rendezvous = "ace_pipe_name";
-
-  // Initialize named pipe listener
-
-  if (acceptor.open (ACE_SPIPE_Addr (rendezvous)) == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n", "open"));
-
-  ACE_DEBUG ((LM_DEBUG, "waiting for connection\n"));
-  
-  // Accept a client connection
-  if (acceptor.accept (new_stream, 0) == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n", "accept"));
-
-  ACE_DEBUG ((LM_DEBUG, "Accepted connection\n"));
-
-  while ((n = new_stream.recv (buf, 1)) > 0)
-    {
-      ACE_ASSERT (t == buf[0]);
-      t++;
-    }
-  ACE_DEBUG ((LM_DEBUG, "End of connection. Closing handle\n"));
-  new_stream.close ();
-  return 0;
-}
-
-void
-spawn ()
-{
-#if !defined (ACE_WIN32)
-  switch (ACE_OS::fork ())
-    {
-    case -1:
-      ACE_ERROR ((LM_ERROR, "%p\n%a", "fork failed"));
-      exit (-1);
-    case 0: 
-      client (0);
-    default:
-      server (0);
-    }
-#elif defined (ACE_HAS_THREADS)
-  if (thr_mgr.spawn (ACE_THR_FUNC (client),
-		     (void *) 0,
-		     THR_NEW_LWP | THR_DETACHED) == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n%a", "thread create failed"));
-
-  if (thr_mgr.spawn (ACE_THR_FUNC (server),
-		     (void *) 0,
-		     THR_NEW_LWP | THR_DETACHED) == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n%a", "thread create failed"));
-  thr_mgr.wait ();
-#else
-  ACE_ERROR ((LM_ERROR, "only one thread may be run in a process on this platform\n%a", 1));
-#endif /* ACE_HAS_THREADS */	
-}
-
-int
-main (int, char *argv[])
-{
-  ACE_START_TEST;
-
-  spawn ();
-
-  ACE_END_TEST;
-  return 0;
-}
-