package r7;

import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;
import x7.C1731g;
import x7.C1734j;
import x7.H;
import x7.J;

/* JADX INFO: loaded from: classes.dex */
public final class r implements H, AutoCloseable {

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final x7.B f16664q;

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

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

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

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

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

    public r(x7.B b8) {
        P6.g.e(b8, "source");
        this.f16664q = b8;
    }

    @Override // x7.H
    public final long M(C1731g c1731g, long j8) throws IOException {
        int i;
        int iM;
        P6.g.e(c1731g, "sink");
        do {
            int i5 = this.f16668u;
            x7.B b8 = this.f16664q;
            if (i5 == 0) {
                b8.y(this.f16669v);
                this.f16669v = 0;
                if ((this.f16666s & 4) == 0) {
                    i = this.f16667t;
                    int iT = l7.b.t(b8);
                    this.f16668u = iT;
                    this.f16665r = iT;
                    int iG = b8.g() & 255;
                    this.f16666s = b8.g() & 255;
                    Logger logger = s.f16670t;
                    if (logger.isLoggable(Level.FINE)) {
                        C1734j c1734j = f.f16608a;
                        logger.fine(f.a(true, this.f16667t, this.f16665r, iG, this.f16666s));
                    }
                    iM = b8.m() & Integer.MAX_VALUE;
                    this.f16667t = iM;
                    if (iG != 9) {
                        throw new IOException(iG + " != TYPE_CONTINUATION");
                    }
                }
            } else {
                long jM = b8.M(c1731g, Math.min(j8, i5));
                if (jM != -1) {
                    this.f16668u -= (int) jM;
                    return jM;
                }
            }
            return -1L;
        } while (iM == i);
        throw new IOException("TYPE_CONTINUATION streamId changed");
    }

    @Override // x7.H
    public final J f() {
        return this.f16664q.f18724q.f();
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
    }
}