package defpackage;

import androidx.media3.container.NalUnitUtil;
import defpackage.cq2;
import defpackage.km9;
import java.lang.Comparable;
import java.util.Arrays;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@gq4
@Metadata(d1 = {"\u0000\u001e\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000f\n\u0000\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0017\u0018\u0000*\u0012\b\u0000\u0010\u0003*\u00020\u0001*\b\u0012\u0004\u0012\u00028\u00000\u00022\u00060\u0004j\u0002`\u0005R\u000b\u0010\u0007\u001a\u00020\u00068\u0002X\u0082\u0004¨\u0006\b"}, d2 = {"Ljm9;", "Lkm9;", "", "T", "", "Lkotlinx/coroutines/internal/SynchronizedObject;", "Lnw;", "_size", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public class jm9<T extends km9 & Comparable<? super T>> {
    public static final /* synthetic */ AtomicIntegerFieldUpdater b = AtomicIntegerFieldUpdater.newUpdater(jm9.class, "_size$volatile");
    private volatile /* synthetic */ int _size$volatile;
    public km9[] a;

    public final void a(cq2.c cVar) {
        cVar.b((cq2.d) this);
        km9[] km9VarArr = this.a;
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = b;
        if (km9VarArr == null) {
            km9VarArr = new km9[4];
            this.a = km9VarArr;
        } else if (atomicIntegerFieldUpdater.get(this) >= km9VarArr.length) {
            Object[] objArrCopyOf = Arrays.copyOf(km9VarArr, atomicIntegerFieldUpdater.get(this) * 2);
            cr4.f(objArrCopyOf, "copyOf(...)");
            km9VarArr = (km9[]) objArrCopyOf;
            this.a = km9VarArr;
        }
        int i = atomicIntegerFieldUpdater.get(this);
        atomicIntegerFieldUpdater.set(this, i + 1);
        km9VarArr[i] = cVar;
        cVar.b = i;
        c(i);
    }

    /* JADX WARN: Removed duplicated region for block: B:17:0x0067  */
    /* JADX WARN: Removed duplicated region for block: B:26:? A[SYNTHETIC] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final km9 b(int i) {
        km9[] km9VarArr = this.a;
        cr4.d(km9VarArr);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = b;
        atomicIntegerFieldUpdater.set(this, atomicIntegerFieldUpdater.get(this) - 1);
        if (i < atomicIntegerFieldUpdater.get(this)) {
            d(i, atomicIntegerFieldUpdater.get(this));
            int i2 = (i - 1) / 2;
            if (i > 0) {
                km9 km9Var = km9VarArr[i];
                cr4.d(km9Var);
                km9 km9Var2 = km9VarArr[i2];
                cr4.d(km9Var2);
                if (((Comparable) km9Var).compareTo(km9Var2) < 0) {
                    d(i, i2);
                    c(i2);
                } else {
                    while (true) {
                        int i3 = i * 2;
                        int i4 = i3 + 1;
                        if (i4 >= atomicIntegerFieldUpdater.get(this)) {
                            break;
                        }
                        km9[] km9VarArr2 = this.a;
                        cr4.d(km9VarArr2);
                        int i5 = i3 + 2;
                        if (i5 < atomicIntegerFieldUpdater.get(this)) {
                            km9 km9Var3 = km9VarArr2[i5];
                            cr4.d(km9Var3);
                            km9 km9Var4 = km9VarArr2[i4];
                            cr4.d(km9Var4);
                            if (((Comparable) km9Var3).compareTo(km9Var4) >= 0) {
                                i5 = i4;
                            }
                            km9 km9Var5 = km9VarArr2[i];
                            cr4.d(km9Var5);
                            km9 km9Var6 = km9VarArr2[i5];
                            cr4.d(km9Var6);
                            if (((Comparable) km9Var5).compareTo(km9Var6) <= 0) {
                                break;
                            }
                            d(i, i5);
                            i = i5;
                        }
                    }
                }
            }
        }
        km9 km9Var7 = km9VarArr[atomicIntegerFieldUpdater.get(this)];
        cr4.d(km9Var7);
        km9Var7.b(null);
        km9Var7.setIndex(-1);
        km9VarArr[atomicIntegerFieldUpdater.get(this)] = null;
        return km9Var7;
    }

    public final void c(int i) {
        while (i > 0) {
            km9[] km9VarArr = this.a;
            cr4.d(km9VarArr);
            int i2 = (i - 1) / 2;
            km9 km9Var = km9VarArr[i2];
            cr4.d(km9Var);
            km9 km9Var2 = km9VarArr[i];
            cr4.d(km9Var2);
            if (((Comparable) km9Var).compareTo(km9Var2) <= 0) {
                return;
            }
            d(i, i2);
            i = i2;
        }
    }

    public final void d(int i, int i2) {
        km9[] km9VarArr = this.a;
        cr4.d(km9VarArr);
        km9 km9Var = km9VarArr[i2];
        cr4.d(km9Var);
        km9 km9Var2 = km9VarArr[i];
        cr4.d(km9Var2);
        km9VarArr[i] = km9Var;
        km9VarArr[i2] = km9Var2;
        km9Var.setIndex(i);
        km9Var2.setIndex(i2);
    }
}