package j;

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

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public w f4637e;

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

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

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

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final g f4641i;

    public t(g gVar) {
        g.h0.c.l.f(gVar, "upstream");
        this.f4641i = gVar;
        d buffer = gVar.getBuffer();
        this.f4636b = buffer;
        w wVar = buffer.f4600b;
        this.f4637e = wVar;
        this.f4638f = wVar != null ? wVar.f4649b : -1;
    }

    @Override // j.b0, java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        this.f4639g = true;
    }

    /* JADX WARN: Removed duplicated region for block: B:15:0x002a  */
    @Override // j.b0
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public long read(j.d r9, long r10) {
        /*
            r8 = this;
            java.lang.String r0 = "sink"
            g.h0.c.l.f(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 L85
            boolean r5 = r8.f4639g
            r5 = r5 ^ r4
            if (r5 == 0) goto L79
            j.w r5 = r8.f4637e
            if (r5 == 0) goto L2a
            j.d r6 = r8.f4636b
            j.w r6 = r6.f4600b
            if (r5 != r6) goto L2b
            int r5 = r8.f4638f
            g.h0.c.l.c(r6)
            int r6 = r6.f4649b
            if (r5 != r6) goto L2b
        L2a:
            r3 = r4
        L2b:
            if (r3 == 0) goto L6d
            if (r2 != 0) goto L30
            return r0
        L30:
            j.g r0 = r8.f4641i
            long r1 = r8.f4640h
            r3 = 1
            long r1 = r1 + r3
            boolean r0 = r0.M(r1)
            if (r0 != 0) goto L40
            r9 = -1
            return r9
        L40:
            j.w r0 = r8.f4637e
            if (r0 != 0) goto L53
            j.d r0 = r8.f4636b
            j.w r0 = r0.f4600b
            if (r0 == 0) goto L53
            r8.f4637e = r0
            g.h0.c.l.c(r0)
            int r0 = r0.f4649b
            r8.f4638f = r0
        L53:
            j.d r0 = r8.f4636b
            long r0 = r0.f4601e
            long r2 = r8.f4640h
            long r0 = r0 - r2
            long r10 = java.lang.Math.min(r10, r0)
            j.d r2 = r8.f4636b
            long r4 = r8.f4640h
            r3 = r9
            r6 = r10
            r2.d(r3, r4, r6)
            long r0 = r8.f4640h
            long r0 = r0 + r10
            r8.f4640h = r0
            return r10
        L6d:
            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
        L79:
            java.lang.IllegalStateException r9 = new java.lang.IllegalStateException
            java.lang.String r10 = "closed"
            java.lang.String r10 = r10.toString()
            r9.<init>(r10)
            throw r9
        L85:
            java.lang.String r9 = "byteCount < 0: "
            java.lang.String r9 = d.b.a.a.a.l(r9, r10)
            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: j.t.read(j.d, long):long");
    }

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