diff options
Diffstat (limited to 'libjava/classpath/test/java.io/PipedStreamTest.java')
-rw-r--r-- | libjava/classpath/test/java.io/PipedStreamTest.java | 134 |
1 files changed, 0 insertions, 134 deletions
diff --git a/libjava/classpath/test/java.io/PipedStreamTest.java b/libjava/classpath/test/java.io/PipedStreamTest.java deleted file mode 100644 index d30bfa3e69a..00000000000 --- a/libjava/classpath/test/java.io/PipedStreamTest.java +++ /dev/null @@ -1,134 +0,0 @@ -/************************************************************************* -/* 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); - } - -} - -} - |