package defpackage;

import androidx.media3.container.NalUnitUtil;
import java.nio.ByteBuffer;
import java.util.zip.CRC32;
import java.util.zip.Deflater;
import kotlin.Metadata;
import kotlin.coroutines.jvm.internal.ContinuationImpl;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\u0002\n\u0000¨\u0006\u0000"}, d2 = {"ktor-utils"}, k = 2, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class c32 {
    public static final byte[] a = new byte[7];

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object a(gp0 gp0Var, Deflater deflater, ByteBuffer byteBuffer, qq3 qq3Var, ContinuationImpl continuationImpl) {
        x22 x22Var;
        if (continuationImpl instanceof x22) {
            x22Var = (x22) continuationImpl;
            int i = x22Var.f;
            if ((i & Integer.MIN_VALUE) != 0) {
                x22Var.f = i - Integer.MIN_VALUE;
            } else {
                x22Var = new x22(continuationImpl);
            }
        }
        Object obj = x22Var.e;
        ck1 ck1Var = ck1.a;
        int i2 = x22Var.f;
        if (i2 == 0) {
            s38.b(obj);
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            qq3 qq3Var2 = x22Var.d;
            ByteBuffer byteBuffer2 = x22Var.c;
            Deflater deflater2 = x22Var.b;
            gp0 gp0Var2 = x22Var.a;
            s38.b(obj);
            qq3Var = qq3Var2;
            gp0Var = gp0Var2;
            byteBuffer = byteBuffer2;
            deflater = deflater2;
        }
        while (((Boolean) qq3Var.invoke()).booleanValue()) {
            byteBuffer.clear();
            if (byteBuffer.hasRemaining()) {
                byteBuffer.position(byteBuffer.position() + deflater.deflate(byteBuffer.array(), byteBuffer.position() + byteBuffer.arrayOffset(), byteBuffer.remaining()));
            }
            byteBuffer.flip();
            x22Var.a = gp0Var;
            x22Var.b = deflater;
            x22Var.c = byteBuffer;
            x22Var.d = qq3Var;
            x22Var.f = 1;
            nv8 nv8VarF = gp0Var.f();
            cr4.g(nv8VarF, "<this>");
            cr4.g(byteBuffer, "bb");
            long j = nv8VarF.getC().c;
            mg0 c = nv8VarF.getC();
            cr4.g(c, "<this>");
            cr4.g(byteBuffer, "source");
            int iRemaining = byteBuffer.remaining();
            while (iRemaining > 0) {
                le8 le8VarK = c.k(1);
                byte[] bArr = le8VarK.a;
                int i3 = le8VarK.c;
                int iMin = Math.min(iRemaining, bArr.length - i3);
                byteBuffer.get(bArr, i3, iMin);
                iRemaining -= iMin;
                if (iMin == 1) {
                    le8VarK.c += iMin;
                    c.c += (long) iMin;
                } else {
                    if (iMin < 0 || iMin > le8VarK.a()) {
                        StringBuilder sbJ = fi7.j(iMin, "Invalid number of bytes written: ", ". Should be in 0..");
                        sbJ.append(le8VarK.a());
                        throw new IllegalStateException(sbJ.toString().toString());
                    }
                    if (iMin != 0) {
                        le8VarK.c += iMin;
                        c.c += (long) iMin;
                    } else if (qe8.a(le8VarK)) {
                        c.d();
                    }
                }
            }
            long j2 = nv8VarF.getC().c;
            nv8VarF.ag();
            Object objB = gp0Var.b(x22Var);
            if (objB != ck1.a) {
                objB = e6a.a;
            }
            if (objB == ck1Var) {
                return ck1Var;
            }
        }
        return e6a.a;
    }

    /* JADX WARN: Code restructure failed: missing block: B:20:0x0066, code lost:
    
        if (defpackage.kp0.d(r7, r8, r0) == r1) goto L21;
     */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object b(gp0 gp0Var, CRC32 crc32, Deflater deflater, ContinuationImpl continuationImpl) {
        b32 b32Var;
        if (continuationImpl instanceof b32) {
            b32Var = (b32) continuationImpl;
            int i = b32Var.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                b32Var.d = i - Integer.MIN_VALUE;
            } else {
                b32Var = new b32(continuationImpl);
            }
        }
        Object obj = b32Var.c;
        ck1 ck1Var = ck1.a;
        int i2 = b32Var.d;
        if (i2 == 0) {
            s38.b(obj);
            int iReverseBytes = Integer.reverseBytes((int) crc32.getValue());
            b32Var.a = gp0Var;
            b32Var.b = deflater;
            b32Var.d = 1;
            if (kp0.d(gp0Var, iReverseBytes, b32Var) != ck1Var) {
            }
            return ck1Var;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s38.b(obj);
            return e6a.a;
        }
        deflater = b32Var.b;
        gp0Var = b32Var.a;
        s38.b(obj);
        int iReverseBytes2 = Integer.reverseBytes(deflater.getTotalIn());
        b32Var.a = null;
        b32Var.b = null;
        b32Var.d = 2;
    }
}