正在查看： Kickcash v16.1 应用的 f.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
Kickcash v16.1 - f.java 源代码
package com.microsoft.clarity.ys;
import com.microsoft.clarity.bt.f;
import com.microsoft.clarity.hr.n;
import com.microsoft.clarity.ht.d;
import com.microsoft.clarity.jt.q;
import com.microsoft.clarity.ts.a0;
import com.microsoft.clarity.ts.b0;
import com.microsoft.clarity.ts.c0;
import com.microsoft.clarity.ts.e0;
import com.microsoft.clarity.ts.g0;
import com.microsoft.clarity.ts.l;
import com.microsoft.clarity.ts.r;
import com.microsoft.clarity.ts.t;
import com.microsoft.clarity.ts.v;
import com.microsoft.clarity.ur.m;
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.Principal;
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 kotlin.jvm.functions.Function0;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import org.jetbrains.annotations.NotNull;
public final class f extends f.d implements com.microsoft.clarity.ts.j {
public static final a t = new a(null);
private Socket c;
private Socket d;
private t e;
private b0 f;
private com.microsoft.clarity.bt.f g;
private com.microsoft.clarity.jt.h h;
private com.microsoft.clarity.jt.g i;
private boolean j;
private boolean k;
private int l;
private int m;
private int n;
private int o;
@NotNull
private final List<Reference<e>> p;
private long q;
@NotNull
private final h r;
private final g0 s;
public static final class a {
private a() {
}
public a(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
}
static final class b extends m implements Function0<List<? extends Certificate>> {
final com.microsoft.clarity.ts.g X;
final t Y;
final com.microsoft.clarity.ts.a Z;
b(com.microsoft.clarity.ts.g gVar, t tVar, com.microsoft.clarity.ts.a aVar) {
super(0);
this.X = gVar;
this.Y = tVar;
this.Z = aVar;
}
@Override
@NotNull
public final List<Certificate> invoke() {
com.microsoft.clarity.gt.c d = this.X.d();
Intrinsics.e(d);
return d.a(this.Y.d(), this.Z.l().i());
}
}
static final class c extends m implements Function0<List<? extends X509Certificate>> {
c() {
super(0);
}
@Override
@NotNull
public final List<X509Certificate> invoke() {
t tVar = f.this.e;
Intrinsics.e(tVar);
List<Certificate> d = tVar.d();
ArrayList arrayList = new ArrayList(n.t(d, 10));
for (Certificate certificate : d) {
if (certificate == null) {
throw new NullPointerException("null cannot be cast to non-null type java.security.cert.X509Certificate");
}
arrayList.add((X509Certificate) certificate);
}
return arrayList;
}
}
public static final class d extends d.AbstractC0015d {
final com.microsoft.clarity.ys.c E0;
final com.microsoft.clarity.jt.h F0;
final com.microsoft.clarity.jt.g G0;
d(com.microsoft.clarity.ys.c cVar, com.microsoft.clarity.jt.h hVar, com.microsoft.clarity.jt.g gVar, boolean z, com.microsoft.clarity.jt.h hVar2, com.microsoft.clarity.jt.g gVar2) {
super(z, hVar2, gVar2);
this.E0 = cVar;
this.F0 = hVar;
this.G0 = gVar;
}
@Override
public void close() {
this.E0.a(-1L, true, true, null);
}
}
public f(@NotNull h connectionPool, @NotNull g0 route) {
Intrinsics.checkNotNullParameter(connectionPool, "connectionPool");
Intrinsics.checkNotNullParameter(route, "route");
this.r = connectionPool;
this.s = route;
this.o = 1;
this.p = new ArrayList();
this.q = Long.MAX_VALUE;
}
private final boolean B(List<g0> list) {
if ((list instanceof Collection) && list.isEmpty()) {
return false;
}
for (g0 g0Var : list) {
if (g0Var.b().type() == Proxy.Type.DIRECT && this.s.b().type() == Proxy.Type.DIRECT && Intrinsics.c(this.s.d(), g0Var.d())) {
return true;
}
}
return false;
}
private final void F(int i) throws IOException {
Socket socket = this.d;
Intrinsics.e(socket);
com.microsoft.clarity.jt.h hVar = this.h;
Intrinsics.e(hVar);
com.microsoft.clarity.jt.g gVar = this.i;
Intrinsics.e(gVar);
socket.setSoTimeout(0);
com.microsoft.clarity.bt.f a2 = new f.b(true, com.microsoft.clarity.xs.e.h).m(socket, this.s.a().l().i(), hVar, gVar).k(this).l(i).a();
this.g = a2;
this.o = com.microsoft.clarity.bt.f.e1.a().d();
com.microsoft.clarity.bt.f.G1(a2, false, null, 3, null);
}
private final boolean G(v vVar) {
t tVar;
if (com.microsoft.clarity.us.c.h && !Thread.holdsLock(this)) {
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread currentThread = Thread.currentThread();
Intrinsics.checkNotNullExpressionValue(currentThread, "Thread.currentThread()");
sb.append(currentThread.getName());
sb.append(" MUST hold lock on ");
sb.append(this);
throw new AssertionError(sb.toString());
}
v l = this.s.a().l();
if (vVar.o() != l.o()) {
return false;
}
if (Intrinsics.c(vVar.i(), l.i())) {
return true;
}
if (this.k || (tVar = this.e) == null) {
return false;
}
Intrinsics.e(tVar);
return e(vVar, tVar);
}
private final boolean e(v vVar, t tVar) {
List<Certificate> d2 = tVar.d();
if (!d2.isEmpty()) {
com.microsoft.clarity.gt.d dVar = com.microsoft.clarity.gt.d.a;
String i = vVar.i();
Certificate certificate = d2.get(0);
if (certificate == null) {
throw new NullPointerException("null cannot be cast to non-null type java.security.cert.X509Certificate");
}
if (dVar.e(i, (X509Certificate) certificate)) {
return true;
}
}
return false;
}
private final void h(int i, int i2, com.microsoft.clarity.ts.e eVar, r rVar) throws IOException {
Socket socket;
int i3;
Proxy b2 = this.s.b();
com.microsoft.clarity.ts.a a2 = this.s.a();
Proxy.Type type = b2.type();
if (type != null && ((i3 = g.a[type.ordinal()]) == 1 || i3 == 2)) {
socket = a2.j().createSocket();
Intrinsics.e(socket);
} else {
socket = new Socket(b2);
}
this.c = socket;
rVar.j(eVar, this.s.d(), b2);
socket.setSoTimeout(i2);
try {
com.microsoft.clarity.dt.j.c.g().f(socket, this.s.d(), i);
try {
this.h = q.d(q.m(socket));
this.i = q.c(q.i(socket));
} catch (NullPointerException e) {
if (Intrinsics.c(e.getMessage(), "throw with null exception")) {
throw new IOException(e);
}
}
} catch (ConnectException e2) {
ConnectException connectException = new ConnectException("Failed to connect to " + this.s.d());
connectException.initCause(e2);
throw connectException;
}
}
private final void i(com.microsoft.clarity.ys.b bVar) throws IOException {
String h;
com.microsoft.clarity.ts.a a2 = this.s.a();
SSLSocketFactory k = a2.k();
SSLSocket sSLSocket = null;
try {
Intrinsics.e(k);
Socket createSocket = k.createSocket(this.c, a2.l().i(), a2.l().o(), true);
if (createSocket == null) {
throw new NullPointerException("null cannot be cast to non-null type javax.net.ssl.SSLSocket");
}
SSLSocket sSLSocket2 = (SSLSocket) createSocket;
try {
l a3 = bVar.a(sSLSocket2);
if (a3.h()) {
com.microsoft.clarity.dt.j.c.g().e(sSLSocket2, a2.l().i(), a2.f());
}
sSLSocket2.startHandshake();
SSLSession sslSocketSession = sSLSocket2.getSession();
t.a aVar = t.e;
Intrinsics.checkNotNullExpressionValue(sslSocketSession, "sslSocketSession");
t b2 = aVar.b(sslSocketSession);
HostnameVerifier e = a2.e();
Intrinsics.e(e);
if (e.verify(a2.l().i(), sslSocketSession)) {
com.microsoft.clarity.ts.g a4 = a2.a();
Intrinsics.e(a4);
this.e = new t(b2.e(), b2.a(), b2.c(), new b(a4, b2, a2));
a4.b(a2.l().i(), new c());
String h2 = a3.h() ? com.microsoft.clarity.dt.j.c.g().h(sSLSocket2) : null;
this.d = sSLSocket2;
this.h = q.d(q.m(sSLSocket2));
this.i = q.c(q.i(sSLSocket2));
this.f = h2 != null ? b0.J0.a(h2) : b0.HTTP_1_1;
com.microsoft.clarity.dt.j.c.g().b(sSLSocket2);
return;
}
List<Certificate> d2 = b2.d();
if (!(!d2.isEmpty())) {
throw new SSLPeerUnverifiedException("Hostname " + a2.l().i() + " not verified (no certificates)");
}
Certificate certificate = d2.get(0);
if (certificate == null) {
throw new NullPointerException("null cannot be cast to non-null type java.security.cert.X509Certificate");
}
X509Certificate x509Certificate = (X509Certificate) certificate;
StringBuilder sb = new StringBuilder();
sb.append("\n |Hostname ");
sb.append(a2.l().i());
sb.append(" not verified:\n | certificate: ");
sb.append(com.microsoft.clarity.ts.g.d.a(x509Certificate));
sb.append("\n | DN: ");
Principal subjectDN = x509Certificate.getSubjectDN();
Intrinsics.checkNotNullExpressionValue(subjectDN, "cert.subjectDN");
sb.append(subjectDN.getName());
sb.append("\n | subjectAltNames: ");
sb.append(com.microsoft.clarity.gt.d.a.a(x509Certificate));
sb.append("\n ");
h = kotlin.text.f.h(sb.toString(), null, 1, null);
throw new SSLPeerUnverifiedException(h);
} catch (Throwable th) {
th = th;
sSLSocket = sSLSocket2;
if (sSLSocket != null) {
com.microsoft.clarity.dt.j.c.g().b(sSLSocket);
}
if (sSLSocket != null) {
com.microsoft.clarity.us.c.k(sSLSocket);
}
throw th;
}
} catch (Throwable th2) {
th = th2;
}
}
private final void j(int i, int i2, int i3, com.microsoft.clarity.ts.e eVar, r rVar) throws IOException {
c0 l = l();
v l2 = l.l();
for (int i4 = 0; i4 < 21; i4++) {
h(i, i2, eVar, rVar);
l = k(i2, i3, l, l2);
if (l == null) {
return;
}
Socket socket = this.c;
if (socket != null) {
com.microsoft.clarity.us.c.k(socket);
}
this.c = null;
this.i = null;
this.h = null;
rVar.h(eVar, this.s.d(), this.s.b(), null);
}
}
private final c0 k(int i, int i2, c0 c0Var, v vVar) throws IOException {
boolean p;
String str = "CONNECT " + com.microsoft.clarity.us.c.P(vVar, true) + " HTTP/1.1";
while (true) {
com.microsoft.clarity.jt.h hVar = this.h;
Intrinsics.e(hVar);
com.microsoft.clarity.jt.g gVar = this.i;
Intrinsics.e(gVar);
com.microsoft.clarity.at.b bVar = new com.microsoft.clarity.at.b(null, this, hVar, gVar);
TimeUnit timeUnit = TimeUnit.MILLISECONDS;
hVar.timeout().g(i, timeUnit);
gVar.timeout().g(i2, timeUnit);
bVar.A(c0Var.e(), str);
bVar.a();
e0.a d2 = bVar.d(false);
Intrinsics.e(d2);
e0 c2 = d2.r(c0Var).c();
bVar.z(c2);
int z = c2.z();
if (z == 200) {
if (hVar.f().F() && gVar.f().F()) {
return null;
}
throw new IOException("TLS tunnel buffered too many bytes!");
}
if (z != 407) {
throw new IOException("Unexpected response code for CONNECT: " + c2.z());
}
c0 a2 = this.s.a().h().a(this.s, c2);
if (a2 == null) {
throw new IOException("Failed to authenticate with proxy");
}
p = kotlin.text.m.p("close", e0.g0(c2, "Connection", null, 2, null), true);
if (p) {
return a2;
}
c0Var = a2;
}
}
private final c0 l() throws IOException {
c0 b2 = new c0.a().l(this.s.a().l()).g("CONNECT", null).e("Host", com.microsoft.clarity.us.c.P(this.s.a().l(), true)).e("Proxy-Connection", "Keep-Alive").e("User-Agent", "okhttp/4.9.2").b();
c0 a2 = this.s.a().h().a(this.s, new e0.a().r(b2).p(b0.HTTP_1_1).g(407).m("Preemptive Authenticate").b(com.microsoft.clarity.us.c.c).s(-1L).q(-1L).j("Proxy-Authenticate", "OkHttp-Preemptive").c());
return a2 != null ? a2 : b2;
}
private final void m(com.microsoft.clarity.ys.b bVar, int i, com.microsoft.clarity.ts.e eVar, r rVar) throws IOException {
if (this.s.a().k() != null) {
rVar.C(eVar);
i(bVar);
rVar.B(eVar, this.e);
if (this.f == b0.HTTP_2) {
F(i);
return;
}
return;
}
List<b0> f = this.s.a().f();
b0 b0Var = b0.H2_PRIOR_KNOWLEDGE;
if (!f.contains(b0Var)) {
this.d = this.c;
this.f = b0.HTTP_1_1;
} else {
this.d = this.c;
this.f = b0Var;
F(i);
}
}
@NotNull
public g0 A() {
return this.s;
}
public final void C(long j) {
this.q = j;
}
public final void D(boolean z) {
this.j = z;
}
@NotNull
public Socket E() {
Socket socket = this.d;
Intrinsics.e(socket);
return socket;
}
public final synchronized void H(@NotNull e call, IOException iOException) {
Intrinsics.checkNotNullParameter(call, "call");
if (iOException instanceof com.microsoft.clarity.bt.n) {
if (((com.microsoft.clarity.bt.n) iOException).X == com.microsoft.clarity.bt.b.REFUSED_STREAM) {
int i = this.n + 1;
this.n = i;
if (i > 1) {
this.j = true;
this.l++;
}
} else if (((com.microsoft.clarity.bt.n) iOException).X != com.microsoft.clarity.bt.b.CANCEL || !call.isCanceled()) {
this.j = true;
this.l++;
}
} else if (!v() || (iOException instanceof com.microsoft.clarity.bt.a)) {
this.j = true;
if (this.m == 0) {
if (iOException != null) {
g(call.k(), this.s, iOException);
}
this.l++;
}
}
}
@Override
public synchronized void a(@NotNull com.microsoft.clarity.bt.f connection, @NotNull com.microsoft.clarity.bt.m settings) {
Intrinsics.checkNotNullParameter(connection, "connection");
Intrinsics.checkNotNullParameter(settings, "settings");
this.o = settings.d();
}
@Override
public void b(@NotNull com.microsoft.clarity.bt.i stream) throws IOException {
Intrinsics.checkNotNullParameter(stream, "stream");
stream.d(com.microsoft.clarity.bt.b.REFUSED_STREAM, null);
}
public final void d() {
Socket socket = this.c;
if (socket != null) {
com.microsoft.clarity.us.c.k(socket);
}
}
public final void f(int r17, int r18, int r19, int r20, boolean r21, @org.jetbrains.annotations.NotNull com.microsoft.clarity.ts.e r22, @org.jetbrains.annotations.NotNull com.microsoft.clarity.ts.r r23) {
throw new UnsupportedOperationException("Method not decompiled: com.microsoft.clarity.ys.f.f(int, int, int, int, boolean, com.microsoft.clarity.ts.e, com.microsoft.clarity.ts.r):void");
}
public final void g(@NotNull a0 client, @NotNull g0 failedRoute, @NotNull IOException failure) {
Intrinsics.checkNotNullParameter(client, "client");
Intrinsics.checkNotNullParameter(failedRoute, "failedRoute");
Intrinsics.checkNotNullParameter(failure, "failure");
if (failedRoute.b().type() != Proxy.Type.DIRECT) {
com.microsoft.clarity.ts.a a2 = failedRoute.a();
a2.i().connectFailed(a2.l().t(), failedRoute.b().address(), failure);
}
client.t().b(failedRoute);
}
@NotNull
public final List<Reference<e>> n() {
return this.p;
}
public final long o() {
return this.q;
}
public final boolean p() {
return this.j;
}
public final int q() {
return this.l;
}
public t r() {
return this.e;
}
public final synchronized void s() {
this.m++;
}
public final boolean t(@NotNull com.microsoft.clarity.ts.a address, List<g0> list) {
Intrinsics.checkNotNullParameter(address, "address");
if (com.microsoft.clarity.us.c.h && !Thread.holdsLock(this)) {
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread currentThread = Thread.currentThread();
Intrinsics.checkNotNullExpressionValue(currentThread, "Thread.currentThread()");
sb.append(currentThread.getName());
sb.append(" MUST hold lock on ");
sb.append(this);
throw new AssertionError(sb.toString());
}
if (this.p.size() >= this.o || this.j || !this.s.a().d(address)) {
return false;
}
if (Intrinsics.c(address.l().i(), A().a().l().i())) {
return true;
}
if (this.g == null || list == null || !B(list) || address.e() != com.microsoft.clarity.gt.d.a || !G(address.l())) {
return false;
}
try {
com.microsoft.clarity.ts.g a2 = address.a();
Intrinsics.e(a2);
String i = address.l().i();
t r = r();
Intrinsics.e(r);
a2.a(i, r.d());
return true;
} catch (SSLPeerUnverifiedException unused) {
return false;
}
}
@NotNull
public String toString() {
Object obj;
StringBuilder sb = new StringBuilder();
sb.append("Connection{");
sb.append(this.s.a().l().i());
sb.append(':');
sb.append(this.s.a().l().o());
sb.append(',');
sb.append(" proxy=");
sb.append(this.s.b());
sb.append(" hostAddress=");
sb.append(this.s.d());
sb.append(" cipherSuite=");
t tVar = this.e;
if (tVar == null || (obj = tVar.a()) == null) {
obj = "none";
}
sb.append(obj);
sb.append(" protocol=");
sb.append(this.f);
sb.append('}');
return sb.toString();
}
public final boolean u(boolean z) {
long j;
if (com.microsoft.clarity.us.c.h && Thread.holdsLock(this)) {
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread currentThread = Thread.currentThread();
Intrinsics.checkNotNullExpressionValue(currentThread, "Thread.currentThread()");
sb.append(currentThread.getName());
sb.append(" MUST NOT hold lock on ");
sb.append(this);
throw new AssertionError(sb.toString());
}
long nanoTime = System.nanoTime();
Socket socket = this.c;
Intrinsics.e(socket);
Socket socket2 = this.d;
Intrinsics.e(socket2);
com.microsoft.clarity.jt.h hVar = this.h;
Intrinsics.e(hVar);
if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) {
return false;
}
com.microsoft.clarity.bt.f fVar = this.g;
if (fVar != null) {
return fVar.s1(nanoTime);
}
synchronized (this) {
j = nanoTime - this.q;
}
if (j < 10000000000L || !z) {
return true;
}
return com.microsoft.clarity.us.c.D(socket2, hVar);
}
public final boolean v() {
return this.g != null;
}
@NotNull
public final com.microsoft.clarity.zs.d w(@NotNull a0 client, @NotNull com.microsoft.clarity.zs.g chain) throws SocketException {
Intrinsics.checkNotNullParameter(client, "client");
Intrinsics.checkNotNullParameter(chain, "chain");
Socket socket = this.d;
Intrinsics.e(socket);
com.microsoft.clarity.jt.h hVar = this.h;
Intrinsics.e(hVar);
com.microsoft.clarity.jt.g gVar = this.i;
Intrinsics.e(gVar);
com.microsoft.clarity.bt.f fVar = this.g;
if (fVar != null) {
return new com.microsoft.clarity.bt.g(client, this, chain, fVar);
}
socket.setSoTimeout(chain.j());
com.microsoft.clarity.jt.e0 timeout = hVar.timeout();
long g = chain.g();
TimeUnit timeUnit = TimeUnit.MILLISECONDS;
timeout.g(g, timeUnit);
gVar.timeout().g(chain.i(), timeUnit);
return new com.microsoft.clarity.at.b(client, this, hVar, gVar);
}
@NotNull
public final d.AbstractC0015d x(@NotNull com.microsoft.clarity.ys.c exchange) throws SocketException {
Intrinsics.checkNotNullParameter(exchange, "exchange");
Socket socket = this.d;
Intrinsics.e(socket);
com.microsoft.clarity.jt.h hVar = this.h;
Intrinsics.e(hVar);
com.microsoft.clarity.jt.g gVar = this.i;
Intrinsics.e(gVar);
socket.setSoTimeout(0);
z();
return new d(exchange, hVar, gVar, true, hVar, gVar);
}
public final synchronized void y() {
this.k = true;
}
public final synchronized void z() {
this.j = true;
}
}