package kotlinx.coroutines.internal;

import java.util.Arrays;

/* JADX INFO: loaded from: classes.dex */
public abstract class w {
    private volatile /* synthetic */ int _size = 0;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private x[] f5183a;

    private final x[] f() {
        x[] xVarArr = this.f5183a;
        if (xVarArr == null) {
            x[] xVarArr2 = new x[4];
            this.f5183a = xVarArr2;
            return xVarArr2;
        }
        if (c() < xVarArr.length) {
            return xVarArr;
        }
        Object[] objArrCopyOf = Arrays.copyOf(xVarArr, c() * 2);
        kotlin.jvm.internal.l.d(objArrCopyOf, "java.util.Arrays.copyOf(this, newSize)");
        x[] xVarArr3 = (x[]) objArrCopyOf;
        this.f5183a = xVarArr3;
        return xVarArr3;
    }

    private final void j(int i2) {
        this._size = i2;
    }

    /* JADX WARN: Removed duplicated region for block: B:10:0x002b  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    private final void k(int r6) {
        /*
            r5 = this;
        L0:
            int r0 = r6 * 2
            int r1 = r0 + 1
            int r2 = r5.c()
            if (r1 < r2) goto Lb
            return
        Lb:
            kotlinx.coroutines.internal.x[] r2 = r5.f5183a
            kotlin.jvm.internal.l.b(r2)
            int r0 = r0 + 2
            int r3 = r5.c()
            if (r0 >= r3) goto L2b
            r3 = r2[r0]
            kotlin.jvm.internal.l.b(r3)
            java.lang.Comparable r3 = (java.lang.Comparable) r3
            r4 = r2[r1]
            kotlin.jvm.internal.l.b(r4)
            int r3 = r3.compareTo(r4)
            if (r3 >= 0) goto L2b
            goto L2c
        L2b:
            r0 = r1
        L2c:
            r1 = r2[r6]
            kotlin.jvm.internal.l.b(r1)
            java.lang.Comparable r1 = (java.lang.Comparable) r1
            r2 = r2[r0]
            kotlin.jvm.internal.l.b(r2)
            int r1 = r1.compareTo(r2)
            if (r1 > 0) goto L3f
            return
        L3f:
            r5.m(r6, r0)
            r6 = r0
            goto L0
        */
        throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.internal.w.k(int):void");
    }

    private final void l(int i2) {
        while (i2 > 0) {
            x[] xVarArr = this.f5183a;
            kotlin.jvm.internal.l.b(xVarArr);
            int i3 = (i2 - 1) / 2;
            x xVar = xVarArr[i3];
            kotlin.jvm.internal.l.b(xVar);
            x xVar2 = xVarArr[i2];
            kotlin.jvm.internal.l.b(xVar2);
            if (((Comparable) xVar).compareTo(xVar2) <= 0) {
                return;
            }
            m(i2, i3);
            i2 = i3;
        }
    }

    private final void m(int i2, int i3) {
        x[] xVarArr = this.f5183a;
        kotlin.jvm.internal.l.b(xVarArr);
        x xVar = xVarArr[i3];
        kotlin.jvm.internal.l.b(xVar);
        x xVar2 = xVarArr[i2];
        kotlin.jvm.internal.l.b(xVar2);
        xVarArr[i2] = xVar;
        xVarArr[i3] = xVar2;
        xVar.d(i2);
        xVar2.d(i3);
    }

    public final void a(x xVar) {
        xVar.a(this);
        x[] xVarArrF = f();
        int iC = c();
        j(iC + 1);
        xVarArrF[iC] = xVar;
        xVar.d(iC);
        l(iC);
    }

    public final x b() {
        x[] xVarArr = this.f5183a;
        if (xVarArr == null) {
            return null;
        }
        return xVarArr[0];
    }

    public final int c() {
        return this._size;
    }

    public final boolean d() {
        return c() == 0;
    }

    public final x e() {
        x xVarB;
        synchronized (this) {
            xVarB = b();
        }
        return xVarB;
    }

    public final boolean g(x xVar) {
        boolean z2;
        synchronized (this) {
            if (xVar.c() == null) {
                z2 = false;
            } else {
                h(xVar.e());
                z2 = true;
            }
        }
        return z2;
    }

    /* JADX WARN: Removed duplicated region for block: B:9:0x003a  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final kotlinx.coroutines.internal.x h(int r6) {
        /*
            r5 = this;
            kotlinx.coroutines.internal.x[] r0 = r5.f5183a
            kotlin.jvm.internal.l.b(r0)
            int r1 = r5.c()
            r2 = -1
            int r1 = r1 + r2
            r5.j(r1)
            int r1 = r5.c()
            if (r6 >= r1) goto L3d
            int r1 = r5.c()
            r5.m(r6, r1)
            int r1 = r6 + (-1)
            int r1 = r1 / 2
            if (r6 <= 0) goto L3a
            r3 = r0[r6]
            kotlin.jvm.internal.l.b(r3)
            java.lang.Comparable r3 = (java.lang.Comparable) r3
            r4 = r0[r1]
            kotlin.jvm.internal.l.b(r4)
            int r3 = r3.compareTo(r4)
            if (r3 >= 0) goto L3a
            r5.m(r6, r1)
            r5.l(r1)
            goto L3d
        L3a:
            r5.k(r6)
        L3d:
            int r6 = r5.c()
            r6 = r0[r6]
            kotlin.jvm.internal.l.b(r6)
            r1 = 0
            r6.a(r1)
            r6.d(r2)
            int r2 = r5.c()
            r0[r2] = r1
            return r6
        */
        throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.internal.w.h(int):kotlinx.coroutines.internal.x");
    }

    public final x i() {
        x xVarH;
        synchronized (this) {
            xVarH = c() > 0 ? h(0) : null;
        }
        return xVarH;
    }
}