package t4;

import androidx.recyclerview.widget.i0;
import java.lang.reflect.Array;
import java.net.SocketAddress;
import java.util.IdentityHashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicLong;
import k4.AbstractC2384C;
import k4.AbstractC2395h;
import k4.C2388a;
import k4.C2389b;
import k4.C2411y;
import k4.EnumC2404q;
import k4.N;
import k4.S;
import k4.r0;

/* JADX INFO: loaded from: classes3.dex */
public final class s extends AbstractC2951b {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final AbstractC2384C f24353a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public k f24354b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public boolean f24355c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public k4.r f24356d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public S f24357e;

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final /* synthetic */ t f24359g;

    public s(t tVar, N n6, h hVar) {
        this.f24359g = tVar;
        S s6 = (S) n6.b();
        if (s6 != null) {
            this.f24357e = s6;
            f fVar = new f(this, s6, 1);
            N nC = N.c();
            nC.d(n6.f19815b);
            C2389b c2389b = n6.f19816c;
            A4.g.o(c2389b, "attrs");
            nC.f19816c = c2389b;
            Object[][] objArr = n6.f19817d;
            Object[][] objArr2 = (Object[][]) Array.newInstance((Class<?>) Object.class, objArr.length, 2);
            nC.f19817d = objArr2;
            System.arraycopy(objArr, 0, objArr2, 0, objArr.length);
            nC.a(fVar);
            this.f24353a = hVar.a(new N(nC.f19815b, nC.f19816c, nC.f19817d));
        } else {
            this.f24353a = hVar.a(n6);
        }
        this.f24358f = this.f24353a.i();
    }

    @Override // k4.AbstractC2384C
    public final C2389b b() {
        k kVar = this.f24354b;
        AbstractC2384C abstractC2384C = this.f24353a;
        if (kVar == null) {
            return abstractC2384C.b();
        }
        C2389b c2389bB = abstractC2384C.b();
        c2389bB.getClass();
        C2388a c2388a = t.f24360n;
        k kVar2 = this.f24354b;
        IdentityHashMap identityHashMap = new IdentityHashMap(1);
        identityHashMap.put(c2388a, kVar2);
        for (Map.Entry entry : c2389bB.f19842a.entrySet()) {
            if (!identityHashMap.containsKey(entry.getKey())) {
                identityHashMap.put((C2388a) entry.getKey(), entry.getValue());
            }
        }
        return new C2389b(identityHashMap);
    }

    @Override // t4.AbstractC2951b, k4.AbstractC2384C
    public final void o() {
        k kVar = this.f24354b;
        if (kVar != null) {
            this.f24354b = null;
            kVar.f24332f.remove(this);
        }
        super.o();
    }

    @Override // k4.AbstractC2384C
    public final void q(S s6) {
        if (this.f24357e != null) {
            s().q(s6);
            return;
        }
        this.f24357e = s6;
        s().q(new f(this, s6, 1));
    }

    @Override // t4.AbstractC2951b, k4.AbstractC2384C
    public final void r(List list) {
        boolean zG = t.g(h());
        t tVar = this.f24359g;
        if (zG && t.g(list)) {
            if (tVar.f24361f.containsValue(this.f24354b)) {
                k kVar = this.f24354b;
                kVar.getClass();
                this.f24354b = null;
                kVar.f24332f.remove(this);
            }
            SocketAddress socketAddress = (SocketAddress) ((C2411y) list.get(0)).f19985a.get(0);
            if (tVar.f24361f.containsKey(socketAddress)) {
                ((k) tVar.f24361f.get(socketAddress)).a(this);
            }
        } else if (!t.g(h()) || t.g(list)) {
            if (!t.g(h()) && t.g(list)) {
                SocketAddress socketAddress2 = (SocketAddress) ((C2411y) list.get(0)).f19985a.get(0);
                if (tVar.f24361f.containsKey(socketAddress2)) {
                    ((k) tVar.f24361f.get(socketAddress2)).a(this);
                }
            }
        } else if (tVar.f24361f.containsKey(g().f19985a.get(0))) {
            k kVar2 = (k) tVar.f24361f.get(g().f19985a.get(0));
            kVar2.getClass();
            this.f24354b = null;
            kVar2.f24332f.remove(this);
            i0 i0Var = kVar2.f24328b;
            ((AtomicLong) i0Var.f13105b).set(0L);
            ((AtomicLong) i0Var.f13106c).set(0L);
            i0 i0Var2 = kVar2.f24329c;
            ((AtomicLong) i0Var2.f13105b).set(0L);
            ((AtomicLong) i0Var2.f13106c).set(0L);
        }
        this.f24353a.r(list);
    }

    @Override // t4.AbstractC2951b
    public final AbstractC2384C s() {
        return this.f24353a;
    }

    public final void t() {
        this.f24355c = true;
        S s6 = this.f24357e;
        r0 r0Var = r0.f19946n;
        A4.g.l(true ^ r0Var.e(), "The error status must not be OK");
        s6.a(new k4.r(EnumC2404q.f19912c, r0Var));
        this.f24358f.g(2, "Subchannel ejected: {0}", this);
    }

    @Override // t4.AbstractC2951b
    public final String toString() {
        return "OutlierDetectionSubchannel{addresses=" + this.f24353a.h() + '}';
    }
}