package o;

import io.reactivex.rxjava3.exceptions.CompositeException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Objects;

/* renamed from: o.fTj, reason: case insensitive filesystem */
/* loaded from: classes.dex */
public final class C13196fTj implements fSJ, InterfaceC13145fSF {
    private List<fSJ> a;
    private volatile boolean d;

    @Override // o.fSJ
    public final void dispose() {
        if (this.d) {
            return;
        }
        synchronized (this) {
            if (this.d) {
                return;
            }
            this.d = true;
            List<fSJ> list = this.a;
            ArrayList arrayList = null;
            this.a = null;
            if (list != null) {
                Iterator<fSJ> it = list.iterator();
                while (it.hasNext()) {
                    try {
                        it.next().dispose();
                    } catch (Throwable th) {
                        C13147fSI.c(th);
                        if (arrayList == null) {
                            arrayList = new ArrayList();
                        }
                        arrayList.add(th);
                    }
                }
                if (arrayList != null) {
                    if (arrayList.size() == 1) {
                        throw fYR.c((Throwable) arrayList.get(0));
                    }
                    throw new CompositeException(arrayList);
                }
            }
        }
    }

    @Override // o.InterfaceC13145fSF
    public final boolean e(fSJ fsj) {
        Objects.requireNonNull(fsj, "d is null");
        if (!this.d) {
            synchronized (this) {
                if (!this.d) {
                    List list = this.a;
                    if (list == null) {
                        list = new LinkedList();
                        this.a = list;
                    }
                    list.add(fsj);
                    return true;
                }
            }
        }
        fsj.dispose();
        return false;
    }

    @Override // o.InterfaceC13145fSF
    public final boolean c(fSJ fsj) {
        if (!b(fsj)) {
            return false;
        }
        fsj.dispose();
        return true;
    }

    @Override // o.InterfaceC13145fSF
    public final boolean b(fSJ fsj) {
        Objects.requireNonNull(fsj, "Disposable item is null");
        if (this.d) {
            return false;
        }
        synchronized (this) {
            if (this.d) {
                return false;
            }
            List<fSJ> list = this.a;
            if (list != null) {
                if (list.remove(fsj)) {
                    return true;
                }
            }
            return false;
        }
    }

    @Override // o.fSJ
    public final boolean isDisposed() {
        return this.d;
    }
}