package i;

/* JADX INFO: compiled from: PeekSource.kt */
/* JADX INFO: loaded from: classes.dex */
public final class v implements d0 {
    private final f b;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private y f1044e;

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

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

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

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

    public v(h hVar) {
        h.x.d.k.d(hVar, "upstream");
        this.f1048i = hVar;
        f fVarC = hVar.c();
        this.b = fVarC;
        y yVar = fVarC.b;
        this.f1044e = yVar;
        this.f1045f = yVar != null ? yVar.b : -1;
    }

    @Override // i.d0, java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        this.f1046g = true;
    }

    /* JADX WARN: Removed duplicated region for block: B:15:0x002a  */
    @Override // i.d0
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public long read(i.f r9, long r10) {
        /*
            r8 = this;
            java.lang.String r0 = "sink"
            h.x.d.k.d(r9, r0)
            r0 = 0
            r1 = 1
            r2 = 0
            int r4 = (r10 > r2 ? 1 : (r10 == r2 ? 0 : -1))
            if (r4 < 0) goto Lf
            r4 = 1
            goto L10
        Lf:
            r4 = 0
        L10:
            if (r4 == 0) goto L89
            boolean r4 = r8.f1046g
            r4 = r4 ^ r1
            if (r4 == 0) goto L7d
            i.y r4 = r8.f1044e
            if (r4 == 0) goto L2a
            i.f r5 = r8.b
            i.y r5 = r5.b
            if (r4 != r5) goto L2b
            int r4 = r8.f1045f
            h.x.d.k.b(r5)
            int r5 = r5.b
            if (r4 != r5) goto L2b
        L2a:
            r0 = 1
        L2b:
            if (r0 == 0) goto L71
            int r0 = (r10 > r2 ? 1 : (r10 == r2 ? 0 : -1))
            if (r0 != 0) goto L32
            return r2
        L32:
            i.h r0 = r8.f1048i
            long r1 = r8.f1047h
            r3 = 1
            long r1 = r1 + r3
            boolean r0 = r0.o(r1)
            if (r0 != 0) goto L42
            r9 = -1
            return r9
        L42:
            i.y r0 = r8.f1044e
            if (r0 != 0) goto L55
            i.f r0 = r8.b
            i.y r0 = r0.b
            if (r0 == 0) goto L55
            r8.f1044e = r0
            h.x.d.k.b(r0)
            int r0 = r0.b
            r8.f1045f = r0
        L55:
            i.f r0 = r8.b
            long r0 = r0.J()
            long r2 = r8.f1047h
            long r0 = r0 - r2
            long r10 = java.lang.Math.min(r10, r0)
            i.f r2 = r8.b
            long r4 = r8.f1047h
            r3 = r9
            r6 = r10
            r2.j(r3, r4, r6)
            long r0 = r8.f1047h
            long r0 = r0 + r10
            r8.f1047h = r0
            return r10
        L71:
            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
        L7d:
            java.lang.IllegalStateException r9 = new java.lang.IllegalStateException
            java.lang.String r10 = "closed"
            java.lang.String r10 = r10.toString()
            r9.<init>(r10)
            throw r9
        L89:
            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: i.v.read(i.f, long):long");
    }

    @Override // i.d0
    public e0 timeout() {
        return this.f1048i.timeout();
    }
}