package androidx.lifecycle;

import java.util.Map;
import p037.p052.p053.p054.C1700;
import p037.p052.p053.p055.C1706;
import p037.p099.AbstractC2210;
import p037.p099.C2221;
import p037.p099.InterfaceC2217;
import p037.p099.InterfaceC2219;
import p037.p099.InterfaceC2230;
import p138.p139.p143.p144.C2803;

/* JADX INFO: loaded from: classes.dex */
public abstract class LiveData<T> {

    /* JADX INFO: renamed from: އ, reason: contains not printable characters */
    public static final Object f946 = new Object();

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public boolean f953;

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public boolean f954;

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final Object f947 = new Object();

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public C1706<InterfaceC2230<? super T>, LiveData<T>.AbstractC0146> f948 = new C1706<>();

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public int f949 = 0;

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public volatile Object f951 = f946;

    /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
    public final Runnable f955 = new RunnableC0144();

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public volatile Object f950 = f946;

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public int f952 = -1;

    public class LifecycleBoundObserver extends LiveData<T>.AbstractC0146 implements InterfaceC2217 {

        /* JADX INFO: renamed from: އ, reason: contains not printable characters */
        public final InterfaceC2219 f956;

        public LifecycleBoundObserver(InterfaceC2219 interfaceC2219, InterfaceC2230<? super T> interfaceC2230) {
            super(interfaceC2230);
            this.f956 = interfaceC2219;
        }

        @Override // androidx.lifecycle.LiveData.AbstractC0146
        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public void mo350() {
            ((C2221) this.f956.getLifecycle()).f7159.remove(this);
        }

        @Override // p037.p099.InterfaceC2217
        /* JADX INFO: renamed from: ֏ */
        public void mo87(InterfaceC2219 interfaceC2219, AbstractC2210.EnumC2211 enumC2211) {
            if (((C2221) this.f956.getLifecycle()).f7160 == AbstractC2210.EnumC2212.DESTROYED) {
                LiveData.this.mo346((InterfaceC2230) this.f959);
            } else {
                m353(((C2221) this.f956.getLifecycle()).f7160.m4274(AbstractC2210.EnumC2212.STARTED));
            }
        }

        @Override // androidx.lifecycle.LiveData.AbstractC0146
        /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
        public boolean mo351() {
            return ((C2221) this.f956.getLifecycle()).f7160.m4274(AbstractC2210.EnumC2212.STARTED);
        }

        @Override // androidx.lifecycle.LiveData.AbstractC0146
        /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
        public boolean mo352(InterfaceC2219 interfaceC2219) {
            return this.f956 == interfaceC2219;
        }
    }

    /* JADX INFO: renamed from: androidx.lifecycle.LiveData$֏, reason: contains not printable characters */
    public class RunnableC0144 implements Runnable {
        public RunnableC0144() {
        }

        /* JADX WARN: Multi-variable type inference failed */
        @Override // java.lang.Runnable
        public void run() {
            Object obj;
            synchronized (LiveData.this.f947) {
                obj = LiveData.this.f951;
                LiveData.this.f951 = LiveData.f946;
            }
            LiveData.this.mo345(obj);
        }
    }

    /* JADX INFO: renamed from: androidx.lifecycle.LiveData$ؠ, reason: contains not printable characters */
    public class C0145 extends LiveData<T>.AbstractC0146 {
        public C0145(LiveData liveData, InterfaceC2230<? super T> interfaceC2230) {
            super(interfaceC2230);
        }

        @Override // androidx.lifecycle.LiveData.AbstractC0146
        /* JADX INFO: renamed from: ؠ */
        public boolean mo351() {
            return true;
        }
    }

    /* JADX INFO: renamed from: androidx.lifecycle.LiveData$ހ, reason: contains not printable characters */
    public abstract class AbstractC0146 {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final InterfaceC2230<? super T> f959;

        /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
        public boolean f960;

        /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
        public int f961 = -1;

        public AbstractC0146(InterfaceC2230<? super T> interfaceC2230) {
            this.f959 = interfaceC2230;
        }

