/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

 *

 * This code is free software; you can redistribute it and/or modify it

 * under the terms of the GNU General Public License version 2 only, as

 * published by the Free Software Foundation.  Oracle designates this

 * particular file as subject to the "Classpath" exception as provided

 * by Oracle in the LICENSE file that accompanied this code.

 *

 * This code is distributed in the hope that it will be useful, but WITHOUT

 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

 * version 2 for more details (a copy is included in the LICENSE file that

 * accompanied this code).

 *

 * You should have received a copy of the GNU General Public License version

 * 2 along with this work; if not, write to the Free Software Foundation,

 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

 *

 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

 * or visit www.oracle.com if you need additional information or have any

 * questions.

 */

package sun.net.www;

import java.io.*;

import sun.net.ProgressSource;

import sun.net.www.http.ChunkedInputStream;

public class MeteredStream extends FilterInputStream {

    // Instance variables.

    /* if expected != -1, after we've read >= expected, we're "closed" and return -1

     * from subsequest read() 's

     */

    protected boolean closed = false;

    protected long expected;

    protected long count = 0;

    protected long markedCount = 0;

    protected int markLimit = -1;

    protected ProgressSource pi;

    public MeteredStream(InputStream is, ProgressSource pi, long expected)

    {

        super(is);

        this.pi = pi;

        this.expected = expected;

        if (pi != null) {

            pi.updateProgress(0, expected);

        }

    }

        if (n == -1) {

            /*

             * don't close automatically when mark is set and is valid;

             * cannot reset() after close()

             */

            if (!isMarked()) {

                close();

            }

            return;

        }

        count += n;

        /**

         * If read beyond the markLimit, invalidate the mark

         */

        if (count - markedCount > markLimit) {

            markLimit = -1;

        }

        if (pi != null)

            pi.updateProgress(count, expected);

        if (isMarked()) {

            return;

        }

        // if expected length is known, we could determine if

        // read overrun.

        if (expected > 0)   {

            if (count >= expected) {

                close();

            }

        }

    }

    /**

     * Returns true if the mark is valid, false otherwise

     */

    private boolean isMarked() {

        if (markLimit < 0) {

            return false;

        }

        // mark is set, but is not valid anymore

        if (count - markedCount > markLimit) {

           return false;

        }

        // mark still holds

        return true;

    }

        }

    }

                throws java.io.IOException {

        }

    }

        }

    }

    public void close() throws IOException {

        }

    }

    }

    }

        }

    }

    public boolean markSupported() {

        }

    }

    @SuppressWarnings("deprecation")

    protected void finalize() throws Throwable {

        try {

            close();

            if (pi != null)

                pi.close();

        }

        finally {

            // Call super class

            super.finalize();

        }

    }

}