package o;

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 o.InterfaceC15299gmn;
import org.greenrobot.eventbus.EventBusException;
import org.greenrobot.eventbus.ThreadMode;

/* renamed from: o.gmk, reason: case insensitive filesystem */
/* loaded from: classes.dex */
public class C15296gmk {
    private static volatile C15296gmk c;
    final InterfaceC15299gmn b;
    final ExecutorService d;
    private final RunnableC15297gml f;
    private final int g;
    private final RunnableC15292gmg h;
    private final ThreadLocal<LWm> i;
    private final boolean j;
    private final boolean k;
    private final InterfaceC15303gmr l;
    private final boolean m;
    private final boolean n;

    /* renamed from: o, reason: collision with root package name */
    private final InterfaceC15304gms f9144o;
    private final boolean p;
    private final C15306gmu q;
    private final Map<Class<?>, CopyOnWriteArrayList<C15310gmy>> r;
    private final Map<Class<?>, Object> s;
    private final boolean t;
    private final Map<Object, List<Class<?>>> v;
    private static final C15298gmm a = new C15298gmm();
    private static final Map<Class<?>, List<Class<?>>> e = new HashMap();

    public static C15296gmk b() {
        C15296gmk c15296gmk;
        C15296gmk c15296gmk2 = c;
        if (c15296gmk2 != null) {
            return c15296gmk2;
        }
        synchronized (C15296gmk.class) {
            c15296gmk = c;
            if (c15296gmk == null) {
                c15296gmk = new C15296gmk();
                c = c15296gmk;
            }
        }
        return c15296gmk;
    }

    public C15296gmk() {
        this(a);
    }

    private C15296gmk(C15298gmm c15298gmm) {
        InterfaceC15299gmn hBt;
        this.i = new ThreadLocal<LWm>(this) { // from class: o.gmk.5
            private C15296gmk a;

            {
                this.a = this;
            }

            @Override // java.lang.ThreadLocal
            protected final /* synthetic */ LWm initialValue() {
                return new LWm();
            }
        };
        InterfaceC15299gmn interfaceC15299gmn = c15298gmm.i;
        if (gmB.b()) {
            hBt = gmB.e().b;
        } else {
            hBt = new InterfaceC15299gmn.HBt();
        }
        this.b = hBt;
        this.r = new HashMap();
        this.v = new HashMap();
        this.s = new ConcurrentHashMap();
        InterfaceC15304gms interfaceC15304gms = c15298gmm.g;
        InterfaceC15304gms interfaceC15304gms2 = gmB.b() ? gmB.e().e : null;
        this.f9144o = interfaceC15304gms2;
        this.l = interfaceC15304gms2 != null ? interfaceC15304gms2.e(this) : null;
        this.f = new RunnableC15297gml(this);
        this.h = new RunnableC15292gmg(this);
        List<InterfaceC15275gmI> list = c15298gmm.k;
        this.g = 0;
        this.q = new C15306gmu(c15298gmm.k, c15298gmm.f, c15298gmm.d);
        this.m = c15298gmm.e;
        this.k = c15298gmm.b;
        this.t = c15298gmm.j;
        this.n = c15298gmm.h;
        this.p = c15298gmm.m;
        this.j = c15298gmm.c;
        this.d = c15298gmm.a;
    }

    public final void a(Object obj) {
        if (C15311gmz.a() && !C15311gmz.d()) {
            throw new RuntimeException("It looks like you are using EventBus on Android, make sure to add the \"eventbus\" Android library to your dependencies.");
        }
        List<C15308gmw> d = this.q.d(obj.getClass());
        synchronized (this) {
            Iterator<C15308gmw> it = d.iterator();
            while (it.hasNext()) {
                b(obj, it.next());
            }
        }
    }

