package O1;

import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;
import java.util.logging.Level;
import org.greenrobot.eventbus.ThreadMode;

/* JADX INFO: loaded from: classes2.dex */
public class c {

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    static volatile c f1474s;

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    private static final d f1475t = new d();

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    private static final Map f1476u = new HashMap();

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private final Map f1477a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private final Map f1478b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private final Map f1479c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private final ThreadLocal f1480d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private final h f1481e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private final l f1482f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private final O1.b f1483g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private final O1.a f1484h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private final p f1485i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    private final ExecutorService f1486j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    private final boolean f1487k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    private final boolean f1488l;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    private final boolean f1489m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    private final boolean f1490n;

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    private final boolean f1491o;

    /* JADX INFO: renamed from: p, reason: collision with root package name */
    private final boolean f1492p;

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    private final int f1493q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    private final g f1494r;

    class a extends ThreadLocal {
        a() {
        }

        /* JADX INFO: Access modifiers changed from: protected */
        @Override // java.lang.ThreadLocal
        /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
        public C0030c initialValue() {
            return new C0030c();
        }
    }

    static /* synthetic */ class b {

        /* JADX INFO: renamed from: a, reason: collision with root package name */
        static final /* synthetic */ int[] f1496a;

        static {
            int[] iArr = new int[ThreadMode.values().length];
            f1496a = iArr;
            try {
                iArr[ThreadMode.POSTING.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            try {
                f1496a[ThreadMode.MAIN.ordinal()] = 2;
            } catch (NoSuchFieldError unused2) {
            }
            try {
                f1496a[ThreadMode.MAIN_ORDERED.ordinal()] = 3;
            } catch (NoSuchFieldError unused3) {
            }
            try {
                f1496a[ThreadMode.BACKGROUND.ordinal()] = 4;
            } catch (NoSuchFieldError unused4) {
            }
            try {
                f1496a[ThreadMode.ASYNC.ordinal()] = 5;
            } catch (NoSuchFieldError unused5) {
            }
        }
    }

    /* JADX INFO: renamed from: O1.c$c, reason: collision with other inner class name */
    static final class C0030c {

        /* JADX INFO: renamed from: a, reason: collision with root package name */
        final List f1497a = new ArrayList();

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        boolean f1498b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        boolean f1499c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        q f1500d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        Object f1501e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        boolean f1502f;

        C0030c() {
        }
    }

    public c() {
        this(f1475t);
    }

    static void a(List list, Class[] clsArr) {
        for (Class cls : clsArr) {
            if (!list.contains(cls)) {
                list.add(cls);
                a(list, cls.getInterfaces());
            }
        }
    }

    private void b(q qVar, Object obj) {
        if (obj != null) {
            p(qVar, obj, i());
        }
    }

    public static c c() {
        if (f1474s == null) {
            synchronized (c.class) {
                try {
                    if (f1474s == null) {
                        f1474s = new c();
                    }
                } finally {
                }
            }
        }
        return f1474s;
    }

    private void f(q qVar, Object obj, Throwable th) {
        if (!(obj instanceof n)) {
            if (this.f1487k) {
                throw new e("Invoking subscriber failed", th);
            }
            if (this.f1488l) {
                this.f1494r.b(Level.SEVERE, "Could not dispatch event: " + obj.getClass() + " to subscribing class " + qVar.f1553a.getClass(), th);
            }
            if (this.f1490n) {
                l(new n(this, th, obj, qVar.f1553a));
                return;
            }
            return;
        }
        if (this.f1488l) {
            g gVar = this.f1494r;
            Level level = Level.SEVERE;
            gVar.b(level, "SubscriberExceptionEvent subscriber " + qVar.f1553a.getClass() + " threw an exception", th);
            n nVar = (n) obj;
            this.f1494r.b(level, "Initial event " + nVar.f1533c + " caused exception in " + nVar.f1534d, nVar.f1532b);
        }
    }

    private boolean i() {
        h hVar = this.f1481e;
        if (hVar != null) {
            return hVar.b();
        }
        return true;
    }

    private static List k(Class cls) {
        List arrayList;
        Map map = f1476u;
        synchronized (map) {
            try {
                arrayList = (List) map.get(cls);
                if (arrayList == null) {
                    arrayList = new ArrayList();
                    for (Class superclass = cls; superclass != null; superclass = superclass.getSuperclass()) {
                        arrayList.add(superclass);
                        a(arrayList, superclass.getInterfaces());
                    }
                    f1476u.put(cls, arrayList);
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        return arrayList;
    }

    private void m(Object obj, C0030c c0030c) {
        boolean zN;
        Class<?> cls = obj.getClass();
        if (this.f1492p) {
            List listK = k(cls);
            int size = listK.size();
            zN = false;
            for (int i2 = 0; i2 < size; i2++) {
                zN |= n(obj, c0030c, (Class) listK.get(i2));
            }
        } else {
            zN = n(obj, c0030c, cls);
        }
        if (zN) {
            return;
        }
        if (this.f1489m) {
            this.f1494r.a(Level.FINE, "No subscribers registered for event " + cls);
        }
        if (!this.f1491o || cls == i.class || cls == n.class) {
            return;
        }
        l(new i(this, obj));
    }

    private boolean n(Object obj, C0030c c0030c, Class cls) {
        CopyOnWriteArrayList<q> copyOnWriteArrayList;
        synchronized (this) {
            copyOnWriteArrayList = (CopyOnWriteArrayList) this.f1477a.get(cls);
        }
        if (copyOnWriteArrayList == null || copyOnWriteArrayList.isEmpty()) {
            return false;
        }
        for (q qVar : copyOnWriteArrayList) {
            c0030c.f1501e = obj;
            c0030c.f1500d = qVar;
            try {
                p(qVar, obj, c0030c.f1499c);
                if (c0030c.f1502f) {
                    return true;
                }
            } finally {
                c0030c.f1501e = null;
                c0030c.f1500d = null;
                c0030c.f1502f = false;
            }
        }
        return true;
    }

    private void p(q qVar, Object obj, boolean z2) {
        int i2 = b.f1496a[qVar.f1554b.f1536b.ordinal()];
        if (i2 == 1) {
            h(qVar, obj);
            return;
        }
        if (i2 == 2) {
            if (z2) {
                h(qVar, obj);
                return;
            } else {
                this.f1482f.a(qVar, obj);
                return;
            }
        }
        if (i2 == 3) {
            l lVar = this.f1482f;
            if (lVar != null) {
                lVar.a(qVar, obj);
                return;
            } else {
                h(qVar, obj);
                return;
            }
        }
        if (i2 == 4) {
            if (z2) {
                this.f1483g.a(qVar, obj);
                return;
            } else {
                h(qVar, obj);
                return;
            }
        }
        if (i2 == 5) {
            this.f1484h.a(qVar, obj);
            return;
        }
        throw new IllegalStateException("Unknown thread mode: " + qVar.f1554b.f1536b);
    }

    private void s(Object obj, o oVar) {
        Class cls = oVar.f1537c;
        q qVar = new q(obj, oVar);
        CopyOnWriteArrayList copyOnWriteArrayList = (CopyOnWriteArrayList) this.f1477a.get(cls);
        if (copyOnWriteArrayList == null) {
            copyOnWriteArrayList = new CopyOnWriteArrayList();
            this.f1477a.put(cls, copyOnWriteArrayList);
        } else if (copyOnWriteArrayList.contains(qVar)) {
            throw new e("Subscriber " + obj.getClass() + " already registered to event " + cls);
        }
        int size = copyOnWriteArrayList.size();
        for (int i2 = 0; i2 <= size; i2++) {
            if (i2 == size || oVar.f1538d > ((q) copyOnWriteArrayList.get(i2)).f1554b.f1538d) {
                copyOnWriteArrayList.add(i2, qVar);
                break;
            }
        }
        List arrayList = (List) this.f1478b.get(obj);
        if (arrayList == null) {
            arrayList = new ArrayList();
            this.f1478b.put(obj, arrayList);
        }
        arrayList.add(cls);
        if (oVar.f1539e) {
            if (!this.f1492p) {
                b(qVar, this.f1479c.get(cls));
                return;
            }
            for (Map.Entry entry : this.f1479c.entrySet()) {
                if (cls.isAssignableFrom((Class) entry.getKey())) {
                    b(qVar, entry.getValue());
                }
            }
        }
    }

    private void u(Object obj, Class cls) {
        List list = (List) this.f1477a.get(cls);
        if (list != null) {
            int size = list.size();
            int i2 = 0;
            while (i2 < size) {
                q qVar = (q) list.get(i2);
                if (qVar.f1553a == obj) {
                    qVar.f1555c = false;
                    list.remove(i2);
                    i2--;
                    size--;
                }
                i2++;
            }
        }
    }

    ExecutorService d() {
        return this.f1486j;
    }

    public g e() {
        return this.f1494r;
    }

    void g(j jVar) {
        Object obj = jVar.f1526a;
        q qVar = jVar.f1527b;
        j.b(jVar);
        if (qVar.f1555c) {
            h(qVar, obj);
        }
    }

    void h(q qVar, Object obj) {
        try {
            qVar.f1554b.f1535a.invoke(qVar.f1553a, obj);
        } catch (IllegalAccessException e2) {
            throw new IllegalStateException("Unexpected exception", e2);
        } catch (InvocationTargetException e3) {
            f(qVar, obj, e3.getCause());
        }
    }

    public synchronized boolean j(Object obj) {
        return this.f1478b.containsKey(obj);
    }

    public void l(Object obj) {
        C0030c c0030c = (C0030c) this.f1480d.get();
        List list = c0030c.f1497a;
        list.add(obj);
        if (c0030c.f1498b) {
            return;
        }
        c0030c.f1499c = i();
        c0030c.f1498b = true;
        if (c0030c.f1502f) {
            throw new e("Internal error. Abort state was not reset");
        }
        while (true) {
            try {
                if (list.isEmpty()) {
                    return;
                } else {
                    m(list.remove(0), c0030c);
                }
            } finally {
                c0030c.f1498b = false;
                c0030c.f1499c = false;
            }
        }
    }

    public void o(Object obj) {
        synchronized (this.f1479c) {
            this.f1479c.put(obj.getClass(), obj);
        }
        l(obj);
    }

    public void q(Object obj) {
        List listA = this.f1485i.a(obj.getClass());
        synchronized (this) {
            try {
                Iterator it = listA.iterator();
                while (it.hasNext()) {
                    s(obj, (o) it.next());
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public Object r(Class cls) {
        Object objCast;
        synchronized (this.f1479c) {
            objCast = cls.cast(this.f1479c.remove(cls));
        }
        return objCast;
    }

    public synchronized void t(Object obj) {
        try {
            List list = (List) this.f1478b.get(obj);
            if (list != null) {
                Iterator it = list.iterator();
                while (it.hasNext()) {
                    u(obj, (Class) it.next());
                }
                this.f1478b.remove(obj);
            } else {
                this.f1494r.a(Level.WARNING, "Subscriber to unregister was not registered before: " + obj.getClass());
            }
        } catch (Throwable th) {
            throw th;
        }
    }

    public String toString() {
        return "EventBus[indexCount=" + this.f1493q + ", eventInheritance=" + this.f1492p + "]";
    }

    c(d dVar) {
        this.f1480d = new a();
        this.f1494r = dVar.b();
        this.f1477a = new HashMap();
        this.f1478b = new HashMap();
        this.f1479c = new ConcurrentHashMap();
        h hVarC = dVar.c();
        this.f1481e = hVarC;
        this.f1482f = hVarC != null ? hVarC.a(this) : null;
        this.f1483g = new O1.b(this);
        this.f1484h = new O1.a(this);
        List list = dVar.f1513j;
        this.f1493q = list != null ? list.size() : 0;
        this.f1485i = new p(dVar.f1513j, dVar.f1511h, dVar.f1510g);
        this.f1488l = dVar.f1504a;
        this.f1489m = dVar.f1505b;
        this.f1490n = dVar.f1506c;
        this.f1491o = dVar.f1507d;
        this.f1487k = dVar.f1508e;
        this.f1492p = dVar.f1509f;
        this.f1486j = dVar.f1512i;
    }
}