');
document.write('
');
document.write('
import java.
util.
zip.
*;
');
document.write('
import java.
io.
OutputStream;
');
document.write('
import java.
io.
IOException;
');
document.write('
');
document.write('
/**
');
document.write(' * This class essentially copies sources of original GZIPOutputStream,
');
document.write(' * just adds ability to pass in desired compression level into constructor
');
document.write(' */');
document.write('
public class GZIPOutputStreamEx
extends DeflaterOutputStream');
document.write('
{');
document.write('
/**
');
document.write(' * CRC-32 of uncompressed data.
');
document.write(' */');
document.write('
protected CRC32 crc =
new CRC32();
');
document.write('
');
document.write('
/*
');
document.write(' * GZIP header magic number.
');
document.write(' */');
document.write('
private final static int GZIP_MAGIC = 0x8b1f;
');
document.write('
');
document.write('
/**
');
document.write(' * Creates a new output stream with the specified buffer size.
');
document.write(' * @param out the output stream
');
document.write(' * @param size the output buffer size
');
document.write(' * @exception IOException If an I/O error has occurred.
');
document.write(' * @exception IllegalArgumentException if size is <= 0
');
document.write(' */');
document.write('
public GZIPOutputStreamEx
(OutputStream out,
int size,
int compression
) throws IOException');
document.write('
{');
document.write('
super(out,
new Deflater(compression,
true), size
);
');
document.write(' writeHeader
();
');
document.write(' crc.
reset();
');
document.write('
}');
document.write('
');
document.write('
/**
');
document.write(' * Creates a new output stream with a default buffer size.
');
document.write(' * @param out the output stream
');
document.write(' * @exception IOException If an I/O error has occurred.
');
document.write(' */');
document.write('
public GZIPOutputStreamEx
(OutputStream out,
int compression
) throws IOException');
document.write('
{');
document.write('
this(out,
512, compression
);
');
document.write('
}');
document.write('
');
document.write('
/**
');
document.write(' * Writes array of bytes to the compressed output stream. This method
');
document.write(' * will block until all the bytes are written.
');
document.write(' * @param buf the data to be written
');
document.write(' * @param off the start offset of the data
');
document.write(' * @param len the length of the data
');
document.write(' * @exception IOException If an I/O error has occurred.
');
document.write(' */');
document.write('
public synchronized void write
(byte[] buf,
int off,
int len
)');
document.write('
throws IOException');
document.write('
{');
document.write('
super.
write(buf, off, len
);
');
document.write(' crc.
update(buf, off, len
);
');
document.write('
}');
document.write('
');
document.write('
/**
');
document.write(' * Finishes writing compressed data to the output stream without closing
');
document.write(' * the underlying stream. Use this method when applying multiple filters
');
document.write(' * in succession to the same output stream.
');
document.write(' * @exception IOException if an I/O error has occurred
');
document.write(' */');
document.write('
public void finish
() throws IOException');
document.write('
{');
document.write('
if (!def.
finished())');
document.write('
{');
document.write(' def.
finish();
');
document.write('
while (!def.
finished())');
document.write('
{');
document.write(' deflate
();
');
document.write('
}');
document.write(' writeTrailer
();
');
document.write('
}');
document.write('
}');
document.write('
');
document.write('
/**
');
document.write(' * Writes remaining compressed data to the output stream and closes the
');
document.write(' * underlying stream.
');
document.write(' * @exception IOException if an I/O error has occurred
');
document.write(' */');
document.write('
public void close
() throws IOException');
document.write('
{');
document.write(' finish
();
');
document.write(' out.
close();
');
document.write('
}');
document.write('
');
document.write('
/*
');
document.write(' * Writes GZIP member header.
');
document.write(' */');
document.write('
private void writeHeader
() throws IOException');
document.write('
{');
document.write(' writeShort
(GZIP_MAGIC
);
// Magic number');
document.write(' out.
write(def.
DEFLATED);
// Compression method (CM)');
document.write(' out.
write(0);
// Flags (FLG)');
document.write(' writeInt
(0);
// Modification time (MTIME)');
document.write(' out.
write(0);
// Extra flags (XFL)');
document.write(' out.
write(0);
// Operating system (OS)');
document.write('
}');
document.write('
');
document.write('
/*
');
document.write(' * Writes GZIP member trailer.
');
document.write(' */');
document.write('
private void writeTrailer
() throws IOException');
document.write('
{');
document.write(' writeInt
((int)crc.
getValue());
// CRC-32 of uncompressed data');
document.write(' writeInt
(def.
getTotalIn());
// Number of uncompressed bytes');
document.write('
}');
document.write('
');
document.write('
/*
');
document.write(' * Writes integer in Intel byte order.
');
document.write(' */');
document.write('
private void writeInt
(int i
) throws IOException');
document.write('
{');
document.write(' writeShort
(i & 0xffff
);
');
document.write(' writeShort
((i >>
16) & 0xffff
);
');
document.write('
}');
document.write('
');
document.write('
/*
');
document.write(' * Writes short integer in Intel byte order.
');
document.write(' */');
document.write('
private void writeShort
(int s
) throws IOException');
document.write('
{');
document.write(' out.
write(s & 0xff
);
');
document.write(' out.
write((s >>
8) & 0xff
);
');
document.write('
}');
document.write('
}');
document.write('
');
document.write('
');
document.write('