package defpackage;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import sun.misc.Unsafe;

/* renamed from: ᵝˎˉ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C2893 extends C1679 implements InterfaceC2628 {

    /* renamed from: ˎˑː, reason: contains not printable characters */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f11251 = AtomicReferenceFieldUpdater.newUpdater(C2893.class, Object.class, "owner$volatile");

    /* renamed from: ᵮᵠـˌ, reason: contains not printable characters */
    public static final /* synthetic */ long f11252 = AbstractC3747.f13986.objectFieldOffset(C2893.class.getDeclaredField("owner$volatile"));
    private volatile /* synthetic */ Object owner$volatile;

    public C2893() {
        super(1);
        this.owner$volatile = AbstractC2231.f8754;
    }

    public final String toString() {
        StringBuilder sb = new StringBuilder("Mutex@");
        sb.append(ˁـᵛ.ᵳٴᵶ(this));
        sb.append("[isLocked=");
        sb.append(mo6602());
        sb.append(",owner=");
        f11251.getClass();
        sb.append(AbstractC3747.f13986.getObjectVolatile(this, f11252));
        sb.append(']');
        return sb.toString();
    }

    @Override // defpackage.InterfaceC2628
    /* renamed from: ˌʾˀ */
    public final void mo6601(Object obj) {
        while (this.mo6602()) {
            f11251.getClass();
            Unsafe unsafe = AbstractC3747.f13986;
            long j = f11252;
            Object objectVolatile = unsafe.getObjectVolatile(this, j);
            C0434 c0434 = AbstractC2231.f8754;
            if (objectVolatile != c0434) {
                if (objectVolatile != obj && obj != null) {
                    throw new IllegalStateException(("This mutex is locked by " + objectVolatile + ", but " + obj + " is expected").toString());
                }
                while (true) {
                    Unsafe unsafe2 = AbstractC3747.f13986;
                    C2893 c2893 = this;
                    if (unsafe2.compareAndSwapObject(c2893, f11252, objectVolatile, c0434)) {
                        c2893.m4810();
                        return;
                    } else {
                        if (unsafe2.getObjectVolatile(c2893, j) != objectVolatile) {
                            this = c2893;
                            break;
                        }
                        this = c2893;
                    }
                }
            }
        }
        ᵹˉᵞ.ᵳٴᵶ("This mutex is not locked");
    }

    /* renamed from: ˎˏʜʾ, reason: contains not printable characters */
    public final boolean m7059() {
        int iM7060 = m7060();
        if (iM7060 == 0) {
            return true;
        }
        if (iM7060 == 1) {
            return false;
        }
        if (iM7060 == 2) {
            throw new IllegalStateException("This mutex is already locked by the specified owner: null".toString());
        }
        ᵹˉᵞ.ᵳٴᵶ("unexpected");
        return false;
    }

    @Override // defpackage.InterfaceC2628
    /* renamed from: ˏᵙ */
    public final boolean mo6602() {
        return Math.max(C1679.f6690.get(this), 0) == 0;
    }

    /* JADX WARN: Code restructure failed: missing block: B:10:0x0022, code lost:
    
        r5 = defpackage.C2893.f11251;
        r2 = r0.f2605;
        r5.set(r2, null);
        r5 = r0.f2606;
        r5.m9404(r1, r5.f18326, new ˇʖᵲᵪ(1, new ᵡᵘˎʽ(r2, r0)));
     */
    @Override // defpackage.InterfaceC2628
    /* renamed from: ᵥᵯˎ */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final java.lang.Object mo6603(defpackage.AbstractC1989 r6) {
        /*
            r5 = this;
            boolean r0 = r5.m7059()
            ᵧˈᵽᵰ r1 = defpackage.C3637.f13536
            if (r0 == 0) goto L9
            goto L50
        L9:
            ᵸʚˑ r6 = ᵱᵞᵪ.ᵞʡ(r6)
            ᵱʽ r6 = ˁـᵛ.ᵡʠ(r6)
            ʿﾞ r0 = new ʿﾞ     // Catch: java.lang.Throwable -> L51
            r0.<init>(r5, r6)     // Catch: java.lang.Throwable -> L51
        L16:
            java.util.concurrent.atomic.AtomicIntegerFieldUpdater r2 = defpackage.C1679.f6690     // Catch: java.lang.Throwable -> L51
            int r2 = r2.getAndDecrement(r5)     // Catch: java.lang.Throwable -> L51
            int r3 = r5.f6698     // Catch: java.lang.Throwable -> L51
            if (r2 > r3) goto L16
            if (r2 <= 0) goto L3d
            java.util.concurrent.atomic.AtomicReferenceFieldUpdater r5 = defpackage.C2893.f11251     // Catch: java.lang.Throwable -> L51
            ᵝˎˉ r2 = r0.f2605     // Catch: java.lang.Throwable -> L51
            r3 = 0
            r5.set(r2, r3)     // Catch: java.lang.Throwable -> L51
            ᵱʽ r5 = r0.f2606     // Catch: java.lang.Throwable -> L51
            ᵡᵘˎʽ r3 = new ᵡᵘˎʽ     // Catch: java.lang.Throwable -> L51
            r3.<init>(r2, r0)     // Catch: java.lang.Throwable -> L51
            int r0 = r5.f18326     // Catch: java.lang.Throwable -> L51
            ˇʖᵲᵪ r2 = new ˇʖᵲᵪ     // Catch: java.lang.Throwable -> L51
            r4 = 1
            r2.<init>(r4, r3)     // Catch: java.lang.Throwable -> L51
            r5.m9404(r1, r0, r2)     // Catch: java.lang.Throwable -> L51
            goto L43
        L3d:
            boolean r2 = r5.m4813(r0)     // Catch: java.lang.Throwable -> L51
            if (r2 == 0) goto L16
        L43:
            java.lang.Object r5 = r6.m9405()
            ᵣˊᵛ r6 = defpackage.EnumC3346.f12524
            if (r5 != r6) goto L4c
            goto L4d
        L4c:
            r5 = r1
        L4d:
            if (r5 != r6) goto L50
            return r5
        L50:
            return r1
        L51:
            r5 = move-exception
            r6.m9396()
            throw r5
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C2893.mo6603(ːᵱ):java.lang.Object");
    }

    /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */
    public final int m7060() {
        int i;
        while (true) {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = C1679.f6690;
            int i2 = atomicIntegerFieldUpdater.get(this);
            int i3 = this.f6698;
            if (i2 > i3) {
                do {
                    i = atomicIntegerFieldUpdater.get(this);
                    if (i > i3) {
                    }
                } while (!atomicIntegerFieldUpdater.compareAndSet(this, i, i3));
            } else {
                if (i2 <= 0) {
                    return 1;
                }
                if (atomicIntegerFieldUpdater.compareAndSet(this, i2, i2 - 1)) {
                    f11251.getClass();
                    AbstractC3747.f13986.putObjectVolatile(this, f11252, (Object) null);
                    return 0;
                }
            }
        }
    }
}