package m4;

import F3.AbstractC0220u;
import java.net.SocketAddress;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;
import k4.AbstractC2384C;
import k4.AbstractC2395h;
import k4.C2389b;
import k4.C2411y;
import k4.EnumC2404q;

/* JADX INFO: renamed from: m4.n1, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes3.dex */
public final class C2529n1 extends k4.T {

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    public static final Logger f21108o = Logger.getLogger(C2529n1.class.getName());

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final AbstractC2395h f21109f;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public C2539r0 f21111h;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public androidx.recyclerview.widget.i0 f21114k;
    public EnumC2404q l;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public EnumC2404q f21115m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public final boolean f21116n;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final HashMap f21110g = new HashMap();

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public int f21112i = 0;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public boolean f21113j = true;

    public C2529n1(AbstractC2395h abstractC2395h) {
        boolean z6 = false;
        EnumC2404q enumC2404q = EnumC2404q.f19913d;
        this.l = enumC2404q;
        this.f21115m = enumC2404q;
        Logger logger = AbstractC2504f0.f20995a;
        String property = System.getenv("GRPC_EXPERIMENTAL_XDS_DUALSTACK_ENDPOINTS");
        property = property == null ? System.getProperty("GRPC_EXPERIMENTAL_XDS_DUALSTACK_ENDPOINTS") : property;
        if (!e4.C.e0(property) && Boolean.parseBoolean(property)) {
            z6 = true;
        }
        this.f21116n = z6;
        this.f21109f = abstractC2395h;
    }

    @Override // k4.T
    public final k4.r0 a(k4.P p6) {
        List list;
        EnumC2404q enumC2404q;
        if (this.l == EnumC2404q.f19914e) {
            return k4.r0.l.g("Already shut down");
        }
        List list2 = p6.f19823a;
        boolean zIsEmpty = list2.isEmpty();
        C2389b c2389b = p6.f19824b;
        if (zIsEmpty) {
            k4.r0 r0VarG = k4.r0.f19946n.g("NameResolver returned no usable address. addrs=" + list2 + ", attrs=" + c2389b);
            c(r0VarG);
            return r0VarG;
        }
        Iterator it = list2.iterator();
        while (it.hasNext()) {
            if (((C2411y) it.next()) == null) {
                k4.r0 r0VarG2 = k4.r0.f19946n.g("NameResolver returned address list with null endpoint. addrs=" + list2 + ", attrs=" + c2389b);
                c(r0VarG2);
                return r0VarG2;
            }
        }
        this.f21113j = true;
        F3.L lO = F3.O.o();
        lO.c(list2);
        F3.p0 p0VarF = lO.f();
        C2539r0 c2539r0 = this.f21111h;
        EnumC2404q enumC2404q2 = EnumC2404q.f19911b;
        if (c2539r0 == null) {
            C2539r0 c2539r02 = new C2539r0();
            c2539r02.f21140a = p0VarF != null ? p0VarF : Collections.EMPTY_LIST;
            this.f21111h = c2539r02;
        } else if (this.l == enumC2404q2) {
            SocketAddress socketAddressA = c2539r0.a();
            C2539r0 c2539r03 = this.f21111h;
            if (p0VarF != null) {
                list = p0VarF;
            } else {
                c2539r03.getClass();
                list = Collections.EMPTY_LIST;
            }
            c2539r03.f21140a = list;
            c2539r03.f21141b = 0;
            c2539r03.f21142c = 0;
            if (this.f21111h.e(socketAddressA)) {
                return k4.r0.f19938e;
            }
            C2539r0 c2539r04 = this.f21111h;
            c2539r04.f21141b = 0;
            c2539r04.f21142c = 0;
        } else {
            c2539r0.f21140a = p0VarF != null ? p0VarF : Collections.EMPTY_LIST;
            c2539r0.f21141b = 0;
            c2539r0.f21142c = 0;
        }
        HashMap map = this.f21110g;
        HashSet<SocketAddress> hashSet = new HashSet(map.keySet());
        HashSet hashSet2 = new HashSet();
        F3.M mListIterator = p0VarF.listIterator(0);
        while (mListIterator.hasNext()) {
            hashSet2.addAll(((C2411y) mListIterator.next()).f19985a);
        }
        for (SocketAddress socketAddress : hashSet) {
            if (!hashSet2.contains(socketAddress)) {
                ((C2526m1) map.remove(socketAddress)).f21101a.o();
            }
        }
        int size = hashSet.size();
        EnumC2404q enumC2404q3 = EnumC2404q.f19910a;
        if (size == 0 || (enumC2404q = this.l) == enumC2404q3 || enumC2404q == enumC2404q2) {
            this.l = enumC2404q3;
            i(enumC2404q3, new C2520k1(k4.O.f19818e));
            g();
            e();
        } else {
            EnumC2404q enumC2404q4 = EnumC2404q.f19913d;
            if (enumC2404q == enumC2404q4) {
                i(enumC2404q4, new C2523l1(this, this));
            } else if (enumC2404q == EnumC2404q.f19912c) {
                g();
                e();
            }
        }
        return k4.r0.f19938e;
    }