    private void b(Object obj, C15308gmw c15308gmw) {
        Class<?> cls = c15308gmw.e;
        C15310gmy c15310gmy = new C15310gmy(obj, c15308gmw);
        CopyOnWriteArrayList<C15310gmy> copyOnWriteArrayList = this.r.get(cls);
        if (copyOnWriteArrayList == null) {
            copyOnWriteArrayList = new CopyOnWriteArrayList<>();
            this.r.put(cls, copyOnWriteArrayList);
        } else if (copyOnWriteArrayList.contains(c15310gmy)) {
            StringBuilder sb = new StringBuilder("Subscriber ");
            sb.append(obj.getClass());
            sb.append(" already registered to event ");
            sb.append(cls);
            throw new EventBusException(sb.toString());
        }
        int size = copyOnWriteArrayList.size();
        for (int i = 0; i <= size; i++) {
            if (i == size || c15308gmw.c > copyOnWriteArrayList.get(i).a.c) {
                copyOnWriteArrayList.add(i, c15310gmy);
                break;
            }
        }
        List<Class<?>> list = this.v.get(obj);
        if (list == null) {
            list = new ArrayList<>();
            this.v.put(obj, list);
        }
        list.add(cls);
        if (c15308gmw.d) {
            if (this.j) {
                for (Map.Entry<Class<?>, Object> entry : this.s.entrySet()) {
                    if (cls.isAssignableFrom(entry.getKey())) {
                        b(c15310gmy, entry.getValue());
                    }
                }
                return;
            }
            b(c15310gmy, this.s.get(cls));
        }
    }

    private void b(C15310gmy c15310gmy, Object obj) {
        if (obj != null) {
            InterfaceC15304gms interfaceC15304gms = this.f9144o;
            d(c15310gmy, obj, interfaceC15304gms == null || interfaceC15304gms.a());
        }
    }

    private void c(Object obj, Class<?> cls) {
        CopyOnWriteArrayList<C15310gmy> copyOnWriteArrayList = this.r.get(cls);
        if (copyOnWriteArrayList != null) {
            int size = copyOnWriteArrayList.size();
            int i = 0;
            while (i < size) {
                C15310gmy c15310gmy = copyOnWriteArrayList.get(i);
                if (c15310gmy.b == obj) {
                    c15310gmy.d = false;
                    copyOnWriteArrayList.remove(i);
                    i--;
                    size--;
                }
                i++;
            }
        }
    }

    public final void b(Object obj) {
        synchronized (this) {
            List<Class<?>> list = this.v.get(obj);
            if (list != null) {
                Iterator<Class<?>> it = list.iterator();
                while (it.hasNext()) {
                    c(obj, it.next());
                }
                this.v.remove(obj);
            } else {
                InterfaceC15299gmn interfaceC15299gmn = this.b;
                Level level = Level.WARNING;
                StringBuilder sb = new StringBuilder("Subscriber to unregister was not registered before: ");
                sb.append(obj.getClass());
                interfaceC15299gmn.c(level, sb.toString());
            }
        }
    }

    public final void e(Object obj) {
        LWm lWm = this.i.get();
        List<Object> list = lWm.a;
        list.add(obj);
        if (lWm.b) {
            return;
        }
        InterfaceC15304gms interfaceC15304gms = this.f9144o;
        lWm.d = interfaceC15304gms == null || interfaceC15304gms.a();
        lWm.b = true;
        boolean z = lWm.e;
        while (!list.isEmpty()) {
            try {
                e(list.remove(0), lWm);
            } finally {
                lWm.b = false;
                lWm.d = false;
            }
        }
    }

    private void e(Object obj, LWm lWm) throws Error {
        boolean a2;
        Class<?> cls = obj.getClass();
        if (this.j) {
            List<Class<?>> a3 = a(cls);
            int size = a3.size();
            a2 = false;
            for (int i = 0; i < size; i++) {
                a2 |= a(obj, lWm, a3.get(i));
            }
        } else {
            a2 = a(obj, lWm, cls);
        }
        if (a2) {
            return;
        }
        if (this.k) {
            this.b.c(Level.FINE, "No subscribers registered for event ".concat(String.valueOf(cls)));
        }
        if (!this.n || cls == C15305gmt.class || cls == C15307gmv.class) {
            return;
        }
        e(new C15305gmt(this, obj));
    }

