package m4; import C0.C0109j; import com.google.protobuf.InterfaceC1332t0; import java.io.IOException; import java.net.InetSocketAddress; import java.net.SocketAddress; import java.util.Collections; import java.util.IdentityHashMap; import java.util.LinkedHashSet; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; import java.util.logging.Level; import java.util.logging.Logger; import k4.AbstractC2395h; import k4.AbstractC2397j; import k4.C2385D; import k4.C2388a; import k4.C2389b; import k4.C2408v; import k4.C2410x; import k4.C2411y; import k4.EnumC2404q; import k4.InterfaceC2402o; import r4.C2888a; /* JADX INFO: loaded from: classes3.dex */ public final class E implements Runnable { /* JADX INFO: renamed from: a, reason: collision with root package name */ public final /* synthetic */ int f20586a; /* JADX INFO: renamed from: b, reason: collision with root package name */ public final /* synthetic */ Object f20587b; /* JADX INFO: renamed from: c, reason: collision with root package name */ public final Object f20588c; public /* synthetic */ E(int i6, Object obj, Object obj2) { this.f20586a = i6; this.f20587b = obj; this.f20588c = obj2; } /* JADX WARN: Removed duplicated region for block: B:130:0x03fc */ /* JADX WARN: Removed duplicated region for block: B:133:0x043f */ /* JADX WARN: Removed duplicated region for block: B:30:0x00bd A[Catch: all -> 0x00ba, TryCatch #5 {all -> 0x00ba, blocks: (B:15:0x005f, B:35:0x00ef, B:18:0x006e, B:20:0x008e, B:22:0x009a, B:27:0x00a8, B:30:0x00bd, B:34:0x00e3, B:33:0x00cc), top: B:293:0x005f }] */ @Override // java.lang.Runnable /* Code decompiled incorrectly, please refer to instructions dump. */ public final void run() throws Throwable { k4.k0 k0Var; List listSingletonList; F f6; C2537q0 c2537q0; Y0 y02; k4.r0 r0VarA; k4.U u6; k4.U u7; Object obj; Object obj2; int i6 = 3; int i7 = 26; int i8 = 2; C4.f fVar = null; c0109j = null; C0109j c0109j = null; fVar = null; C4.f fVar2 = null; boolean z6 = false; char c6 = 1; switch (this.f20586a) { case 0: ((O0) this.f20587b).a(k4.r0.f19941h.g(((StringBuilder) this.f20588c).toString()), true); return; case 1: AbstractC2397j abstractC2397j = ((O0) this.f20587b).f20705f; k4.r0 r0Var = (k4.r0) this.f20588c; abstractC2397j.cancel(r0Var.f19950b, r0Var.f19951c); return; case 2: ((O0) this.f20587b).f20705f.sendMessage(this.f20588c); return; case 3: ((J) this.f20587b).f20650a.onHeaders((k4.g0) this.f20588c); return; case 4: ((J) this.f20587b).f20650a.onMessage((InterfaceC1332t0) this.f20588c); return; case 5: A4.g.t(((S0) ((M) this.f20587b).f20676h.f20267b).f20768G.get(), "Channel must have been shut down"); return; case 6: ((Q) this.f20587b).f20728c.d((InterfaceC2402o) this.f20588c); return; case 7: ((Q) this.f20587b).f20728c.k((C2410x) this.f20588c); return; case 8: ((Q) this.f20587b).f20728c.n((C2408v) this.f20588c); return; case 9: ((Q) this.f20587b).f20728c.f((C2888a) this.f20588c); return; case 10: ((Q) this.f20587b).f20728c.g((k4.r0) this.f20588c); return; case 11: ((P) this.f20587b).f20715a.a((l2.c) this.f20588c); return; case 12: ((P) this.f20587b).f20715a.e((k4.g0) this.f20588c); return; case 13: AbstractC2395h abstractC2395h = (AbstractC2395h) this.f20588c; Logger logger = U.f20847s; Level level = Level.FINER; boolean zIsLoggable = logger.isLoggable(level); U u8 = (U) this.f20587b; if (zIsLoggable) { logger.finer("Attempting DNS resolution of " + u8.f20858f); } try { try { C2385D c2385dA = u8.f20853a.a(InetSocketAddress.createUnresolved(u8.f20858f, u8.f20859g)); C2411y c2411y = c2385dA != null ? new C2411y(c2385dA) : null; List list = Collections.EMPTY_LIST; C2389b c2389b = C2389b.f19841b; k4.w0 w0Var = u8.f20862j; if (c2411y != null) { if (logger.isLoggable(level)) { logger.finer("Using proxy address " + c2411y); } listSingletonList = Collections.singletonList(c2411y); k0Var = null; } else { C4.f fVarS = u8.s(); try { k4.r0 r0Var2 = (k4.r0) fVarS.f741b; if (r0Var2 != null) { abstractC2395h.h(r0Var2); f6 = new F(i8, this, ((k4.r0) fVarS.f741b) == null); w0Var.execute(f6); return; } else { List list2 = (List) fVarS.f742c; if (list2 != null) { list = list2; } k4.k0 k0Var2 = (k4.k0) fVarS.f743d; k0Var = k0Var2 != null ? k0Var2 : null; fVar = fVarS; listSingletonList = list; } } catch (IOException e6) { e = e6; fVar = fVarS; abstractC2395h.h(k4.r0.f19946n.g("Unable to resolve host " + u8.f20858f).f(e)); u8.f20862j.execute(new F(i8, this, fVar != null && ((k4.r0) fVar.f741b) == null)); return; } catch (Throwable th) { th = th; fVar2 = fVarS; u8.f20862j.execute(new F(i8, this, fVar2 != null && ((k4.r0) fVar2.f741b) == null)); throw th; } } abstractC2395h.i(new k4.l0(listSingletonList, c2389b, k0Var)); f6 = new F(i8, this, fVar != null && ((k4.r0) fVar.f741b) == null); w0Var.execute(f6); return; } catch (Throwable th2) { th = th2; } } catch (IOException e7) { e = e7; } break; case 14: C2539r0 c2539r0 = ((C2548u0) this.f20587b).l; SocketAddress socketAddress = (SocketAddress) ((C2411y) c2539r0.f21140a.get(c2539r0.f21141b)).f19985a.get(c2539r0.f21142c); C2539r0 c2539r02 = ((C2548u0) this.f20587b).l; c2539r02.f21140a = (List) this.f20588c; c2539r02.d(); ((C2548u0) this.f20587b).f21183m = (List) this.f20588c; EnumC2404q enumC2404q = ((C2548u0) this.f20587b).f21193w.f19935a; EnumC2404q enumC2404q2 = EnumC2404q.f19911b; if (enumC2404q == enumC2404q2 || ((C2548u0) this.f20587b).f21193w.f19935a == EnumC2404q.f19910a) { C2539r0 c2539r03 = ((C2548u0) this.f20587b).l; int i9 = 0; while (true) { if (i9 < c2539r03.f21140a.size()) { int iIndexOf = ((C2411y) c2539r03.f21140a.get(i9)).f19985a.indexOf(socketAddress); if (iIndexOf == -1) { i9++; } else { c2539r03.f21141b = i9; c2539r03.f21142c = iIndexOf; } } else if (((C2548u0) this.f20587b).f21193w.f19935a == enumC2404q2) { c2537q0 = ((C2548u0) this.f20587b).f21192v; ((C2548u0) this.f20587b).f21192v = null; ((C2548u0) this.f20587b).l.d(); C2548u0.g((C2548u0) this.f20587b, EnumC2404q.f19913d); } else { ((C2548u0) this.f20587b).f21191u.d(k4.r0.f19946n.g("InternalSubchannel closed pending transport due to address change")); C2548u0 c2548u0 = (C2548u0) this.f20587b; c2548u0.f21191u = null; c2548u0.l.d(); C2548u0.h((C2548u0) this.f20587b); } } c2537q0 = null; } else { c2537q0 = null; } if (c2537q0 != null) { C2548u0 c2548u02 = (C2548u0) this.f20587b; if (c2548u02.f21187q != null) { c2548u02.f21188r.d(k4.r0.f19946n.g("InternalSubchannel closed transport early due to address change")); ((C2548u0) this.f20587b).f21187q.d(); C2548u0 c2548u03 = (C2548u0) this.f20587b; c2548u03.f21187q = null; c2548u03.f21188r = null; } C2548u0 c2548u04 = (C2548u0) this.f20587b; c2548u04.f21188r = c2537q0; c2548u04.f21187q = c2548u04.f21182k.c(new I2.K(this, 7), 5L, TimeUnit.SECONDS, c2548u04.f21177f); return; } return; case 15: if (((C2548u0) ((C0109j) this.f20587b).f608d).f21193w.f19935a == EnumC2404q.f19914e) { return; } C2537q0 c2537q02 = ((C2548u0) ((C0109j) this.f20587b).f608d).f21192v; C0109j c0109j2 = (C0109j) this.f20587b; C2537q0 c2537q03 = (C2537q0) c0109j2.f607c; if (c2537q02 == c2537q03) { ((C2548u0) c0109j2.f608d).f21192v = null; ((C2548u0) ((C0109j) this.f20587b).f608d).l.d(); C2548u0.g((C2548u0) ((C0109j) this.f20587b).f608d, EnumC2404q.f19913d); return; } C2548u0 c2548u05 = (C2548u0) c0109j2.f608d; if (c2548u05.f21191u == c2537q03) { A4.g.r(((C2548u0) ((C0109j) this.f20587b).f608d).f21193w.f19935a, "Expected state is CONNECTING, actual state is %s", c2548u05.f21193w.f19935a == EnumC2404q.f19910a); C2539r0 c2539r04 = ((C2548u0) ((C0109j) this.f20587b).f608d).l; C2411y c2411y2 = (C2411y) c2539r04.f21140a.get(c2539r04.f21141b); int i10 = c2539r04.f21142c + 1; c2539r04.f21142c = i10; if (i10 >= c2411y2.f19985a.size()) { c2539r04.f21141b++; c2539r04.f21142c = 0; } C2539r0 c2539r05 = ((C2548u0) ((C0109j) this.f20587b).f608d).l; if (c2539r05.f21141b < c2539r05.f21140a.size()) { C2548u0.h((C2548u0) ((C0109j) this.f20587b).f608d); return; } C2548u0 c2548u06 = (C2548u0) ((C0109j) this.f20587b).f608d; c2548u06.f21191u = null; c2548u06.l.d(); C2548u0 c2548u07 = (C2548u0) ((C0109j) this.f20587b).f608d; k4.r0 r0Var3 = (k4.r0) this.f20588c; c2548u07.f21182k.d(); A4.g.l(!r0Var3.e(), "The error status must not be OK"); c2548u07.i(new k4.r(EnumC2404q.f19912c, r0Var3)); if (c2548u07.f21184n == null) { c2548u07.f21174c.getClass(); c2548u07.f21184n = i2.g(); } long jA = c2548u07.f21184n.a(); TimeUnit timeUnit = TimeUnit.NANOSECONDS; long jB = jA - c2548u07.f21185o.b(); c2548u07.f21180i.g(2, "TRANSIENT_FAILURE ({0}). Will reconnect after {1} ns", C2548u0.j(r0Var3), Long.valueOf(jB)); A4.g.t(c2548u07.f21186p == null, "previous reconnectTask is not done"); c2548u07.f21186p = c2548u07.f21182k.c(new RunnableC2525m0(c2548u07, 0), jB, timeUnit, c2548u07.f21177f); return; } return; case 16: L0 l02 = (L0) this.f20587b; l02.getClass(); Logger logger2 = S0.f20758d0; Level level2 = Level.WARNING; S0 s02 = l02.f20667f; k4.J j4 = s02.f20786a; k4.r0 r0Var4 = (k4.r0) this.f20588c; logger2.log(level2, "[{0}] Failed to resolve name. status={1}", new Object[]{j4, r0Var4}); P0 p02 = s02.f20778Q; if (p02.f20718a.get() == S0.f20760j0) { p02.t(null); } if (s02.f20791c0 != 3) { s02.f20776O.g(3, "Failed to resolve name: {0}", r0Var4); s02.f20791c0 = 3; } K0 k02 = s02.f20811x; K0 k03 = l02.f20665d; if (k03 != k02) { return; } ((k4.T) k03.f20657d.f534c).c(r0Var4); return; case 17: L0 l03 = (L0) this.f20587b; S0 s03 = l03.f20667f; if (s03.f20809v != l03.f20666e) { return; } k4.l0 l0Var = (k4.l0) this.f20588c; List list3 = l0Var.f19893a; s03.f20776O.g(1, "Resolved address: {0}, config={1}", list3, l0Var.f19894b); S0 s04 = ((L0) this.f20587b).f20667f; if (s04.f20791c0 != 2) { s04.f20776O.g(2, "Address resolved: {0}", list3); ((L0) this.f20587b).f20667f.f20791c0 = 2; } k4.l0 l0Var2 = (k4.l0) this.f20588c; k4.k0 k0Var3 = l0Var2.f19895c; S1 s12 = (S1) l0Var2.f19894b.f19842a.get(U1.f20877d); C2389b c2389b2 = ((k4.l0) this.f20588c).f19894b; C2388a c2388a = k4.H.f19805a; k4.H h5 = (k4.H) c2389b2.f19842a.get(c2388a); Y0 y03 = (k0Var3 == null || (obj2 = k0Var3.f19892b) == null) ? null : (Y0) obj2; k4.r0 r0Var5 = k0Var3 != null ? k0Var3.f19891a : null; S0 s05 = ((L0) this.f20587b).f20667f; if (s05.f20781T) { if (y03 != null) { if (h5 != null) { s05.f20778Q.t(h5); if (y03.b() != null) { ((L0) this.f20587b).f20667f.f20776O.f(1, "Method configs in service config will be discarded due to presence ofconfig-selector"); } } else { s05.f20778Q.t(y03.b()); } } else if (r0Var5 == null) { y03 = S0.f20759i0; s05.f20778Q.t(null); } else { if (!s05.f20780S) { s05.f20776O.f(2, "Fallback to error due to invalid first service config without default config"); ((L0) this.f20587b).h(k0Var3.f19891a); if (s12 != null) { boolean zE = k0Var3.f19891a.e(); U1 u12 = s12.f20814a; if (!zE) { u12.f20879b.a(new I2.K(u12, 15)); return; } C2512i c2512i = u12.f20879b; k4.w0 w0Var2 = c2512i.f21050b; w0Var2.d(); w0Var2.execute(new F1.r(c2512i, i7)); return; } return; } y03 = s05.f20779R; } if (!y03.equals(((L0) this.f20587b).f20667f.f20779R)) { ((L0) this.f20587b).f20667f.f20776O.g(2, "Service config changed{0}", y03 == S0.f20759i0 ? " to empty" : ""); S0 s06 = ((L0) this.f20587b).f20667f; s06.f20779R = y03; s06.f20787a0.f3544b = y03.f20917d; } try { ((L0) this.f20587b).f20667f.f20780S = true; } catch (RuntimeException e8) { S0.f20758d0.log(Level.WARNING, "[" + ((L0) this.f20587b).f20667f.f20786a + "] Unexpected exception from parsing service config", (Throwable) e8); } y02 = y03; break; } else { if (y03 != null) { s05.f20776O.f(2, "Service config from name resolver discarded by channel settings"); } ((L0) this.f20587b).f20667f.getClass(); y02 = S0.f20759i0; if (h5 != null) { ((L0) this.f20587b).f20667f.f20776O.f(2, "Config selector from name resolver discarded by channel settings"); } ((L0) this.f20587b).f20667f.f20778Q.t(y02.b()); } C2389b c2389b3 = ((k4.l0) this.f20588c).f19894b; L0 l04 = (L0) this.f20587b; if (l04.f20665d == l04.f20667f.f20811x) { c2389b3.getClass(); androidx.recyclerview.widget.i0 i0Var = new androidx.recyclerview.widget.i0(c2389b3, i6); if (c2389b3.f19842a.containsKey(c2388a)) { IdentityHashMap identityHashMap = new IdentityHashMap(((C2389b) i0Var.f13105b).f19842a); identityHashMap.remove(c2388a); i0Var.f13105b = new C2389b(identityHashMap); } IdentityHashMap identityHashMap2 = (IdentityHashMap) i0Var.f13106c; if (identityHashMap2 != null) { identityHashMap2.remove(c2388a); } Map map = y02.f20919f; if (map != null) { i0Var.u(k4.T.f19826b, map); i0Var.c(); } C2389b c2389bC = i0Var.c(); C0.J j6 = ((L0) this.f20587b).f20665d.f20657d; C2389b c2389b4 = C2389b.f19841b; k4.P p6 = new k4.P(list3, c2389bC, y02.f20918e); j6.getClass(); b2 b2Var = (b2) p6.f19825c; K0 k04 = (K0) j6.f533b; if (b2Var == null) { try { k2 k2Var = (k2) j6.f536e; String str = (String) k2Var.f21088c; k4.U uB = ((k4.V) k2Var.f21087b).b(str); if (uB == null) { throw new C2509h("Trying to load '" + str + "' because using default policy, but it's unavailable"); } b2Var = new b2(uB, null); u6 = (k4.U) j6.f535d; u7 = b2Var.f20955a; if (u6 != null || !u7.a().equals(((k4.U) j6.f535d).a())) { k04.k(EnumC2404q.f19910a, new C2503f(0)); ((k4.T) j6.f534c).f(); j6.f535d = u7; k4.T t6 = (k4.T) j6.f534c; j6.f534c = u7.b(k04); k04.f20658e.f20776O.g(2, "Load balancer changed from {0} to {1}", t6.getClass().getSimpleName(), ((k4.T) j6.f534c).getClass().getSimpleName()); } obj = b2Var.f20956b; if (obj != null) { k04.f20658e.f20776O.g(1, "Load-balancing config: {0}", obj); } r0VarA = ((k4.T) j6.f534c).a(new k4.P(p6.f19823a, p6.f19824b, obj)); } catch (C2509h e9) { k04.k(EnumC2404q.f19912c, new C2520k1(k4.r0.f19945m.g(e9.getMessage()))); ((k4.T) j6.f534c).f(); j6.f535d = null; j6.f534c = new C2506g(); r0VarA = k4.r0.f19938e; } } else { u6 = (k4.U) j6.f535d; u7 = b2Var.f20955a; if (u6 != null) { k04.k(EnumC2404q.f19910a, new C2503f(0)); ((k4.T) j6.f534c).f(); j6.f535d = u7; k4.T t62 = (k4.T) j6.f534c; j6.f534c = u7.b(k04); k04.f20658e.f20776O.g(2, "Load balancer changed from {0} to {1}", t62.getClass().getSimpleName(), ((k4.T) j6.f534c).getClass().getSimpleName()); obj = b2Var.f20956b; if (obj != null) { } r0VarA = ((k4.T) j6.f534c).a(new k4.P(p6.f19823a, p6.f19824b, obj)); } } if (s12 != null) { boolean zE2 = r0VarA.e(); U1 u13 = s12.f20814a; if (!zE2) { u13.f20879b.a(new I2.K(u13, 15)); return; } C2512i c2512i2 = u13.f20879b; k4.w0 w0Var3 = c2512i2.f21050b; w0Var3.d(); w0Var3.execute(new F1.r(c2512i2, i7)); return; } return; } return; case 18: P0 p03 = (P0) this.f20588c; Object obj3 = p03.f20718a.get(); D0 d02 = S0.f20760j0; O0 o02 = (O0) this.f20587b; if (obj3 != d02) { o02.d(); return; } S0 s07 = p03.f20721d; if (s07.f20763B == null) { s07.f20763B = new LinkedHashSet(); s07.f20785Z.l(s07.f20764C, true); } s07.f20763B.add(o02); return; case 19: ((r) this.f20588c).run(); O0 o03 = (O0) this.f20587b; o03.f20712n.f20721d.f20800m.execute(new G(o03, z ? 1 : 0)); return; case 20: synchronized (((H0) ((E) this.f20587b).f20587b).f20620i) { try { E e10 = (E) this.f20587b; if (((C0109j) e10.f20588c).f606b) { z6 = true; } else { H0 h0 = (H0) e10.f20587b; h0.f20625o = h0.f20625o.a((P1) this.f20588c); H0 h02 = (H0) ((E) this.f20587b).f20587b; if (h02.u(h02.f20625o)) { Q1 q12 = ((H0) ((E) this.f20587b).f20587b).f20623m; if (q12 != null) { if (q12.f20739d.get() <= q12.f20737b) { c6 = 0; } if (c6 != 0) { } } H0 h03 = (H0) ((E) this.f20587b).f20587b; c0109j = new C0109j(h03.f20620i); h03.f20633w = c0109j; } else { H0 h04 = (H0) ((E) this.f20587b).f20587b; M1 m12 = h04.f20625o; if (!m12.f20688h) { m12 = new M1(m12.f20682b, m12.f20683c, m12.f20684d, m12.f20686f, m12.f20687g, m12.f20681a, true, m12.f20685e); } h04.f20625o = m12; ((H0) ((E) this.f20587b).f20587b).f20633w = null; } } } finally { } break; } if (z6) { P1 p12 = (P1) this.f20588c; p12.f20722a.l(new k2(4, (H0) ((E) this.f20587b).f20587b, p12)); ((P1) this.f20588c).f20722a.g(k4.r0.f19939f.g("Unneeded hedging")); return; } else { if (c0109j != null) { H0 h05 = (H0) ((E) this.f20587b).f20587b; c0109j.f(h05.f20615d.schedule(new E(21, h05, c0109j), h05.f20618g.f21045b, TimeUnit.NANOSECONDS)); } ((H0) ((E) this.f20587b).f20587b).s((P1) this.f20588c); return; } case 21: H0 h06 = (H0) this.f20587b; P1 p1Q = h06.q(h06.f20625o.f20685e, false); if (p1Q == null) { return; } ((H0) this.f20587b).f20613b.execute(new E(20, this, p1Q)); return; case 22: ((H0) ((k2) this.f20587b).f21088c).f20631u.e((k4.g0) this.f20588c); return; default: ((H0) ((k2) this.f20587b).f21088c).f20631u.a((l2.c) this.f20588c); return; } } public E(U u6, AbstractC2395h abstractC2395h) { this.f20586a = 13; this.f20587b = u6; A4.g.o(abstractC2395h, "savedListener"); this.f20588c = abstractC2395h; } public E(P0 p02, O0 o02) { this.f20586a = 18; this.f20588c = p02; this.f20587b = o02; } }