正在查看: All File Recovery v1.0.2 应用的 f.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。
正在查看: All File Recovery v1.0.2 应用的 f.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。
package Zd;
import Dc.K;
import Rd.C0390b;
import Td.C;
import Td.C0414a;
import Td.C0420g;
import Td.C0425l;
import Td.D;
import Td.E;
import Td.G;
import Td.I;
import Td.InterfaceC0418e;
import Td.InterfaceC0423j;
import Td.r;
import Td.t;
import Td.w;
import ae.C0513g;
import ae.InterfaceC0510d;
import bd.InterfaceC0517a;
import be.C0523b;
import ce.C0526a;
import ce.EnumC0527b;
import ce.f;
import ce.n;
import ef.l;
import ef.m;
import he.AbstractC0628c;
import he.C0629d;
import ie.e;
import java.io.IOException;
import java.lang.ref.Reference;
import java.net.ConnectException;
import java.net.Proxy;
import java.net.Socket;
import java.net.SocketException;
import java.security.cert.Certificate;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLPeerUnverifiedException;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocket;
import javax.net.ssl.SSLSocketFactory;
import ke.InterfaceC0714m;
import ke.InterfaceC0715n;
import ke.c0;
import ke.d0;
import ke.s0;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.Lambda;
import kotlin.jvm.internal.SourceDebugExtension;
import nd.C0750D;
@SourceDebugExtension({"SMAP\nRealConnection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 Util.kt\nokhttp3/internal/Util\n+ 4 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n*L\n1#1,765:1\n1#2:766\n608#3,4:767\n608#3,4:774\n615#3,4:778\n1747#4,3:771\n*S KotlinDebug\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection\n*L\n529#1:767,4\n582#1:774,4\n648#1:778,4\n574#1:771,3\n*E\n"})
public final class f extends f.c implements InterfaceC0423j {
@l
public static final a t = new a();
@l
public static final String u = "throw with null exception";
public static final int v = 21;
public static final long w = 10000000000L;
@l
public final g c;
@l
public final I d;
@m
public Socket e;
@m
public Socket f;
@m
public t g;
@m
public D h;
@m
public ce.f i;
@m
public InterfaceC0715n j;
@m
public InterfaceC0714m k;
public boolean l;
public boolean m;
public int n;
public int o;
public int p;
public int q;
@l
public final List<Reference<Zd.e>> r;
public long s;
public static final class a {
public a() {
}
@l
public final f a(@l g connectionPool, @l I route, @l Socket socket, long j) {
Intrinsics.checkNotNullParameter(connectionPool, "connectionPool");
Intrinsics.checkNotNullParameter(route, "route");
Intrinsics.checkNotNullParameter(socket, "socket");
f fVar = new f(connectionPool, route);
fVar.f = socket;
fVar.s = j;
return fVar;
}
public a(DefaultConstructorMarker defaultConstructorMarker) {
}
}
public class b {
public static final int[] a;
static {
int[] iArr = new int[Proxy.Type.values().length];
try {
iArr[Proxy.Type.DIRECT.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
iArr[Proxy.Type.HTTP.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
a = iArr;
}
}
public static final class c extends Lambda implements InterfaceC0517a<List<? extends Certificate>> {
public final C0420g a;
public final t b;
public final C0414a c;
public c(C0420g c0420g, t tVar, C0414a c0414a) {
super(0);
this.a = c0420g;
this.b = tVar;
this.c = c0414a;
}
@Override
@l
public final List<? extends Certificate> invoke() {
AbstractC0628c abstractC0628c = this.a.b;
Intrinsics.checkNotNull(abstractC0628c);
return abstractC0628c.a(this.b.m(), this.c.i.d);
}
}
@SourceDebugExtension({"SMAP\nRealConnection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection$connectTls$2\n+ 2 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n*L\n1#1,765:1\n1549#2:766\n1620#2,3:767\n*S KotlinDebug\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection$connectTls$2\n*L\n411#1:766\n411#1:767,3\n*E\n"})
public static final class d extends Lambda implements InterfaceC0517a<List<? extends X509Certificate>> {
public d() {
super(0);
}
@Override
@l
public final List<? extends X509Certificate> invoke() {
t tVar = f.this.g;
Intrinsics.checkNotNull(tVar);
List<Certificate> m = tVar.m();
ArrayList arrayList = new ArrayList(K.b0(m, 10));
for (Certificate certificate : m) {
Intrinsics.checkNotNull(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
arrayList.add((X509Certificate) certificate);
}
return arrayList;
}
}
public static final class e extends e.d {
public final Zd.c d;
public e(InterfaceC0715n interfaceC0715n, InterfaceC0714m interfaceC0714m, Zd.c cVar) {
super(true, interfaceC0715n, interfaceC0714m);
this.d = cVar;
}
@Override
public void close() {
this.d.a(-1L, true, true, null);
}
}
public f(@l g connectionPool, @l I route) {
Intrinsics.checkNotNullParameter(connectionPool, "connectionPool");
Intrinsics.checkNotNullParameter(route, "route");
this.c = connectionPool;
this.d = route;
this.q = 1;
this.r = new ArrayList();
this.s = Long.MAX_VALUE;
}
public final boolean A() {
return this.i != null;
}
@l
public final InterfaceC0510d B(@l C client, @l C0513g chain) throws SocketException {
Intrinsics.checkNotNullParameter(client, "client");
Intrinsics.checkNotNullParameter(chain, "chain");
Socket socket = this.f;
Intrinsics.checkNotNull(socket);
InterfaceC0715n interfaceC0715n = this.j;
Intrinsics.checkNotNull(interfaceC0715n);
InterfaceC0714m interfaceC0714m = this.k;
Intrinsics.checkNotNull(interfaceC0714m);
ce.f fVar = this.i;
if (fVar != null) {
return new ce.g(client, this, chain, fVar);
}
socket.setSoTimeout(chain.g);
s0 timeout = interfaceC0715n.timeout();
long j = chain.g;
TimeUnit timeUnit = TimeUnit.MILLISECONDS;
timeout.j(j, timeUnit);
interfaceC0714m.timeout().j(chain.h, timeUnit);
return new C0523b(client, this, interfaceC0715n, interfaceC0714m);
}
@l
public final e.d C(@l Zd.c exchange) throws SocketException {
Intrinsics.checkNotNullParameter(exchange, "exchange");
Socket socket = this.f;
Intrinsics.checkNotNull(socket);
InterfaceC0715n interfaceC0715n = this.j;
Intrinsics.checkNotNull(interfaceC0715n);
InterfaceC0714m interfaceC0714m = this.k;
Intrinsics.checkNotNull(interfaceC0714m);
socket.setSoTimeout(0);
E();
return new e(interfaceC0715n, interfaceC0714m, exchange);
}
public final synchronized void D() {
this.m = true;
}
public final synchronized void E() {
this.l = true;
}
public final boolean F(List<I> list) {
List<I> list2 = list;
if ((list2 instanceof Collection) && list2.isEmpty()) {
return false;
}
for (I i : list2) {
Proxy.Type type = i.b.type();
Proxy.Type type2 = Proxy.Type.DIRECT;
if (type == type2 && this.d.b.type() == type2 && Intrinsics.areEqual(this.d.c, i.c)) {
return true;
}
}
return false;
}
public final void G(long j) {
this.s = j;
}
public final void H(boolean z) {
this.l = z;
}
public final void I(int i) {
this.n = i;
}
public final void J(int i) throws IOException {
Socket socket = this.f;
Intrinsics.checkNotNull(socket);
InterfaceC0715n interfaceC0715n = this.j;
Intrinsics.checkNotNull(interfaceC0715n);
InterfaceC0714m interfaceC0714m = this.k;
Intrinsics.checkNotNull(interfaceC0714m);
socket.setSoTimeout(0);
f.a aVar = new f.a(true, Yd.d.i);
aVar.y(socket, this.d.a.i.d, interfaceC0715n, interfaceC0714m);
Intrinsics.checkNotNullParameter(this, "listener");
aVar.g = this;
aVar.i = i;
ce.f fVar = new ce.f(aVar);
this.i = fVar;
ce.f.D.getClass();
this.q = ce.f.F.f();
ce.f.o2(fVar, false, null, 3, null);
}
public final boolean K(w wVar) {
t tVar;
if (Ud.f.h && !Thread.holdsLock(this)) {
throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this);
}
w wVar2 = this.d.a.i;
if (wVar.e != wVar2.e) {
return false;
}
if (Intrinsics.areEqual(wVar.d, wVar2.d)) {
return true;
}
if (!this.m && (tVar = this.g) != null) {
Intrinsics.checkNotNull(tVar);
if (j(wVar, tVar)) {
return true;
}
}
return false;
}
public final synchronized void L(@l Zd.e call, @m IOException iOException) {
try {
Intrinsics.checkNotNullParameter(call, "call");
if (iOException instanceof n) {
if (((n) iOException).a == EnumC0527b.REFUSED_STREAM) {
int i = this.p + 1;
this.p = i;
if (i > 1) {
this.l = true;
this.n++;
}
} else if (((n) iOException).a != EnumC0527b.CANCEL || !call.p) {
this.l = true;
this.n++;
}
} else if (!A() || (iOException instanceof C0526a)) {
this.l = true;
if (this.o == 0) {
if (iOException != null) {
l(call.a, this.d, iOException);
}
this.n++;
}
}
} catch (Throwable th) {
throw th;
}
}
@Override
@l
public D a() {
D d2 = this.h;
Intrinsics.checkNotNull(d2);
return d2;
}
@Override
@l
public I b() {
return this.d;
}
@Override
@m
public t c() {
return this.g;
}
@Override
@l
public Socket d() {
Socket socket = this.f;
Intrinsics.checkNotNull(socket);
return socket;
}
@Override
public synchronized void e(@l ce.f connection, @l ce.m settings) {
Intrinsics.checkNotNullParameter(connection, "connection");
Intrinsics.checkNotNullParameter(settings, "settings");
this.q = settings.f();
}
@Override
public void f(@l ce.i stream) throws IOException {
Intrinsics.checkNotNullParameter(stream, "stream");
stream.d(EnumC0527b.REFUSED_STREAM, null);
}
public final void i() {
Socket socket = this.e;
if (socket != null) {
Ud.f.q(socket);
}
}
public final boolean j(w wVar, t tVar) {
List<Certificate> m = tVar.m();
if (!m.isEmpty()) {
C0629d c0629d = C0629d.a;
String str = wVar.d;
Certificate certificate = m.get(0);
Intrinsics.checkNotNull(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
if (c0629d.e(str, (X509Certificate) certificate)) {
return true;
}
}
return false;
}
public final void k(int r13, int r14, int r15, int r16, boolean r17, @ef.l Td.InterfaceC0418e r18, @ef.l Td.r r19) {
throw new UnsupportedOperationException("Method not decompiled: Zd.f.k(int, int, int, int, boolean, Td.e, Td.r):void");
}
public final void l(@l C client, @l I failedRoute, @l IOException failure) {
Intrinsics.checkNotNullParameter(client, "client");
Intrinsics.checkNotNullParameter(failedRoute, "failedRoute");
Intrinsics.checkNotNullParameter(failure, "failure");
if (failedRoute.b.type() != Proxy.Type.DIRECT) {
C0414a c0414a = failedRoute.a;
c0414a.h.connectFailed(c0414a.i.Z(), failedRoute.b.address(), failure);
}
client.D.b(failedRoute);
}
public final void m(int i, int i2, InterfaceC0418e interfaceC0418e, r rVar) throws IOException {
Socket createSocket;
I i3 = this.d;
Proxy proxy = i3.b;
C0414a c0414a = i3.a;
Proxy.Type type = proxy.type();
int i4 = type == null ? -1 : b.a[type.ordinal()];
if (i4 == 1 || i4 == 2) {
createSocket = c0414a.b.createSocket();
Intrinsics.checkNotNull(createSocket);
} else {
createSocket = new Socket(proxy);
}
this.e = createSocket;
rVar.j(interfaceC0418e, this.d.c, proxy);
createSocket.setSoTimeout(i2);
try {
ee.h.a.getClass();
ee.h.b.g(createSocket, this.d.c, i);
try {
this.j = d0.c(c0.t(createSocket));
this.k = d0.b(c0.o(createSocket));
} catch (NullPointerException e2) {
if (Intrinsics.areEqual(e2.getMessage(), u)) {
throw new IOException(e2);
}
}
} catch (ConnectException e3) {
ConnectException connectException = new ConnectException("Failed to connect to " + this.d.c);
connectException.initCause(e3);
throw connectException;
}
}
public final void n(Zd.b bVar) throws IOException {
C0414a c0414a = this.d.a;
SSLSocketFactory sSLSocketFactory = c0414a.c;
SSLSocket sSLSocket = null;
String str = null;
try {
Intrinsics.checkNotNull(sSLSocketFactory);
Socket socket = this.e;
w wVar = c0414a.i;
Socket createSocket = sSLSocketFactory.createSocket(socket, wVar.d, wVar.e, true);
Intrinsics.checkNotNull(createSocket, "null cannot be cast to non-null type javax.net.ssl.SSLSocket");
SSLSocket sSLSocket2 = (SSLSocket) createSocket;
try {
C0425l a2 = bVar.a(sSLSocket2);
if (a2.b) {
ee.h.a.getClass();
ee.h.b.f(sSLSocket2, c0414a.i.d, c0414a.j);
}
sSLSocket2.startHandshake();
SSLSession sslSocketSession = sSLSocket2.getSession();
t.a aVar = t.e;
Intrinsics.checkNotNullExpressionValue(sslSocketSession, "sslSocketSession");
t c2 = aVar.c(sslSocketSession);
HostnameVerifier hostnameVerifier = c0414a.d;
Intrinsics.checkNotNull(hostnameVerifier);
if (hostnameVerifier.verify(c0414a.i.d, sslSocketSession)) {
C0420g c0420g = c0414a.e;
Intrinsics.checkNotNull(c0420g);
this.g = new t(c2.a, c2.b, c2.c, new c(c0420g, c2, c0414a));
c0420g.c(c0414a.i.d, new d());
if (a2.b) {
ee.h.a.getClass();
str = ee.h.b.j(sSLSocket2);
}
this.f = sSLSocket2;
this.j = d0.c(c0.t(sSLSocket2));
this.k = d0.b(c0.o(sSLSocket2));
this.h = str != null ? D.b.a(str) : D.HTTP_1_1;
ee.h.a.getClass();
ee.h.b.c(sSLSocket2);
return;
}
List<Certificate> m = c2.m();
if (m.isEmpty()) {
throw new SSLPeerUnverifiedException("Hostname " + c0414a.i.d + " not verified (no certificates)");
}
Certificate certificate = m.get(0);
Intrinsics.checkNotNull(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
X509Certificate x509Certificate = (X509Certificate) certificate;
throw new SSLPeerUnverifiedException(C0750D.x("\n |Hostname " + c0414a.i.d + " not verified:\n | certificate: " + C0420g.c.a(x509Certificate) + "\n | DN: " + x509Certificate.getSubjectDN().getName() + "\n | subjectAltNames: " + C0629d.a.a(x509Certificate) + "\n ", null, 1, null));
} catch (Throwable th) {
th = th;
sSLSocket = sSLSocket2;
if (sSLSocket != null) {
ee.h.a.getClass();
ee.h.b.c(sSLSocket);
}
if (sSLSocket != null) {
Ud.f.q(sSLSocket);
}
throw th;
}
} catch (Throwable th2) {
th = th2;
}
}
public final void o(int i, int i2, int i3, InterfaceC0418e interfaceC0418e, r rVar) throws IOException {
E q = q();
w wVar = q.a;
for (int i4 = 0; i4 < 21; i4++) {
m(i, i2, interfaceC0418e, rVar);
q = p(i2, i3, q, wVar);
if (q == null) {
return;
}
Socket socket = this.e;
if (socket != null) {
Ud.f.q(socket);
}
this.e = null;
this.k = null;
this.j = null;
I i5 = this.d;
rVar.h(interfaceC0418e, i5.c, i5.b, null);
}
}
public final E p(int i, int i2, E request, w wVar) throws IOException {
String str = "CONNECT " + Ud.f.f0(wVar, true) + " HTTP/1.1";
while (true) {
InterfaceC0715n interfaceC0715n = this.j;
Intrinsics.checkNotNull(interfaceC0715n);
InterfaceC0714m interfaceC0714m = this.k;
Intrinsics.checkNotNull(interfaceC0714m);
C0523b c0523b = new C0523b(null, this, interfaceC0715n, interfaceC0714m);
TimeUnit timeUnit = TimeUnit.MILLISECONDS;
interfaceC0715n.timeout().j(i, timeUnit);
interfaceC0714m.timeout().j(i2, timeUnit);
c0523b.C(request.c, str);
c0523b.b();
G.a g = c0523b.g(false);
Intrinsics.checkNotNull(g);
g.getClass();
Intrinsics.checkNotNullParameter(request, "request");
g.a = request;
G c2 = g.c();
c0523b.B(c2);
int i3 = c2.d;
if (i3 == 200) {
if (interfaceC0715n.B().g1() && interfaceC0714m.B().g1()) {
return null;
}
throw new IOException("TLS tunnel buffered too many bytes!");
}
if (i3 != 407) {
throw new IOException("Unexpected response code for CONNECT: " + c2.d);
}
I i4 = this.d;
E a2 = i4.a.f.a(i4, c2);
if (a2 == null) {
throw new IOException("Failed to authenticate with proxy");
}
if (com.vungle.ads.internal.presenter.i.CLOSE.equalsIgnoreCase(c2.D0("Connection", null))) {
return a2;
}
request = a2;
}
}
public final E q() throws IOException {
E.a aVar = new E.a();
aVar.B(this.d.a.i);
aVar.p("CONNECT", null);
aVar.n("Host", Ud.f.f0(this.d.a.i, true));
aVar.n("Proxy-Connection", "Keep-Alive");
aVar.n("User-Agent", Ud.f.j);
E request = aVar.b();
G.a aVar2 = new G.a();
Intrinsics.checkNotNullParameter(request, "request");
aVar2.a = request;
aVar2.B(D.HTTP_1_1);
aVar2.c = 407;
Intrinsics.checkNotNullParameter("Preemptive Authenticate", "message");
aVar2.d = "Preemptive Authenticate";
aVar2.g = Ud.f.c;
aVar2.k = -1L;
aVar2.l = -1L;
aVar2.v("Proxy-Authenticate", "OkHttp-Preemptive");
G c2 = aVar2.c();
I i = this.d;
E a2 = i.a.f.a(i, c2);
return a2 == null ? request : a2;
}
public final void r(Zd.b bVar, int i, InterfaceC0418e interfaceC0418e, r rVar) throws IOException {
C0414a c0414a = this.d.a;
if (c0414a.c != null) {
rVar.C(interfaceC0418e);
n(bVar);
rVar.B(interfaceC0418e, this.g);
if (this.h == D.HTTP_2) {
J(i);
return;
}
return;
}
List<D> list = c0414a.j;
D d2 = D.H2_PRIOR_KNOWLEDGE;
if (!list.contains(d2)) {
this.f = this.e;
this.h = D.HTTP_1_1;
} else {
this.f = this.e;
this.h = d2;
J(i);
}
}
@l
public final List<Reference<Zd.e>> s() {
return this.r;
}
@l
public final g t() {
return this.c;
}
@l
public String toString() {
Object obj;
StringBuilder sb = new StringBuilder("Connection{");
sb.append(this.d.a.i.d);
sb.append(C0390b.h);
sb.append(this.d.a.i.e);
sb.append(", proxy=");
sb.append(this.d.b);
sb.append(" hostAddress=");
sb.append(this.d.c);
sb.append(" cipherSuite=");
t tVar = this.g;
if (tVar == null || (obj = tVar.b) == null) {
obj = "none";
}
sb.append(obj);
sb.append(" protocol=");
sb.append(this.h);
sb.append(C0390b.j);
return sb.toString();
}
public final long u() {
return this.s;
}
public final boolean v() {
return this.l;
}
public final int w() {
return this.n;
}
public final synchronized void x() {
this.o++;
}
public final boolean y(@l C0414a address, @m List<I> list) {
Intrinsics.checkNotNullParameter(address, "address");
if (Ud.f.h && !Thread.holdsLock(this)) {
throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this);
}
if (this.r.size() >= this.q || this.l || !this.d.a.o(address)) {
return false;
}
if (Intrinsics.areEqual(address.i.d, this.d.a.i.d)) {
return true;
}
if (this.i == null || list == null || !F(list) || address.d != C0629d.a || !K(address.i)) {
return false;
}
try {
C0420g c0420g = address.e;
Intrinsics.checkNotNull(c0420g);
String str = address.i.d;
t tVar = this.g;
Intrinsics.checkNotNull(tVar);
c0420g.a(str, tVar.m());
return true;
} catch (SSLPeerUnverifiedException unused) {
return false;
}
}
public final boolean z(boolean z) {
long j;
if (Ud.f.h && Thread.holdsLock(this)) {
throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this);
}
long nanoTime = System.nanoTime();
Socket socket = this.e;
Intrinsics.checkNotNull(socket);
Socket socket2 = this.f;
Intrinsics.checkNotNull(socket2);
InterfaceC0715n interfaceC0715n = this.j;
Intrinsics.checkNotNull(interfaceC0715n);
if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) {
return false;
}
ce.f fVar = this.i;
if (fVar != null) {
return fVar.k1(nanoTime);
}
synchronized (this) {
j = nanoTime - this.s;
}
if (j < w || !z) {
return true;
}
return Ud.f.N(socket2, interfaceC0715n);
}
}