package t4;

import androidx.recyclerview.widget.i0;
import java.net.SocketAddress;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
import k4.AbstractC2395h;
import k4.C2388a;
import k4.C2389b;
import k4.C2411y;
import k4.P;
import k4.T;
import k4.U;
import k4.r0;
import k4.u0;
import k4.v0;
import k4.w0;
import m4.i2;

/* JADX INFO: loaded from: classes3.dex */
public final class t extends T {

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public static final C2388a f24360n = new C2388a("addressTrackerKey");

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final w0 f24362g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final C2954e f24363h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final i2 f24364i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final ScheduledExecutorService f24365j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public i0 f24366k;
    public Long l;

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

    public t(AbstractC2395h abstractC2395h) {
        i2 i2Var = i2.f21060b;
        AbstractC2395h abstractC2395hB = abstractC2395h.b();
        this.f24367m = abstractC2395hB;
        this.f24363h = new C2954e(new C2953d(this, abstractC2395h));
        this.f24361f = new l();
        w0 w0VarD = abstractC2395h.d();
        A4.g.o(w0VarD, "syncContext");
        this.f24362g = w0VarD;
        ScheduledExecutorService scheduledExecutorServiceC = abstractC2395h.c();
        A4.g.o(scheduledExecutorServiceC, "timeService");
        this.f24365j = scheduledExecutorServiceC;
        this.f24364i = i2Var;
        abstractC2395hB.f(1, "OutlierDetection lb created.");
    }

    public static boolean g(List list) {
        Iterator it = list.iterator();
        int size = 0;
        while (it.hasNext()) {
            size += ((C2411y) it.next()).f19985a.size();
            if (size > 1) {
                return false;
            }
        }
        return true;
    }

    public static ArrayList h(l lVar, int i6) {
        ArrayList arrayList = new ArrayList();
        Iterator<Object> it = lVar.values().iterator();
        while (it.hasNext()) {
            k kVar = (k) it.next();
            if (kVar.c() >= i6) {
                arrayList.add(kVar);
            }
        }
        return arrayList;
    }

    @Override // k4.T
    public final r0 a(P p6) {
        AbstractC2395h abstractC2395h = this.f24367m;
        abstractC2395h.g(1, "Received resolution result: {0}", p6);
        o oVar = (o) p6.f19825c;
        ArrayList<SocketAddress> arrayList = new ArrayList();
        Iterator it = p6.f19823a.iterator();
        while (it.hasNext()) {
            arrayList.addAll(((C2411y) it.next()).f19985a);
        }
        l lVar = this.f24361f;
        lVar.keySet().retainAll(arrayList);
        Iterator it2 = lVar.f24333a.values().iterator();
        while (it2.hasNext()) {
            ((k) it2.next()).f24327a = oVar;
        }
        for (SocketAddress socketAddress : arrayList) {
            HashMap map = lVar.f24333a;
            if (!map.containsKey(socketAddress)) {
                map.put(socketAddress, new k(oVar));
            }
        }
        U u6 = oVar.f24347g.f20955a;
        C2954e c2954e = this.f24363h;
        c2954e.i(u6);
        if (oVar.f24345e == null && oVar.f24346f == null) {
            i0 i0Var = this.f24366k;
            if (i0Var != null) {
                i0Var.d();
                this.l = null;
                for (k kVar : lVar.f24333a.values()) {
                    if (kVar.d()) {
                        kVar.e();
                    }
                    kVar.f24331e = 0;
                }
            }
        } else {
            Long l = this.l;
            Long l6 = oVar.f24341a;
            Long lValueOf = l == null ? l6 : Long.valueOf(Math.max(0L, l6.longValue() - (this.f24364i.e() - this.l.longValue())));
            i0 i0Var2 = this.f24366k;
            if (i0Var2 != null) {
                i0Var2.d();
                for (k kVar2 : lVar.f24333a.values()) {
                    i0 i0Var3 = kVar2.f24328b;
                    ((AtomicLong) i0Var3.f13105b).set(0L);
                    ((AtomicLong) i0Var3.f13106c).set(0L);
                    i0 i0Var4 = kVar2.f24329c;
                    ((AtomicLong) i0Var4.f13105b).set(0L);
                    ((AtomicLong) i0Var4.f13106c).set(0L);
                }
            }
            C1.o oVar2 = new C1.o(this, oVar, abstractC2395h, 11);
            long jLongValue = lValueOf.longValue();
            long jLongValue2 = l6.longValue();
            TimeUnit timeUnit = TimeUnit.NANOSECONDS;
            w0 w0Var = this.f24362g;
            w0Var.getClass();
            v0 v0Var = new v0(oVar2);
            this.f24366k = new i0(v0Var, this.f24365j.scheduleWithFixedDelay(new u0(w0Var, v0Var, oVar2, jLongValue2), jLongValue, jLongValue2, timeUnit));
        }
        C2389b c2389b = C2389b.f19841b;
        c2954e.d(new P(p6.f19823a, p6.f19824b, oVar.f24347g.f20956b));
        return r0.f19938e;
    }

    @Override // k4.T
    public final void c(r0 r0Var) {
        this.f24363h.c(r0Var);
    }

    @Override // k4.T
    public final void f() {
        this.f24363h.f();
    }
}