package com.bytedance.sdk.component.ajl.fm.ro;

import android.os.Handler;
import android.os.Looper;
import com.bytedance.sdk.component.ajl.fm.jnr;
import com.bytedance.sdk.component.ajl.fm.wsy;
import java.util.Comparator;
import java.util.concurrent.Executor;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.atomic.AtomicLong;

/* JADX INFO: loaded from: classes.dex */
public class yz {
    private final PriorityBlockingQueue<com.bytedance.sdk.component.ajl.fm.yz.fm> duv;

    /* JADX INFO: renamed from: ef, reason: collision with root package name */
    private volatile com.bytedance.sdk.component.ajl.fm.ro.ro.lb f6593ef;
    private final Comparator<com.bytedance.sdk.component.ajl.fm.yz.fm> ku;
    private volatile Handler vt;
    public static final yz fm = new yz();
    public static final com.bytedance.sdk.component.ajl.fm.ro.fm.fm yz = new com.bytedance.sdk.component.ajl.fm.ro.fm.fm();
    public static final AtomicLong jnr = new AtomicLong(0);
    public static final AtomicLong ajl = new AtomicLong(0);
    public static final long wsy = System.currentTimeMillis();
    public static long wu = 0;
    public volatile boolean ro = false;

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    public volatile boolean f6594lb = false;

    private yz() {
        Comparator<com.bytedance.sdk.component.ajl.fm.yz.fm> comparator = new Comparator<com.bytedance.sdk.component.ajl.fm.yz.fm>() { // from class: com.bytedance.sdk.component.ajl.fm.ro.yz.1
            @Override // java.util.Comparator
            /* JADX INFO: renamed from: fm, reason: merged with bridge method [inline-methods] */
            public int compare(com.bytedance.sdk.component.ajl.fm.yz.fm fmVar, com.bytedance.sdk.component.ajl.fm.yz.fm fmVar2) {
                return yz.this.fm(fmVar, fmVar2);
            }
        };
        this.ku = comparator;
        this.duv = new PriorityBlockingQueue<>(8, comparator);
    }

    public PriorityBlockingQueue<com.bytedance.sdk.component.ajl.fm.yz.fm> fm() {
        return this.duv;
    }

    public void jnr() {
        com.bytedance.sdk.component.ajl.fm.lb.ro.fm(yz.hxv(), 1);
        final com.bytedance.sdk.component.ajl.fm.ro.ro.lb lbVar = this.f6593ef;
        if (Looper.myLooper() != Looper.getMainLooper()) {
            if (lbVar != null) {
                lbVar.lb(2);
                return;
            }
            return;
        }
        jnr jnrVarFhx = wsy.ajl().fhx();
        if (jnrVarFhx != null) {
            Executor executorYz = jnrVarFhx.yz();
            if (executorYz == null) {
                executorYz = jnrVarFhx.jnr();
            }
            if (executorYz != null) {
                executorYz.execute(new com.bytedance.sdk.component.ajl.fm.jnr.jnr("flush") { // from class: com.bytedance.sdk.component.ajl.fm.ro.yz.3
                    @Override // java.lang.Runnable
                    public void run() {
                        com.bytedance.sdk.component.ajl.fm.ro.ro.lb lbVar2 = lbVar;
                        if (lbVar2 != null) {
                            lbVar2.lb(2);
                        }
                    }
                });
            }
        }
    }

