package okio;

import java.util.zip.Deflater;

/* JADX INFO: loaded from: classes2.dex */
public final class j implements C {

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

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

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    private final Deflater f6038r;

    public j(g sink, Deflater deflater) {
        kotlin.jvm.internal.l.e(sink, "sink");
        kotlin.jvm.internal.l.e(deflater, "deflater");
        this.f6037g = sink;
        this.f6038r = deflater;
    }

    private final void a(boolean z2) {
        y yVarK;
        int iDeflate;
        C0688f buffer = this.f6037g.getBuffer();
        while (true) {
            yVarK = buffer.K(1);
            if (z2) {
                Deflater deflater = this.f6038r;
                byte[] bArr = yVarK.f6071a;
                int i2 = yVarK.f6073c;
                iDeflate = deflater.deflate(bArr, i2, 8192 - i2, 2);
            } else {
                Deflater deflater2 = this.f6038r;
                byte[] bArr2 = yVarK.f6071a;
                int i3 = yVarK.f6073c;
                iDeflate = deflater2.deflate(bArr2, i3, 8192 - i3);
            }
            if (iDeflate > 0) {
                yVarK.f6073c += iDeflate;
                buffer.F(buffer.G() + ((long) iDeflate));
                this.f6037g.emitCompleteSegments();
            } else if (this.f6038r.needsInput()) {
                break;
            }
        }
        if (yVarK.f6072b == yVarK.f6073c) {
            buffer.f6021b = yVarK.b();
            A.b(yVarK);
        }
    }

    public final void b() {
        this.f6038r.finish();
        a(false);
    }

    @Override // okio.C, java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel
    public void close() throws Throwable {
        if (this.f6036b) {
            return;
        }
        try {
            b();
            th = null;
        } catch (Throwable th) {
            th = th;
        }
        try {
            this.f6038r.end();
        } catch (Throwable th2) {
            if (th == null) {
                th = th2;
            }
        }
        try {
            this.f6037g.close();
        } catch (Throwable th3) {
            if (th == null) {
                th = th3;
            }
        }
        this.f6036b = true;
        if (th != null) {
            throw th;
        }
    }

    @Override // okio.C, java.io.Flushable
    public void flush() {
        a(true);
        this.f6037g.flush();
    }

    @Override // okio.C
    public F timeout() {
        return this.f6037g.timeout();
    }

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

    @Override // okio.C
    public void write(C0688f source, long j2) {
        kotlin.jvm.internal.l.e(source, "source");
        AbstractC0685c.b(source.G(), 0L, j2);
        while (j2 > 0) {
            y yVar = source.f6021b;
            kotlin.jvm.internal.l.b(yVar);
            int iMin = (int) Math.min(j2, yVar.f6073c - yVar.f6072b);
            this.f6038r.setInput(yVar.f6071a, yVar.f6072b, iMin);
            a(false);
            long j3 = iMin;
            source.F(source.G() - j3);
            int i2 = yVar.f6072b + iMin;
            yVar.f6072b = i2;
            if (i2 == yVar.f6073c) {
                source.f6021b = yVar.b();
                A.b(yVar);
            }
            j2 -= j3;
        }
    }

    /* JADX WARN: 'this' call moved to the top of the method (can break code semantics) */
    public j(C sink, Deflater deflater) {
        this(q.c(sink), deflater);
        kotlin.jvm.internal.l.e(sink, "sink");
        kotlin.jvm.internal.l.e(deflater, "deflater");
    }
}