package O2;

import a1.C0222i;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import i1.InterfaceC0622b;
import java.util.concurrent.Callable;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public final /* synthetic */ class b implements h, InterfaceC0622b {

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final /* synthetic */ int f2281k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public final /* synthetic */ Object f2282l;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final /* synthetic */ long f2283m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public final /* synthetic */ Object f2284n;

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    public final /* synthetic */ Object f2285o;

    public /* synthetic */ b(g gVar, Object obj, long j5, TimeUnit timeUnit, int i) {
        this.f2281k = i;
        this.f2282l = gVar;
        this.f2285o = obj;
        this.f2283m = j5;
        this.f2284n = timeUnit;
    }

    @Override // i1.InterfaceC0622b
    public Object a() {
        g1.j jVar = (g1.j) this.f2282l;
        h1.h hVar = (h1.h) jVar.f6447c;
        hVar.getClass();
        Iterable iterable = (Iterable) this.f2285o;
        if (iterable.iterator().hasNext()) {
            String str = "UPDATE events SET num_attempts = num_attempts + 1 WHERE _id in " + h1.h.m(iterable);
            SQLiteDatabase sQLiteDatabaseA = hVar.a();
            sQLiteDatabaseA.beginTransaction();
            try {
                sQLiteDatabaseA.compileStatement(str).execute();
                Cursor cursorRawQuery = sQLiteDatabaseA.rawQuery("SELECT COUNT(*), transport_name FROM events WHERE num_attempts >= 16 GROUP BY transport_name", null);
                while (cursorRawQuery.moveToNext()) {
                    try {
                        hVar.k(cursorRawQuery.getInt(0), d1.c.MAX_RETRIES_REACHED, cursorRawQuery.getString(1));
                    } catch (Throwable th) {
                        cursorRawQuery.close();
                        throw th;
                    }
                }
                cursorRawQuery.close();
                sQLiteDatabaseA.compileStatement("DELETE FROM events WHERE num_attempts >= 16").execute();
                sQLiteDatabaseA.setTransactionSuccessful();
            } finally {
                sQLiteDatabaseA.endTransaction();
            }
        }
        hVar.f(new h1.e(jVar.f6451g.b() + this.f2283m, (C0222i) this.f2284n));
        return null;
    }

    @Override // O2.h
    public ScheduledFuture b(final g3.c cVar) {
        switch (this.f2281k) {
            case 0:
                g gVar = (g) this.f2282l;
                return gVar.f2302l.schedule(new e(gVar, (Runnable) this.f2285o, cVar, 1), this.f2283m, (TimeUnit) this.f2284n);
            default:
                final g gVar2 = (g) this.f2282l;
                final Callable callable = (Callable) this.f2285o;
                return gVar2.f2302l.schedule(new Callable() { // from class: O2.f
                    @Override // java.util.concurrent.Callable
                    public final Object call() {
                        g gVar3 = gVar2;
                        int i = 5;
                        return gVar3.f2301k.submit(new F.j(i, callable, cVar));
                    }
                }, this.f2283m, (TimeUnit) this.f2284n);
        }
    }

    public /* synthetic */ b(g1.j jVar, Iterable iterable, C0222i c0222i, long j5) {
        this.f2281k = 2;
        this.f2282l = jVar;
        this.f2285o = iterable;
        this.f2284n = c0222i;
        this.f2283m = j5;
    }
}