package J4;

import B4.A;
import B4.C0015k;
import G4.t;
import d4.C0550i;
import i4.EnumC0643a;
import j4.AbstractC0801c;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: loaded from: classes.dex */
public final class e extends i implements a {

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f1035g = AtomicReferenceFieldUpdater.newUpdater(e.class, Object.class, "owner$volatile");
    private volatile /* synthetic */ Object owner$volatile = f.f1036a;

    public final Object c(AbstractC0801c abstractC0801c) {
        boolean zD = d();
        C0550i c0550i = C0550i.f6143a;
        if (!zD) {
            C0015k c0015kE = A.e(S4.d.w(abstractC0801c));
            try {
                a(new d(this, c0015kE));
                Object objQ = c0015kE.q();
                EnumC0643a enumC0643a = EnumC0643a.f6670k;
                if (objQ != enumC0643a) {
                    objQ = c0550i;
                }
                if (objQ == enumC0643a) {
                    return objQ;
                }
            } catch (Throwable th) {
                c0015kE.x();
                throw th;
            }
        }
        return c0550i;
    }

    public final boolean d() {
        int i;
        char c6;
        while (true) {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = i.f1043f;
            int i5 = atomicIntegerFieldUpdater.get(this);
            if (i5 > 1) {
                do {
                    i = atomicIntegerFieldUpdater.get(this);
                    if (i > 1) {
                    }
                } while (!atomicIntegerFieldUpdater.compareAndSet(this, i, 1));
            } else {
                if (i5 <= 0) {
                    c6 = 1;
                    break;
                }
                if (atomicIntegerFieldUpdater.compareAndSet(this, i5, i5 - 1)) {
                    f1035g.set(this, null);
                    c6 = 0;
                    break;
                }
            }
        }
        if (c6 == 0) {
            return true;
        }
        if (c6 == 1) {
            return false;
        }
        if (c6 != 2) {
            throw new IllegalStateException("unexpected");
        }
        throw new IllegalStateException("This mutex is already locked by the specified owner: null".toString());
    }

    public final void e(Object obj) {
        while (Math.max(i.f1043f.get(this), 0) == 0) {
            AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f1035g;
            Object obj2 = atomicReferenceFieldUpdater.get(this);
            t tVar = f.f1036a;
            if (obj2 != tVar) {
                if (obj2 == obj || obj == null) {
                    while (!atomicReferenceFieldUpdater.compareAndSet(this, obj2, tVar)) {
                        if (atomicReferenceFieldUpdater.get(this) != obj2) {
                            break;
                        }
                    }
                    b();
                    return;
                }
                throw new IllegalStateException(("This mutex is locked by " + obj2 + ", but " + obj + " is expected").toString());
            }
        }
        throw new IllegalStateException("This mutex is not locked");
    }

    public final String toString() {
        StringBuilder sb = new StringBuilder("Mutex@");
        sb.append(A.d(this));
        sb.append("[isLocked=");
        sb.append(Math.max(i.f1043f.get(this), 0) == 0);
        sb.append(",owner=");
        sb.append(f1035g.get(this));
        sb.append(']');
        return sb.toString();
    }
}