package f.a.k;

import java.util.ArrayList;

/* JADX INFO: compiled from: CompositeDisposable.java */
/* JADX INFO: loaded from: classes.dex */
public final class a implements b, f.a.n.a.a {
    f.a.n.h.d<b> b;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    volatile boolean f822e;

    @Override // f.a.n.a.a
    public boolean a(b bVar) {
        f.a.n.b.b.d(bVar, "Disposable item is null");
        if (this.f822e) {
            return false;
        }
        synchronized (this) {
            if (this.f822e) {
                return false;
            }
            f.a.n.h.d<b> dVar = this.b;
            if (dVar != null && dVar.e(bVar)) {
                return true;
            }
            return false;
        }
    }

    @Override // f.a.n.a.a
    public boolean b(b bVar) {
        if (!a(bVar)) {
            return false;
        }
        bVar.dispose();
        return true;
    }

    @Override // f.a.n.a.a
    public boolean c(b bVar) {
        f.a.n.b.b.d(bVar, "d is null");
        if (!this.f822e) {
            synchronized (this) {
                if (!this.f822e) {
                    f.a.n.h.d<b> dVar = this.b;
                    if (dVar == null) {
                        dVar = new f.a.n.h.d<>();
                        this.b = dVar;
                    }
                    dVar.a(bVar);
                    return true;
                }
            }
        }
        bVar.dispose();
        return false;
    }

    public void d() {
        if (this.f822e) {
            return;
        }
        synchronized (this) {
            if (this.f822e) {
                return;
            }
            f.a.n.h.d<b> dVar = this.b;
            this.b = null;
            e(dVar);
        }
    }

    @Override // f.a.k.b
    public void dispose() {
        if (this.f822e) {
            return;
        }
        synchronized (this) {
            if (this.f822e) {
                return;
            }
            this.f822e = true;
            f.a.n.h.d<b> dVar = this.b;
            this.b = null;
            e(dVar);
        }
    }

    void e(f.a.n.h.d<b> dVar) {
        if (dVar == null) {
            return;
        }
        ArrayList arrayList = null;
        for (Object obj : dVar.b()) {
            if (obj instanceof b) {
                try {
                    ((b) obj).dispose();
                } catch (Throwable th) {
                    f.a.l.b.b(th);
                    if (arrayList == null) {
                        arrayList = new ArrayList();
                    }
                    arrayList.add(th);
                }
            }
        }
        if (arrayList != null) {
            if (arrayList.size() != 1) {
                throw new f.a.l.a(arrayList);
            }
            throw f.a.n.h.b.a((Throwable) arrayList.get(0));
        }
    }

    public boolean f() {
        return this.f822e;
    }
}