DeflaterOutputStream.java revision 51b1b6997fd3f980076b8081f7f1165ccc2a4008
151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski/* 251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Copyright (c) 1996, 2009, Oracle and/or its affiliates. All rights reserved. 351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * This code is free software; you can redistribute it and/or modify it 651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * under the terms of the GNU General Public License version 2 only, as 751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * published by the Free Software Foundation. Oracle designates this 851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * particular file as subject to the "Classpath" exception as provided 951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * by Oracle in the LICENSE file that accompanied this code. 1051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 1151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * This code is distributed in the hope that it will be useful, but WITHOUT 1251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 1351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 1451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * version 2 for more details (a copy is included in the LICENSE file that 1551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * accompanied this code). 1651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 1751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * You should have received a copy of the GNU General Public License version 1851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 2 along with this work; if not, write to the Free Software Foundation, 1951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. 2051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 2151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA 2251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * or visit www.oracle.com if you need additional information or have any 2351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * questions. 2451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 2551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 2651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebskipackage java.util.zip; 2751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 2851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebskiimport java.io.FilterOutputStream; 2951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebskiimport java.io.OutputStream; 3051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebskiimport java.io.InputStream; 3151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebskiimport java.io.IOException; 3251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 3351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski/** 3451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * This class implements an output stream filter for compressing data in 3551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * the "deflate" compression format. It is also used as the basis for other 3651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * types of compression filters, such as GZIPOutputStream. 3751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 3851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @see Deflater 3951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @author David Connelly 4051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 4151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebskipublic 4251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebskiclass DeflaterOutputStream extends FilterOutputStream { 4351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 4451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Compressor for this stream. 4551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 4651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski protected Deflater def; 4751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 4851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 4951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Output buffer for writing compressed data. 5051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 5151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski protected byte[] buf; 5251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 5351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 5451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Indicates that the stream has been closed. 5551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 5651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 5751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski private boolean closed = false; 5851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 5951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski private final boolean syncFlush; 6051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 6151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 6251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Creates a new output stream with the specified compressor, 6351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * buffer size and flush mode. 6451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 6551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param out the output stream 6651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param def the compressor ("deflater") 6751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param size the output buffer size 6851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param syncFlush 6951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * if {@code true} the {@link #flush()} method of this 7051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * instance flushes the compressor with flush mode 7151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * {@link Deflater#SYNC_FLUSH} before flushing the output 7251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * stream, otherwise only flushes the output stream 7351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 7451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @throws IllegalArgumentException if size is <= 0 7551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 7651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @since 1.7 7751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 7851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public DeflaterOutputStream(OutputStream out, 7951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski Deflater def, 8051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski int size, 8151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski boolean syncFlush) { 8251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski super(out); 8351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (out == null || def == null) { 8451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski throw new NullPointerException(); 8551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } else if (size <= 0) { 8651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski throw new IllegalArgumentException("buffer size <= 0"); 8751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 8851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this.def = def; 8951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this.buf = new byte[size]; 9051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this.syncFlush = syncFlush; 9151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 9251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 9351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 9451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 9551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Creates a new output stream with the specified compressor and 9651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * buffer size. 9751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 9851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * <p>The new output stream instance is created as if by invoking 9951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * the 4-argument constructor DeflaterOutputStream(out, def, size, false). 10051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 10151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param out the output stream 10251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param def the compressor ("deflater") 10351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param size the output buffer size 10451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @exception IllegalArgumentException if size is <= 0 10551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 10651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public DeflaterOutputStream(OutputStream out, Deflater def, int size) { 10751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this(out, def, size, false); 10851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 10951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 11051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 11151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Creates a new output stream with the specified compressor, flush 11251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * mode and a default buffer size. 11351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 11451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param out the output stream 11551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param def the compressor ("deflater") 11651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param syncFlush 11751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * if {@code true} the {@link #flush()} method of this 11851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * instance flushes the compressor with flush mode 11951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * {@link Deflater#SYNC_FLUSH} before flushing the output 12051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * stream, otherwise only flushes the output stream 12151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 12251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @since 1.7 12351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 12451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public DeflaterOutputStream(OutputStream out, 12551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski Deflater def, 12651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski boolean syncFlush) { 12751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this(out, def, 512, syncFlush); 12851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 12951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 13051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 13151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 13251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Creates a new output stream with the specified compressor and 13351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * a default buffer size. 13451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 13551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * <p>The new output stream instance is created as if by invoking 13651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * the 3-argument constructor DeflaterOutputStream(out, def, false). 13751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 13851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param out the output stream 13951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param def the compressor ("deflater") 14051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 14151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public DeflaterOutputStream(OutputStream out, Deflater def) { 14251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this(out, def, 512, false); 14351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 14451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 14551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski boolean usesDefaultDeflater = false; 14651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 14751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 14851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 14951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Creates a new output stream with a default compressor, a default 15051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * buffer size and the specified flush mode. 15151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 15251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param out the output stream 15351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param syncFlush 15451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * if {@code true} the {@link #flush()} method of this 15551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * instance flushes the compressor with flush mode 15651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * {@link Deflater#SYNC_FLUSH} before flushing the output 15751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * stream, otherwise only flushes the output stream 15851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 15951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @since 1.7 16051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 16151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public DeflaterOutputStream(OutputStream out, boolean syncFlush) { 16251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this(out, new Deflater(), 512, syncFlush); 16351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski usesDefaultDeflater = true; 16451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 16551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 16651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 16751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Creates a new output stream with a default compressor and buffer size. 16851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 16951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * <p>The new output stream instance is created as if by invoking 17051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * the 2-argument constructor DeflaterOutputStream(out, false). 17151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 17251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param out the output stream 17351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 17451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public DeflaterOutputStream(OutputStream out) { 17551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski this(out, false); 17651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski usesDefaultDeflater = true; 17751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 17851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 17951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 18051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Writes a byte to the compressed output stream. This method will 18151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * block until the byte can be written. 18251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param b the byte to be written 18351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @exception IOException if an I/O error has occurred 18451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 18551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public void write(int b) throws IOException { 18651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski byte[] buf = new byte[1]; 18751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski buf[0] = (byte)(b & 0xff); 18851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski write(buf, 0, 1); 18951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 19051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 19151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 19251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Writes an array of bytes to the compressed output stream. This 19351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * method will block until all the bytes are written. 19451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param b the data to be written 19551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param off the start offset of the data 19651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @param len the length of the data 19751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @exception IOException if an I/O error has occurred 19851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 19951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public void write(byte[] b, int off, int len) throws IOException { 20051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (def.finished()) { 20151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski throw new IOException("write beyond end of stream"); 20251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 20351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if ((off | len | (off + len) | (b.length - (off + len))) < 0) { 20451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski throw new IndexOutOfBoundsException(); 20551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } else if (len == 0) { 20651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski return; 20751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 20851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (!def.finished()) { 20951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski def.setInput(b, off, len); 21051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski while (!def.needsInput()) { 21151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski deflate(); 21251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 21351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 21451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 21551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 21651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 21751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Finishes writing compressed data to the output stream without closing 21851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * the underlying stream. Use this method when applying multiple filters 21951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * in succession to the same output stream. 22051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @exception IOException if an I/O error has occurred 22151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 22251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public void finish() throws IOException { 22351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (!def.finished()) { 22451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski def.finish(); 22551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski while (!def.finished()) { 22651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski deflate(); 22751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 22851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 22951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 23051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 23151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 23251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Writes remaining compressed data to the output stream and closes the 23351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * underlying stream. 23451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @exception IOException if an I/O error has occurred 23551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 23651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public void close() throws IOException { 23751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (!closed) { 23851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski finish(); 23951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (usesDefaultDeflater) 24051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski def.end(); 24151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski out.close(); 24251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski closed = true; 24351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 24451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 24551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 24651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 24751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Writes next block of compressed data to the output stream. 24851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @throws IOException if an I/O error has occurred 24951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 25051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski protected void deflate() throws IOException { 25151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski int len = def.deflate(buf, 0, buf.length); 25251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (len > 0) { 25351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski out.write(buf, 0, len); 25451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 25551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 25651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski 25751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski /** 25851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * Flushes the compressed output stream. 25951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 26051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * If {@link #DeflaterOutputStream(OutputStream, Deflater, int, boolean) 26151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * syncFlush} is {@code true} when this compressed output stream is 26251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * constructed, this method first flushes the underlying {@code compressor} 26351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * with the flush mode {@link Deflater#SYNC_FLUSH} to force 26451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * all pending data to be flushed out to the output stream and then 26551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * flushes the output stream. Otherwise this method only flushes the 26651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * output stream without flushing the {@code compressor}. 26751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 26851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @throws IOException if an I/O error has occurred 26951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * 27051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski * @since 1.7 27151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski */ 27251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski public void flush() throws IOException { 27351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (syncFlush && !def.finished()) { 27451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski int len = 0; 27551b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski while ((len = def.deflate(buf, 0, buf.length, Deflater.SYNC_FLUSH)) > 0) 27651b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski { 27751b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski out.write(buf, 0, len); 27851b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski if (len < buf.length) 27951b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski break; 28051b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 28151b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 28251b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski out.flush(); 28351b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski } 28451b1b6997fd3f980076b8081f7f1165ccc2a4008Piotr Jastrzebski} 285