package com.bytedance.sdk.openadsdk.gof;

import android.content.Context;
import android.os.Handler;
import android.os.HandlerThread;
import android.os.Looper;
import com.bytedance.sdk.component.utils.wey;
import com.bytedance.sdk.component.utils.wu;
import com.bytedance.sdk.component.wu.fm.ajl;
import com.bytedance.sdk.openadsdk.core.fhx;
import com.bytedance.sdk.openadsdk.core.gof;
import java.util.List;
import org.json.JSONObject;

/* JADX INFO: loaded from: classes2.dex */
public class lb {
    private static volatile fm fm;

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private static volatile HandlerThread f7411lb = wu.fm("pag__bus_monitor", 0);
    private static Boolean ro;
    private static volatile ajl yz;

    /* JADX INFO: Access modifiers changed from: private */
    public static ajl jnr() {
        if (f7411lb == null || !f7411lb.isAlive()) {
            synchronized (fhx.class) {
                try {
                    if (f7411lb == null || !f7411lb.isAlive()) {
                        HandlerThread handlerThreadFm = wu.fm("pag_init_handle", -1);
                        f7411lb = handlerThreadFm;
                        yz = fm(handlerThreadFm.getLooper());
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        } else if (yz == null) {
            synchronized (fhx.class) {
                try {
                    if (yz == null) {
                        yz = fm(f7411lb.getLooper());
                    }
                } finally {
                }
            }
        }
        return yz;
    }

    public static void ro(yz yzVar) {
        fm().fm(new jnr(yzVar, 0, 1, 0));
    }

    public static fm fm() {
        if (fm == null) {
            synchronized (lb.class) {
                try {
                    if (fm == null) {
                        fm = fm.fm(new ro() { // from class: com.bytedance.sdk.openadsdk.gof.lb.1
                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public Context getContext() {
                                return gof.fm();
                            }

                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public ajl getHandler() {
                                return lb.jnr();
                            }

                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public int getOnceLogCount() {
                                int iFm = com.bytedance.sdk.openadsdk.hlt.jnr.fm("bus_monitor_config", "once_count", 10);
                                if (iFm > 100 || iFm < 5) {
                                    return 10;
                                }
                                return iFm;
                            }

                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public int getOnceLogInterval() {
                                int iFm = com.bytedance.sdk.openadsdk.hlt.jnr.fm("bus_monitor_config", "once_interval", 10000);
                                if (iFm < 10000) {
                                    return 10000;
                                }
                                return iFm;
                            }

                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public HandlerThread getSafeHandlerThread(String str, int i10) {
                                return wu.fm(str, i10);
                            }

                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public int getUploadIntervalTime() {
                                int iFm = com.bytedance.sdk.openadsdk.hlt.jnr.fm("bus_monitor_config", "interval", 86400000);
                                if (iFm < 3600000) {
                                    return 86400000;
                                }
                                return iFm;
                            }

                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public boolean isMonitorOpen() {
                                if (lb.ro != null) {
                                    return lb.ro.booleanValue();
                                }
                                Boolean unused = lb.ro = Boolean.valueOf(com.bytedance.sdk.openadsdk.hlt.jnr.fm("bus_monitor_config", "enable", 1) == 1);
                                return lb.ro.booleanValue();
                            }

                            @Override // com.bytedance.sdk.openadsdk.gof.ro
                            public void onMonitorUpload(List<com.bytedance.sdk.openadsdk.gof.ro.fm> list) {
                                if (list == null || list.isEmpty()) {
                                    return;
                                }
                                for (final com.bytedance.sdk.openadsdk.gof.ro.fm fmVar : list) {
                                    com.bytedance.sdk.openadsdk.irt.yz.fm("bus_monitor", false, new com.bytedance.sdk.openadsdk.irt.ro() { // from class: com.bytedance.sdk.openadsdk.gof.lb.1.1
                                        @Override // com.bytedance.sdk.openadsdk.irt.ro
                                        public com.bytedance.sdk.openadsdk.irt.fm.lb fm() throws Exception {
                                            JSONObject jSONObject = new JSONObject();
                                            try {
                                                jSONObject.put("sdk_version", fmVar.ro());
                                                jSONObject.put("scene", fmVar.lb());
                                                jSONObject.put("start_count", fmVar.yz());
                                                jSONObject.put("success_count", fmVar.jnr());
                                                jSONObject.put("fail_count", fmVar.ajl());
                                                jSONObject.put("rit", fmVar.wsy());
                                                jSONObject.put("tag", fmVar.wu());
                                                jSONObject.put("label", fmVar.ef());
                                                jSONObject.put("mediation", fmVar.ku());
                                                jSONObject.put("is_init", fmVar.duv());
                                                jSONObject.put("extra", fmVar.dsz());
                                                jSONObject.put("date_device", fmVar.vt());
                                                return com.bytedance.sdk.openadsdk.irt.fm.yz.ro().fm("bus_monitor").ro(jSONObject.toString());
                                            } catch (Exception e10) {
                                                wey.fm("BusMonitorUtils", "onMonitorUpload: ", e10);
                                                return null;
                                            }
                                        }
                                    });
                                }
                            }
                        });
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        }
        return fm;
    }

    public static void lb(yz yzVar) {
        fm().fm(new jnr(yzVar, 0, 0, 1));
    }

    public static void ro() {
        fm().fm(true);
    }

    public static void fm(yz yzVar) {
        fm().fm(new jnr(yzVar, 1, 0, 0));
    }

    private static ajl fm(Looper looper) {
        return new ajl(new Handler(looper)) { // from class: com.bytedance.sdk.openadsdk.gof.lb.2
            @Override // com.bytedance.sdk.component.wu.fm.ajl
            public boolean fm() {
                return com.bytedance.sdk.openadsdk.hlt.jnr.fm("bus_handler_run_dispatch", 0) == 1;
            }
        };
    }
}