aboutsummaryrefslogtreecommitdiff
path: root/libjava/java/io/PipedOutputStream.java
diff options
context:
space:
mode:
Diffstat (limited to 'libjava/java/io/PipedOutputStream.java')
-rw-r--r--libjava/java/io/PipedOutputStream.java97
1 files changed, 0 insertions, 97 deletions
diff --git a/libjava/java/io/PipedOutputStream.java b/libjava/java/io/PipedOutputStream.java
deleted file mode 100644
index 901fb9e5484..00000000000
--- a/libjava/java/io/PipedOutputStream.java
+++ /dev/null
@@ -1,97 +0,0 @@
-// PipedOutputStream.java - Write bytes to a pipe.
-
-/* Copyright (C) 1998, 1999, 2000 Free Software Foundation
-
- This file is part of libgcj.
-
-This software is copyrighted work licensed under the terms of the
-Libgcj License. Please consult the file "LIBGCJ_LICENSE" for
-details. */
-
-package java.io;
-
-/**
- * @author Tom Tromey <tromey@cygnus.com>
- * @date September 24, 1998
- */
-
-/* Written using "Java Class Libraries", 2nd edition, ISBN 0-201-31002-3
- * "The Java Language Specification", ISBN 0-201-63451-1
- * Status: Believed complete and correct.
- */
-
-public class PipedOutputStream extends OutputStream
-{
- public void close () throws IOException
- {
- closed = true;
-
- // Notify PipedInputStream that there is no more data to be had.
- destination.receive(-1);
- }
-
- public void connect (PipedInputStream dest) throws IOException
- {
- if (closed)
- throw new IOException("pipe closed");
-
- if (destination != null)
- if (destination == dest)
- return;
- else
- throw new IOException("pipe already connected");
-
- destination = dest;
- try
- {
- dest.connect(this);
- }
- catch (IOException ex)
- {
- destination = null;
- throw ex;
- }
- }
-
- public synchronized void flush () throws IOException
- {
- // There doesn't seem to be anything to do here.
-
- // TBD: Should this maybe do a notifyAll as a way for the user
- // to wake up the input stream to check for bytes to read? Shouldn't
- // be necessary but if there aren't any bytes, other threads will just
- // go blocak again anyway so it wouldn't hurt.
- }
-
- public PipedOutputStream ()
- {
- closed = false;
- }
-
- public PipedOutputStream (PipedInputStream dest) throws IOException
- {
- closed = false;
- connect (dest);
- }
-
- public void write (int oneByte) throws IOException
- {
- if (closed)
- throw new IOException ();
- destination.receive(oneByte);
- }
-
- public void write (byte[] buffer, int offset, int count) throws IOException
- {
- if (closed)
- throw new IOException ();
- if (offset < 0 || count < 0 || offset + count > buffer.length)
- throw new ArrayIndexOutOfBoundsException ();
- for (int i = 0; i < count; ++i)
- destination.receive (buffer[offset + i]);
- }
-
- // Instance variables.
- private PipedInputStream destination;
- private boolean closed;
-}