[patch] 2011-11-07_tc6_FlushableGZIPOutputStream.patch

2011-11-07_tc6_FlushableGZIPOutputStream.patch (text/plain), 3.69 KB, created by Konstantin Kolinko on 2011-11-07 02:45:47 UTC

(hide)

Description: 2011-11-07_tc6_FlushableGZIPOutputStream.patch

Filename:

MIME Type:

Creator: Konstantin Kolinko

Created: 2011-11-07 02:45:47 UTC

Size: 3.69 KB

patch

obsolete

>Index: java/org/apache/coyote/http11/filters/FlushableGZIPOutputStream.java >=================================================================== >--- java/org/apache/coyote/http11/filters/FlushableGZIPOutputStream.java (revision 1197793) >+++ java/org/apache/coyote/http11/filters/FlushableGZIPOutputStream.java (working copy) >@@ -35,58 +35,74 @@ > super(os); > } > >- private static final byte[] EMPTYBYTEARRAY = new byte[0]; >- private boolean hasData = false; >- > /** >- * Here we make sure we have received data, so that the header has been for >- * sure written to the output stream already. >+ * It is used to reserve one byte of real data so that it can be used when >+ * flushing the stream. > */ >+ private byte[] lastByte = new byte[1]; >+ private boolean hasLastByte = false; >+ > @Override >- public synchronized void write(byte[] bytes, int i, int i1) >+ public void write(byte[] bytes) throws IOException { >+ write(bytes, 0, bytes.length); >+ } >+ >+ @Override >+ public synchronized void write(byte[] bytes, int offset, int length) > throws IOException { >- super.write(bytes, i, i1); >- hasData = true; >+ if (length > 0) { >+ flushLastByte(); >+ if (length > 1) { >+ super.write(bytes, offset, length - 1); >+ } >+ rememberLastByte(bytes[offset + length - 1]); >+ } > } > > @Override > public synchronized void write(int i) throws IOException { >- super.write(i); >- hasData = true; >+ flushLastByte(); >+ rememberLastByte((byte) i); > } > > @Override >- public synchronized void write(byte[] bytes) throws IOException { >- super.write(bytes); >- hasData = true; >+ public synchronized void close() throws IOException { >+ flushLastByte(); >+ super.close(); > } > >+ private void rememberLastByte(byte b) { >+ lastByte[0] = b; >+ hasLastByte = true; >+ } >+ >+ private void flushLastByte() throws IOException { >+ if (hasLastByte) { >+ super.write(lastByte, 0, 1); >+ hasLastByte = false; >+ } >+ } >+ > @Override > public synchronized void flush() throws IOException { >- if (!hasData) { >- return; // do not allow the gzip header to be flushed on its own >- } >+ if (hasLastByte) { >+ // - do not allow the gzip header to be flushed on its own >+ // - do not do anything if there is no data to send > >- // trick the deflater to flush >- /** >- * Now this is tricky: We force the Deflater to flush its data by >- * switching compression level. As yet, a perplexingly simple workaround >- * for >- * http://developer.java.sun.com/developer/bugParade/bugs/4255743.html >- */ >- if (!def.finished()) { >- def.setInput(EMPTYBYTEARRAY, 0, 0); >- >- def.setLevel(Deflater.NO_COMPRESSION); >- deflate(); >- >- def.setLevel(Deflater.DEFAULT_COMPRESSION); >- deflate(); >- >- out.flush(); >+ // trick the deflater to flush >+ /** >+ * Now this is tricky: We force the Deflater to flush its data by >+ * switching compression level. As yet, a perplexingly simple workaround >+ * for >+ * http://developer.java.sun.com/developer/bugParade/bugs/4255743.html >+ */ >+ if (!def.finished()) { >+ def.setLevel(Deflater.NO_COMPRESSION); >+ flushLastByte(); >+ def.setLevel(Deflater.DEFAULT_COMPRESSION); >+ } > } >- >- hasData = false; // no more data to flush >+ out.flush(); > } > > /* View Attachment As Diff View Attachment As Raw

This is ASF Bugzilla: the Apache Software Foundation bug system. In case of problems with the functioning of ASF Bugzilla, please contact bugzilla-admin@apache.org. Please Note: this e-mail address is only for reporting problems with ASF Bugzilla. Mail about any other subject will be silently ignored.

• • Home
  • | New
  • | Browse
  • | Search
  • |
    [?]
  • | Reports
  • | Help
  • | New Account
  • | Log In
    Remember [x]
  • | Forgot Password
    Login: [x]