package j;

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

/* JADX INFO: compiled from: JvmOkio.kt */
/* JADX INFO: loaded from: classes.dex */
public final class p implements b0 {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final InputStream f4629b;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final c0 f4630e;

    public p(InputStream inputStream, c0 c0Var) {
        g.h0.c.l.f(inputStream, "input");
        g.h0.c.l.f(c0Var, "timeout");
        this.f4629b = inputStream;
        this.f4630e = c0Var;
    }

    @Override // j.b0, java.io.Closeable, java.lang.AutoCloseable
    public void close() throws IOException {
        this.f4629b.close();
    }

    @Override // j.b0
    public long read(d dVar, long j2) throws IOException {
        g.h0.c.l.f(dVar, "sink");
        if (j2 == 0) {
            return 0L;
        }
        if (!(j2 >= 0)) {
            throw new IllegalArgumentException(d.b.a.a.a.l("byteCount < 0: ", j2).toString());
        }
        try {
            this.f4630e.throwIfReached();
            w wVarX = dVar.x(1);
            int i2 = this.f4629b.read(wVarX.a, wVarX.f4650c, (int) Math.min(j2, 8192 - wVarX.f4650c));
            if (i2 != -1) {
                wVarX.f4650c += i2;
                long j3 = i2;
                dVar.f4601e += j3;
                return j3;
            }
            if (wVarX.f4649b != wVarX.f4650c) {
                return -1L;
            }
            dVar.f4600b = wVarX.a();
            x.a(wVarX);
            return -1L;
        } catch (AssertionError e2) {
            if (f.a.y.a.o0(e2)) {
                throw new IOException(e2);
            }
            throw e2;
        }
    }

    @Override // j.b0
    public c0 timeout() {
        return this.f4630e;
    }

    public String toString() {
        StringBuilder sbB = d.b.a.a.a.B("source(");
        sbB.append(this.f4629b);
        sbB.append(')');
        return sbB.toString();
    }
}