package defpackage;

import androidx.media3.container.NalUnitUtil;
import java.io.IOException;
import java.util.zip.Deflater;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Ld32;", "Lmv8;", "okio"}, k = 1, mv = {1, 9, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class d32 implements mv8 {
    public final su7 a;
    public final Deflater b;
    public boolean c;

    public d32(lg0 lg0Var, Deflater deflater) {
        this.a = eu6.c(lg0Var);
        this.b = deflater;
    }

    public final void a(boolean z) throws IOException {
        me8 me8VarAf;
        int iDeflate;
        su7 su7Var = this.a;
        lg0 lg0Var = su7Var.b;
        while (true) {
            me8VarAf = lg0Var.af(1);
            byte[] bArr = me8VarAf.a;
            Deflater deflater = this.b;
            if (z) {
                try {
                    int i = me8VarAf.c;
                    iDeflate = deflater.deflate(bArr, i, 8192 - i, 2);
                } catch (NullPointerException e) {
                    throw new IOException("Deflater already closed", e);
                }
            } else {
                int i2 = me8VarAf.c;
                iDeflate = deflater.deflate(bArr, i2, 8192 - i2);
            }
            if (iDeflate > 0) {
                me8VarAf.c += iDeflate;
                lg0Var.b += (long) iDeflate;
                su7Var.v();
            } else if (deflater.needsInput()) {
                break;
            }
        }
        if (me8VarAf.b == me8VarAf.c) {
            lg0Var.a = me8VarAf.a();
            te8.a(me8VarAf);
        }
    }

    @Override // defpackage.mv8, java.io.Closeable, java.lang.AutoCloseable
    public final void close() throws Throwable {
        Deflater deflater = this.b;
        if (this.c) {
            return;
        }
        try {
            deflater.finish();
            a(false);
            th = null;
        } catch (Throwable th) {
            th = th;
        }
        try {
            deflater.end();
        } catch (Throwable th2) {
            if (th == null) {
                th = th2;
            }
        }
        try {
            this.a.close();
        } catch (Throwable th3) {
            if (th == null) {
                th = th3;
            }
        }
        this.c = true;
        if (th != null) {
            throw th;
        }
    }

    @Override // defpackage.mv8, java.io.Flushable
    public final void flush() throws IOException {
        a(true);
        this.a.flush();
    }

    @Override // defpackage.mv8
    /* JADX INFO: renamed from: timeout */
    public final ko9 getB() {
        return this.a.a.getB();
    }

    public final String toString() {
        return "DeflaterSink(" + this.a + ')';
    }

    @Override // defpackage.mv8
    public final void write(lg0 lg0Var, long j) throws IOException {
        cr4.g(lg0Var, "source");
        C0696t.b(lg0Var.b, 0L, j);
        while (j > 0) {
            me8 me8Var = lg0Var.a;
            cr4.d(me8Var);
            int iMin = (int) Math.min(j, me8Var.c - me8Var.b);
            this.b.setInput(me8Var.a, me8Var.b, iMin);
            a(false);
            long j2 = iMin;
            lg0Var.b -= j2;
            int i = me8Var.b + iMin;
            me8Var.b = i;
            if (i == me8Var.c) {
                lg0Var.a = me8Var.a();
                te8.a(me8Var);
            }
            j -= j2;
        }
    }
}