Dynamic Spot Pro v1.0版本的 MD5 值为：5adb64d1f11ed2f16f84b684ff810780
以下内容为反编译后的 g1.java 源代码，内容仅作参考
package f.a.m1;
import com.appsflyer.oaid.BuildConfig;
import f.a.a;
import f.a.c0;
import f.a.e;
import f.a.i0;
import f.a.j1;
import f.a.m1.c2;
import f.a.m1.d2;
import f.a.m1.g0;
import f.a.m1.i;
import f.a.m1.j;
import f.a.m1.l;
import f.a.m1.m1;
import f.a.m1.n1;
import f.a.m1.r;
import f.a.q0;
import java.lang.Thread;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Arrays;
import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.regex.Pattern;
public final class g1 extends f.a.l0 implements f.a.d0<Object> {
public static final Logger d0 = Logger.getLogger(g1.class.getName());
public static final Pattern e0 = Pattern.compile("[a-zA-Z][a-zA-Z0-9+.-]*:/.*");
public static final f.a.e1 f0 = f.a.e1.n.g("Channel shutdownNow invoked");
public static final f.a.e1 g0 = f.a.e1.n.g("Channel shutdown invoked");
public static final f.a.e1 h0 = f.a.e1.n.g("Subchannel shutdown invoked");
public boolean A;
public final b0 D;
public volatile boolean G;
public volatile boolean H;
public final l.a J;
public final f.a.m1.l K;
public final q L;
public final f.a.e M;
public final f.a.b0 N;
public Boolean O;
public Map<String, ?> P;
public final Map<String, ?> Q;
public final boolean R;
public d2.x T;
public final long U;
public final long V;
public final boolean W;
public j1.b Z;
public final f.a.e0 f10054a;
public f.a.m1.j a0;
public final String f10055b;
public final q0.c f10056c;
public final c2 c0;
public final q0.a f10057d;
public final f.a.m1.i f10058e;
public final v f10059f;
public final Executor f10060g;
public final s1<? extends Executor> f10061h;
public final h f10062i;
public final p2 f10063j;
public final int k;
public boolean m;
public final f.a.t n;
public final f.a.m o;
public final a.f.b.a.i<a.f.b.a.h> p;
public final long q;
public final h2 s;
public final j.a t;
public final f.a.d u;
public final String v;
public f.a.q0 w;
public boolean x;
public k y;
public volatile i0.h z;
public final f.a.j1 l = new f.a.j1(new a());
public final y r = new y();
public final Set<y0> B = new HashSet(16, 0.75f);
public final Set<t1> C = new HashSet(1, 0.75f);
public final p E = new p(null);
public final AtomicBoolean F = new AtomicBoolean(false);
public final CountDownLatch I = new CountDownLatch(1);
public final d2.q S = new d2.q();
public final n1.a X = new g(null);
public final x0<Object> Y = new i(null);
public final r.e b0 = new e(null);
public class a implements Thread.UncaughtExceptionHandler {
public a() {
}
@Override
public void uncaughtException(Thread thread, Throwable th) {
Logger logger = g1.d0;
Level level = Level.SEVERE;
StringBuilder d2 = a.c.a.a.a.d("[");
d2.append(g1.this.f10054a);
d2.append("] Uncaught exception in the SynchronizationContext. Panic!");
logger.log(level, d2.toString(), th);
g1 g1Var = g1.this;
if (g1Var.A) {
return;
}
g1Var.A = true;
g1Var.n(true);
g1Var.t(false);
h1 h1Var = new h1(g1Var, th);
g1Var.z = h1Var;
g1Var.D.i(h1Var);
g1Var.M.a(e.a.ERROR, "PANIC! Entering TRANSIENT_FAILURE");
g1Var.r.a(f.a.n.TRANSIENT_FAILURE);
}
}
public final class b implements l.a {
public final p2 f10065a;
public b(g1 g1Var, p2 p2Var) {
this.f10065a = p2Var;
}
@Override
public f.a.m1.l a() {
return new f.a.m1.l(this.f10065a);
}
}
public final class c implements Runnable {
public c() {
}
@Override
public void run() {
if (g1.this.F.get()) {
return;
}
g1 g1Var = g1.this;
if (g1Var.y == null) {
return;
}
g1Var.n(false);
g1.m(g1.this);
}
}
public final class d implements Runnable {
public d() {
}
@Override
public void run() {
if (g1.this.F.get()) {
return;
}
j1.b bVar = g1.this.Z;
if (bVar != null) {
j1.a aVar = bVar.f9755a;
if ((aVar.f9754g || aVar.f9753f) ? false : true) {
a.f.a.d.e.r.g.v(g1.this.x, "name resolver must be started");
g1 g1Var = g1.this;
g1Var.l.c();
g1Var.o();
g1Var.l.c();
if (g1Var.x) {
g1Var.w.b();
}
}
}
Iterator<y0> it = g1.this.B.iterator();
while (it.hasNext()) {
it.next().m();
}
Iterator<t1> it2 = g1.this.C.iterator();
if (it2.hasNext()) {
it2.next();
throw null;
}
}
}
public final class e implements r.e {
public final class a implements Runnable {
public a() {
}
@Override
public void run() {
g1.this.p();
}
}
public e(a aVar) {
}
public u a(i0.e eVar) {
i0.h hVar = g1.this.z;
if (!g1.this.F.get()) {
if (hVar == null) {
f.a.j1 j1Var = g1.this.l;
a aVar = new a();
Queue<Runnable> queue = j1Var.f9750f;
a.f.a.d.e.r.g.q(aVar, "runnable is null");
queue.add(aVar);
j1Var.a();
} else {
u f2 = q0.f(hVar.a(eVar), ((w1) eVar).f10399a.b());
if (f2 != null) {
return f2;
}
}
}
return g1.this.D;
}
}
public class f implements Runnable {
public f() {
}
@Override
public void run() {
g1 g1Var = g1.this;
g1Var.Z = null;
g1Var.l.c();
if (g1Var.x) {
g1Var.w.b();
}
}
}
public final class g implements n1.a {
public g(a aVar) {
}
@Override
public void a() {
a.f.a.d.e.r.g.v(g1.this.F.get(), "Channel must have been shut down");
g1.this.G = true;
g1.this.t(false);
g1 g1Var = g1.this;
if (g1Var == null) {
throw null;
}
g1.l(g1Var);
}
@Override
public void b() {
}
@Override
public void c(boolean z) {
g1 g1Var = g1.this;
g1Var.Y.c(g1Var.D, z);
}
@Override
public void d(f.a.e1 e1Var) {
a.f.a.d.e.r.g.v(g1.this.F.get(), "Channel must have been shut down");
}
}
public static final class h {
public final s1<? extends Executor> f10072a;
public Executor f10073b;
public h(s1<? extends Executor> s1Var) {
a.f.a.d.e.r.g.q(s1Var, "executorPool");
this.f10072a = s1Var;
}
}
public final class i extends x0<Object> {
public i(a aVar) {
}
@Override
public void a() {
g1.this.p();
}
@Override
public void b() {
if (g1.this.F.get()) {
return;
}
g1.this.s();
}
}
public class j implements Runnable {
public j(a aVar) {
}
@Override
public void run() {
g1.m(g1.this);
}
}
public class k extends i0.c {
public f.a.i0 f10076a;
public final class a implements Runnable {
public final i0.h f10078e;
public final f.a.n f10079f;
public a(i0.h hVar, f.a.n nVar) {
this.f10078e = hVar;
this.f10079f = nVar;
}
@Override
public void run() {
k kVar = k.this;
g1 g1Var = g1.this;
if (kVar != g1Var.y) {
return;
}
i0.h hVar = this.f10078e;
g1Var.z = hVar;
g1Var.D.i(hVar);
f.a.n nVar = this.f10079f;
if (nVar != f.a.n.SHUTDOWN) {
g1.this.M.b(e.a.INFO, "Entering {0} state", nVar);
g1.this.r.a(this.f10079f);
}
}
}
public k(a aVar) {
}
@Override
public i0.g a(List list, f.a.a aVar) {
g1.k(g1.this, "createSubchannel()");
a.f.a.d.e.r.g.q(list, "addressGroups");
a.f.a.d.e.r.g.q(aVar, "attrs");
a.f.a.d.e.r.g.v(!g1.this.H, "Channel is terminated");
o oVar = new o(aVar);
long a2 = g1.this.f10063j.a();
q qVar = new q(f.a.e0.b("Subchannel", null), g1.this.k, a2, "Subchannel for " + list);
String b2 = g1.this.b();
g1 g1Var = g1.this;
String str = g1Var.v;
j.a aVar2 = g1Var.t;
v vVar = g1Var.f10059f;
ScheduledExecutorService z = vVar.z();
g1 g1Var2 = g1.this;
a.f.b.a.i<a.f.b.a.h> iVar = g1Var2.p;
f.a.j1 j1Var = g1Var2.l;
k1 k1Var = new k1(this, oVar);
g1 g1Var3 = g1.this;
y0 y0Var = new y0(list, b2, str, aVar2, vVar, z, iVar, j1Var, k1Var, g1Var3.N, g1Var3.J.a(), qVar, g1.this.f10063j);
q qVar2 = g1.this.L;
c0.a aVar3 = c0.a.CT_INFO;
Long valueOf = Long.valueOf(a2);
a.f.a.d.e.r.g.q("Child Subchannel created", "description");
a.f.a.d.e.r.g.q(aVar3, "severity");
a.f.a.d.e.r.g.q(valueOf, "timestampNanos");
a.f.a.d.e.r.g.v(true, "at least one of channelRef and subchannelRef must be null");
qVar2.b(new f.a.c0("Child Subchannel created", aVar3, valueOf.longValue(), null, y0Var, null));
f.a.b0.a(g1.this.N.f9674b, y0Var);
oVar.f10090a = y0Var;
f.a.j1 j1Var2 = g1.this.l;
j1 j1Var3 = new j1(this, y0Var);
Queue<Runnable> queue = j1Var2.f9750f;
a.f.a.d.e.r.g.q(j1Var3, "runnable is null");
queue.add(j1Var3);
j1Var2.a();
return oVar;
}
@Override
public void b(f.a.n nVar, i0.h hVar) {
a.f.a.d.e.r.g.q(nVar, "newState");
a.f.a.d.e.r.g.q(hVar, "newPicker");
g1.k(g1.this, "updateBalancingState()");
f.a.j1 j1Var = g1.this.l;
a aVar = new a(hVar, nVar);
Queue<Runnable> queue = j1Var.f9750f;
a.f.a.d.e.r.g.q(aVar, "runnable is null");
queue.add(aVar);
j1Var.a();
}
}
public final class l extends q0.e {
public final k f10081a;
public final f.a.q0 f10082b;
public final class a implements Runnable {
public final f.a.e1 f10084e;
public a(f.a.e1 e1Var) {
this.f10084e = e1Var;
}
@Override
public void run() {
l.c(l.this, this.f10084e);
}
}
public final class b implements Runnable {
public final q0.f f10086e;
public b(q0.f fVar) {
this.f10086e = fVar;
}
@Override
public void run() {
Map<String, ?> map;
Map<String, ?> map2;
e.a aVar = e.a.INFO;
q0.f fVar = this.f10086e;
List<f.a.v> list = fVar.f10725a;
f.a.a aVar2 = fVar.f10726b;
g1.this.M.b(e.a.DEBUG, "Resolved address: {0}, config={1}", list, aVar2);
Boolean bool = g1.this.O;
if (bool == null || !bool.booleanValue()) {
g1.this.M.b(aVar, "Address resolved: {0}", list);
g1.this.O = Boolean.TRUE;
}
g1.this.a0 = null;
Map<String, ?> map3 = (Map) aVar2.f9655a.get(p0.f10258a);
g1 g1Var = g1.this;
if (!g1Var.R) {
if (map3 != null) {
g1Var.M.a(aVar, "Service config from name resolver discarded by channel settings");
}
map2 = g1.this.Q;
} else {
if (map3 != null) {
map = map3;
} else {
map = g1Var.Q;
if (map != null) {
g1Var.M.a(aVar, "Received no service config, using default service config");
}
}
g1 g1Var2 = g1.this;
if (map != g1Var2.P) {
f.a.e eVar = g1Var2.M;
Object[] objArr = new Object[1];
objArr[0] = map == null ? " to null" : BuildConfig.FLAVOR;
eVar.b(aVar, "Service config changed{0}", objArr);
g1.this.P = map;
}
try {
g1.this.r();
} catch (RuntimeException e2) {
Logger logger = g1.d0;
Level level = Level.WARNING;
StringBuilder d2 = a.c.a.a.a.d("[");
d2.append(g1.this.f10054a);
d2.append("] Unexpected exception from parsing service config");
logger.log(level, d2.toString(), (Throwable) e2);
}
map2 = map;
}
l lVar = l.this;
if (lVar.f10081a == g1.this.y) {
if (list.isEmpty() && !l.this.f10081a.f10076a.a()) {
l lVar2 = l.this;
f.a.e1 e1Var = f.a.e1.n;
StringBuilder d3 = a.c.a.a.a.d("Name resolver ");
d3.append(l.this.f10082b);
d3.append(" returned an empty list");
l.c(lVar2, e1Var.g(d3.toString()));
return;
}
if (map2 != map3) {
a.b b2 = aVar2.b();
b2.b(p0.f10258a, map2);
aVar2 = b2.a();
}
f.a.i0 i0Var = l.this.f10081a.f10076a;
f.a.a aVar3 = f.a.a.f9654b;
i0Var.c(new i0.f(list, aVar2, null, null));
}
}
}
public l(k kVar, f.a.q0 q0Var) {
a.f.a.d.e.r.g.q(kVar, "helperImpl");
this.f10081a = kVar;
a.f.a.d.e.r.g.q(q0Var, "resolver");
this.f10082b = q0Var;
}
public static void c(l lVar, f.a.e1 e1Var) {
if (lVar != null) {
g1.d0.log(Level.WARNING, "[{0}] Failed to resolve name. status={1}", new Object[]{g1.this.f10054a, e1Var});
Boolean bool = g1.this.O;
if (bool == null || bool.booleanValue()) {
g1.this.M.b(e.a.WARNING, "Failed to resolve name: {0}", e1Var);
g1.this.O = Boolean.FALSE;
}
k kVar = lVar.f10081a;
if (kVar != g1.this.y) {
return;
}
kVar.f10076a.b(e1Var);
j1.b bVar = g1.this.Z;
if (bVar != null) {
j1.a aVar = bVar.f9755a;
if ((aVar.f9754g || aVar.f9753f) ? false : true) {
return;
}
}
g1 g1Var = g1.this;
if (g1Var.a0 == null) {
if (((g0.a) g1Var.t) != null) {
g1Var.a0 = new g0();
} else {
throw null;
}
}
long a2 = ((g0) g1.this.a0).a();
g1.this.M.b(e.a.DEBUG, "Scheduling DNS resolution backoff for {0} ns", Long.valueOf(a2));
g1 g1Var2 = g1.this;
f.a.j1 j1Var = g1Var2.l;
f fVar = new f();
TimeUnit timeUnit = TimeUnit.NANOSECONDS;
ScheduledExecutorService z = g1.this.f10059f.z();
if (j1Var != null) {
j1.a aVar2 = new j1.a(fVar);
g1Var2.Z = new j1.b(aVar2, z.schedule(new f.a.i1(j1Var, aVar2, fVar), a2, timeUnit), null);
return;
}
throw null;
}
throw null;
}
@Override
public void a(f.a.e1 e1Var) {
a.f.a.d.e.r.g.h(!e1Var.e(), "the error status must not be OK");
f.a.j1 j1Var = g1.this.l;
a aVar = new a(e1Var);
Queue<Runnable> queue = j1Var.f9750f;
a.f.a.d.e.r.g.q(aVar, "runnable is null");
queue.add(aVar);
j1Var.a();
}
@Override
public void b(q0.f fVar) {
f.a.j1 j1Var = g1.this.l;
b bVar = new b(fVar);
Queue<Runnable> queue = j1Var.f9750f;
a.f.a.d.e.r.g.q(bVar, "runnable is null");
queue.add(bVar);
j1Var.a();
}
}
public class m extends f.a.d {
public final String f10088a;
public m(String str, a aVar) {
a.f.a.d.e.r.g.q(str, "authority");
this.f10088a = str;
}
@Override
public String b() {
return this.f10088a;
}
@Override
public <ReqT, RespT> f.a.f<ReqT, RespT> h(f.a.p0<ReqT, RespT> p0Var, f.a.c cVar) {
g1 g1Var = g1.this;
if (g1Var != null) {
Executor executor = cVar.f9677b;
if (executor == null) {
executor = g1Var.f10060g;
}
g1 g1Var2 = g1.this;
r.e eVar = g1Var2.b0;
ScheduledExecutorService z = g1Var2.H ? null : g1.this.f10059f.z();
g1 g1Var3 = g1.this;
r rVar = new r(p0Var, executor, cVar, eVar, z, g1Var3.K, g1Var3.W);
g1 g1Var4 = g1.this;
rVar.p = g1Var4.m;
rVar.q = g1Var4.n;
rVar.r = g1Var4.o;
return rVar;
}
throw null;
}
}
public static final class n extends q0.g {
public n(boolean z, int i2, int i3, f.a.m1.i iVar) {
a.f.a.d.e.r.g.q(iVar, "autoLoadBalancerFactory");
}
}
public final class o extends f.a.m1.e {
public y0 f10090a;
public final Object f10091b = new Object();
public final f.a.a f10092c;
public boolean f10093d;
public ScheduledFuture<?> f10094e;
public final class a implements Runnable {
public a() {
}
@Override
public void run() {
o.this.f10090a.d(g1.h0);
}
}
public o(f.a.a aVar) {
a.f.a.d.e.r.g.q(aVar, "attrs");
this.f10092c = aVar;
}
@Override
public void a() {
g1.k(g1.this, "Subchannel.shutdown()");
synchronized (this.f10091b) {
if (!this.f10093d) {
this.f10093d = true;
} else {
if (!g1.this.G || this.f10094e == null) {
return;
}
this.f10094e.cancel(false);
this.f10094e = null;
}
if (g1.this.G) {
this.f10090a.d(g1.g0);
} else {
this.f10094e = g1.this.f10059f.z().schedule(new e1(new a()), 5L, TimeUnit.SECONDS);
}
}
}
public String toString() {
return this.f10090a.f10411a.toString();
}
}
public final class p {
public final Object f10097a = new Object();
public Collection<s> f10098b = new HashSet();
public p(a aVar) {
}
}
public g1(f.a.m1.b<?> bVar, v vVar, j.a aVar, s1<? extends Executor> s1Var, a.f.b.a.i<a.f.b.a.h> iVar, List<f.a.g> list, p2 p2Var) {
int i2;
String str = bVar.f9801d;
a.f.a.d.e.r.g.q(str, "target");
this.f10055b = str;
this.f10054a = f.a.e0.b("Channel", str);
this.f10056c = bVar.f9800c;
f.a.z0 z0Var = q0.f10285b ? q0.m : q0.l;
this.W = bVar.m && !bVar.n;
this.f10058e = new f.a.m1.i(bVar.f9802e);
f.a.n1.d dVar = (f.a.n1.d) bVar;
int ordinal = dVar.H.ordinal();
if (ordinal == 0) {
i2 = 443;
} else {
if (ordinal != 1) {
throw new AssertionError(dVar.H + " not handled");
}
i2 = 80;
}
Integer valueOf = Integer.valueOf(i2);
if (z0Var != null) {
f.a.j1 j1Var = this.l;
if (j1Var != null) {
q0.a aVar2 = new q0.a(valueOf, z0Var, j1Var, new n(this.W, bVar.f9806i, bVar.f9807j, this.f10058e));
this.f10057d = aVar2;
this.w = q(this.f10055b, this.f10056c, aVar2);
a.f.a.d.e.r.g.q(p2Var, "timeProvider");
this.f10063j = p2Var;
this.k = 0;
q qVar = new q(this.f10054a, 0, p2Var.a(), a.c.a.a.a.o(a.c.a.a.a.d("Channel for '"), this.f10055b, "'"));
this.L = qVar;
this.M = new f.a.m1.p(qVar, p2Var);
s1<? extends Executor> s1Var2 = bVar.f9798a;
a.f.a.d.e.r.g.q(s1Var2, "executorPool");
this.f10061h = s1Var2;
a.f.a.d.e.r.g.q(s1Var, "balancerRpcExecutorPool");
this.f10062i = new h(s1Var);
Executor a2 = this.f10061h.a();
a.f.a.d.e.r.g.q(a2, "executor");
Executor executor = a2;
this.f10060g = executor;
b0 b0Var = new b0(executor, this.l);
this.D = b0Var;
b0Var.e(this.X);
this.t = aVar;
f.a.m1.k kVar = new f.a.m1.k(vVar, this.f10060g);
this.f10059f = kVar;
a.f.a.d.e.r.g.q(kVar.z(), "delegate");
this.s = new h2(this.W, bVar.f9806i, bVar.f9807j);
this.Q = null;
this.P = null;
this.R = bVar.p;
this.u = f.a.i.a(f.a.i.a(new m(this.w.a(), null), Arrays.asList(this.s)), list);
a.f.a.d.e.r.g.q(iVar, "stopwatchSupplier");
this.p = iVar;
long j2 = bVar.f9805h;
if (j2 == -1) {
this.q = j2;
} else {
a.f.a.d.e.r.g.k(j2 >= f.a.m1.b.y, "invalid idleTimeoutMillis %s", bVar.f9805h);
this.q = bVar.f9805h;
}
this.c0 = new c2(new j(null), this.l, this.f10059f.z(), iVar.get());
this.m = false;
f.a.t tVar = bVar.f9803f;
a.f.a.d.e.r.g.q(tVar, "decompressorRegistry");
this.n = tVar;
f.a.m mVar = bVar.f9804g;
a.f.a.d.e.r.g.q(mVar, "compressorRegistry");
this.o = mVar;
this.v = null;
this.V = bVar.k;
this.U = bVar.l;
b bVar2 = new b(this, p2Var);
this.J = bVar2;
this.K = bVar2.a();
f.a.b0 b0Var2 = bVar.o;
a.f.a.d.e.r.g.p(b0Var2);
this.N = b0Var2;
f.a.b0.a(b0Var2.f9673a, this);
if (this.R) {
return;
}
if (this.Q != null) {
this.M.a(e.a.INFO, "Service config look-up disabled, using default service config");
}
r();
return;
}
throw null;
}
throw null;
}
public static void k(g1 g1Var, String str) {
if (g1Var == null) {
throw null;
}
try {
g1Var.l.c();
} catch (IllegalStateException e2) {
d0.log(Level.WARNING, str + " should be called from SynchronizationContext. This warning will become an exception in a future release. See https://github.com/grpc/grpc-java/issues/5015 for more details", (Throwable) e2);
}
}
public static void l(g1 g1Var) {
if (!g1Var.H && g1Var.F.get() && g1Var.B.isEmpty() && g1Var.C.isEmpty()) {
g1Var.M.a(e.a.INFO, "Terminated");
f.a.b0.b(g1Var.N.f9673a, g1Var);
g1Var.H = true;
g1Var.I.countDown();
g1Var.f10061h.b(g1Var.f10060g);
h hVar = g1Var.f10062i;
synchronized (hVar) {
if (hVar.f10073b != null) {
hVar.f10073b = hVar.f10072a.b(hVar.f10073b);
}
}
g1Var.f10059f.close();
}
}
public static void m(g1 g1Var) {
g1Var.t(true);
g1Var.D.i(null);
g1Var.M.a(e.a.INFO, "Entering IDLE state");
g1Var.r.a(f.a.n.IDLE);
if (true ^ g1Var.Y.f10402a.isEmpty()) {
g1Var.p();
}
}
public static f.a.q0 q(String str, q0.c cVar, q0.a aVar) {
URI uri;
f.a.q0 b2;
StringBuilder sb = new StringBuilder();
try {
uri = new URI(str);
} catch (URISyntaxException e2) {
sb.append(e2.getMessage());
uri = null;
}
if (uri != null && (b2 = cVar.b(uri, aVar)) != null) {
return b2;
}
boolean matches = e0.matcher(str).matches();
String str2 = BuildConfig.FLAVOR;
if (!matches) {
try {
f.a.q0 b3 = cVar.b(new URI(cVar.a(), BuildConfig.FLAVOR, "/" + str, null), aVar);
if (b3 != null) {
return b3;
}
} catch (URISyntaxException e3) {
throw new IllegalArgumentException(e3);
}
}
Object[] objArr = new Object[2];
objArr[0] = str;
if (sb.length() > 0) {
str2 = " (" + ((Object) sb) + ")";
}
objArr[1] = str2;
throw new IllegalArgumentException(String.format("cannot find a NameResolver for %s%s", objArr));
}
@Override
public String b() {
return this.u.b();
}
@Override
public f.a.e0 c() {
return this.f10054a;
}
@Override
public <ReqT, RespT> f.a.f<ReqT, RespT> h(f.a.p0<ReqT, RespT> p0Var, f.a.c cVar) {
return this.u.h(p0Var, cVar);
}
@Override
public void i() {
f.a.j1 j1Var = this.l;
c cVar = new c();
Queue<Runnable> queue = j1Var.f9750f;
a.f.a.d.e.r.g.q(cVar, "runnable is null");
queue.add(cVar);
j1Var.a();
}
@Override
public void j() {
f.a.j1 j1Var = this.l;
d dVar = new d();
Queue<Runnable> queue = j1Var.f9750f;
a.f.a.d.e.r.g.q(dVar, "runnable is null");
queue.add(dVar);
j1Var.a();
}
public final void n(boolean z) {
ScheduledFuture<?> scheduledFuture;
c2 c2Var = this.c0;
c2Var.f9890f = false;
if (!z || (scheduledFuture = c2Var.f9891g) == null) {
return;
}
scheduledFuture.cancel(false);
c2Var.f9891g = null;
}
public final void o() {
this.l.c();
j1.b bVar = this.Z;
if (bVar != null) {
bVar.f9755a.f9753f = true;
bVar.f9756b.cancel(false);
this.Z = null;
this.a0 = null;
}
}
public void p() {
this.l.c();
if (this.F.get() || this.A) {
return;
}
if (!this.Y.f10402a.isEmpty()) {
n(false);
} else {
s();
}
if (this.y != null) {
return;
}
this.M.a(e.a.INFO, "Exiting idle mode");
k kVar = new k(null);
f.a.m1.i iVar = this.f10058e;
if (iVar != null) {
kVar.f10076a = new i.b(kVar);
this.y = kVar;
this.w.d(new l(kVar, this.w));
this.x = true;
return;
}
throw null;
}
public final void r() {
m1 m1Var;
List<?> d2;
h2 h2Var = this.s;
Map<String, ?> map = this.P;
List<?> list = null;
if (h2Var != null) {
if (map == null) {
m1Var = new m1(new HashMap(), new HashMap(), null, null);
} else {
boolean z = h2Var.f10115b;
int i2 = h2Var.f10116c;
int i3 = h2Var.f10117d;
d2.x l2 = z ? i2.l(map) : null;
HashMap hashMap = new HashMap();
HashMap hashMap2 = new HashMap();
List<Map<String, ?>> h2 = i2.h(map);
if (h2 == null) {
m1Var = new m1(hashMap, hashMap2, l2, null);
} else {
for (Map<String, ?> map2 : h2) {
m1.a aVar = new m1.a(map2, z, i2, i3);
if (map2.containsKey("name")) {
d2 = i2.d(map2, "name");
i2.a(d2);
} else {
d2 = list;
}
a.f.a.d.e.r.g.l((d2 == null || d2.isEmpty()) ? false : true, "no names in method config %s", map2);
Iterator<?> it = d2.iterator();
while (it.hasNext()) {
Map map3 = (Map) it.next();
String k2 = !map3.containsKey("service") ? list : i2.k(map3, "service");
a.f.a.d.e.r.g.h(!a.f.b.a.g.b(k2), "missing service name");
String k3 = !map3.containsKey("method") ? null : i2.k(map3, "method");
if (a.f.b.a.g.b(k3)) {
a.f.a.d.e.r.g.l(!hashMap2.containsKey(k2), "Duplicate service %s", k2);
hashMap2.put(k2, aVar);
} else {
String a2 = f.a.p0.a(k2, k3);
a.f.a.d.e.r.g.l(!hashMap.containsKey(a2), "Duplicate method name %s", a2);
hashMap.put(a2, aVar);
}
list = null;
}
}
m1Var = new m1(hashMap, hashMap2, l2, null);
}
}
h2Var.f10114a.set(m1Var);
h2Var.f10118e = true;
if (this.W) {
this.T = i2.l(this.P);
return;
}
return;
}
throw null;
}
public final void s() {
long j2 = this.q;
if (j2 == -1) {
return;
}
c2 c2Var = this.c0;
TimeUnit timeUnit = TimeUnit.MILLISECONDS;
if (c2Var == null) {
throw null;
}
long nanos = timeUnit.toNanos(j2);
long a2 = c2Var.f9888d.a(TimeUnit.NANOSECONDS) + nanos;
c2Var.f9890f = true;
if (a2 - c2Var.f9889e < 0 || c2Var.f9891g == null) {
ScheduledFuture<?> scheduledFuture = c2Var.f9891g;
if (scheduledFuture != null) {
scheduledFuture.cancel(false);
}
c2Var.f9891g = c2Var.f9885a.schedule(new c2.c(null), nanos, TimeUnit.NANOSECONDS);
}
c2Var.f9889e = a2;
}
public final void t(boolean z) {
this.l.c();
if (z) {
a.f.a.d.e.r.g.v(this.x, "nameResolver is not started");
a.f.a.d.e.r.g.v(this.y != null, "lbHelper is null");
}
if (this.w != null) {
o();
this.w.c();
this.x = false;
if (z) {
this.w = q(this.f10055b, this.f10056c, this.f10057d);
} else {
this.w = null;
}
}
k kVar = this.y;
if (kVar != null) {
kVar.f10076a.e();
this.y = null;
}
this.z = null;
}
public String toString() {
a.f.b.a.f A0 = a.f.a.d.e.r.g.A0(this);
A0.b("logId", this.f10054a.f9707c);
A0.d("target", this.f10055b);
return A0.toString();
}
}