package androidx.lifecycle;

import androidx.lifecycle.f;

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

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    static final Object f904k = new Object();
    final Object a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private c.b.a.b.b<r<? super T>, LiveData<T>.c> f905b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    int f906c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private boolean f907d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private volatile Object f908e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    volatile Object f909f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private int f910g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private boolean f911h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private boolean f912i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    private final Runnable f913j;

    class LifecycleBoundObserver extends LiveData<T>.c implements j {

        /* JADX INFO: renamed from: i, reason: collision with root package name */
        final l f914i;

        LifecycleBoundObserver(l lVar, r<? super T> rVar) {
            super(rVar);
            this.f914i = lVar;
        }

        @Override // androidx.lifecycle.j
        public void d(l lVar, f.b bVar) {
            f.c cVarB = this.f914i.a().b();
            if (cVarB == f.c.DESTROYED) {
                LiveData.this.l(this.f917b);
                return;
            }
            f.c cVar = null;
            while (cVar != cVarB) {
                h(k());
                cVar = cVarB;
                cVarB = this.f914i.a().b();
            }
        }

        @Override // androidx.lifecycle.LiveData.c
        void i() {
            this.f914i.a().c(this);
        }

        @Override // androidx.lifecycle.LiveData.c
        boolean j(l lVar) {
            return this.f914i == lVar;
        }

        @Override // androidx.lifecycle.LiveData.c
        boolean k() {
            return this.f914i.a().b().isAtLeast(f.c.STARTED);
        }
    }

    class a implements Runnable {
        a() {
        }

        /* JADX WARN: Multi-variable type inference failed */
        @Override // java.lang.Runnable
        public void run() {
            Object obj;
            synchronized (LiveData.this.a) {
                obj = LiveData.this.f909f;
                LiveData.this.f909f = LiveData.f904k;
            }
            LiveData.this.m(obj);
        }
    }

    private class b extends LiveData<T>.c {
        b(LiveData liveData, r<? super T> rVar) {
            super(rVar);
        }

        @Override // androidx.lifecycle.LiveData.c
        boolean k() {
            return true;
        }
    }

    private abstract class c {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        final r<? super T> f917b;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        boolean f918f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        int f919g = -1;

        c(r<? super T> rVar) {
            this.f917b = rVar;
        }

        void h(boolean z) {
            if (z == this.f918f) {
                return;
            }
            this.f918f = z;
            LiveData.this.b(z ? 1 : -1);
            if (this.f918f) {
                LiveData.this.d(this);
            }
        }

        void i() {
        }

        boolean j(l lVar) {
            return false;
        }

        abstract boolean k();
    }

    public LiveData(T t) {
        this.a = new Object();
        this.f905b = new c.b.a.b.b<>();
        this.f906c = 0;
        this.f909f = f904k;
        this.f913j = new a();
        this.f908e = t;
        this.f910g = 0;
    }

    static void a(String str) {
        if (c.b.a.a.a.c().a()) {
            return;
        }
        throw new IllegalStateException("Cannot invoke " + str + " on a background thread");
    }

    private void c(LiveData<T>.c cVar) {
        if (cVar.f918f) {
            if (!cVar.k()) {
                cVar.h(false);
                return;
            }
            int i2 = cVar.f919g;
            int i3 = this.f910g;
            if (i2 >= i3) {
                return;
            }
            cVar.f919g = i3;
            cVar.f917b.a((Object) this.f908e);
        }
    }

    void b(int i2) {
        int i3 = this.f906c;
        this.f906c = i2 + i3;
        if (this.f907d) {
            return;
        }
        this.f907d = true;
        while (true) {
            try {
                if (i3 == this.f906c) {
                    return;
                }
                boolean z = i3 == 0 && this.f906c > 0;
                boolean z2 = i3 > 0 && this.f906c == 0;
                int i4 = this.f906c;
                if (z) {
                    i();
                } else if (z2) {
                    j();
                }
                i3 = i4;
            } finally {
                this.f907d = false;
            }
        }
    }

    void d(LiveData<T>.c cVar) {
        if (this.f911h) {
            this.f912i = true;
            return;
        }
        this.f911h = true;
        do {
            this.f912i = false;
            if (cVar != null) {
                c(cVar);
                cVar = null;
            } else {
                c.b.a.b.b<r<? super T>, LiveData<T>.c>.d dVarC = this.f905b.c();
                while (dVarC.hasNext()) {
                    c((c) dVarC.next().getValue());
                    if (this.f912i) {
                        break;
                    }
                }
            }
        } while (this.f912i);
        this.f911h = false;
    }

    public T e() {
        T t = (T) this.f908e;
        if (t != f904k) {
            return t;
        }
        return null;
    }

    public boolean f() {
        return this.f906c > 0;
    }

    public void g(l lVar, r<? super T> rVar) {
        a("observe");
        if (lVar.a().b() == f.c.DESTROYED) {
            return;
        }
        LifecycleBoundObserver lifecycleBoundObserver = new LifecycleBoundObserver(lVar, rVar);
        LiveData<T>.c cVarF = this.f905b.f(rVar, lifecycleBoundObserver);
        if (cVarF != null && !cVarF.j(lVar)) {
            throw new IllegalArgumentException("Cannot add the same observer with different lifecycles");
        }
        if (cVarF != null) {
            return;
        }
        lVar.a().a(lifecycleBoundObserver);
    }

    public void h(r<? super T> rVar) {
        a("observeForever");
        b bVar = new b(this, rVar);
        LiveData<T>.c cVarF = this.f905b.f(rVar, bVar);
        if (cVarF instanceof LifecycleBoundObserver) {
            throw new IllegalArgumentException("Cannot add the same observer with different lifecycles");
        }
        if (cVarF != null) {
            return;
        }
        bVar.h(true);
    }

    protected void i() {
    }

    protected void j() {
    }

    protected void k(T t) {
        boolean z;
        synchronized (this.a) {
            z = this.f909f == f904k;
            this.f909f = t;
        }
        if (z) {
            c.b.a.a.a.c().b(this.f913j);
        }
    }

    public void l(r<? super T> rVar) {
        a("removeObserver");
        LiveData<T>.c cVarG = this.f905b.g(rVar);
        if (cVarG == null) {
            return;
        }
        cVarG.i();
        cVarG.h(false);
    }

    protected void m(T t) {
        a("setValue");
        this.f910g++;
        this.f908e = t;
        d(null);
    }

    public LiveData() {
        this.a = new Object();
        this.f905b = new c.b.a.b.b<>();
        this.f906c = 0;
        this.f909f = f904k;
        this.f913j = new a();
        this.f908e = f904k;
        this.f910g = -1;
    }
}