package l;

/* JADX INFO: compiled from: PeekSource.kt */
/* JADX INFO: loaded from: classes.dex */
public final class s implements a0 {
    private final f b;
    private v d;
    private int e;
    private boolean f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private long f944g;

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

    public s(h hVar) {
        j.p0.d.r.g(hVar, "upstream");
        this.f945h = hVar;
        f fVarA = hVar.a();
        this.b = fVarA;
        v vVar = fVarA.b;
        this.d = vVar;
        this.e = vVar != null ? vVar.b : -1;
    }

    @Override // l.a0, java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        this.f = true;
    }

    /* JADX WARN: Removed duplicated region for block: B:20:0x002f  */
    @Override // l.a0
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public long read(l.f r9, long r10) {
        /*
            r8 = this;
            java.lang.String r0 = "sink"
            j.p0.d.r.g(r9, r0)
            r0 = 0
            int r2 = (r10 > r0 ? 1 : (r10 == r0 ? 0 : -1))
            r3 = 0
            r4 = 1
            if (r2 < 0) goto Lf
            r5 = r4
            goto L10
        Lf:
            r5 = r3
        L10:
            if (r5 == 0) goto L90
            boolean r5 = r8.f
            r5 = r5 ^ r4
            if (r5 == 0) goto L84
            l.v r5 = r8.d
            r6 = 0
            if (r5 == 0) goto L2f
            l.f r7 = r8.b
            l.v r7 = r7.b
            if (r5 != r7) goto L30
            int r5 = r8.e
            if (r7 == 0) goto L2b
            int r7 = r7.b
            if (r5 != r7) goto L30
            goto L2f
        L2b:
            j.p0.d.r.p()
            throw r6
        L2f:
            r3 = r4
        L30:
            if (r3 == 0) goto L78
            if (r2 != 0) goto L35
            return r0
        L35:
            l.h r0 = r8.f945h
            long r1 = r8.f944g
            r3 = 1
            long r1 = r1 + r3
            boolean r0 = r0.q(r1)
            if (r0 != 0) goto L45
            r9 = -1
            return r9
        L45:
            l.v r0 = r8.d
            if (r0 != 0) goto L5c
            l.f r0 = r8.b
            l.v r0 = r0.b
            if (r0 == 0) goto L5c
            r8.d = r0
            if (r0 == 0) goto L58
            int r0 = r0.b
            r8.e = r0
            goto L5c
        L58:
            j.p0.d.r.p()
            throw r6
        L5c:
            l.f r0 = r8.b
            long r0 = r0.K()
            long r2 = r8.f944g
            long r0 = r0 - r2
            long r10 = java.lang.Math.min(r10, r0)
            l.f r2 = r8.b
            long r4 = r8.f944g
            r3 = r9
            r6 = r10
            r2.l(r3, r4, r6)
            long r0 = r8.f944g
            long r0 = r0 + r10
            r8.f944g = r0
            return r10
        L78:
            java.lang.IllegalStateException r9 = new java.lang.IllegalStateException
            java.lang.String r10 = "Peek source is invalid because upstream source was used"
            java.lang.String r10 = r10.toString()
            r9.<init>(r10)
            throw r9
        L84:
            java.lang.IllegalStateException r9 = new java.lang.IllegalStateException
            java.lang.String r10 = "closed"
            java.lang.String r10 = r10.toString()
            r9.<init>(r10)
            throw r9
        L90:
            java.lang.StringBuilder r9 = new java.lang.StringBuilder
            r9.<init>()
            java.lang.String r0 = "byteCount < 0: "
            r9.append(r0)
            r9.append(r10)
            java.lang.String r9 = r9.toString()
            java.lang.IllegalArgumentException r10 = new java.lang.IllegalArgumentException
            java.lang.String r9 = r9.toString()
            r10.<init>(r9)
            throw r10
        */
        throw new UnsupportedOperationException("Method not decompiled: l.s.read(l.f, long):long");
    }

    @Override // l.a0
    public b0 timeout() {
        return this.f945h.timeout();
    }
}