You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by re...@apache.org on 2002/03/07 05:27:23 UTC
cvs commit: jakarta-tomcat-connectors/coyote/src/java/org/apache/coyote/tomcat4 CoyoteInputStream.java CoyoteOutputStream.java CoyoteWriter.java OutputBuffer.java
remm 02/03/06 20:27:23
Added: coyote/src/java/org/apache/coyote/tomcat4
CoyoteInputStream.java CoyoteOutputStream.java
CoyoteWriter.java OutputBuffer.java
Log:
- Add the I/O handling classes, which revolve around Tomcat 3.3's OutputBuffer,
which is very efficient at handling both chars and bytes. The main benefit is to
avoid the cost of creating disposable writers, as is currently done in Catalina
(and which is very expensive).
- Includes a cleanup over the Tomcat 3.3 code; parts of the code, like content
length delimitation, are the responsability of the processor, and have been
removed.
Revision Changes Path
1.1 jakarta-tomcat-connectors/coyote/src/java/org/apache/coyote/tomcat4/CoyoteInputStream.java
Index: CoyoteInputStream.java
===================================================================
/*
* ====================================================================
*
* The Apache Software License, Version 1.1
*
* Copyright (c) 1999 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution, if
* any, must include the following acknowlegement:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowlegement may appear in the software itself,
* if and wherever such third-party acknowlegements normally appear.
*
* 4. The names "The Jakarta Project", "Tomcat", and "Apache Software
* Foundation" must not be used to endorse or promote products derived
* from this software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache"
* nor may "Apache" appear in their names without prior written
* permission of the Apache Group.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*
* [Additional notices, if required by prior licensing conditions]
*
*/
package org.apache.coyote.tomcat4;
import java.io.InputStream;
import java.io.IOException;
import javax.servlet.ServletInputStream;
import org.apache.tomcat.util.buf.ByteChunk;
import org.apache.coyote.Request;
/**
* This class handles the readin input bytes, as well as the input buffering.
*
* @author Remy Maucherat
*/
public class CoyoteInputStream extends ServletInputStream {
// ----------------------------------------------------- Instance Variables
private boolean closed = false;
private Request coyoteRequest;
private ByteChunk readChunk = new ByteChunk();
/**
* Current read position in the byte buffer.
*/
private int pos = -1;
private int end = -1;
private byte[] readBuffer = null;
// --------------------------------------------------------- Public Methods
void setRequest(Request coyoteRequest) {
this.coyoteRequest = coyoteRequest;
}
/**
* Recycle the input stream.
*/
void recycle() {
closed = false;
pos = -1;
end = -1;
readBuffer = null;
}
// --------------------------------------------- ServletInputStream Methods
public int read()
throws IOException {
if (closed)
throw new IOException("Stream closed");
// Read additional bytes if none are available
while (pos >= end) {
if (readBytes() < 0)
return -1;
}
return (readBuffer[pos++] & 0xFF);
}
public int read(byte[] b) throws IOException {
return read(b, 0, b.length);
}
public int read(byte[] b, int off, int len)
throws IOException {
if (closed)
throw new IOException("Stream closed");
// Read additional bytes if none are available
while (pos >= end) {
if (readBytes() < 0)
return -1;
}
int n = -1;
if ((end - pos) > len) {
n = len;
} else {
n = end - pos;
}
System.arraycopy(readBuffer, pos, b, off, n);
pos += n;
return n;
}
public int readLine(byte[] b, int off, int len) throws IOException {
return super.readLine(b, off, len);
}
/**
* Close the stream
* Since we re-cycle, we can't allow the call to super.close()
* which would permantely disable us.
*/
public void close() {
closed = true;
}
// ------------------------------------------------------ Protected Methods
/**
* Read bytes to the read chunk buffer.
*/
protected int readBytes()
throws IOException {
int result = coyoteRequest.doRead(readChunk);
if (result > 0) {
readBuffer = readChunk.getBytes();
end = readChunk.getEnd();
pos = readChunk.getStart();
}
return result;
}
}
1.1 jakarta-tomcat-connectors/coyote/src/java/org/apache/coyote/tomcat4/CoyoteOutputStream.java
Index: CoyoteOutputStream.java
===================================================================
/*
* ====================================================================
*
* The Apache Software License, Version 1.1
*
* Copyright (c) 1999 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution, if
* any, must include the following acknowlegement:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowlegement may appear in the software itself,
* if and wherever such third-party acknowlegements normally appear.
*
* 4. The names "The Jakarta Project", "Tomcat", and "Apache Software
* Foundation" must not be used to endorse or promote products derived
* from this software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache"
* nor may "Apache" appear in their names without prior written
* permission of the Apache Group.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*
* [Additional notices, if required by prior licensing conditions]
*
*/
package org.apache.coyote.tomcat4;
import java.io.IOException;
import javax.servlet.ServletOutputStream;
import org.apache.coyote.Response;
/**
* Coyote implementation of the servlet output stream.
*
* @author Costin Manolache
* @author Remy Maucherat
*/
final class CoyoteOutputStream
extends ServletOutputStream {
// ----------------------------------------------------- Instance Variables
protected OutputBuffer ob;
// ----------------------------------------------------------- Constructors
protected CoyoteOutputStream(OutputBuffer ob) {
this.ob = ob;
}
// --------------------------------------------------- OutputStream Methods
public void write(int i)
throws IOException {
ob.writeByte(i);
}
public void write(byte[] b)
throws IOException {
write(b, 0, b.length);
}
public void write(byte[] b, int off, int len)
throws IOException {
ob.write(b, off, len);
}
/**
* Will send the buffer to the client.
*/
public void flush()
throws IOException {
if (ob.flushCharsNeeded())
ob.flushChars();
ob.flushBytes();
}
public void close()
throws IOException {
if (ob.flushCharsNeeded())
ob.flushChars();
ob.flushBytes();
}
// -------------------------------------------- ServletOutputStream Methods
public void print(String s)
throws IOException {
ob.write(s);
}
}
1.1 jakarta-tomcat-connectors/coyote/src/java/org/apache/coyote/tomcat4/CoyoteWriter.java
Index: CoyoteWriter.java
===================================================================
/*
* ====================================================================
*
* The Apache Software License, Version 1.1
*
* Copyright (c) 1999 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution, if
* any, must include the following acknowlegement:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowlegement may appear in the software itself,
* if and wherever such third-party acknowlegements normally appear.
*
* 4. The names "The Jakarta Project", "Tomcat", and "Apache Software
* Foundation" must not be used to endorse or promote products derived
* from this software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache"
* nor may "Apache" appear in their names without prior written
* permission of the Apache Group.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*
* [Additional notices, if required by prior licensing conditions]
*
*/
package org.apache.coyote.tomcat4;
import java.io.IOException;
import java.io.PrintWriter;
import javax.servlet.ServletOutputStream;
/**
* Coyote implementation of the servlet writer.
*
* @author Costin Manolache
* @author Remy Maucherat
*/
final class CoyoteWriter
extends PrintWriter {
// ----------------------------------------------------- Instance Variables
protected OutputBuffer ob;
// ----------------------------------------------------------- Constructors
public CoyoteWriter(OutputBuffer ob) {
super(ob);
this.ob = ob;
}
// --------------------------------------------------------- Writer Methods
public void flush() {
super.flush();
}
public void write(char buf[], int offset, int count) {
super.write(buf, offset, count);
}
public void write(String str) {
super.write( str );
}
public void close() {
// We don't close the PrintWriter - super() is not called,
// so the stream can be reused. We close ob.
try {
ob.close();
} catch (IOException ex ) {
ex.printStackTrace();
}
}
// ---------------------------------------------------- PrintWriter Methods
public void print(String str) {
super.print( str );
}
public void println(String str) {
super.println(str);
}
}
1.1 jakarta-tomcat-connectors/coyote/src/java/org/apache/coyote/tomcat4/OutputBuffer.java
Index: OutputBuffer.java
===================================================================
/*
* ====================================================================
*
* The Apache Software License, Version 1.1
*
* Copyright (c) 1999 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution, if
* any, must include the following acknowlegement:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowlegement may appear in the software itself,
* if and wherever such third-party acknowlegements normally appear.
*
* 4. The names "The Jakarta Project", "Tomcat", and "Apache Software
* Foundation" must not be used to endorse or promote products derived
* from this software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache"
* nor may "Apache" appear in their names without prior written
* permission of the Apache Group.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*
* [Additional notices, if required by prior licensing conditions]
*
*/
package org.apache.coyote.tomcat4;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.io.Writer;
import java.util.Hashtable;
import org.apache.tomcat.util.buf.ByteChunk;
import org.apache.tomcat.util.buf.C2BConverter;
import org.apache.tomcat.util.buf.CharChunk;
import org.apache.coyote.Response;
/**
* The buffer used by Tomcat response. This is a derivative of the Tomcat 3.3
* OutputBuffer, with the removal of some of the state handling (which in
* Coyote is mostly the Processor's responsability).
*
* @author Costin Manolache
* @author Remy Maucherat
*/
public class OutputBuffer extends Writer
implements ByteChunk.ByteOutputChannel, CharChunk.CharOutputChannel {
// -------------------------------------------------------------- Constants
public static final String DEFAULT_ENCODING="ISO-8859-1";
public static final int DEFAULT_BUFFER_SIZE = 8*1024;
static final int debug = 0;
// The buffer can be used for byte[] and char[] writing
// ( this is needed to support ServletOutputStream and for
// efficient implementations of templating systems )
public final int INITIAL_STATE = 0;
public final int CHAR_STATE = 1;
public final int BYTE_STATE = 2;
// ----------------------------------------------------- Instance Variables
private int defaultBufferSize = DEFAULT_BUFFER_SIZE;
private int defaultCharBufferSize = DEFAULT_BUFFER_SIZE / 2 ;
private int state = 0;
// statistics
private int bytesWritten = 0;
private int charsWritten;
private boolean closed = false;
private boolean doFlush = false;
/**
* The buffer
*/
private ByteChunk bb;
private CharChunk cb;
/**
* Byte chunk used to output bytes.
*/
private ByteChunk outputChunk = new ByteChunk();
private String enc;
private boolean gotEnc = false;
protected Hashtable encoders = new Hashtable();
protected C2BConverter conv;
private Response coyoteResponse;
// ----------------------------------------------------------- Constructors
/**
* Default constructor. Allocate the buffer with the default buffer size.
*/
public OutputBuffer() {
this(DEFAULT_BUFFER_SIZE);
}
public OutputBuffer(int size) {
bb = new ByteChunk(size);
bb.setLimit(size);
bb.setByteOutputChannel(this);
cb = new CharChunk(size);
cb.setCharOutputChannel(this);
cb.setLimit(size);
}
// ------------------------------------------------------------- Properties
/**
* Associated Coyote response.
*/
public void setResponse(Response coyoteResponse) {
this.coyoteResponse = coyoteResponse;
}
/**
* Get associated Coyote response.
*/
public Response getResponse() {
return this.coyoteResponse;
}
// --------------------------------------------------------- Public Methods
/**
* Recycle the output buffer.
*/
public void recycle() {
if (debug > 0)
log("recycle()");
state = INITIAL_STATE;
bytesWritten = 0;
charsWritten = 0;
cb.recycle();
bb.recycle();
closed = false;
if (conv!= null) {
conv.recycle();
}
gotEnc = false;
enc = null;
}
public void close()
throws IOException {
flush();
closed =true;
}
public void flush()
throws IOException {
doFlush = true;
if (state == CHAR_STATE) {
cb.flushBuffer();
bb.flushBuffer();
state = BYTE_STATE;
} else if (state == BYTE_STATE) {
bb.flushBuffer();
} else if (state == INITIAL_STATE)
realWriteBytes(null, 0, 0); // nothing written yet
doFlush = false;
}
// ------------------------------------------------------------- Properties
/**
* Sends the buffer data to the client output, checking the
* state of Response and calling the right interceptors.
*/
public void realWriteBytes(byte buf[], int off, int cnt)
throws IOException {
if (debug > 2)
log("realWrite(b, " + off + ", " + cnt + ") " + coyoteResponse);
if (closed)
return;
if (coyoteResponse == null)
return;
// If we really have something to write
if (cnt > 0) {
// real write to the adapter
outputChunk.setBytes(buf, off, cnt);
coyoteResponse.doWrite(outputChunk);
}
}
// -------------------- Adding bytes to the buffer --------------------
// Like BufferedOutputStream, without sync
public void write(byte b[], int off, int len) throws IOException {
if (state == CHAR_STATE)
cb.flushBuffer();
state = BYTE_STATE;
writeBytes( b, off, len );
}
private void writeBytes(byte b[], int off, int len)
throws IOException {
if (closed)
return;
if (debug > 0)
log("write(b,off,len)");
bb.append(b, off, len);
bytesWritten += len;
// if called from within flush(), then immediately flush
// remaining bytes
if (doFlush) {
bb.flushBuffer();
}
}
// XXX Char or byte ?
public void writeByte(int b)
throws IOException {
if (state == CHAR_STATE)
cb.flushBuffer();
state = BYTE_STATE;
if (debug > 0)
log("write(b)");
bb.append( (byte)b );
bytesWritten++;
}
// -------------------- Adding chars to the buffer
public void write(int c)
throws IOException {
state = CHAR_STATE;
if (debug > 0)
log("writeChar(b)");
cb.append((char) c);
charsWritten++;
}
public void write(char c[])
throws IOException {
write(c, 0, c.length);
}
public void write(char c[], int off, int len)
throws IOException {
state = CHAR_STATE;
if (debug > 0)
log("write(c,off,len)" + cb.getLength() + " " + cb.getLimit());
cb.append(c, off, len);
charsWritten += len;
}
public void write(StringBuffer sb)
throws IOException {
state = CHAR_STATE;
if (debug > 1)
log("write(s,off,len)");
int len = sb.length();
charsWritten += len;
cb.append(sb);
}
/**
* Append a string to the buffer
*/
public void write(String s, int off, int len)
throws IOException {
state=CHAR_STATE;
if (debug > 1)
log("write(s,off,len)");
charsWritten += len;
if (s==null)
s="null";
cb.append( s, off, len );
}
public void write(String s)
throws IOException {
state = CHAR_STATE;
if (s==null)
s="null";
write(s, 0, s.length());
}
public void flushChars()
throws IOException {
if (debug > 0)
log("flushChars() " + cb.getLength());
cb.flushBuffer();
state = BYTE_STATE;
}
public boolean flushCharsNeeded() {
return state == CHAR_STATE;
}
public void setEncoding(String s) {
enc = s;
}
public void realWriteChars(char c[], int off, int len)
throws IOException {
if (debug > 0)
log("realWrite(c,o,l) " + cb.getOffset() + " " + len);
if (!gotEnc)
setConverter();
if (debug > 0)
log("encoder: " + conv + " " + gotEnc);
conv.convert(c, off, len);
conv.flushBuffer(); // ???
}
protected void setConverter() {
if (coyoteResponse != null)
enc = coyoteResponse.getCharacterEncoding();
if (debug > 0)
log("Got encoding: " + enc);
gotEnc = true;
if (enc == null)
enc = DEFAULT_ENCODING;
conv = (C2BConverter) encoders.get(enc);
if (conv == null) {
try {
conv = new C2BConverter(bb,enc);
encoders.put(enc, conv);
} catch (IOException e) {
conv = (C2BConverter) encoders.get(DEFAULT_ENCODING);
if (conv == null) {
try {
conv = new C2BConverter(bb, DEFAULT_ENCODING);
encoders.put(DEFAULT_ENCODING, conv);
} catch (IOException ex) {
// Ignore
}
}
}
}
}
// -------------------- BufferedOutputStream compatibility
/**
* Real write - this buffer will be sent to the client
*/
public void flushBytes()
throws IOException {
if (debug > 0)
log("flushBytes() " + bb.getLength());
bb.flushBuffer();
}
public int getBytesWritten() {
return bytesWritten;
}
public int getCharsWritten() {
return charsWritten;
}
/**
* True if this buffer hasn't been used ( since recycle() ) -
* i.e. no chars or bytes have been added to the buffer.
*/
public boolean isNew() {
return (bytesWritten == 0) && (charsWritten == 0);
}
public void setBufferSize(int size) {
if (size > bb.getLimit()) {// ??????
bb.setLimit( size );
}
}
public void reset() {
//count=0;
bb.recycle();
bytesWritten = 0;
cb.recycle();
charsWritten = 0;
gotEnc = false;
enc = null;
}
public int getBufferSize() {
return bb.getLimit();
}
protected void log( String s ) {
System.out.println("OutputBuffer: " + s );
}
}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>