package t5;

import android.text.TextUtils;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

/* JADX INFO: loaded from: classes.dex */
public final class e extends FilterInputStream {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final long f32959a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public int f32960b;

    public e(InputStream inputStream, long j10) {
        super(inputStream);
        this.f32959a = j10;
    }

    @NonNull
    public static InputStream obtain(@NonNull InputStream inputStream, @Nullable String str) {
        return new e(inputStream, parseContentLength(str));
    }

    private static int parseContentLength(@Nullable String str) {
        if (!TextUtils.isEmpty(str)) {
            try {
                return Integer.parseInt(str);
            } catch (NumberFormatException unused) {
            }
        }
        return -1;
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final synchronized int available() {
        return (int) Math.max(this.f32959a - ((long) this.f32960b), ((FilterInputStream) this).in.available());
    }

    public final void e(int i10) throws IOException {
        if (i10 >= 0) {
            this.f32960b += i10;
            return;
        }
        long j10 = this.f32960b;
        long j11 = this.f32959a;
        if (j11 - j10 <= 0) {
            return;
        }
        StringBuilder sbS = defpackage.e.s("Failed to read all expected data, expected: ", j11, ", but read: ");
        sbS.append(this.f32960b);
        throw new IOException(sbS.toString());
    }

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final synchronized int read() {
        int i10;
        i10 = super.read();
        e(i10 >= 0 ? 1 : -1);
        return i10;
    }

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

    @Override // java.io.FilterInputStream, java.io.InputStream
    public final synchronized int read(byte[] bArr, int i10, int i11) {
        int i12;
        i12 = super.read(bArr, i10, i11);
        e(i12);
        return i12;
    }
}