1 files changed, 134 insertions, 0 deletions
diff --git a/libjava/classpath/test/java.io/PipedStreamTest.java b/libjava/classpath/test/java.io/PipedStreamTest.java
new file mode 100644
index 0000000..d30bfa3
--- /dev/null
+++ b/libjava/classpath/test/java.io/PipedStreamTest.java
@@ -0,0 +1,134 @@
+/*************************************************************************
+/* PipedStreamTest.java -- Tests Piped{Input,Output}Stream's
+/*
+/* Copyright (c) 1998 Free Software Foundation, Inc.
+/* Written by Aaron M. Renn (arenn@urbanophile.com)
+/*
+/* This program is free software; you can redistribute it and/or modify
+/* it under the terms of the GNU General Public License as published 
+/* by the Free Software Foundation, either version 2 of the License, or
+/* (at your option) any later version.
+/*
+/* This program is distributed in the hope that it will be useful, but
+/* WITHOUT ANY WARRANTY; without even the implied warranty of
+/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+/* GNU General Public License for more details.
+/*
+/* You should have received a copy of the GNU General Public License
+/* along with this program; if not, write to the Free Software Foundation
+/* Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
+/*************************************************************************/
+
+import java.io.*;
+
+public class PipedStreamTest
+{
+
+public static void
+main(String[] argv) throws InterruptedException
+{
+  // Set up a reasonable buffer size for this test if one is not already
+  // specified
+  String prop = System.getProperty("gnu.java.io.pipe_size");
+//  if (prop == null)
+//    System.setProperty("gnu.java.io.pipe_size", "32");
+
+  try
+    {
+      System.out.println("Started test of PipedInputStream and " +
+                         "PipedOutputStream");
+
+      System.out.println("Test 1: Basic piped stream test");
+
+      // Set up the thread to write
+      PipedStreamTestWriter pstw = new PipedStreamTestWriter();
+      String str = pstw.getStr();
+      PipedOutputStream pos = pstw.getStream();
+
+      // Now set up our reader
+      PipedInputStream pis = new PipedInputStream();
+      pis.connect(pos); 
+      new Thread(pstw).start();
+
+      byte[] buf = new byte[12];
+      int bytes_read, total_read = 0;
+      while((bytes_read = pis.read(buf)) != -1)
+        {
+          System.out.print(new String(buf, 0, bytes_read));
+          System.out.flush();
+          Thread.sleep(10); // A short delay
+          total_read += bytes_read;
+        }
+
+      if (total_read == str.length())
+        System.out.println("PASSED: Basic piped stream test");
+      else
+        System.out.println("FAILED: Basic piped stream test");
+    }
+  catch (IOException e) 
+    {
+      System.out.println("FAILED: Basic piped stream test: " + e);
+    }
+}
+
+} // class PipedStreamTest
+
+class PipedStreamTestWriter implements Runnable
+{
+
+String str;
+StringBufferInputStream sbis;
+PipedOutputStream out;
+
+public
+PipedStreamTestWriter()
+{
+  str = "I went to work for Andersen Consulting after I graduated\n" +
+     "from college.  They sent me to their training facility in St. Charles,\n" +
+     "Illinois and tried to teach me COBOL.  I didn't want to learn it.\n" +
+     "The instructors said I had a bad attitude and I got a green sheet\n" +
+     "which is a nasty note in your file saying what a jerk you are.\n";
+
+  sbis = new StringBufferInputStream(str);
+
+  out = new PipedOutputStream();
+}
+
+public PipedOutputStream
+getStream()
+{
+  return(out);
+}
+
+public String
+getStr()
+{
+  return(str);
+}
+
+public void
+run() 
+{
+  byte[] buf = new byte[32];
+
+  int bytes_read;
+
+  try
+    {
+      int b = sbis.read();
+      out.write(b);
+
+      while ((bytes_read = sbis.read(buf)) != -1)
+        out.write(buf, 0, bytes_read);
+
+      out.close();
+    }
+  catch(IOException e)
+    {
+      System.out.println("FAILED: Basic piped stream test: " + e);
+    }
+
+}
+
+}
+