    @Override // k4.T
    public final void c(k4.r0 r0Var) {
        HashMap map = this.f21110g;
        Iterator it = map.values().iterator();
        while (it.hasNext()) {
            ((C2526m1) it.next()).f21101a.o();
        }
        map.clear();
        i(EnumC2404q.f19912c, new C2520k1(k4.O.a(r0Var)));
    }

    @Override // k4.T
    public final void e() {
        AbstractC2384C abstractC2384C;
        C2539r0 c2539r0 = this.f21111h;
        if (c2539r0 == null || !c2539r0.c() || this.l == EnumC2404q.f19914e) {
            return;
        }
        SocketAddress socketAddressA = this.f21111h.a();
        HashMap map = this.f21110g;
        boolean zContainsKey = map.containsKey(socketAddressA);
        Logger logger = f21108o;
        if (zContainsKey) {
            abstractC2384C = ((C2526m1) map.get(socketAddressA)).f21101a;
        } else {
            C2517j1 c2517j1 = new C2517j1(this);
            k4.N nC = k4.N.c();
            nC.d(AbstractC0220u.p(new C2411y(socketAddressA)));
            nC.a(c2517j1);
            final AbstractC2384C abstractC2384CA = this.f21109f.a(new k4.N(nC.f19815b, nC.f19816c, nC.f19817d));
            if (abstractC2384CA == null) {
                logger.warning("Was not able to create subchannel for " + socketAddressA);
                throw new IllegalStateException("Can't create subchannel");
            }
            C2526m1 c2526m1 = new C2526m1(abstractC2384CA, c2517j1);
            c2517j1.f21065b = c2526m1;
            map.put(socketAddressA, c2526m1);
            if (abstractC2384CA.b().f19842a.get(k4.T.f19828d) == null) {
                c2517j1.f21064a = k4.r.a(EnumC2404q.f19911b);
            }
            abstractC2384CA.q(new k4.S() { // from class: m4.i1
                @Override // k4.S
                public final void a(k4.r rVar) {
                    AbstractC2384C abstractC2384C2;
                    C2529n1 c2529n1 = this.f21058a;
                    c2529n1.getClass();
                    EnumC2404q enumC2404q = rVar.f19935a;
                    HashMap map2 = c2529n1.f21110g;
                    AbstractC2384C abstractC2384C3 = abstractC2384CA;
                    C2526m1 c2526m12 = (C2526m1) map2.get((SocketAddress) abstractC2384C3.g().f19985a.get(0));
                    if (c2526m12 == null || (abstractC2384C2 = c2526m12.f21101a) != abstractC2384C3 || enumC2404q == EnumC2404q.f19914e) {
                        return;
                    }
                    EnumC2404q enumC2404q2 = EnumC2404q.f19913d;
                    AbstractC2395h abstractC2395h = c2529n1.f21109f;
                    if (enumC2404q == enumC2404q2) {
                        abstractC2395h.j();
                    }
                    C2526m1.a(c2526m12, enumC2404q);
                    EnumC2404q enumC2404q3 = c2529n1.l;
                    EnumC2404q enumC2404q4 = EnumC2404q.f19912c;
                    EnumC2404q enumC2404q5 = EnumC2404q.f19910a;
                    if (enumC2404q3 == enumC2404q4 || c2529n1.f21115m == enumC2404q4) {
                        if (enumC2404q == enumC2404q5) {
                            return;
                        }
                        if (enumC2404q == enumC2404q2) {
                            c2529n1.e();
                            return;
                        }
                    }
                    int iOrdinal = enumC2404q.ordinal();
                    if (iOrdinal == 0) {
                        c2529n1.l = enumC2404q5;
                        c2529n1.i(enumC2404q5, new C2520k1(k4.O.f19818e));
                        return;
                    }
                    if (iOrdinal == 1) {
                        c2529n1.g();
                        for (C2526m1 c2526m13 : map2.values()) {
                            if (!c2526m13.f21101a.equals(abstractC2384C2)) {
                                c2526m13.f21101a.o();
                            }
                        }
                        map2.clear();
                        EnumC2404q enumC2404q6 = EnumC2404q.f19911b;
                        C2526m1.a(c2526m12, enumC2404q6);
                        map2.put((SocketAddress) abstractC2384C2.g().f19985a.get(0), c2526m12);
                        c2529n1.f21111h.e((SocketAddress) abstractC2384C3.g().f19985a.get(0));
                        c2529n1.l = enumC2404q6;
                        c2529n1.j(c2526m12);
                        return;
                    }
                    if (iOrdinal != 2) {
                        if (iOrdinal != 3) {
                            throw new IllegalArgumentException("Unsupported state:" + enumC2404q);
                        }
                        C2539r0 c2539r02 = c2529n1.f21111h;
                        c2539r02.f21141b = 0;
                        c2539r02.f21142c = 0;
                        c2529n1.l = enumC2404q2;
                        c2529n1.i(enumC2404q2, new C2523l1(c2529n1, c2529n1));
                        return;
                    }
                    if (c2529n1.f21111h.c() && ((C2526m1) map2.get(c2529n1.f21111h.a())).f21101a == abstractC2384C3 && c2529n1.f21111h.b()) {
                        c2529n1.g();
                        c2529n1.e();
                    }
                    C2539r0 c2539r03 = c2529n1.f21111h;
                    if (c2539r03 == null || c2539r03.c()) {
                        return;
                    }
                    int size = map2.size();
                    List list = c2529n1.f21111h.f21140a;
                    if (size < (list != null ? list.size() : 0)) {
                        return;
                    }
                    Iterator it = map2.values().iterator();
                    while (it.hasNext()) {
                        if (!((C2526m1) it.next()).f21104d) {
                            return;
                        }
                    }
                    c2529n1.l = enumC2404q4;
                    c2529n1.i(enumC2404q4, new C2520k1(k4.O.a(rVar.f19936b)));
                    int i6 = c2529n1.f21112i + 1;
                    c2529n1.f21112i = i6;
                    List list2 = c2529n1.f21111h.f21140a;
                    if (i6 >= (list2 != null ? list2.size() : 0) || c2529n1.f21113j) {
                        c2529n1.f21113j = false;
                        c2529n1.f21112i = 0;
                        abstractC2395h.j();
                    }
                }
            });
            abstractC2384C = abstractC2384CA;
        }
        int iOrdinal = ((C2526m1) map.get(socketAddressA)).f21102b.ordinal();
        if (iOrdinal == 0) {
            if (this.f21116n) {
                h();
                return;
            } else {
                abstractC2384C.n();
                return;
            }
        }
        if (iOrdinal == 1) {
            logger.warning("Requesting a connection even though we have a READY subchannel");
            return;
        }
        if (iOrdinal == 2) {
            this.f21111h.b();
            e();
        } else {
            if (iOrdinal != 3) {
                return;
            }
            abstractC2384C.n();
            C2526m1.a((C2526m1) map.get(socketAddressA), EnumC2404q.f19910a);
            h();
        }
    }