        /* JADX INFO: renamed from: ֏ */
        public void mo350() {
        }

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public void m353(boolean z) {
            if (z == this.f960) {
                return;
            }
            this.f960 = z;
            boolean z2 = LiveData.this.f949 == 0;
            LiveData.this.f949 += this.f960 ? 1 : -1;
            if (z2 && this.f960) {
                LiveData.this.mo348();
            }
            LiveData liveData = LiveData.this;
            if (liveData.f949 == 0 && !this.f960) {
                liveData.mo349();
            }
            if (this.f960) {
                LiveData.this.m344(this);
            }
        }

        /* JADX INFO: renamed from: ؠ */
        public abstract boolean mo351();

        /* JADX INFO: renamed from: ބ */
        public boolean mo352(InterfaceC2219 interfaceC2219) {
            return false;
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public static void m338(String str) {
        if (!C1700.m3321().mo3323()) {
            throw new IllegalStateException(C2803.m4880("Cannot invoke ", str, " on a background thread"));
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public T m339() {
        T t = (T) this.f950;
        if (t != f946) {
            return t;
        }
        return null;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m340(LiveData<T>.AbstractC0146 abstractC0146) {
        if (abstractC0146.f960) {
            if (!abstractC0146.mo351()) {
                abstractC0146.m353(false);
                return;
            }
            int i = abstractC0146.f961;
            int i2 = this.f952;
            if (i >= i2) {
                return;
            }
            abstractC0146.f961 = i2;
            abstractC0146.f959.mo1576((Object) this.f950);
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void mo341(T t) {
        boolean z;
        synchronized (this.f947) {
            z = this.f951 == f946;
            this.f951 = t;
        }
        if (z) {
            C1700.m3321().f5543.mo3324(this.f955);
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void mo342(InterfaceC2219 interfaceC2219, InterfaceC2230<? super T> interfaceC2230) {
        m338("observe");
        if (((C2221) interfaceC2219.getLifecycle()).f7160 == AbstractC2210.EnumC2212.DESTROYED) {
            return;
        }
        LifecycleBoundObserver lifecycleBoundObserver = new LifecycleBoundObserver(interfaceC2219, interfaceC2230);
        LiveData<T>.AbstractC0146 abstractC0146Mo3327 = this.f948.mo3327(interfaceC2230, lifecycleBoundObserver);
        if (abstractC0146Mo3327 != null && !abstractC0146Mo3327.mo352(interfaceC2219)) {
            throw new IllegalArgumentException("Cannot add the same observer with different lifecycles");
        }
        if (abstractC0146Mo3327 != null) {
            return;
        }
        interfaceC2219.getLifecycle().mo4273(lifecycleBoundObserver);
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m343(InterfaceC2230<? super T> interfaceC2230) {
        m338("observeForever");
        C0145 c0145 = new C0145(this, interfaceC2230);
        LiveData<T>.AbstractC0146 abstractC0146Mo3327 = this.f948.mo3327(interfaceC2230, c0145);
        if (abstractC0146Mo3327 instanceof LifecycleBoundObserver) {
            throw new IllegalArgumentException("Cannot add the same observer with different lifecycles");
        }
        if (abstractC0146Mo3327 != null) {
            return;
        }
        c0145.m353(true);
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public void m344(LiveData<T>.AbstractC0146 abstractC0146) {
        if (this.f953) {
            this.f954 = true;
            return;
        }
        this.f953 = true;
        do {
            this.f954 = false;
            if (abstractC0146 != null) {
                m340((AbstractC0146) abstractC0146);
                abstractC0146 = null;
            } else {
                C1706<InterfaceC2230<? super T>, LiveData<T>.AbstractC0146>.C1710 c1710M3329 = this.f948.m3329();
                while (c1710M3329.hasNext()) {
                    m340((AbstractC0146) ((Map.Entry) c1710M3329.next()).getValue());
                    if (this.f954) {
                        break;
                    }
                }
            }
        } while (this.f954);
        this.f953 = false;
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public void mo345(T t) {
        m338("setValue");
        this.f952++;
        this.f950 = t;
        m344((AbstractC0146) null);
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public void mo346(InterfaceC2230<? super T> interfaceC2230) {
        m338("removeObserver");
        LiveData<T>.AbstractC0146 abstractC0146Remove = this.f948.remove(interfaceC2230);
        if (abstractC0146Remove == null) {
            return;
        }
        abstractC0146Remove.mo350();
        abstractC0146Remove.m353(false);
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public boolean m347() {
        return this.f949 > 0;
    }

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public void mo348() {
    }

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public void mo349() {
    }
}