package z0;

import java.io.InputStream;
import x0.AbstractC1709a;

/* JADX INFO: loaded from: classes.dex */
public final class j extends InputStream implements AutoCloseable {

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final h f19132q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final k f19133r;

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public boolean f19135t = false;

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    public boolean f19136u = false;

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public final byte[] f19134s = new byte[1];

    public j(h hVar, k kVar) {
        this.f19132q = hVar;
        this.f19133r = kVar;
    }

    public final void a() {
        if (this.f19135t) {
            return;
        }
        this.f19132q.g(this.f19133r);
        this.f19135t = true;
    }

    @Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        if (this.f19136u) {
            return;
        }
        this.f19132q.close();
        this.f19136u = true;
    }

    @Override // java.io.InputStream
    public final int read() {
        byte[] bArr = this.f19134s;
        if (read(bArr, 0, bArr.length) == -1) {
            return -1;
        }
        return bArr[0] & 255;
    }

    @Override // java.io.InputStream
    public final int read(byte[] bArr) {
        return read(bArr, 0, bArr.length);
    }

    @Override // java.io.InputStream
    public final int read(byte[] bArr, int i, int i5) {
        AbstractC1709a.j(!this.f19136u);
        a();
        int iP = this.f19132q.p(bArr, i, i5);
        if (iP == -1) {
            return -1;
        }
        return iP;
    }
}