    @Override // k4.T
    public final void f() {
        Level level = Level.FINE;
        HashMap map = this.f21110g;
        f21108o.log(level, "Shutting down, currently have {} subchannels created", Integer.valueOf(map.size()));
        EnumC2404q enumC2404q = EnumC2404q.f19914e;
        this.l = enumC2404q;
        this.f21115m = enumC2404q;
        g();
        Iterator it = map.values().iterator();
        while (it.hasNext()) {
            ((C2526m1) it.next()).f21101a.o();
        }
        map.clear();
    }

    public final void g() {
        androidx.recyclerview.widget.i0 i0Var = this.f21114k;
        if (i0Var != null) {
            i0Var.d();
            this.f21114k = null;
        }
    }

    public final void h() {
        if (this.f21116n) {
            androidx.recyclerview.widget.i0 i0Var = this.f21114k;
            if (i0Var != null) {
                k4.v0 v0Var = (k4.v0) i0Var.f13105b;
                if (!v0Var.f19972c && !v0Var.f19971b) {
                    return;
                }
            }
            AbstractC2395h abstractC2395h = this.f21109f;
            this.f21114k = abstractC2395h.d().c(new I2.K(this, 11), 250L, TimeUnit.MILLISECONDS, abstractC2395h.c());
        }
    }

    public final void i(EnumC2404q enumC2404q, k4.Q q6) {
        if (enumC2404q == this.f21115m && (enumC2404q == EnumC2404q.f19913d || enumC2404q == EnumC2404q.f19910a)) {
            return;
        }
        this.f21115m = enumC2404q;
        this.f21109f.k(enumC2404q, q6);
    }

    public final void j(C2526m1 c2526m1) {
        EnumC2404q enumC2404q = c2526m1.f21102b;
        EnumC2404q enumC2404q2 = EnumC2404q.f19911b;
        if (enumC2404q != enumC2404q2) {
            return;
        }
        k4.r rVar = c2526m1.f21103c.f21064a;
        EnumC2404q enumC2404q3 = rVar.f19935a;
        if (enumC2404q3 == enumC2404q2) {
            i(enumC2404q2, new F0(k4.O.b(c2526m1.f21101a, null)));
            return;
        }
        EnumC2404q enumC2404q4 = EnumC2404q.f19912c;
        if (enumC2404q3 == enumC2404q4) {
            i(enumC2404q4, new C2520k1(k4.O.a(rVar.f19936b)));
        } else if (this.f21115m != enumC2404q4) {
            i(enumC2404q3, new C2520k1(k4.O.f19818e));
        }
    }
}