package com.google.firebase.messaging;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

/* JADX INFO: renamed from: com.google.firebase.messaging.d, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes.dex */
public final class C0500d extends FilterInputStream {

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public long f5886k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public long f5887l;

    public C0500d(InputStream inputStream) {
        super(inputStream);
        this.f5887l = -1L;
        this.f5886k = 1048577L;
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final int available() {
        return (int) Math.min(((FilterInputStream) this).in.available(), this.f5886k);
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final synchronized void mark(int i) {
        ((FilterInputStream) this).in.mark(i);
        this.f5887l = this.f5886k;
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final int read() throws IOException {
        if (this.f5886k == 0) {
            return -1;
        }
        int i = ((FilterInputStream) this).in.read();
        if (i != -1) {
            this.f5886k--;
        }
        return i;
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final synchronized void reset() {
        if (!((FilterInputStream) this).in.markSupported()) {
            throw new IOException("Mark not supported");
        }
        if (this.f5887l == -1) {
            throw new IOException("Mark not set");
        }
        ((FilterInputStream) this).in.reset();
        this.f5886k = this.f5887l;
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final long skip(long j5) throws IOException {
        long jSkip = ((FilterInputStream) this).in.skip(Math.min(j5, this.f5886k));
        this.f5886k -= jSkip;
        return jSkip;
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final int read(byte[] bArr, int i, int i5) throws IOException {
        long j5 = this.f5886k;
        if (j5 == 0) {
            return -1;
        }
        int i6 = ((FilterInputStream) this).in.read(bArr, i, (int) Math.min(i5, j5));
        if (i6 != -1) {
            this.f5886k -= (long) i6;
        }
        return i6;
    }
}