package kotlinx.coroutines.internal;

import java.util.Arrays;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import kotlinx.coroutines.n0;
import kotlinx.coroutines.o0;

/* JADX INFO: loaded from: classes.dex */
public class y {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f29498b = AtomicIntegerFieldUpdater.newUpdater(y.class, "_size$volatile");
    private volatile /* synthetic */ int _size$volatile;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public n0[] f29499a;

    public final void a(n0 n0Var) {
        n0Var.d((o0) this);
        n0[] n0VarArr = this.f29499a;
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f29498b;
        if (n0VarArr == null) {
            n0VarArr = new n0[4];
            this.f29499a = n0VarArr;
        } else if (atomicIntegerFieldUpdater.get(this) >= n0VarArr.length) {
            Object[] objArrCopyOf = Arrays.copyOf(n0VarArr, atomicIntegerFieldUpdater.get(this) * 2);
            nb.g.h(objArrCopyOf, "copyOf(...)");
            n0VarArr = (n0[]) objArrCopyOf;
            this.f29499a = n0VarArr;
        }
        int i10 = atomicIntegerFieldUpdater.get(this);
        atomicIntegerFieldUpdater.set(this, i10 + 1);
        n0VarArr[i10] = n0Var;
        n0Var.f29512b = i10;
        c(i10);
    }

    /* JADX WARN: Removed duplicated region for block: B:17:0x0063  */
    /* JADX WARN: Removed duplicated region for block: B:26:? A[SYNTHETIC] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final n0 b(int i10) {
        Object[] objArr = this.f29499a;
        nb.g.f(objArr);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f29498b;
        atomicIntegerFieldUpdater.set(this, atomicIntegerFieldUpdater.get(this) - 1);
        if (i10 < atomicIntegerFieldUpdater.get(this)) {
            d(i10, atomicIntegerFieldUpdater.get(this));
            int i11 = (i10 - 1) / 2;
            if (i10 > 0) {
                n0 n0Var = objArr[i10];
                nb.g.f(n0Var);
                Object obj = objArr[i11];
                nb.g.f(obj);
                if (n0Var.compareTo(obj) < 0) {
                    d(i10, i11);
                    c(i11);
                } else {
                    while (true) {
                        int i12 = i10 * 2;
                        int i13 = i12 + 1;
                        if (i13 >= atomicIntegerFieldUpdater.get(this)) {
                            break;
                        }
                        Object[] objArr2 = this.f29499a;
                        nb.g.f(objArr2);
                        int i14 = i12 + 2;
                        if (i14 < atomicIntegerFieldUpdater.get(this)) {
                            Comparable comparable = objArr2[i14];
                            nb.g.f(comparable);
                            Object obj2 = objArr2[i13];
                            nb.g.f(obj2);
                            if (comparable.compareTo(obj2) >= 0) {
                                i14 = i13;
                            }
                            Comparable comparable2 = objArr2[i10];
                            nb.g.f(comparable2);
                            Comparable comparable3 = objArr2[i14];
                            nb.g.f(comparable3);
                            if (comparable2.compareTo(comparable3) <= 0) {
                                break;
                            }
                            d(i10, i14);
                            i10 = i14;
                        }
                    }
                }
            }
        }
        n0 n0Var2 = objArr[atomicIntegerFieldUpdater.get(this)];
        nb.g.f(n0Var2);
        n0Var2.d(null);
        n0Var2.f29512b = -1;
        objArr[atomicIntegerFieldUpdater.get(this)] = null;
        return n0Var2;
    }

    public final void c(int i10) {
        while (i10 > 0) {
            n0[] n0VarArr = this.f29499a;
            nb.g.f(n0VarArr);
            int i11 = (i10 - 1) / 2;
            n0 n0Var = n0VarArr[i11];
            nb.g.f(n0Var);
            n0 n0Var2 = n0VarArr[i10];
            nb.g.f(n0Var2);
            if (n0Var.compareTo(n0Var2) <= 0) {
                return;
            }
            d(i10, i11);
            i10 = i11;
        }
    }

    public final void d(int i10, int i11) {
        n0[] n0VarArr = this.f29499a;
        nb.g.f(n0VarArr);
        n0 n0Var = n0VarArr[i11];
        nb.g.f(n0Var);
        n0 n0Var2 = n0VarArr[i10];
        nb.g.f(n0Var2);
        n0VarArr[i10] = n0Var;
        n0VarArr[i11] = n0Var2;
        n0Var.f29512b = i10;
        n0Var2.f29512b = i11;
    }
}