package defpackage;

import android.database.Cursor;
import android.database.sqlite.SQLiteException;
import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import androidx.room.RoomDatabase;
import defpackage.as4;
import java.io.IOException;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.locks.Lock;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes.dex */
@Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\n\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lbs4;", "Ljava/lang/Runnable;", "room-runtime_release"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class bs4 implements Runnable {
    public final /* synthetic */ as4 a;

    public bs4(as4 as4Var) {
        this.a = as4Var;
    }

    public final pl8 a() throws IOException {
        as4 as4Var = this.a;
        pl8 pl8Var = new pl8();
        Cursor cursorQuery$default = RoomDatabase.query$default(as4Var.a, new xt8("SELECT * FROM room_table_modification_log WHERE invalidated = 1;"), null, 2, null);
        while (cursorQuery$default.moveToNext()) {
            try {
                pl8Var.add(Integer.valueOf(cursorQuery$default.getInt(0)));
            } finally {
            }
        }
        cursorQuery$default.close();
        pl8 pl8VarA = km8.a(pl8Var);
        if (pl8VarA.a.isEmpty()) {
            return pl8VarA;
        }
        if (this.a.h == null) {
            throw new IllegalStateException("Required value was null.");
        }
        pe9 pe9Var = this.a.h;
        if (pe9Var == null) {
            throw new IllegalArgumentException("Required value was null.");
        }
        pe9Var.executeUpdateDelete();
        return pl8VarA;
    }

    @Override // java.lang.Runnable
    public final void run() {
        Set setA;
        Lock closeLock$room_runtime_release = this.a.a.getCloseLock$room_runtime_release();
        closeLock$room_runtime_release.lock();
        try {
            try {
                try {
                } catch (SQLiteException e) {
                    Log.e("ROOM", "Cannot run invalidation tracker. Is the db closed?", e);
                    setA = pk2.a;
                }
            } catch (IllegalStateException e2) {
                Log.e("ROOM", "Cannot run invalidation tracker. Is the db closed?", e2);
                setA = pk2.a;
            }
            if (this.a.b()) {
                if (this.a.f.compareAndSet(true, false)) {
                    if (this.a.a.inTransaction()) {
                        return;
                    }
                    je9 writableDatabase = this.a.a.getOpenHelper().getWritableDatabase();
                    writableDatabase.beginTransactionNonExclusive();
                    try {
                        setA = a();
                        writableDatabase.setTransactionSuccessful();
                        if (setA.isEmpty()) {
                            return;
                        }
                        as4 as4Var = this.a;
                        synchronized (as4Var.k) {
                            Iterator it = as4Var.k.iterator();
                            while (it.hasNext()) {
                                ((as4.d) ((Map.Entry) it.next()).getValue()).a(setA);
                            }
                        }
                    } finally {
                        writableDatabase.endTransaction();
                    }
                }
            }
        } finally {
            closeLock$room_runtime_release.unlock();
        }
    }
}