package p037.p109;

import android.annotation.SuppressLint;
import androidx.lifecycle.LiveData;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.atomic.AtomicBoolean;
import p037.p052.p053.p054.C1700;
import p037.p109.C2387;

/* JADX INFO: renamed from: މ.ސ.މ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C2410<T> extends LiveData<T> {

    /* JADX INFO: renamed from: ވ, reason: contains not printable characters */
    public final AbstractC2401 f7639;

    /* JADX INFO: renamed from: މ, reason: contains not printable characters */
    public final boolean f7640;

    /* JADX INFO: renamed from: ފ, reason: contains not printable characters */
    public final Callable<T> f7641;

    /* JADX INFO: renamed from: ދ, reason: contains not printable characters */
    public final C2386 f7642;

    /* JADX INFO: renamed from: ތ, reason: contains not printable characters */
    public final C2387.AbstractC2390 f7643;

    /* JADX INFO: renamed from: ލ, reason: contains not printable characters */
    public final AtomicBoolean f7644 = new AtomicBoolean(true);

    /* JADX INFO: renamed from: ގ, reason: contains not printable characters */
    public final AtomicBoolean f7645 = new AtomicBoolean(false);

    /* JADX INFO: renamed from: ޏ, reason: contains not printable characters */
    public final AtomicBoolean f7646 = new AtomicBoolean(false);
    public final Runnable mRefreshRunnable = new RunnableC2411();

    /* JADX INFO: renamed from: ސ, reason: contains not printable characters */
    public final Runnable f7647 = new RunnableC2412();

    /* JADX INFO: renamed from: މ.ސ.މ$֏, reason: contains not printable characters */
    public class RunnableC2411 implements Runnable {
        public RunnableC2411() {
        }

        @Override // java.lang.Runnable
        public void run() {
            boolean z;
            if (C2410.this.f7646.compareAndSet(false, true)) {
                C2410 c2410 = C2410.this;
                C2387 c2387 = c2410.f7639.f7599;
                C2387.AbstractC2390 abstractC2390 = c2410.f7643;
                if (c2387 == null) {
                    throw null;
                }
                c2387.m4456(new C2387.C2392(c2387, abstractC2390));
            }
            do {
                if (C2410.this.f7645.compareAndSet(false, true)) {
                    T tCall = null;
                    z = false;
                    while (C2410.this.f7644.compareAndSet(true, false)) {
                        try {
                            try {
                                tCall = C2410.this.f7641.call();
                                z = true;
                            } catch (Exception e) {
                                throw new RuntimeException("Exception while computing database live data.", e);
                            }
                        } finally {
                            C2410.this.f7645.set(false);
                        }
                    }
                    if (z) {
                        C2410.this.mo341(tCall);
                    }
                } else {
                    z = false;
                }
                if (!z) {
                    return;
                }
            } while (C2410.this.f7644.get());
        }
    }

    /* JADX INFO: renamed from: މ.ސ.މ$ؠ, reason: contains not printable characters */
    public class RunnableC2412 implements Runnable {
        public RunnableC2412() {
        }

        @Override // java.lang.Runnable
        public void run() {
            boolean zM347 = C2410.this.m347();
            if (C2410.this.f7644.compareAndSet(false, true) && zM347) {
                C2410 c2410 = C2410.this;
                (c2410.f7640 ? c2410.f7639.f7597 : c2410.f7639.f7596).execute(C2410.this.mRefreshRunnable);
            }
        }
    }

    /* JADX INFO: renamed from: މ.ސ.މ$ހ, reason: contains not printable characters */
    public class C2413 extends C2387.AbstractC2390 {
        public C2413(String[] strArr) {
            super(strArr);
        }

        @Override // p037.p109.C2387.AbstractC2390
        /* JADX INFO: renamed from: ֏ */
        public void mo4471(Set<String> set) {
            C1700 c1700M3321 = C1700.m3321();
            Runnable runnable = C2410.this.f7647;
            if (c1700M3321.mo3323()) {
                runnable.run();
            } else {
                c1700M3321.mo3324(runnable);
            }
        }
    }

    @SuppressLint({"RestrictedApi"})
    public C2410(AbstractC2401 abstractC2401, C2386 c2386, boolean z, Callable<T> callable, String[] strArr) {
        this.f7639 = abstractC2401;
        this.f7640 = z;
        this.f7641 = callable;
        this.f7642 = c2386;
        this.f7643 = new C2413(strArr);
    }

    @Override // androidx.lifecycle.LiveData
    /* JADX INFO: renamed from: ހ */
    public void mo348() {
        this.f7642.f7546.add(this);
        (this.f7640 ? this.f7639.f7597 : this.f7639.f7596).execute(this.mRefreshRunnable);
    }

    @Override // androidx.lifecycle.LiveData
    /* JADX INFO: renamed from: ށ */
    public void mo349() {
        this.f7642.f7546.remove(this);
    }
}