package r7;

import x7.C1731g;
import x7.F;
import x7.J;

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

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final boolean f16674q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final C1731g f16675r = new C1731g();

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

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public final /* synthetic */ w f16677t;

    public t(w wVar, boolean z8) {
        this.f16677t = wVar;
        this.f16674q = z8;
    }

    @Override // x7.F
    public final void X(C1731g c1731g, long j8) {
        P6.g.e(c1731g, "source");
        byte[] bArr = l7.b.f14412a;
        C1731g c1731g2 = this.f16675r;
        c1731g2.X(c1731g, j8);
        while (c1731g2.f18765r >= 16384) {
            a(false);
        }
    }

    /* JADX WARN: Finally extract failed */
    public final void a(boolean z8) {
        long jMin;
        boolean z9;
        w wVar = this.f16677t;
        synchronized (wVar) {
            wVar.f16695l.h();
            while (wVar.f16689e >= wVar.f16690f && !this.f16674q && !this.f16676s && wVar.f() == 0) {
                try {
                    wVar.l();
                } catch (Throwable th) {
                    wVar.f16695l.k();
                    throw th;
                }
            }
            wVar.f16695l.k();
            wVar.b();
            jMin = Math.min(wVar.f16690f - wVar.f16689e, this.f16675r.f18765r);
            wVar.f16689e += jMin;
            z9 = z8 && jMin == this.f16675r.f18765r;
        }
        this.f16677t.f16695l.h();
        try {
            w wVar2 = this.f16677t;
            wVar2.f16686b.r(wVar2.f16685a, z9, this.f16675r, jMin);
        } finally {
            this.f16677t.f16695l.k();
        }
    }

    @Override // x7.F, java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        w wVar = this.f16677t;
        byte[] bArr = l7.b.f14412a;
        synchronized (wVar) {
            if (this.f16676s) {
                return;
            }
            boolean z8 = wVar.f() == 0;
            w wVar2 = this.f16677t;
            if (!wVar2.f16693j.f16674q) {
                if (this.f16675r.f18765r > 0) {
                    while (this.f16675r.f18765r > 0) {
                        a(true);
                    }
                } else if (z8) {
                    wVar2.f16686b.r(wVar2.f16685a, true, null, 0L);
                }
            }
            synchronized (this.f16677t) {
                this.f16676s = true;
            }
            this.f16677t.f16686b.flush();
            this.f16677t.a();
        }
    }

    @Override // x7.F
    public final J f() {
        return this.f16677t.f16695l;
    }

    @Override // x7.F, java.io.Flushable
    public final void flush() {
        w wVar = this.f16677t;
        byte[] bArr = l7.b.f14412a;
        synchronized (wVar) {
            wVar.b();
        }
        while (this.f16675r.f18765r > 0) {
            a(false);
            this.f16677t.f16686b.flush();
        }
    }
}