    public void lb() {
        if (this.f6593ef == null || !this.f6593ef.isAlive()) {
            return;
        }
        synchronized (this) {
            try {
                if (this.f6593ef != null && this.f6593ef.isAlive()) {
                    if (this.vt != null) {
                        this.vt.removeCallbacksAndMessages(null);
                    }
                    this.f6593ef.fm(false);
                    this.f6593ef.quitSafely();
                    this.f6593ef = null;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public void ro() {
        yz();
        jnr();
    }

    public boolean yz() {
        try {
            if (this.f6593ef != null || com.bytedance.sdk.component.ajl.fm.ro.ro()) {
                return false;
            }
            synchronized (this) {
                if (this.f6593ef != null) {
                    return false;
                }
                this.f6593ef = new com.bytedance.sdk.component.ajl.fm.ro.ro.lb(this.duv);
                this.f6593ef.start();
                return true;
            }
        } catch (Throwable th) {
            th.getMessage();
            return false;
        }
    }

    public void fm(Handler handler) {
        this.vt = handler;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public int fm(com.bytedance.sdk.component.ajl.fm.yz.fm fmVar, com.bytedance.sdk.component.ajl.fm.yz.fm fmVar2) {
        long jFm;
        long jRo;
        long jRo2;
        long jFm2;
        if (fmVar == null) {
            return fmVar2 == null ? 0 : -1;
        }
        if (fmVar2 == null) {
            return 1;
        }
        if (fmVar.jnr() == fmVar2.jnr()) {
            if (fmVar.fm() != null) {
                jFm = fmVar.fm().fm();
                jRo = fmVar.fm().ro();
            } else {
                jFm = 0;
                jRo = 0;
            }
            if (fmVar2.fm() != null) {
                jFm2 = fmVar2.fm().fm();
                jRo2 = fmVar2.fm().ro();
            } else {
                jRo2 = 0;
                jFm2 = 0;
            }
            if (jFm == 0 || jFm2 == 0) {
                return 0;
            }
            long j10 = jFm - jFm2;
            if (Math.abs(j10) > 2147483647L) {
                return 0;
            }
            if (j10 != 0) {
                return (int) j10;
            }
            if (jRo == 0 || jRo2 == 0) {
                return 0;
            }
            return (int) (jRo - jRo2);
        }
        return fmVar.jnr() - fmVar2.jnr();
    }

    public void fm(com.bytedance.sdk.component.ajl.fm.yz.fm fmVar, int i10) {
        yz();
        jnr jnrVarFhx = wsy.ajl().fhx();
        com.bytedance.sdk.component.ajl.fm.ro.ro.lb lbVar = this.f6593ef;
        if (lbVar != null) {
            fm(jnrVarFhx, fmVar);
            lbVar.fm(fmVar, fmVar.jnr() == 4);
        }
    }

    private void fm(final jnr jnrVar, com.bytedance.sdk.component.ajl.fm.yz.fm fmVar) {
        if (jnrVar != null) {
            try {
                if (jnrVar.wsy()) {
                    final long jRo = (fmVar == null || fmVar.fm() == null) ? 0L : fmVar.fm().ro();
                    if (jRo == 1) {
                        wu = System.currentTimeMillis();
                    }
                    AtomicLong atomicLongBwv = yz.bwv();
                    com.bytedance.sdk.component.ajl.fm.lb.ro.fm(atomicLongBwv, 1);
                    if (atomicLongBwv.get() == 200) {
                        if (Looper.getMainLooper() == Looper.myLooper()) {
                            Executor executorYz = jnrVar.yz();
                            if (executorYz == null) {
                                executorYz = jnrVar.jnr();
                            }
                            if (executorYz != null) {
                                executorYz.execute(new com.bytedance.sdk.component.ajl.fm.jnr.jnr("report") { // from class: com.bytedance.sdk.component.ajl.fm.ro.yz.2
                                    @Override // java.lang.Runnable
                                    public void run() {
                                        yz.this.fm(jnrVar, jRo);
                                    }
                                });
                                return;
                            }
                            return;
                        }
                        fm(jnrVar, jRo);
                    }
                }
            } catch (Exception unused) {
            }
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(jnr jnrVar, long j10) {
        com.bytedance.sdk.component.ajl.fm.ro.ro.lb lbVar = this.f6593ef;
        if (jnrVar == null || lbVar == null) {
            return;
        }
        com.bytedance.sdk.component.ajl.fm.ro.fm.fm fmVar = yz;
        lbVar.fm(jnrVar.fm(fmVar.ro(j10)), true);
        fmVar.qf();
    }
}