001: /*
002: * <copyright>
003: *
004: * Copyright 1997-2004 BBNT Solutions, LLC
005: * under sponsorship of the Defense Advanced Research Projects
006: * Agency (DARPA).
007: *
008: * You can redistribute this software and/or modify it under the
009: * terms of the Cougaar Open Source License as published on the
010: * Cougaar Open Source Website (www.cougaar.org).
011: *
012: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
013: * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
014: * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
015: * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
016: * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
017: * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
018: * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
019: * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
020: * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
021: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
022: * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
023: *
024: * </copyright>
025: */
026:
027: package org.cougaar.util;
028:
029: import java.io.IOException;
030:
031: /**
032: * An efficient implementation of PipedOutputStream
033: **/
034: public class PipedOutputStream extends java.io.OutputStream {
035: /**
036: * The PipedInputStream this is connected to.
037: **/
038: private PipedInputStream pis;
039: /**
040: * Set if this stream has been closed
041: **/
042: private boolean closed = false;
043:
044: /**
045: * Create an unconnected PipedOutputStream. To be used this must be
046: * passed to a new PipedInputStream or a new PipedInputStream must
047: * be connected to this.
048: **/
049: public PipedOutputStream() {
050: }
051:
052: /**
053: * Create an PipedOutputStream connected to the given
054: * PipedInputStream. The pair of streams is immediately ready to be
055: * used if this constructor is used.
056: * @param pis the PipedInputStream to connect to this.
057: **/
058: public PipedOutputStream(PipedInputStream pis) {
059: this .pis = pis;
060: }
061:
062: /**
063: * Connect an PipedInputStream to this. This must be unconnected.
064: * @param pis the PipedInputStream to connect.
065: **/
066: public synchronized void connect(PipedInputStream pis) {
067: if (this .pis != null && this .pis != pis) {
068: throw new IllegalArgumentException("Already connected");
069: }
070: this .pis = pis;
071: }
072:
073: /**
074: * Write a byte to the pipe. The byte is put into the connected
075: * PipedInputStream.
076: * @param b the byte to put.
077: * @exception IOException if this stream is closed or not connected
078: * or connected to a closed PipedInputStream.
079: **/
080: public synchronized void write(int b) throws IOException {
081: if (closed)
082: throw new IOException("Closed");
083: if (pis == null)
084: throw new IOException("Not Connected");
085: pis.put(b);
086: }
087:
088: /**
089: * Write an array of bytes to the pipe. All the bytes in the array
090: * are put into the connected PipedInputStream.
091: * @param b the byte to put.
092: * @exception IOException if this stream is closed or not connected
093: * or connected to a closed PipedInputStream.
094: **/
095: public synchronized void write(byte[] b, int off, int len)
096: throws IOException {
097: if (closed)
098: throw new IOException("Closed");
099: if (pis == null)
100: throw new IOException("Not Connected");
101: pis.put(b, off, len);
102: }
103:
104: /**
105: * Write part of an array of bytes to the pipe. Some of the bytes in
106: * the array are put into the connected PipedInputStream.
107: * @param b the byte to put.
108: * @exception IOException if this stream is closed or not connected
109: * or connected to a closed PipedInputStream.
110: **/
111: public synchronized void write(byte[] b) throws IOException {
112: if (closed)
113: throw new IOException("Closed");
114: if (pis == null)
115: throw new IOException("Not Connected");
116: pis.put(b, 0, b.length);
117: }
118:
119: /**
120: * Insure that all bytes that have been written are accessible to
121: * the reader of the connected PipedInputStream.
122: * @exception IOException if this stream is closed or not connected.
123: **/
124: public synchronized void flush() throws IOException {
125: if (closed)
126: throw new IOException("Closed");
127: if (pis == null)
128: throw new IOException("Not Connected");
129: pis.flush();
130: }
131:
132: /**
133: * Close this stream. The connection PipedInputStream will signal
134: * EOF when all the bytes have been read.
135: * @exception IOException if this stream is already closed
136: **/
137: public synchronized void close() throws IOException {
138: if (closed)
139: throw new IOException("Closed");
140: if (pis != null) {
141: pis.setEOF();
142: }
143: closed = true;
144: }
145: }
|