package m6;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteFullException;
import android.os.Handler;
import android.os.Message;
import android.os.SystemClock;
import androidx.media3.common.C;
import com.bytedance.sdk.openadsdk.TTAdConstant;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import l6.g;
import l6.h;
import l6.i;
import tv.danmaku.ijk.media.player.IMediaPlayer;

/* JADX INFO: loaded from: classes.dex */
public final class d implements Handler.Callback, i {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final Context f30397a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final l6.d f30398b;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public volatile a f30400d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public volatile Handler f30401e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public volatile Handler f30402f;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final ConcurrentHashMap f30399c = new ConcurrentHashMap();

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

    public d(Context context, l6.d dVar) {
        this.f30397a = context;
        this.f30398b = dVar;
        dVar.ro(true);
        for (Map.Entry<Class<? extends l6.b>, h> entry : dVar.jnr().entrySet()) {
            Class<? extends l6.b> key = entry.getKey();
            this.f30399c.put(key, new f(this, entry.getValue()));
            Objects.toString(key);
        }
        new b(this, "AppLogS", 0).start();
        new b(this, "AppLogU", 1).start();
    }

    public static void c(d dVar) {
        if (dVar.f30401e == null || dVar.f30402f == null) {
            return;
        }
        for (f fVar : dVar.f30399c.values()) {
            try {
                a aVarA = dVar.a();
                n6.a aVar = fVar.f30416j;
                h hVar = fVar.f30409c;
                long jJnr = hVar.jnr();
                if (jJnr > 0) {
                    try {
                        int iDelete = aVarA.getWritableDatabase().delete(hVar.yz(), "create_time < ?", new String[]{String.valueOf(System.currentTimeMillis() - jJnr)});
                        if (iDelete > 0 && aVar != null) {
                            aVar.a(4, iDelete);
                        }
                    } catch (Throwable unused) {
                        if (aVar != null) {
                            aVar.a(10003, 1);
                        }
                    }
                }
                dVar.d(fVar, false);
                n6.a aVar2 = fVar.f30416j;
                if (aVar2 != null) {
                    aVar2.b(dVar.f30401e.getLooper(), fVar);
                }
            } catch (Exception unused2) {
            }
        }
        dVar.f30403g = true;
    }

