Package net.i2p.i2ptunnel

Class HTTPResponseOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

net.i2p.i2ptunnel.HTTPResponseOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

class HTTPResponseOutputStream
extends FilterOutputStream

This does the transparent gzip decompression on the client side. Extended in I2PTunnelHTTPServer to do the compression on the server side. Simple stream for delivering an HTTP response to the client, trivially filtered to make sure "Connection: close" is always in the response. Perhaps add transparent handling of the Content-Encoding: x-i2p-gzip, adjusting the headers to say Content-Encoding: identity? Content-Encoding: gzip is trivial as well, but Transfer-Encoding: chunked makes it more work than is worthwhile at the moment.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	_contentEncoding	lower-case, trimmed
protected String	_contentType	lower-case, trimmed
protected long	_dataExpected
protected boolean	_gzip
protected ByteArray	_headerBuffer

Fields inherited from class java.io.FilterOutputStream

out

Constructor Summary

Constructors

Constructor	Description
HTTPResponseOutputStream(OutputStream raw)

Method Summary

Modifier and Type	Method	Description
protected void	beginProcessing()
void	close()
protected String	filterResponseLine(String line)	Possibly tweak that first HTTP response line (HTTP/1.0 200 OK, etc).
protected void	finishHeaders()
protected boolean	shouldCompress()
void	write(byte[] buf)
void	write(byte[] buf, int off, int len)
void	write(int c)

Methods inherited from class java.io.FilterOutputStream

flush

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

_headerBuffer

protected ByteArray _headerBuffer

_gzip

protected boolean _gzip

_dataExpected

protected long _dataExpected

_contentType

protected String _contentType

lower-case, trimmed

_contentEncoding

protected String _contentEncoding

lower-case, trimmed

Constructor Details

HTTPResponseOutputStream

public HTTPResponseOutputStream(OutputStream raw)

Method Details

write

public void write(int c)
           throws IOException

Overrides:

write in class FilterOutputStream

Throws:

IOException

write

public void write(byte[] buf)
           throws IOException

Overrides:

write in class FilterOutputStream

Throws:

IOException

write

public void write(byte[] buf,
 int off,
 int len)
           throws IOException

Overrides:

write in class FilterOutputStream

Throws:

IOException

filterResponseLine

protected String filterResponseLine(String line)

Possibly tweak that first HTTP response line (HTTP/1.0 200 OK, etc). Overridden on server side.

shouldCompress

protected boolean shouldCompress()

finishHeaders

protected void finishHeaders()
                      throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class FilterOutputStream

Throws:

IOException

beginProcessing

protected void beginProcessing()
                        throws IOException

Throws:

IOException