    private boolean a(Object obj, LWm lWm, Class<?> cls) {
        CopyOnWriteArrayList<C15310gmy> copyOnWriteArrayList;
        synchronized (this) {
            copyOnWriteArrayList = this.r.get(cls);
        }
        if (copyOnWriteArrayList == null || copyOnWriteArrayList.isEmpty()) {
            return false;
        }
        Iterator<C15310gmy> it = copyOnWriteArrayList.iterator();
        while (it.hasNext()) {
            C15310gmy next = it.next();
            lWm.c = obj;
            lWm.g = next;
            try {
                d(next, obj, lWm.d);
                boolean z = lWm.e;
            } finally {
                lWm.c = null;
                lWm.g = null;
                lWm.e = false;
            }
        }
        return true;
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    /* renamed from: o.gmk$1, reason: invalid class name */
    /* loaded from: classes.dex */
    public static /* synthetic */ class AnonymousClass1 {
        static final int[] b;

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

    private void d(C15310gmy c15310gmy, Object obj, boolean z) {
        int i = AnonymousClass1.b[c15310gmy.a.h.ordinal()];
        if (i != 1) {
            if (i != 2) {
                if (i == 3) {
                    InterfaceC15303gmr interfaceC15303gmr = this.l;
                    if (interfaceC15303gmr != null) {
                        interfaceC15303gmr.a(c15310gmy, obj);
                        return;
                    } else {
                        a(c15310gmy, obj);
                        return;
                    }
                }
                if (i == 4) {
                    if (z) {
                        this.f.a(c15310gmy, obj);
                        return;
                    } else {
                        a(c15310gmy, obj);
                        return;
                    }
                }
                if (i != 5) {
                    StringBuilder sb = new StringBuilder("Unknown thread mode: ");
                    sb.append(c15310gmy.a.h);
                    throw new IllegalStateException(sb.toString());
                }
                RunnableC15292gmg runnableC15292gmg = this.h;
                runnableC15292gmg.c.a(C15302gmq.c(c15310gmy, obj));
                runnableC15292gmg.b.d.execute(runnableC15292gmg);
                return;
            }
            if (!z) {
                this.l.a(c15310gmy, obj);
                return;
            }
        }
        a(c15310gmy, obj);
    }

    private static List<Class<?>> a(Class<?> cls) {
        List<Class<?>> list;
        Map<Class<?>, List<Class<?>>> map = e;
        synchronized (map) {
            list = map.get(cls);
            if (list == null) {
                list = new ArrayList<>();
                for (Class<?> cls2 = cls; cls2 != null; cls2 = cls2.getSuperclass()) {
                    list.add(cls2);
                    b(list, cls2.getInterfaces());
                }
                e.put(cls, list);
            }
        }
        return list;
    }

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

    /* JADX INFO: Access modifiers changed from: package-private */
    public final void a(C15310gmy c15310gmy, Object obj) {
        try {
            c15310gmy.a.a.invoke(c15310gmy.b, obj);
        } catch (IllegalAccessException e2) {
            throw new IllegalStateException("Unexpected exception", e2);
        } catch (InvocationTargetException e3) {
            c(c15310gmy, obj, e3.getCause());
        }
    }

    private void c(C15310gmy c15310gmy, Object obj, Throwable th) {
        if (!(obj instanceof C15307gmv)) {
            if (this.p) {
                throw new EventBusException("Invoking subscriber failed", th);
            }
            if (this.m) {
                InterfaceC15299gmn interfaceC15299gmn = this.b;
                Level level = Level.SEVERE;
                StringBuilder sb = new StringBuilder("Could not dispatch event: ");
                sb.append(obj.getClass());
                sb.append(" to subscribing class ");
                sb.append(c15310gmy.b.getClass());
                interfaceC15299gmn.b(level, sb.toString(), th);
            }
            if (this.t) {
                e(new C15307gmv(this, th, obj, c15310gmy.b));
                return;
            }
            return;
        }
        if (this.m) {
            InterfaceC15299gmn interfaceC15299gmn2 = this.b;
            Level level2 = Level.SEVERE;
            StringBuilder sb2 = new StringBuilder("SubscriberExceptionEvent subscriber ");
            sb2.append(c15310gmy.b.getClass());
            sb2.append(" threw an exception");
            interfaceC15299gmn2.b(level2, sb2.toString(), th);
            C15307gmv c15307gmv = (C15307gmv) obj;
            InterfaceC15299gmn interfaceC15299gmn3 = this.b;
            Level level3 = Level.SEVERE;
            StringBuilder sb3 = new StringBuilder("Initial event ");
            sb3.append(c15307gmv.a);
            sb3.append(" caused exception in ");
            sb3.append(c15307gmv.b);
            interfaceC15299gmn3.b(level3, sb3.toString(), c15307gmv.d);
        }
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    /* renamed from: o.gmk$LWm */
    /* loaded from: classes.dex */
    public static final class LWm {
        final List<Object> a = new ArrayList();
        boolean b;
        Object c;
        boolean d;
        boolean e;
        C15310gmy g;

        LWm() {
        }
    }

    public String toString() {
        StringBuilder sb = new StringBuilder("EventBus[indexCount=");
        sb.append(this.g);
        sb.append(", eventInheritance=");
        sb.append(this.j);
        sb.append("]");
        return sb.toString();
    }
}