package k.c.a;

import android.os.Looper;
import android.util.Log;
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.Objects;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;

/* JADX INFO: compiled from: EventBus.java */
/* JADX INFO: loaded from: classes.dex */
public class c {
    public static volatile c a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final d f4938b = new d();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final Map<Class<?>, List<Class<?>>> f4939c = new HashMap();

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final Map<Class<?>, CopyOnWriteArrayList<n>> f4940d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final Map<Object, List<Class<?>>> f4941e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final Map<Class<?>, Object> f4942f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final ThreadLocal<b> f4943g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final f f4944h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final k.c.a.b f4945i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final k.c.a.a f4946j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final m f4947k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public final ExecutorService f4948l;
    public final boolean m;
    public final boolean n;
    public final boolean o;
    public final boolean p;
    public final boolean q;

    /* JADX INFO: compiled from: EventBus.java */
    public class a extends ThreadLocal<b> {
        public a(c cVar) {
        }

        @Override // java.lang.ThreadLocal
        public b initialValue() {
            return new b();
        }
    }

    /* JADX INFO: compiled from: EventBus.java */
    public static final class b {
        public final List<Object> a = new ArrayList();

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

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

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public Object f4951d;
    }

    public c() {
        d dVar = f4938b;
        this.f4943g = new a(this);
        this.f4940d = new HashMap();
        this.f4941e = new HashMap();
        this.f4942f = new ConcurrentHashMap();
        this.f4944h = new f(this, Looper.getMainLooper(), 10);
        this.f4945i = new k.c.a.b(this);
        this.f4946j = new k.c.a.a(this);
        Objects.requireNonNull(dVar);
        this.f4947k = new m(null, false, false);
        this.m = true;
        this.n = true;
        this.o = true;
        this.p = true;
        this.q = true;
        this.f4948l = dVar.f4952b;
    }

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

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

    public static List<Class<?>> f(Class<?> cls) {
        List<Class<?>> list;
        Map<Class<?>, List<Class<?>>> map = f4939c;
        synchronized (map) {
            List<Class<?>> list2 = map.get(cls);
            list = list2;
            if (list2 == null) {
                ArrayList arrayList = new ArrayList();
                for (Class<?> superclass = cls; superclass != null; superclass = superclass.getSuperclass()) {
                    arrayList.add(superclass);
                    a(arrayList, superclass.getInterfaces());
                }
                f4939c.put(cls, arrayList);
                list = arrayList;
            }
        }
        return list;
    }

    public final void b(n nVar, Object obj) {
        if (obj != null) {
            j(nVar, obj, Looper.getMainLooper() == Looper.myLooper());
        }
    }

    public void d(h hVar) {
        Object obj = hVar.f4956b;
        n nVar = hVar.f4957c;
        hVar.f4956b = null;
        hVar.f4957c = null;
        hVar.f4958d = null;
        List<h> list = h.a;
        synchronized (list) {
            if (list.size() < 10000) {
                list.add(hVar);
            }
        }
        if (nVar.f4975c) {
            e(nVar, obj);
        }
    }

    public void e(n nVar, Object obj) {
        try {
            nVar.f4974b.a.invoke(nVar.a, obj);
        } catch (IllegalAccessException e2) {
            throw new IllegalStateException("Unexpected exception", e2);
        } catch (InvocationTargetException e3) {
            Throwable cause = e3.getCause();
            if (!(obj instanceof k)) {
                if (this.m) {
                    StringBuilder sbB = d.b.a.a.a.B("Could not dispatch event: ");
                    sbB.append(obj.getClass());
                    sbB.append(" to subscribing class ");
                    sbB.append(nVar.a.getClass());
                    Log.e("EventBus", sbB.toString(), cause);
                }
                if (this.o) {
                    g(new k(this, cause, obj, nVar.a));
                    return;
                }
                return;
            }
            if (this.m) {
                StringBuilder sbB2 = d.b.a.a.a.B("SubscriberExceptionEvent subscriber ");
                sbB2.append(nVar.a.getClass());
                sbB2.append(" threw an exception");
                Log.e("EventBus", sbB2.toString(), cause);
                k kVar = (k) obj;
                StringBuilder sbB3 = d.b.a.a.a.B("Initial event ");
                sbB3.append(kVar.f4960b);
                sbB3.append(" caused exception in ");
                sbB3.append(kVar.f4961c);
                Log.e("EventBus", sbB3.toString(), kVar.a);
            }
        }
    }

    public void g(Object obj) {
        b bVar = this.f4943g.get();
        List<Object> list = bVar.a;
        list.add(obj);
        if (bVar.f4949b) {
            return;
        }
        bVar.f4950c = Looper.getMainLooper() == Looper.myLooper();
        bVar.f4949b = true;
        while (!list.isEmpty()) {
            try {
                h(list.remove(0), bVar);
            } finally {
                bVar.f4949b = false;
                bVar.f4950c = false;
            }
        }
    }