    public final a a() {
        if (this.f30400d == null) {
            synchronized (this) {
                try {
                    if (this.f30400d == null) {
                        this.f30400d = new a(this.f30397a, this, this.f30398b);
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        }
        return this.f30400d;
    }

    public final void b(l6.b bVar, boolean z10) {
        int size;
        char c6;
        Handler handler;
        Objects.toString(bVar);
        f fVar = (f) this.f30399c.get(bVar.getClass());
        if (fVar == null) {
            return;
        }
        synchronized (fVar.f30407a) {
            fVar.f30407a.add(bVar);
            size = fVar.f30407a.size();
        }
        if (bVar.ro() == 1) {
            c6 = 6;
        } else {
            int iZ = (int) (hb.a.Z(true) * fVar.f30409c.ef());
            if (iZ <= 0) {
                iZ = 1;
            }
            c6 = size > iZ ? (char) 2 : (char) 1;
        }
        if ((c6 & 4) == 4 && this.f30398b.fm()) {
            bVar.toString();
            a();
            fVar.g();
        }
        if (z10 || (c6 & 2) == 2) {
            if (this.f30402f != null) {
                this.f30402f.removeMessages(1001, fVar);
            }
            bVar.toString();
            f(fVar);
        } else if (this.f30402f != null && !this.f30402f.hasMessages(1001, fVar)) {
            Handler handler2 = this.f30402f;
            Message messageObtainMessage = this.f30402f.obtainMessage(1001, fVar);
            long jZ = (long) (hb.a.Z(true) * fVar.f30409c.vt());
            if (jZ <= 0) {
                jZ = 100;
            }
            handler2.sendMessageDelayed(messageObtainMessage, jZ);
            fVar.f30409c.vt();
            hb.a.Z(true);
        }
        n6.a aVar = fVar.f30416j;
        if (aVar == null || (handler = aVar.f30888f) == null || handler.hasMessages(10000)) {
            return;
        }
        aVar.f30888f.sendEmptyMessageDelayed(10000, 60000L);
    }

    public final void d(f fVar, boolean z10) {
        long jMin = 0;
        if (!z10) {
            long jZ = (long) (hb.a.Z(false) * fVar.f30409c.fm());
            if (jZ <= 0 || jZ > TTAdConstant.AD_MAX_EVENT_TIME) {
                jZ = C.DEFAULT_SEEK_FORWARD_INCREMENT_MS;
            }
            if (fVar.f30415i.get() < 2) {
                jMin = jZ;
            } else {
                jMin = (long) Math.min(600000.0d, Math.pow(2.0d, fVar.f30415i.get()) * jZ);
                fVar.f30415i.get();
            }
        }
        this.f30401e.removeMessages(1002, fVar);
        this.f30401e.sendMessageDelayed(this.f30401e.obtainMessage(1002, fVar), jMin);
        Objects.toString(fVar.f30409c);
    }

    public final void e(f fVar, boolean z10, boolean z11, boolean z12) {
        if (z11 && !z10) {
            Objects.toString(fVar.f30409c);
            return;
        }
        if (z11 && z12) {
            Objects.toString(fVar.f30409c);
        } else if (this.f30401e.hasMessages(1002, fVar)) {
            return;
        }
        d(fVar, z11 && z10);
    }

    /* JADX WARN: Not initialized variable reg: 8, insn: 0x0223: IF  (r8 I:??[int, boolean, OBJECT, ARRAY, byte, short, char]) == (0 ??[int, boolean, OBJECT, ARRAY, byte, short, char])  -> B:144:0x022e (LINE:548), block:B:140:0x0223 */
    /* JADX WARN: Removed duplicated region for block: B:121:0x01dd  */
    /* JADX WARN: Removed duplicated region for block: B:201:? A[RETURN, SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:62:0x0112 A[Catch: Exception -> 0x0130, PHI: r8 r15
      0x0112: PHI (r8v8 android.database.sqlite.SQLiteDatabase) = (r8v7 android.database.sqlite.SQLiteDatabase), (r8v9 android.database.sqlite.SQLiteDatabase) binds: [B:72:0x012d, B:61:0x0110] A[DONT_GENERATE, DONT_INLINE]
      0x0112: PHI (r15v6 java.util.ArrayList) = (r15v5 java.util.ArrayList), (r15v7 java.util.ArrayList) binds: [B:72:0x012d, B:61:0x0110] A[DONT_GENERATE, DONT_INLINE], TRY_LEAVE, TryCatch #0 {Exception -> 0x0130, blocks: (B:71:0x0129, B:62:0x0112, B:60:0x010c), top: B:157:0x0029 }] */
    /* JADX WARN: Removed duplicated region for block: B:76:0x0133  */
    /* JADX WARN: Removed duplicated region for block: B:97:0x01aa A[Catch: Exception -> 0x01d4, PHI: r4
      0x01aa: PHI (r4v10 android.database.sqlite.SQLiteDatabase) = (r4v9 android.database.sqlite.SQLiteDatabase), (r4v11 android.database.sqlite.SQLiteDatabase) binds: [B:105:0x01be, B:96:0x01a8] A[DONT_GENERATE, DONT_INLINE], TRY_LEAVE, TryCatch #6 {Exception -> 0x01d4, blocks: (B:95:0x01a4, B:97:0x01aa, B:104:0x01ba), top: B:169:0x0168 }] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void f(f fVar) {
        ArrayList arrayList;
        SQLiteDatabase sQLiteDatabase;
        ArrayList arrayList2;
        boolean z10;
        HashSet<String> hashSet;
        SQLiteDatabase writableDatabase;
        SQLiteDatabase writableDatabase2;
        if (fVar.f30407a.size() == 0) {
            Objects.toString(fVar.f30409c);
            return;
        }
        l6.d dVar = this.f30398b;
        a aVarA = a();
        synchronized (fVar.f30407a) {
            arrayList = new ArrayList(fVar.f30407a);
        }
        boolean z11 = true;
        boolean z12 = false;
        try {
            if (arrayList.isEmpty()) {
                z10 = false;
                Objects.toString(fVar.f30409c);
                if (this.f30401e != null) {
                    if (!z10) {
                        a();
                        fVar.g();
                        return;
                    }
                    if (!this.f30401e.hasMessages(1002, fVar) && !(!fVar.f30410d.isEmpty())) {
                        z12 = true;
                    }
                    boolean z13 = !this.f30398b.ef();
                    if (z12 || !fVar.f30420n || fVar.f30414h.get() < fVar.f30409c.wu()) {
                        z11 = z12;
                    } else {
                        Objects.toString(fVar.f30409c);
                        z13 = true;
                    }
                    if (z11) {
                        d(fVar, z13);
                        return;
                    }
                    return;
                }
                return;
            }
            try {
                writableDatabase2 = aVarA.getWritableDatabase();
                try {
                    try {
                        writableDatabase2.beginTransaction();
                        if (fVar.f30417k == null) {
                            fVar.f30417k = writableDatabase2.compileStatement("INSERT OR REPLACE INTO " + fVar.f30409c.yz() + "(data_id,data,priority,upload_retry_count,create_time) VALUES (?,?,?,?,?)");
                        }
                        int size = arrayList.size();
                        int i10 = 0;
                        while (i10 < size) {
                            try {
                                l6.b bVar = (l6.b) arrayList.get(i10);
                                byte[] bArrYz = bVar.yz();
                                if (bArrYz == null || bArrYz.length == 0) {
                                    arrayList2 = arrayList;
                                    bVar.toString();
                                    n6.a aVar = fVar.f30416j;
                                    if (aVar != null) {
                                        aVar.a(9, 1);
                                    }
                                } else {
                                    l6.c cVarYz = dVar.yz();
                                    if (cVarYz != null) {
                                        byte[] bArrFm = cVarYz.fm(bArrYz);
                                        if (bArrFm != null) {
                                            n6.a aVar2 = fVar.f30416j;
                                            if (aVar2 != null) {
                                                aVar2.a(5, 1);
                                            }
                                            bArrYz = bArrFm;
                                        } else {
                                            n6.a aVar3 = fVar.f30416j;
                                            if (aVar3 != null) {
                                                aVar3.a(6, 1);
                                            }
                                        }
                                    }
                                    fVar.f30417k.clearBindings();
                                    fVar.f30417k.bindString(1, bVar.ajl());
                                    fVar.f30417k.bindBlob(2, bArrYz);
                                    arrayList2 = arrayList;
                                    try {
                                        try {
                                            fVar.f30417k.bindLong(3, bVar.ro());
                                            fVar.f30417k.bindLong(4, bVar.jnr());
                                            fVar.f30417k.bindLong(5, bVar.fm());
                                            fVar.f30417k.executeInsert();
                                        } catch (Throwable unused) {
                                            n6.a aVar4 = fVar.f30416j;
                                            if (aVar4 != null) {
                                                aVar4.a(IMediaPlayer.MEDIA_INFO_VIDEO_DECODED_START, 1);
                                            }
                                            if (writableDatabase2 != null && writableDatabase2.inTransaction()) {
                                                writableDatabase2.endTransaction();
                                            }
                                            z10 = false;
                                            if (z10) {
                                            }
                                            Objects.toString(fVar.f30409c);
                                            if (this.f30401e != null) {
                                            }
                                        }
                                    } catch (Exception unused2) {
                                        try {
                                            n6.a aVar5 = fVar.f30416j;
                                            if (aVar5 != null) {
                                                aVar5.a(12, 1);
                                            }
                                        } catch (SQLiteFullException unused3) {
                                            arrayList2.size();
                                            n6.a aVar6 = fVar.f30416j;
                                            if (aVar6 != null) {
                                                aVar6.a(IMediaPlayer.MEDIA_INFO_FIND_STREAM_INFO, 1);
                                            }
                                            if (writableDatabase2 != null && writableDatabase2.inTransaction()) {
                                            }
                                            z10 = false;
                                            if (z10) {
                                            }
                                            Objects.toString(fVar.f30409c);
                                            if (this.f30401e != null) {
                                            }
                                        }
                                    }
                                }
                            } catch (Exception unused4) {
                                arrayList2 = arrayList;
                            }
                            i10++;
                            arrayList = arrayList2;
                        }
                        arrayList2 = arrayList;
                        writableDatabase2.setTransactionSuccessful();
                        arrayList2.size();
                        try {
                            if (writableDatabase2.inTransaction()) {
                                writableDatabase2.endTransaction();
                            }
                        } catch (Exception unused5) {
                        }
                        z10 = true;
                    } catch (SQLiteFullException unused6) {
                        arrayList2 = arrayList;
                    }
                } catch (Throwable unused7) {
                    arrayList2 = arrayList;
                }
            } catch (SQLiteFullException unused8) {
                arrayList2 = arrayList;
                writableDatabase2 = null;
            } catch (Throwable unused9) {
                arrayList2 = arrayList;
                writableDatabase2 = null;
            }
            if (z10) {
                fVar.f30419m = SystemClock.elapsedRealtime();
                fVar.f30414h.addAndGet(arrayList2.size());
                synchronized (fVar.f30407a) {
                    ArrayList arrayList3 = arrayList2;
                    fVar.f30407a.removeAll(arrayList3);
                    arrayList3.size();
                }
                if (!fVar.f30411e.isEmpty()) {
                    synchronized (fVar.f30411e) {
                        hashSet = new HashSet(fVar.f30411e);
                        fVar.f30411e.clear();
                    }
                    try {
                        writableDatabase = aVarA.getWritableDatabase();
                    } catch (Throwable unused10) {
                        writableDatabase = null;
                    }
                    try {
                        writableDatabase.beginTransaction();
                        HashSet hashSet2 = new HashSet();
                        for (String str : hashSet) {
                            if (writableDatabase.delete(fVar.f30409c.yz(), "data_id = ?", new String[]{str}) == 0) {
                                hashSet2.add(str);
                            }
                        }
                        writableDatabase.setTransactionSuccessful();
                        hashSet.size();
                        hashSet2.size();
                    } catch (Throwable unused11) {
                        try {
                            n6.a aVar7 = fVar.f30416j;
                            if (aVar7 != null) {
                                aVar7.a(10002, 1);
                            }
                            if (writableDatabase != null && writableDatabase.inTransaction()) {
                            }
                        } catch (Throwable th) {
                            if (writableDatabase != null) {
                                try {
                                    if (writableDatabase.inTransaction()) {
                                        writableDatabase.endTransaction();
                                    }
                                } catch (Exception unused12) {
                                }
                            }
                            throw th;
                        }
                    }
                    if (writableDatabase.inTransaction()) {
                        writableDatabase.endTransaction();
                    }
                }
            }
            Objects.toString(fVar.f30409c);
            if (this.f30401e != null) {
            }
            z10 = false;
            if (z10) {
            }
            Objects.toString(fVar.f30409c);
            if (this.f30401e != null) {
            }
        } catch (Throwable th2) {
            if (sQLiteDatabase != null) {
                try {
                    if (sQLiteDatabase.inTransaction()) {
                        sQLiteDatabase.endTransaction();
                    }
                } catch (Exception unused13) {
                }
            }
            throw th2;
        }
    }

    public final void g(l6.b bVar) {
        g gVarRo = this.f30398b.ro();
        ExecutorService executorServiceFm = gVarRo != null ? gVarRo.fm() : null;
        if (executorServiceFm == null) {
            if (o6.b.f31425b == null) {
                synchronized (o6.b.class) {
                    try {
                        if (o6.b.f31425b == null) {
                            o6.b.f31425b = new ThreadPoolExecutor(1, 2, 60L, TimeUnit.SECONDS, new PriorityBlockingQueue(), new o6.a(1));
                        }
                    } catch (Throwable th) {
                        throw th;
                    }
                }
            }
            executorServiceFm = o6.b.f31425b;
        }
        Objects.toString(bVar);
        executorServiceFm.execute(new c(this, bVar.wsy(), bVar));
    }

    @Override // android.os.Handler.Callback
    public final boolean handleMessage(Message message) {
        if (!com.bumptech.glide.f.f5562b) {
            return true;
        }
        try {
            switch (message.what) {
                case 1000:
                    Object obj = message.obj;
                    if (!(obj instanceof l6.b)) {
                        obj.getClass();
                    } else {
                        b((l6.b) obj, false);
                    }
                    break;
                case 1001:
                    f((f) message.obj);
                    break;
                case 1002:
                    f fVar = (f) message.obj;
                    if (!this.f30398b.vt()) {
                        fVar.d(a(), this.f30398b.wu());
                    } else {
                        fVar.b(a());
                    }
                    break;
                case 1003:
                    ((f) message.obj).h(a());
                    break;
                case 1004:
                    ((f) message.obj).e(a());
                    break;
            }
        } catch (Exception unused) {
        }
        return true;
    }
}