package okio;

/* JADX INFO: loaded from: classes2.dex */
public final class v implements E {

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private final C0688f f6058b;

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

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

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

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

    public v(h upstream) {
        kotlin.jvm.internal.l.e(upstream, "upstream");
        this.f6057H = upstream;
        C0688f buffer = upstream.getBuffer();
        this.f6058b = buffer;
        y yVar = buffer.f6021b;
        this.f6059g = yVar;
        this.f6060r = yVar != null ? yVar.f6072b : -1;
    }

    @Override // okio.E, java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        this.f6061x = true;
    }

    /* JADX WARN: Removed duplicated region for block: B:15:0x0029  */
    @Override // okio.E
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public long read(okio.C0688f r9, long r10) {
        /*
            r8 = this;
            java.lang.String r0 = "sink"
            kotlin.jvm.internal.l.e(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 L7e
            boolean r5 = r8.f6061x
            if (r5 != 0) goto L76
            okio.y r5 = r8.f6059g
            if (r5 == 0) goto L29
            okio.f r6 = r8.f6058b
            okio.y r6 = r6.f6021b
            if (r5 != r6) goto L2a
            int r5 = r8.f6060r
            kotlin.jvm.internal.l.b(r6)
            int r6 = r6.f6072b
            if (r5 != r6) goto L2a
        L29:
            r3 = r4
        L2a:
            if (r3 == 0) goto L6e
            if (r2 != 0) goto L2f
            return r0
        L2f:
            okio.h r0 = r8.f6057H
            long r1 = r8.f6062y
            r3 = 1
            long r1 = r1 + r3
            boolean r0 = r0.E(r1)
            if (r0 != 0) goto L3f
            r9 = -1
            return r9
        L3f:
            okio.y r0 = r8.f6059g
            if (r0 != 0) goto L52
            okio.f r0 = r8.f6058b
            okio.y r0 = r0.f6021b
            if (r0 == 0) goto L52
            r8.f6059g = r0
            kotlin.jvm.internal.l.b(r0)
            int r0 = r0.f6072b
            r8.f6060r = r0
        L52:
            okio.f r0 = r8.f6058b
            long r0 = r0.G()
            long r2 = r8.f6062y
            long r0 = r0 - r2
            long r10 = java.lang.Math.min(r10, r0)
            okio.f r2 = r8.f6058b
            long r4 = r8.f6062y
            r3 = r9
            r6 = r10
            r2.f(r3, r4, r6)
            long r0 = r8.f6062y
            long r0 = r0 + r10
            r8.f6062y = r0
            return r10
        L6e:
            java.lang.IllegalStateException r9 = new java.lang.IllegalStateException
            java.lang.String r10 = "Peek source is invalid because upstream source was used"
            r9.<init>(r10)
            throw r9
        L76:
            java.lang.IllegalStateException r9 = new java.lang.IllegalStateException
            java.lang.String r10 = "closed"
            r9.<init>(r10)
            throw r9
        L7e:
            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: okio.v.read(okio.f, long):long");
    }

    @Override // okio.E
    public F timeout() {
        return this.f6057H.timeout();
    }
}