package O1;

import Z6.AbstractC0385z;
import Z6.C0381v;
import android.content.Intent;
import com.martsnew.data.local.AppDatabase_Impl;
import java.util.Collections;
import java.util.IdentityHashMap;
import java.util.LinkedHashMap;
import java.util.concurrent.locks.ReentrantLock;

/* JADX INFO: renamed from: O1.j, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes.dex */
public final class C0234j {

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final String[] f5041b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final T f5042c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final LinkedHashMap f5043d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final ReentrantLock f5044e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final C0232h f5045f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final C0232h f5046g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public Intent f5047h;
    public C0238n i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final Object f5048j;

    public C0234j(AppDatabase_Impl appDatabase_Impl, LinkedHashMap linkedHashMap, LinkedHashMap linkedHashMap2, String... strArr) {
        this.f5040a = appDatabase_Impl;
        this.f5041b = strArr;
        T t6 = new T(appDatabase_Impl, linkedHashMap, linkedHashMap2, strArr, appDatabase_Impl.f4922j, new F5.n(1, this, C0234j.class, "notifyInvalidatedObservers", "notifyInvalidatedObservers(Ljava/util/Set;)V", 0, 4));
        this.f5042c = t6;
        this.f5043d = new LinkedHashMap();
        this.f5044e = new ReentrantLock();
        this.f5045f = new C0232h(this, 0);
        this.f5046g = new C0232h(this, 1);
        P6.g.d(Collections.newSetFromMap(new IdentityHashMap()), "newSetFromMap(...)");
        this.f5048j = new Object();
        t6.f5008k = new C0232h(this, 2);
    }

    public final void a() {
        T t6 = this.f5042c;
        t6.getClass();
        C0232h c0232h = this.f5045f;
        P6.g.e(c0232h, "onRefreshScheduled");
        C0232h c0232h2 = this.f5046g;
        P6.g.e(c0232h2, "onRefreshCompleted");
        if (t6.f5007j.compareAndSet(false, true)) {
            c0232h.a();
            e7.c cVar = t6.f4999a.f4914a;
            if (cVar != null) {
                AbstractC0385z.r(cVar, new C0381v(), new M(t6, c0232h2, null), 2);
            } else {
                P6.g.h("coroutineScope");
                throw null;
            }
        }
    }

    public final Object b(G6.i iVar) {
        Object objE;
        AppDatabase_Impl appDatabase_Impl = this.f5040a;
        return ((!appDatabase_Impl.g() || appDatabase_Impl.h()) && (objE = this.f5042c.e(iVar)) == F6.a.f2580q) ? objE : A6.n.f457a;
    }
}