正在查看： 万能钥匙 v1.1.23 应用的 d.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
万能钥匙 v1.1.23 - d.java 源代码
package com.wifitutu.link.foundation.network;
import ah0.l;
import androidx.annotation.RequiresPermission;
import com.meituan.robust.ChangeQuickRedirect;
import com.meituan.robust.PatchProxy;
import com.meituan.robust.PatchProxyResult;
import com.wifitutu.link.foundation.kernel.h;
import com.wifitutu.link.foundation.network.d;
import java.net.HttpURLConnection;
import java.net.URLConnection;
import java.util.List;
import kotlin.Metadata;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.a0;
import kotlin.jvm.internal.d0;
import kotlin.jvm.internal.f0;
import kotlin.jvm.internal.n;
import kotlin.jvm.internal.p;
import lg0.C3037l0;
import lg0.C3218h;
import lg0.InterfaceC3056q1;
import lg0.d6;
import lg0.e0;
import lg0.f4;
import lg0.h4;
import lg0.j5;
import lg0.o4;
import lg0.q6;
import lg0.r6;
import lg0.t3;
import lg0.t6;
import os.C2620c0;
import os.C2647f2;
import os.C2710m2;
import os.C2736q0;
import os.b0$a;
import uj0.a;
@Metadata(d1 = {"\u0000,\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\u0018\u0000 \t2\u00020\u0001:\u0001\u0006B\u0007¢\u0006\u0004\b\u0002\u0010\u0003J\u000f\u0010\u0005\u001a\u00020\u0004H\u0016¢\u0006\u0004\b\u0005\u0010\u0003J\u000f\u0010\u0006\u001a\u00020\u0004H\u0016¢\u0006\u0004\b\u0006\u0010\u0003J\u0017\u0010\t\u001a\u00020\u00042\u0006\u0010\b\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\t\u0010\nR\u0018\u0010\u000e\u001a\u0004\u0018\u00010\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\f\u0010\rR\u0014\u0010\u0012\u001a\u00020\u000f8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0010\u0010\u0011¨\u0006\u0013"}, d2 = {"Lcom/wifitutu/link/foundation/network/d;", "Lcom/wifitutu/link/foundation/network/a;", "<init>", "()V", "Llg0/e0;", "start", "a", "", "samples", "e", "(I)V", "Lqs/q1;", "c", "Lqs/q1;", "_jobwatcher", "Lqs/f4;", "d", "Lqs/f4;", "_lo", "lib-network_release"}, k = 1, mv = {1, 8, 0}, xi = 48)
public final class d extends a {
public static ChangeQuickRedirect changeQuickRedirect;
public static final Companion INSTANCE = new Companion(null);
public InterfaceC3056q1 _jobwatcher;
public final f4 _lo = new f4();
@Metadata(d1 = {"\u0000*\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0086\u0003\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003J)\u0010\n\u001a\u00020\b2\u0006\u0010\u0005\u001a\u00020\u00042\u0012\u0010\t\u001a\u000e\u0012\u0004\u0012\u00020\u0007\u0012\u0004\u0012\u00020\b0\u0006¢\u0006\u0004\b\n\u0010\u000bJ)\u0010\f\u001a\u00020\b2\u0006\u0010\u0005\u001a\u00020\u00042\u0012\u0010\t\u001a\u000e\u0012\u0004\u0012\u00020\u0007\u0012\u0004\u0012\u00020\b0\u0006¢\u0006\u0004\b\f\u0010\u000bJ\u0017\u0010\u000f\u001a\u0004\u0018\u00010\u00072\u0006\u0010\u000e\u001a\u00020\r¢\u0006\u0004\b\u000f\u0010\u0010J\u0019\u0010\u0011\u001a\u0004\u0018\u00010\u00072\u0006\u0010\u000e\u001a\u00020\rH\u0007¢\u0006\u0004\b\u0011\u0010\u0010¨\u0006\u0012"}, d2 = {"Lcom/wifitutu/link/foundation/network/d$a;", "", "<init>", "()V", "", "samples", "Lkotlin/Function1;", "", "Llg0/e0;", "cb", "c", "(ILah0/l;)V", "f", "Lqs/t6;", "cfg", "e", "(Lqs/t6;)Ljava/lang/Boolean;", "h", "lib-network_release"}, k = 1, mv = {1, 8, 0}, xi = 48)
public static final class Companion {
public static ChangeQuickRedirect changeQuickRedirect;
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class C0261a extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final C0261a s = new C0261a();
public C0261a() {
super(0);
}
@Override
public final Object invoke() {
return "选择IPv4的地址用来测试是否可以请求公网数据";
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class b extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final b s = new b();
public b() {
super(0);
}
@Override
public final Object invoke() {
return "选择IPv6的地址用来测试是否可以请求公网数据";
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class c extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final c s = new c();
public c() {
super(0);
}
@Override
public final Object invoke() {
return "选择IPv46的地址用来测试是否可以请求公网数据";
}
}
@Metadata(d1 = {"\u0000\b\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0003\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0001\u0010\u0002"}, d2 = {"Llg0/e0;", "invoke", "()V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class C0262d extends p implements ah0.a<e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final t6 s;
public final f0<Boolean> t;
@Metadata(d1 = {"\u0000\b\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0003\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0001\u0010\u0002"}, d2 = {"Llg0/e0;", "invoke", "()V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class C0263a extends p implements ah0.a<e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final f0<HttpURLConnection> s;
public final t6 t;
public final f0<Boolean> u;
public C0263a(f0<HttpURLConnection> f0Var, t6 t6Var, f0<Boolean> f0Var2) {
super(0);
this.s = f0Var;
this.t = t6Var;
this.u = f0Var2;
}
@Override
public e0 invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12915, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke2();
return e0.a;
}
public final void invoke2() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12914, new Class[0], Void.TYPE).isSupported) {
return;
}
f0<HttpURLConnection> f0Var = this.s;
URLConnection openConnection = r6.c(this.t).openConnection();
n.g(openConnection, "null cannot be cast to non-null type java.net.HttpURLConnection");
HttpURLConnection httpURLConnection = (HttpURLConnection) openConnection;
httpURLConnection.setRequestMethod("GET");
httpURLConnection.setInstanceFollowRedirects(false);
httpURLConnection.setConnectTimeout((int) uj0.a.t(C2736q0.a(C2647f2.d()).g7()));
httpURLConnection.setReadTimeout((int) uj0.a.t(C2736q0.a(C2647f2.d()).n7()));
httpURLConnection.setUseCaches(false);
f0Var.a = httpURLConnection;
HttpURLConnection httpURLConnection2 = (HttpURLConnection) this.s.a;
if (httpURLConnection2 != null) {
f0<Boolean> f0Var2 = this.u;
t6 t6Var = this.t;
httpURLConnection2.connect();
f0Var2.a = Boolean.valueOf(r6.a(t6Var, httpURLConnection2));
}
}
}
public C0262d(t6 t6Var, f0<Boolean> f0Var) {
super(0);
this.s = t6Var;
this.t = f0Var;
}
@Override
public e0 invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12913, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke2();
return e0.a;
}
public final void invoke2() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12912, new Class[0], Void.TYPE).isSupported) {
return;
}
f0 f0Var = new f0();
d6.k(new C0263a(f0Var, this.s, this.t));
HttpURLConnection httpURLConnection = (HttpURLConnection) f0Var.a;
if (httpURLConnection != null) {
httpURLConnection.disconnect();
}
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class e extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final e s = new e();
public e() {
super(0);
}
@Override
public final Object invoke() {
return "选择IPv4的地址用来测试wifi是否可以请求公网数据";
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class f extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final f s = new f();
public f() {
super(0);
}
@Override
public final Object invoke() {
return "选择IPv6的地址用来测试wifi是否可以请求公网数据";
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class g extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final g s = new g();
public g() {
super(0);
}
@Override
public final Object invoke() {
return "选择IPv46的地址用来测试wifi是否可以请求公网数据";
}
}
@Metadata(d1 = {"\u0000\u000e\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\u00020\u00022\b\u0010\u0001\u001a\u0004\u0018\u00010\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Ljava/net/HttpURLConnection;", "conn", "Llg0/e0;", "a", "(Ljava/net/HttpURLConnection;)V"}, k = 3, mv = {1, 8, 0})
public static final class h extends p implements l<HttpURLConnection, e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final f0<Boolean> s;
public final t6 t;
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class C0264a extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public final Throwable s;
public C0264a(Throwable th) {
super(0);
this.s = th;
}
@Override
public final Object invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12918, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
return "CheckWifiSync Connect Exception: " + j5.a(this.s);
}
}
@Metadata(d1 = {"\u0000\b\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0003\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0001\u0010\u0002"}, d2 = {"Llg0/e0;", "invoke", "()V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class b extends p implements ah0.a<e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final HttpURLConnection s;
public final t6 t;
public final f0<Boolean> u;
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class C0265a extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public final HttpURLConnection s;
public C0265a(HttpURLConnection httpURLConnection) {
super(0);
this.s = httpURLConnection;
}
@Override
public final Object invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12921, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
return "CheckWifiSync Start conn.responseCode=" + this.s.getResponseCode();
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class C0266b extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public final HttpURLConnection s;
public C0266b(HttpURLConnection httpURLConnection) {
super(0);
this.s = httpURLConnection;
}
@Override
public final Object invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12922, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
return "CheckWifiSync Start conn.responseMessage=" + this.s.getResponseMessage();
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class c extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final c s = new c();
public c() {
super(0);
}
@Override
public final Object invoke() {
return "CheckWifiSync Connect Exception retry success";
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class C0267d extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public final Throwable s;
public C0267d(Throwable th) {
super(0);
this.s = th;
}
@Override
public final Object invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12923, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
return "CheckWifiSync Connect retry Exception: " + j5.a(this.s);
}
}
public b(HttpURLConnection httpURLConnection, t6 t6Var, f0<Boolean> f0Var) {
super(0);
this.s = httpURLConnection;
this.t = t6Var;
this.u = f0Var;
}
@Override
public e0 invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12920, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke2();
return e0.a;
}
public final void invoke2() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12919, new Class[0], Void.TYPE).isSupported) {
return;
}
try {
this.s.connect();
h4.l().j("network", new C0265a(this.s));
h4.l().j("network", new C0266b(this.s));
if (r6.b(this.t, this.s)) {
this.u.a = Boolean.FALSE;
h4.l().j("network", c.s);
}
} catch (Throwable th) {
h4.l().u("network", new C0267d(th));
}
}
}
@Metadata(d1 = {"\u0000\b\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0003\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0001\u0010\u0002"}, d2 = {"Llg0/e0;", "invoke", "()V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class c extends p implements ah0.a<e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final HttpURLConnection s;
public c(HttpURLConnection httpURLConnection) {
super(0);
this.s = httpURLConnection;
}
@Override
public e0 invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12925, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke2();
return e0.a;
}
public final void invoke2() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12924, new Class[0], Void.TYPE).isSupported) {
return;
}
this.s.disconnect();
}
}
public h(f0<Boolean> f0Var, t6 t6Var) {
super(1);
this.s = f0Var;
this.t = t6Var;
}
public final void a(HttpURLConnection httpURLConnection) {
if (PatchProxy.proxy(new Object[]{httpURLConnection}, this, changeQuickRedirect, false, 12916, new Class[]{HttpURLConnection.class}, Void.TYPE).isSupported) {
return;
}
if (httpURLConnection == null) {
this.s.a = null;
return;
}
try {
httpURLConnection.setRequestMethod("GET");
httpURLConnection.setInstanceFollowRedirects(false);
httpURLConnection.setConnectTimeout((int) uj0.a.t(C2736q0.a(C2647f2.d()).g7()));
httpURLConnection.setReadTimeout((int) uj0.a.t(C2736q0.a(C2647f2.d()).n7()));
httpURLConnection.setUseCaches(false);
httpURLConnection.connect();
this.s.a = Boolean.valueOf(r6.a(this.t, httpURLConnection));
} catch (Throwable th) {
h4.l().u("network", new C0264a(th));
if (n.d(b0$a.a(C2620c0.a(C2647f2.d()), "V1_LSKEY_134955", false, null, 6, null), "B")) {
pt.h.a.i(new b(httpURLConnection, this.t, this.s));
}
}
d6.k(new c(httpURLConnection));
}
@Override
public e0 invoke(HttpURLConnection httpURLConnection) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{httpURLConnection}, this, changeQuickRedirect, false, 12917, new Class[]{Object.class}, Object.class);
if (proxy.isSupported) {
return proxy.result;
}
a(httpURLConnection);
return e0.a;
}
}
public Companion() {
}
public Companion(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
public static final void d(List list, int i, a0 a0Var, l lVar, d0 d0Var) {
if (PatchProxy.proxy(new Object[]{list, new Integer(i), a0Var, lVar, d0Var}, (Object) null, changeQuickRedirect, true, 12910, new Class[]{List.class, Integer.TYPE, a0.class, l.class, d0.class}, Void.TYPE).isSupported) {
return;
}
Boolean e2 = d.INSTANCE.e((t6) list.get(i));
if (a0Var.a) {
return;
}
Boolean bool = Boolean.TRUE;
if (n.d(e2, bool)) {
a0Var.a = true;
lVar.invoke(bool);
return;
}
int i2 = d0Var.a - 1;
d0Var.a = i2;
if (i2 == 0) {
lVar.invoke(Boolean.FALSE);
}
}
public static final void g(List list, int i, a0 a0Var, l lVar, d0 d0Var) {
if (PatchProxy.proxy(new Object[]{list, new Integer(i), a0Var, lVar, d0Var}, (Object) null, changeQuickRedirect, true, 12911, new Class[]{List.class, Integer.TYPE, a0.class, l.class, d0.class}, Void.TYPE).isSupported) {
return;
}
Boolean h2 = d.INSTANCE.h((t6) list.get(i));
if (a0Var.a) {
return;
}
Boolean bool = Boolean.TRUE;
if (n.d(h2, bool)) {
a0Var.a = true;
lVar.invoke(bool);
return;
}
int i2 = d0Var.a - 1;
d0Var.a = i2;
if (i2 == 0) {
lVar.invoke(Boolean.FALSE);
}
}
public final void c(int samples, final l<? super Boolean, e0> cb) {
List<t6> b2;
if (PatchProxy.proxy(new Object[]{new Integer(samples), cb}, this, changeQuickRedirect, false, 12906, new Class[]{Integer.TYPE, l.class}, Void.TYPE).isSupported) {
return;
}
if (C2710m2.a(com.wifitutu.link.foundation.core.a.c(C2647f2.d()).P())) {
h4.l().y("network", C0261a.s);
b2 = pt.c.c(C2736q0.a(C2647f2.d()).j3());
} else if (C2710m2.b(com.wifitutu.link.foundation.core.a.c(C2647f2.d()).P())) {
h4.l().y("network", b.s);
b2 = pt.c.d(C2736q0.a(C2647f2.d()).j3());
} else {
h4.l().y("network", c.s);
b2 = pt.c.b(C2736q0.a(C2647f2.d()).j3());
}
final List k = C3037l0.k(b2, samples, true);
final d0 d0Var = new d0();
d0Var.a = k.size();
final a0 a0Var = new a0();
int size = k.size();
for (final int i = 0; i < size; i++) {
C2647f2.d().d().execute(new Runnable() {
@Override
public final void run() {
d.Companion.d(k, i, a0Var, cb, d0Var);
}
});
}
}
public final Boolean e(t6 cfg) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{cfg}, this, changeQuickRedirect, false, 12908, new Class[]{t6.class}, Boolean.class);
if (proxy.isSupported) {
return (Boolean) proxy.result;
}
f0 f0Var = new f0();
d6.k(new C0262d(cfg, f0Var));
return (Boolean) f0Var.a;
}
public final void f(int samples, final l<? super Boolean, e0> cb) {
List<t6> b2;
if (PatchProxy.proxy(new Object[]{new Integer(samples), cb}, this, changeQuickRedirect, false, 12907, new Class[]{Integer.TYPE, l.class}, Void.TYPE).isSupported) {
return;
}
if (C2710m2.c(com.wifitutu.link.foundation.core.a.c(C2647f2.d()).P())) {
h4.l().y("network", e.s);
b2 = pt.c.c(C2736q0.a(C2647f2.d()).j3());
} else if (C2710m2.d(com.wifitutu.link.foundation.core.a.c(C2647f2.d()).P())) {
h4.l().y("network", f.s);
b2 = pt.c.d(C2736q0.a(C2647f2.d()).j3());
} else {
h4.l().y("network", g.s);
b2 = pt.c.b(C2736q0.a(C2647f2.d()).j3());
}
final List k = C3037l0.k(b2, samples, true);
final d0 d0Var = new d0();
d0Var.a = k.size();
final a0 a0Var = new a0();
int size = k.size();
for (final int i = 0; i < size; i++) {
C2647f2.d().d().execute(new Runnable() {
@Override
public final void run() {
d.Companion.g(k, i, a0Var, cb, d0Var);
}
});
}
}
@RequiresPermission("android.permission.ACCESS_NETWORK_STATE")
public final Boolean h(t6 cfg) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{cfg}, this, changeQuickRedirect, false, 12909, new Class[]{t6.class}, Boolean.class);
if (proxy.isSupported) {
return (Boolean) proxy.result;
}
f0 f0Var = new f0();
C3218h.a(r6.c(cfg), o4.WIFI, new h(f0Var, cfg));
return (Boolean) f0Var.a;
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class b extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final b s = new b();
public b() {
super(0);
}
@Override
public final Object invoke() {
return "检查当前网络是否可以请求数据";
}
}
@Metadata(d1 = {"\u0000\u000e\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0001\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"", "loid", "Llg0/e0;", "b", "(I)V"}, k = 3, mv = {1, 8, 0})
public static final class c extends p implements l<Integer, e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final int s;
public final d t;
@Metadata(d1 = {"\u0000\u000e\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0005\u001a\u00020\u00022\u0006\u0010\u0001\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"", "available", "Llg0/e0;", "invoke", "(Z)V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class a extends p implements l<Boolean, e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final d s;
public final int t;
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class C0268a extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final C0268a s = new C0268a();
public C0268a() {
super(0);
}
@Override
public final Object invoke() {
return "当前网络可以连接到外部互联网";
}
}
@Metadata(d1 = {"\u0000\b\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0003\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0001\u0010\u0002"}, d2 = {"Llg0/e0;", "invoke", "()V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class b extends p implements ah0.a<e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final d s;
public b(d dVar) {
super(0);
this.s = dVar;
}
@Override
public e0 invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12931, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke2();
return e0.a;
}
public final void invoke2() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12930, new Class[0], Void.TYPE).isSupported) {
return;
}
InterfaceC3056q1 interfaceC3056q1 = this.s._jobwatcher;
if (interfaceC3056q1 != null) {
interfaceC3056q1.cancel();
}
this.s._jobwatcher = null;
}
}
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class C0269c extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final C0269c s = new C0269c();
public C0269c() {
super(0);
}
@Override
public final Object invoke() {
return "当前网络无法连接到外部互联网";
}
}
@Metadata(d1 = {"\u0000\b\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0003\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0001\u0010\u0002"}, d2 = {"Llg0/e0;", "invoke", "()V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class C0270d extends p implements ah0.a<e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final d s;
@Metadata(d1 = {"\u0000\u000e\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0001\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lqs/t3;", "it", "Llg0/e0;", "a", "(Lqs/t3;)V"}, k = 3, mv = {1, 8, 0})
public static final class C0271a extends p implements l<t3, e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final d s;
public C0271a(d dVar) {
super(1);
this.s = dVar;
}
public final void a(t3 t3Var) {
if (!PatchProxy.proxy(new Object[]{t3Var}, this, changeQuickRedirect, false, 12934, new Class[]{t3.class}, Void.TYPE).isSupported && com.wifitutu.link.foundation.kernel.d.d().r().getForegrounding()) {
this.s.a();
}
}
@Override
public e0 invoke(t3 t3Var) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{t3Var}, this, changeQuickRedirect, false, 12935, new Class[]{Object.class}, Object.class);
if (proxy.isSupported) {
return proxy.result;
}
a(t3Var);
return e0.a;
}
}
public C0270d(d dVar) {
super(0);
this.s = dVar;
}
@Override
public e0 invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12933, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke2();
return e0.a;
}
public final void invoke2() {
if (!PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12932, new Class[0], Void.TYPE).isSupported && this.s._jobwatcher == null) {
d dVar = this.s;
a.a aVar = uj0.a.b;
dVar._jobwatcher = q6.f(uj0.c.p(5, uj0.d.e), null, false, false, false, new C0271a(this.s), 30, null);
}
}
}
public a(d dVar, int i) {
super(1);
this.s = dVar;
this.t = i;
}
@Override
public e0 invoke(Boolean bool) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{bool}, this, changeQuickRedirect, false, 12929, new Class[]{Object.class}, Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke(bool.booleanValue());
return e0.a;
}
public final void invoke(boolean z) {
if (!PatchProxy.proxy(new Object[]{new Byte(z ? (byte) 1 : (byte) 0)}, this, changeQuickRedirect, false, 12928, new Class[]{Boolean.TYPE}, Void.TYPE).isSupported && this.s._lo.a(this.t)) {
if (z) {
h4.l().y("network", C0268a.s);
h.a.a(this.s.getBus(), Boolean.TRUE, false, 0L, 6, null);
d dVar = this.s;
d6.b(dVar, new b(dVar));
return;
}
h4.l().y("network", C0269c.s);
h.a.a(this.s.getBus(), Boolean.FALSE, false, 0L, 6, null);
d dVar2 = this.s;
d6.b(dVar2, new C0270d(dVar2));
}
}
}
public c(int i, d dVar) {
super(1);
this.s = i;
this.t = dVar;
}
public final void b(int i) {
if (PatchProxy.proxy(new Object[]{new Integer(i)}, this, changeQuickRedirect, false, 12926, new Class[]{Integer.TYPE}, Void.TYPE).isSupported) {
return;
}
d.INSTANCE.c(this.s, new a(this.t, i));
}
@Override
public e0 invoke(Integer num) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{num}, this, changeQuickRedirect, false, 12927, new Class[]{Object.class}, Object.class);
if (proxy.isSupported) {
return proxy.result;
}
b(num.intValue());
return e0.a;
}
}
@Metadata(d1 = {"\u0000\b\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0003\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0001\u0010\u0002"}, d2 = {"Llg0/e0;", "invoke", "()V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public static final class C0272d extends p implements ah0.a<e0> {
public static ChangeQuickRedirect changeQuickRedirect;
@Metadata(d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0004\u0018\u00010\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "invoke"}, k = 3, mv = {1, 8, 0}, xi = 48)
public static final class a extends p implements ah0.a<Object> {
public static ChangeQuickRedirect changeQuickRedirect;
public static final a s = new a();
public a() {
super(0);
}
@Override
public final Object invoke() {
return "正在监听网络可用性";
}
}
@Metadata(d1 = {"\u0000\u000e\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0001\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lqs/t3;", "it", "Llg0/e0;", "a", "(Lqs/t3;)V"}, k = 3, mv = {1, 8, 0})
public static final class b extends p implements l<t3, e0> {
public static ChangeQuickRedirect changeQuickRedirect;
public final d s;
public b(d dVar) {
super(1);
this.s = dVar;
}
public final void a(t3 t3Var) {
if (!PatchProxy.proxy(new Object[]{t3Var}, this, changeQuickRedirect, false, 12938, new Class[]{t3.class}, Void.TYPE).isSupported && com.wifitutu.link.foundation.kernel.d.d().r().getForegrounding()) {
this.s.a();
}
}
@Override
public e0 invoke(t3 t3Var) {
PatchProxyResult proxy = PatchProxy.proxy(new Object[]{t3Var}, this, changeQuickRedirect, false, 12939, new Class[]{Object.class}, Object.class);
if (proxy.isSupported) {
return proxy.result;
}
a(t3Var);
return e0.a;
}
}
public C0272d() {
super(0);
}
@Override
public e0 invoke() {
PatchProxyResult proxy = PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12937, new Class[0], Object.class);
if (proxy.isSupported) {
return proxy.result;
}
invoke2();
return e0.a;
}
public final void invoke2() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12936, new Class[0], Void.TYPE).isSupported) {
return;
}
if (d.this._jobwatcher != null) {
h4.l().u("network", a.s);
return;
}
d.this.getBus().open();
d dVar = d.this;
a.a aVar = uj0.a.b;
dVar._jobwatcher = q6.f(uj0.c.p(5, uj0.d.e), null, false, false, false, new b(d.this), 30, null);
}
}
@Override
public void a() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12904, new Class[0], Void.TYPE).isSupported) {
return;
}
e(C2736q0.a(C2647f2.d()).N3());
}
public void e(int samples) {
if (PatchProxy.proxy(new Object[]{new Integer(samples)}, this, changeQuickRedirect, false, 12905, new Class[]{Integer.TYPE}, Void.TYPE).isSupported) {
return;
}
h4.l().y("network", b.s);
this._lo.b(new c(samples, this));
}
@Override
public void start() {
if (PatchProxy.proxy(new Object[0], this, changeQuickRedirect, false, 12902, new Class[0], Void.TYPE).isSupported) {
return;
}
d6.b(this, new C0272d());
}
}