package android.arch.lifecycle;

import android.arch.lifecycle.c;

/* JADX INFO: loaded from: classes.dex */
public abstract class LiveData<T> {
    private static final Object i = new Object();

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private a.a.a.b.b<k<T>, LiveData<T>.a> f341b = new a.a.a.b.b<>();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private int f342c = 0;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private volatile Object f343d = i;

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private int f345f = -1;
    private boolean g;
    private boolean h;

    class LifecycleBoundObserver extends LiveData<T>.a implements GenericLifecycleObserver {

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

        LifecycleBoundObserver(e eVar, k<T> kVar) {
            super(kVar);
            this.f346e = eVar;
        }

        @Override // android.arch.lifecycle.GenericLifecycleObserver
        public void g(e eVar, c.a aVar) {
            if (this.f346e.a().b() == c.b.DESTROYED) {
                LiveData.this.l(this.f348a);
            } else {
                h(k());
            }
        }

        @Override // android.arch.lifecycle.LiveData.a
        void i() {
            this.f346e.a().c(this);
        }

        @Override // android.arch.lifecycle.LiveData.a
        boolean j(e eVar) {
            return this.f346e == eVar;
        }

        @Override // android.arch.lifecycle.LiveData.a
        boolean k() {
            return this.f346e.a().b().isAtLeast(c.b.STARTED);
        }
    }

    private abstract class a {

        /* JADX INFO: renamed from: a, reason: collision with root package name */
        final k<T> f348a;

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

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

        a(k<T> kVar) {
            this.f348a = kVar;
        }

        void h(boolean z) {
            if (z == this.f349b) {
                return;
            }
            this.f349b = z;
            boolean z2 = LiveData.this.f342c == 0;
            LiveData.this.f342c += this.f349b ? 1 : -1;
            if (z2 && this.f349b) {
                LiveData.this.j();
            }
            if (LiveData.this.f342c == 0 && !this.f349b) {
                LiveData.this.k();
            }
            if (this.f349b) {
                LiveData.this.f(this);
            }
        }

        void i() {
        }

        boolean j(e eVar) {
            return false;
        }

        abstract boolean k();
    }

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

    private void e(LiveData<T>.a aVar) {
        if (aVar.f349b) {
            if (!aVar.k()) {
                aVar.h(false);
                return;
            }
            int i2 = aVar.f350c;
            int i3 = this.f345f;
            if (i2 >= i3) {
                return;
            }
            aVar.f350c = i3;
            aVar.f348a.a((T) this.f343d);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void f(LiveData<T>.a aVar) {
        if (this.g) {
            this.h = true;
            return;
        }
        this.g = true;
        do {
            this.h = false;
            if (aVar != null) {
                e(aVar);
                aVar = null;
            } else {
                a.a.a.b.b<k<T>, LiveData<T>.a>.e eVarE = this.f341b.e();
                while (eVarE.hasNext()) {
                    e((a) eVarE.next().getValue());
                    if (this.h) {
                        break;
                    }
                }
            }
        } while (this.h);
        this.g = false;
    }

    public T g() {
        T t = (T) this.f343d;
        if (t != i) {
            return t;
        }
        return null;
    }

    public boolean h() {
        return this.f342c > 0;
    }

    public void i(e eVar, k<T> kVar) {
        if (eVar.a().b() == c.b.DESTROYED) {
            return;
        }
        LifecycleBoundObserver lifecycleBoundObserver = new LifecycleBoundObserver(eVar, kVar);
        LiveData<T>.a aVarH = this.f341b.h(kVar, lifecycleBoundObserver);
        if (aVarH != null && !aVarH.j(eVar)) {
            throw new IllegalArgumentException("Cannot add the same observer with different lifecycles");
        }
        if (aVarH != null) {
            return;
        }
        eVar.a().a(lifecycleBoundObserver);
    }

    protected void j() {
    }

    protected void k() {
    }

    public void l(k<T> kVar) {
        d("removeObserver");
        LiveData<T>.a aVarI = this.f341b.i(kVar);
        if (aVarI == null) {
            return;
        }
        aVarI.i();
        aVarI.h(false);
    }

    protected void m(T t) {
        d("setValue");
        this.f345f++;
        this.f343d = t;
        f(null);
    }
}