    public final void h(Object obj, b bVar) throws Error {
        boolean zI;
        Class<?> cls = obj.getClass();
        if (this.q) {
            List<Class<?>> listF = f(cls);
            int size = listF.size();
            zI = false;
            for (int i2 = 0; i2 < size; i2++) {
                zI |= i(obj, bVar, listF.get(i2));
            }
        } else {
            zI = i(obj, bVar, cls);
        }
        if (zI) {
            return;
        }
        if (this.n) {
            Log.d("EventBus", "No subscribers registered for event " + cls);
        }
        if (!this.p || cls == g.class || cls == k.class) {
            return;
        }
        g(new g(this, obj));
    }

    public final boolean i(Object obj, b bVar, Class<?> cls) {
        CopyOnWriteArrayList<n> copyOnWriteArrayList;
        synchronized (this) {
            copyOnWriteArrayList = this.f4940d.get(cls);
        }
        if (copyOnWriteArrayList == null || copyOnWriteArrayList.isEmpty()) {
            return false;
        }
        for (n nVar : copyOnWriteArrayList) {
            bVar.f4951d = obj;
            j(nVar, obj, bVar.f4950c);
        }
        return true;
    }

    public final void j(n nVar, Object obj, boolean z) {
        int iOrdinal = nVar.f4974b.f4962b.ordinal();
        if (iOrdinal == 0) {
            e(nVar, obj);
            return;
        }
        if (iOrdinal == 1) {
            if (z) {
                e(nVar, obj);
                return;
            }
            f fVar = this.f4944h;
            Objects.requireNonNull(fVar);
            h hVarA = h.a(nVar, obj);
            synchronized (fVar) {
                fVar.a.a(hVarA);
                if (!fVar.f4955d) {
                    fVar.f4955d = true;
                    if (!fVar.sendMessage(fVar.obtainMessage())) {
                        throw new e("Could not send handler message");
                    }
                }
            }
            return;
        }
        if (iOrdinal != 2) {
            if (iOrdinal != 3) {
                StringBuilder sbB = d.b.a.a.a.B("Unknown thread mode: ");
                sbB.append(nVar.f4974b.f4962b);
                throw new IllegalStateException(sbB.toString());
            }
            k.c.a.a aVar = this.f4946j;
            Objects.requireNonNull(aVar);
            aVar.f4933b.a(h.a(nVar, obj));
            aVar.f4934e.f4948l.execute(aVar);
            return;
        }
        if (!z) {
            e(nVar, obj);
            return;
        }
        k.c.a.b bVar = this.f4945i;
        Objects.requireNonNull(bVar);
        h hVarA2 = h.a(nVar, obj);
        synchronized (bVar) {
            bVar.f4935b.a(hVarA2);
            if (!bVar.f4937f) {
                bVar.f4937f = true;
                bVar.f4936e.f4948l.execute(bVar);
            }
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:15:0x003d  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public void k(java.lang.Object r12) {
        /*
            r11 = this;
            java.lang.Class r0 = r12.getClass()
            k.c.a.m r1 = r11.f4947k
            java.util.Objects.requireNonNull(r1)
            java.util.Map<java.lang.Class<?>, java.util.List<k.c.a.l>> r2 = k.c.a.m.a
            java.lang.Object r2 = r2.get(r0)
            java.util.List r2 = (java.util.List) r2
            if (r2 == 0) goto L14
            goto L77
        L14:
            k.c.a.m$a r2 = r1.c()
            r2.f4971e = r0
            r3 = 0
            r2.f4972f = r3
            r4 = 0
            r2.f4973g = r4
        L20:
            java.lang.Class<?> r5 = r2.f4971e
            if (r5 == 0) goto L65
            k.c.a.o.a r5 = r2.f4973g
            if (r5 == 0) goto L3d
            k.c.a.o.a r5 = r5.b()
            if (r5 == 0) goto L3d
            k.c.a.o.a r5 = r2.f4973g
            k.c.a.o.a r5 = r5.b()
            java.lang.Class<?> r6 = r2.f4971e
            java.lang.Class r7 = r5.c()
            if (r6 != r7) goto L3d
            goto L3e
        L3d:
            r5 = r4
        L3e:
            r2.f4973g = r5
            if (r5 == 0) goto L5e
            k.c.a.l[] r5 = r5.a()
            int r6 = r5.length
            r7 = r3
        L48:
            if (r7 >= r6) goto L61
            r8 = r5[r7]
            java.lang.reflect.Method r9 = r8.a
            java.lang.Class<?> r10 = r8.f4963c
            boolean r9 = r2.a(r9, r10)
            if (r9 == 0) goto L5b
            java.util.List<k.c.a.l> r9 = r2.a
            r9.add(r8)
        L5b:
            int r7 = r7 + 1
            goto L48
        L5e:
            r1.a(r2)
        L61:
            r2.c()
            goto L20
        L65:
            java.util.List r2 = r1.b(r2)
            r1 = r2
            java.util.ArrayList r1 = (java.util.ArrayList) r1
            boolean r1 = r1.isEmpty()
            if (r1 != 0) goto L91
            java.util.Map<java.lang.Class<?>, java.util.List<k.c.a.l>> r1 = k.c.a.m.a
            r1.put(r0, r2)
        L77:
            monitor-enter(r11)
            java.util.Iterator r0 = r2.iterator()     // Catch: java.lang.Throwable -> L8e
        L7c:
            boolean r1 = r0.hasNext()     // Catch: java.lang.Throwable -> L8e
            if (r1 == 0) goto L8c
            java.lang.Object r1 = r0.next()     // Catch: java.lang.Throwable -> L8e
            k.c.a.l r1 = (k.c.a.l) r1     // Catch: java.lang.Throwable -> L8e
            r11.l(r12, r1)     // Catch: java.lang.Throwable -> L8e
            goto L7c
        L8c:
            monitor-exit(r11)     // Catch: java.lang.Throwable -> L8e
            return
        L8e:
            r12 = move-exception
            monitor-exit(r11)     // Catch: java.lang.Throwable -> L8e
            throw r12
        L91:
            k.c.a.e r12 = new k.c.a.e
            java.lang.StringBuilder r1 = new java.lang.StringBuilder
            r1.<init>()
            java.lang.String r2 = "Subscriber "
            r1.append(r2)
            r1.append(r0)
            java.lang.String r0 = " and its super classes have no public methods with the @Subscribe annotation"
            r1.append(r0)
            java.lang.String r0 = r1.toString()
            r12.<init>(r0)
            throw r12
        */
        throw new UnsupportedOperationException("Method not decompiled: k.c.a.c.k(java.lang.Object):void");
    }

    public final void l(Object obj, l lVar) {
        Class<?> cls = lVar.f4963c;
        n nVar = new n(obj, lVar);
        CopyOnWriteArrayList<n> copyOnWriteArrayList = this.f4940d.get(cls);
        if (copyOnWriteArrayList == null) {
            copyOnWriteArrayList = new CopyOnWriteArrayList<>();
            this.f4940d.put(cls, copyOnWriteArrayList);
        } else if (copyOnWriteArrayList.contains(nVar)) {
            StringBuilder sbB = d.b.a.a.a.B("Subscriber ");
            sbB.append(obj.getClass());
            sbB.append(" already registered to event ");
            sbB.append(cls);
            throw new e(sbB.toString());
        }
        int size = copyOnWriteArrayList.size();
        for (int i2 = 0; i2 <= size; i2++) {
            if (i2 == size || lVar.f4964d > copyOnWriteArrayList.get(i2).f4974b.f4964d) {
                copyOnWriteArrayList.add(i2, nVar);
                break;
            }
        }
        List<Class<?>> arrayList = this.f4941e.get(obj);
        if (arrayList == null) {
            arrayList = new ArrayList<>();
            this.f4941e.put(obj, arrayList);
        }
        arrayList.add(cls);
        if (lVar.f4965e) {
            if (!this.q) {
                b(nVar, this.f4942f.get(cls));
                return;
            }
            for (Map.Entry<Class<?>, Object> entry : this.f4942f.entrySet()) {
                if (cls.isAssignableFrom(entry.getKey())) {
                    b(nVar, entry.getValue());
                }
            }
        }
    }

    public synchronized void m(Object obj) {
        List<Class<?>> list = this.f4941e.get(obj);
        if (list != null) {
            Iterator<Class<?>> it = list.iterator();
            while (it.hasNext()) {
                CopyOnWriteArrayList<n> copyOnWriteArrayList = this.f4940d.get(it.next());
                if (copyOnWriteArrayList != null) {
                    int size = copyOnWriteArrayList.size();
                    int i2 = 0;
                    while (i2 < size) {
                        n nVar = copyOnWriteArrayList.get(i2);
                        if (nVar.a == obj) {
                            nVar.f4975c = false;
                            copyOnWriteArrayList.remove(i2);
                            i2--;
                            size--;
                        }
                        i2++;
                    }
                }
            }
            this.f4941e.remove(obj);
        } else {
            Log.w("EventBus", "Subscriber to unregister was not registered before: " + obj.getClass());
        }
    }

    public String toString() {
        StringBuilder sbC = d.b.a.a.a.C("EventBus[indexCount=", 0, ", eventInheritance=");
        sbC.append(this.q);
        sbC.append("]");
        return sbC.toString();
    }
}