package androidx.lifecycle;

import androidx.lifecycle.g;

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

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

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private h.b<q<? super T>, LiveData<T>.c> f2516b = new h.b<>();

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

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

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

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

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

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

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        final /* synthetic */ LiveData f2525f;

        @Override // androidx.lifecycle.i
        public void g(k kVar, g.b bVar) {
            g.c cVarB = this.f2524e.a().b();
            if (cVarB == g.c.DESTROYED) {
                this.f2525f.h(this.f2527a);
                return;
            }
            g.c cVar = null;
            while (cVar != cVarB) {
                h(j());
                cVar = cVarB;
                cVarB = this.f2524e.a().b();
            }
        }

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

        @Override // androidx.lifecycle.LiveData.c
        boolean j() {
            return this.f2524e.a().b().isAtLeast(g.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.f2515a) {
                obj = LiveData.this.f2520f;
                LiveData.this.f2520f = LiveData.f2514j;
            }
            LiveData.this.i(obj);
        }
    }

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

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

    private abstract class c {

        /* JADX INFO: renamed from: a, reason: collision with root package name */
        final q<? super T> f2527a;

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

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

        c(q<? super T> qVar) {
            this.f2527a = qVar;
        }

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

        void i() {
        }

        abstract boolean j();
    }

    public LiveData() {
        Object obj = f2514j;
        this.f2520f = obj;
        new a();
        this.f2519e = obj;
        this.f2521g = -1;
    }

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

    private void c(LiveData<T>.c cVar) {
        if (cVar.f2528b) {
            if (!cVar.j()) {
                cVar.h(false);
                return;
            }
            int i3 = cVar.f2529c;
            int i4 = this.f2521g;
            if (i3 >= i4) {
                return;
            }
            cVar.f2529c = i4;
            cVar.f2527a.a((Object) this.f2519e);
        }
    }

    void b(int i3) {
        int i4 = this.f2517c;
        this.f2517c = i3 + i4;
        if (this.f2518d) {
            return;
        }
        this.f2518d = true;
        while (true) {
            try {
                int i5 = this.f2517c;
                if (i4 == i5) {
                    return;
                }
                boolean z2 = i4 == 0 && i5 > 0;
                boolean z3 = i4 > 0 && i5 == 0;
                if (z2) {
                    f();
                } else if (z3) {
                    g();
                }
                i4 = i5;
            } finally {
                this.f2518d = false;
            }
        }
    }

    void d(LiveData<T>.c cVar) {
        if (this.f2522h) {
            this.f2523i = true;
            return;
        }
        this.f2522h = true;
        do {
            this.f2523i = false;
            if (cVar != null) {
                c(cVar);
                cVar = null;
            } else {
                h.b<q<? super T>, LiveData<T>.c>.d dVarD = this.f2516b.d();
                while (dVarD.hasNext()) {
                    c((c) dVarD.next().getValue());
                    if (this.f2523i) {
                        break;
                    }
                }
            }
        } while (this.f2523i);
        this.f2522h = false;
    }

    public void e(q<? super T> qVar) {
        a("observeForever");
        b bVar = new b(this, qVar);
        LiveData<T>.c cVarG = this.f2516b.g(qVar, bVar);
        if (cVarG instanceof LifecycleBoundObserver) {
            throw new IllegalArgumentException("Cannot add the same observer with different lifecycles");
        }
        if (cVarG != null) {
            return;
        }
        bVar.h(true);
    }

    protected void f() {
    }

    protected void g() {
    }

    public void h(q<? super T> qVar) {
        a("removeObserver");
        LiveData<T>.c cVarH = this.f2516b.h(qVar);
        if (cVarH == null) {
            return;
        }
        cVarH.i();
        cVarH.h(false);
    }

    protected void i(T t2) {
        a("setValue");
        this.f2521g++;
        this.f2519e = t2;
        d(null);
    }
}