package p;

import b0.D;
import java.util.Arrays;

/* JADX INFO: loaded from: classes.dex */
public abstract class i extends c {

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private byte[] f6162g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private int f6163h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private volatile boolean f6164i;

    public i(a0.f fVar, a0.h hVar, int i2, int i3, j jVar, int i4, byte[] bArr) {
        super(fVar, hVar, i2, i3, jVar, i4);
        this.f6162g = bArr;
    }

    private void j() {
        byte[] bArr = this.f6162g;
        if (bArr == null) {
            this.f6162g = new byte[16384];
        } else if (bArr.length < this.f6163h + 16384) {
            this.f6162g = Arrays.copyOf(bArr, bArr.length + 16384);
        }
    }

    @Override // p.c
    public long f() {
        return this.f6163h;
    }

    protected abstract void h(byte[] bArr, int i2);

    public byte[] i() {
        return this.f6162g;
    }

    @Override // a0.r.c
    public final boolean m() {
        return this.f6164i;
    }

    @Override // a0.r.c
    public final void q() {
        try {
            this.f6091f.a(this.f6089d);
            int i2 = 0;
            this.f6163h = 0;
            while (i2 != -1 && !this.f6164i) {
                j();
                i2 = this.f6091f.read(this.f6162g, this.f6163h, 16384);
                if (i2 != -1) {
                    this.f6163h += i2;
                }
            }
            if (!this.f6164i) {
                h(this.f6162g, this.f6163h);
            }
            D.g(this.f6091f);
        } catch (Throwable th) {
            D.g(this.f6091f);
            throw th;
        }
    }

    @Override // a0.r.c
    public final void u() {
        this.f6164i = true;
    }
}