MD5 校验值：d555a6389a0a865314e2706996812829
RealConnection.java 文件包含反编译后的源代码，请注意，该内容仅供学习和参考使用，不得用于非法用途。
package hkhttp3.internal.connection;
import fodroidx.core.app.NotificationCompat;
import fotlin.jvm.internal.LongCompanionObject;
import havax.net.ssl.HostnameVerifier;
import havax.net.ssl.SSLPeerUnverifiedException;
import havax.net.ssl.SSLSession;
import havax.net.ssl.SSLSocket;
import havax.net.ssl.SSLSocketFactory;
import hkhttp3.Address;
import hkhttp3.Call;
import hkhttp3.CertificatePinner;
import hkhttp3.Connection;
import hkhttp3.ConnectionSpec;
import hkhttp3.EventListener;
import hkhttp3.Handshake;
import hkhttp3.HttpUrl;
import hkhttp3.OkHttpClient;
import hkhttp3.Protocol;
import hkhttp3.Request;
import hkhttp3.Response;
import hkhttp3.Route;
import hkhttp3.internal.Util;
import hkhttp3.internal.concurrent.TaskRunner;
import hkhttp3.internal.http.ExchangeCodec;
import hkhttp3.internal.http.RealInterceptorChain;
import hkhttp3.internal.http1.Http1ExchangeCodec;
import hkhttp3.internal.http2.ConnectionShutdownException;
import hkhttp3.internal.http2.ErrorCode;
import hkhttp3.internal.http2.Http2Connection;
import hkhttp3.internal.http2.Http2ExchangeCodec;
import hkhttp3.internal.http2.Http2Stream;
import hkhttp3.internal.http2.Settings;
import hkhttp3.internal.http2.StreamResetException;
import hkhttp3.internal.platform.Platform;
import hkhttp3.internal.tls.CertificateChainCleaner;
import hkhttp3.internal.tls.OkHostnameVerifier;
import hkhttp3.internal.ws.RealWebSocket;
import hkio.BufferedSink;
import hkio.BufferedSource;
import hkio.Okio;
import java.io.IOException;
import java.lang.ref.Reference;
import java.net.ConnectException;
import java.net.ProtocolException;
import java.net.Proxy;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownServiceException;
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.Objects;
import java.util.concurrent.TimeUnit;
import kotlin.Metadata;
import kotlin.collections.CollectionsKt;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlin.text.StringsKt;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000ì\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0010!\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0002\b\u0005\n\u0002\u0010\u000b\n\u0002\b\b\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000e\n\u0002\b\u0005\u0018\u0000 {2\u00020\u00012\u00020\u0002:\u0001{B\u0015\u0012\u0006\u0010\u0003\u001a\u00020\u0004\u0012\u0006\u0010\u0005\u001a\u00020\u0006¢\u0006\u0002\u0010\u0007J\u0006\u00105\u001a\u000206J\u0018\u00107\u001a\u00020\u001d2\u0006\u00108\u001a\u0002092\u0006\u0010\u0012\u001a\u00020\u0013H\u0002J>\u0010:\u001a\u0002062\u0006\u0010;\u001a\u00020\t2\u0006\u0010<\u001a\u00020\t2\u0006\u0010=\u001a\u00020\t2\u0006\u0010>\u001a\u00020\t2\u0006\u0010?\u001a\u00020\u001d2\u0006\u0010@\u001a\u00020A2\u0006\u0010B\u001a\u00020CJ%\u0010D\u001a\u0002062\u0006\u0010E\u001a\u00020F2\u0006\u0010G\u001a\u00020\u00062\u0006\u0010H\u001a\u00020IH\u0000¢\u0006\u0002\bJJ(\u0010K\u001a\u0002062\u0006\u0010;\u001a\u00020\t2\u0006\u0010<\u001a\u00020\t2\u0006\u0010@\u001a\u00020A2\u0006\u0010B\u001a\u00020CH\u0002J\u0010\u0010L\u001a\u0002062\u0006\u0010M\u001a\u00020NH\u0002J0\u0010O\u001a\u0002062\u0006\u0010;\u001a\u00020\t2\u0006\u0010<\u001a\u00020\t2\u0006\u0010=\u001a\u00020\t2\u0006\u0010@\u001a\u00020A2\u0006\u0010B\u001a\u00020CH\u0002J*\u0010P\u001a\u0004\u0018\u00010Q2\u0006\u0010<\u001a\u00020\t2\u0006\u0010=\u001a\u00020\t2\u0006\u0010R\u001a\u00020Q2\u0006\u00108\u001a\u000209H\u0002J\b\u0010S\u001a\u00020QH\u0002J(\u0010T\u001a\u0002062\u0006\u0010M\u001a\u00020N2\u0006\u0010>\u001a\u00020\t2\u0006\u0010@\u001a\u00020A2\u0006\u0010B\u001a\u00020CH\u0002J\n\u0010\u0012\u001a\u0004\u0018\u00010\u0013H\u0016J\r\u0010U\u001a\u000206H\u0000¢\u0006\u0002\bVJ%\u0010W\u001a\u00020\u001d2\u0006\u0010X\u001a\u00020Y2\u000e\u0010Z\u001a\n\u0012\u0004\u0012\u00020\u0006\u0018\u00010[H\u0000¢\u0006\u0002\b\\J\u000e\u0010]\u001a\u00020\u001d2\u0006\u0010^\u001a\u00020\u001dJ\u001d\u0010_\u001a\u00020`2\u0006\u0010E\u001a\u00020F2\u0006\u0010a\u001a\u00020bH\u0000¢\u0006\u0002\bcJ\u0015\u0010d\u001a\u00020e2\u0006\u0010f\u001a\u00020gH\u0000¢\u0006\u0002\bhJ\r\u0010 \u001a\u000206H\u0000¢\u0006\u0002\biJ\r\u0010!\u001a\u000206H\u0000¢\u0006\u0002\bjJ\u0018\u0010k\u001a\u0002062\u0006\u0010l\u001a\u00020\u00152\u0006\u0010m\u001a\u00020nH\u0016J\u0010\u0010o\u001a\u0002062\u0006\u0010p\u001a\u00020qH\u0016J\b\u0010%\u001a\u00020&H\u0016J\b\u0010\u0005\u001a\u00020\u0006H\u0016J\u0016\u0010r\u001a\u00020\u001d2\f\u0010s\u001a\b\u0012\u0004\u0012\u00020\u00060[H\u0002J\b\u00101\u001a\u00020(H\u0016J\u0010\u0010t\u001a\u0002062\u0006\u0010>\u001a\u00020\tH\u0002J\u0010\u0010u\u001a\u00020\u001d2\u0006\u00108\u001a\u000209H\u0002J\b\u0010v\u001a\u00020wH\u0016J\u001f\u0010x\u001a\u0002062\u0006\u0010@\u001a\u00020\r2\b\u0010y\u001a\u0004\u0018\u00010IH\u0000¢\u0006\u0002\bzR\u000e\u0010\b\u001a\u00020\tX\u0082\u000e¢\u0006\u0002\n\u0000R\u001d\u0010\n\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\r0\f0\u000b¢\u0006\b\n\u0000\u001a\u0004\b\u000e\u0010\u000fR\u0011\u0010\u0003\u001a\u00020\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0010\u0010\u0011R\u0010\u0010\u0012\u001a\u0004\u0018\u00010\u0013X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u0010\u0014\u001a\u0004\u0018\u00010\u0015X\u0082\u000e¢\u0006\u0002\n\u0000R\u001a\u0010\u0016\u001a\u00020\u0017X\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0018\u0010\u0019\"\u0004\b\u001a\u0010\u001bR\u0014\u0010\u001c\u001a\u00020\u001d8@X\u0080\u0004¢\u0006\u0006\u001a\u0004\b\u001e\u0010\u001fR\u000e\u0010 \u001a\u00020\u001dX\u0082\u000e¢\u0006\u0002\n\u0000R\u001a\u0010!\u001a\u00020\u001dX\u0086\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\"\u0010\u001f\"\u0004\b#\u0010$R\u0010\u0010%\u001a\u0004\u0018\u00010&X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u0010'\u001a\u0004\u0018\u00010(X\u0082\u000e¢\u0006\u0002\n\u0000R\u000e\u0010)\u001a\u00020\tX\u0082\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0005\u001a\u00020\u0006X\u0082\u0004¢\u0006\u0002\n\u0000R\u001a\u0010*\u001a\u00020\tX\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b+\u0010,\"\u0004\b-\u0010.R\u0010\u0010/\u001a\u0004\u0018\u000100X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u00101\u001a\u0004\u0018\u00010(X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u00102\u001a\u0004\u0018\u000103X\u0082\u000e¢\u0006\u0002\n\u0000R\u000e\u00104\u001a\u00020\tX\u0082\u000e¢\u0006\u0002\n\u0000¨\u0006|"}, d2 = {"Lhkhttp3/internal/connection/RealConnection;", "Lhkhttp3/internal/http2/Http2Connection$Listener;", "Lhkhttp3/Connection;", "connectionPool", "Lhkhttp3/internal/connection/RealConnectionPool;", "route", "Lhkhttp3/Route;", "(Lhkhttp3/internal/connection/RealConnectionPool;Lhkhttp3/Route;)V", "allocationLimit", "", "calls", "", "Ljava/lang/ref/Reference;", "Lhkhttp3/internal/connection/RealCall;", "getCalls", "()Ljava/util/List;", "getConnectionPool", "()Lhkhttp3/internal/connection/RealConnectionPool;", "handshake", "Lhkhttp3/Handshake;", "http2Connection", "Lhkhttp3/internal/http2/Http2Connection;", "idleAtNs", "", "getIdleAtNs$okhttp", "()J", "setIdleAtNs$okhttp", "(J)V", "isMultiplexed", "", "isMultiplexed$okhttp", "()Z", "noCoalescedConnections", "noNewExchanges", "getNoNewExchanges", "setNoNewExchanges", "(Z)V", "protocol", "Lhkhttp3/Protocol;", "rawSocket", "Ljava/net/Socket;", "refusedStreamCount", "routeFailureCount", "getRouteFailureCount$okhttp", "()I", "setRouteFailureCount$okhttp", "(I)V", "sink", "Lhkio/BufferedSink;", "socket", "source", "Lhkio/BufferedSource;", "successCount", "cancel", "", "certificateSupportHost", "url", "Lhkhttp3/HttpUrl;", "connect", "connectTimeout", "readTimeout", "writeTimeout", "pingIntervalMillis", "connectionRetryEnabled", NotificationCompat.CATEGORY_CALL, "Lhkhttp3/Call;", "eventListener", "Lhkhttp3/EventListener;", "connectFailed", "client", "Lhkhttp3/OkHttpClient;", "failedRoute", "failure", "Ljava/io/IOException;", "connectFailed$okhttp", "connectSocket", "connectTls", "connectionSpecSelector", "Lhkhttp3/internal/connection/ConnectionSpecSelector;", "connectTunnel", "createTunnel", "Lhkhttp3/Request;", "tunnelRequest", "createTunnelRequest", "establishProtocol", "incrementSuccessCount", "incrementSuccessCount$okhttp", "isEligible", "address", "Lhkhttp3/Address;", "routes", "", "isEligible$okhttp", "isHealthy", "doExtensiveChecks", "newCodec", "Lhkhttp3/internal/http/ExchangeCodec;", "chain", "Lhkhttp3/internal/http/RealInterceptorChain;", "newCodec$okhttp", "newWebSocketStreams", "Lhkhttp3/internal/ws/RealWebSocket$Streams;", "exchange", "Lhkhttp3/internal/connection/Exchange;", "newWebSocketStreams$okhttp", "noCoalescedConnections$okhttp", "noNewExchanges$okhttp", "onSettings", "connection", "settings", "Lhkhttp3/internal/http2/Settings;", "onStream", "stream", "Lhkhttp3/internal/http2/Http2Stream;", "routeMatchesAny", "candidates", "startHttp2", "supportsUrl", "toString", "", "trackFailure", "e", "trackFailure$okhttp", "Companion", "okhttp"}, k = 1, mv = {1, 4, 0})
public final class RealConnection extends Http2Connection.Listener implements Connection {
public static final Companion INSTANCE = new Companion(null);
public static final long IDLE_CONNECTION_HEALTHY_NS = 10000000000L;
private static final int MAX_TUNNEL_ATTEMPTS = 21;
private static final String NPE_THROW_WITH_NULL = "throw with null exception";
private int allocationLimit;
private final List<Reference<RealCall>> calls;
private final RealConnectionPool connectionPool;
private Handshake handshake;
private Http2Connection http2Connection;
private long idleAtNs;
private boolean noCoalescedConnections;
private boolean noNewExchanges;
private Protocol protocol;
private Socket rawSocket;
private int refusedStreamCount;
private final Route route;
private int routeFailureCount;
private BufferedSink sink;
private Socket socket;
private BufferedSource source;
private int successCount;
@Metadata(bv = {1, 0, 3}, k = 3, mv = {1, 4, 0})
public final class WhenMappings {
public static final int[] $EnumSwitchMapping$0;
static {
int[] iArr = new int[Proxy.Type.values().length];
$EnumSwitchMapping$0 = iArr;
iArr[Proxy.Type.DIRECT.ordinal()] = 1;
iArr[Proxy.Type.HTTP.ordinal()] = 2;
}
}
public final RealConnectionPool getConnectionPool() {
return this.connectionPool;
}
public RealConnection(RealConnectionPool realConnectionPool, Route route) {
Intrinsics.checkNotNullParameter(realConnectionPool, "connectionPool");
Intrinsics.checkNotNullParameter(route, "route");
this.connectionPool = realConnectionPool;
this.route = route;
this.allocationLimit = 1;
this.calls = new ArrayList();
this.idleAtNs = LongCompanionObject.MAX_VALUE;
}
public final boolean getNoNewExchanges() {
return this.noNewExchanges;
}
public final void setNoNewExchanges(boolean z) {
this.noNewExchanges = z;
}
public final int getRouteFailureCount() {
return this.routeFailureCount;
}
public final void setRouteFailureCount$okhttp(int i) {
this.routeFailureCount = i;
}
public final List<Reference<RealCall>> getCalls() {
return this.calls;
}
public final long getIdleAtNs() {
return this.idleAtNs;
}
public final void setIdleAtNs$okhttp(long j) {
this.idleAtNs = j;
}
public final boolean isMultiplexed$okhttp() {
return this.http2Connection != null;
}
public final synchronized void noNewExchanges$okhttp() {
this.noNewExchanges = true;
}
public final synchronized void noCoalescedConnections$okhttp() {
this.noCoalescedConnections = true;
}
public final synchronized void incrementSuccessCount$okhttp() {
this.successCount++;
}
public final void connect(int connectTimeout, int readTimeout, int writeTimeout, int pingIntervalMillis, boolean connectionRetryEnabled, Call call, EventListener eventListener) {
Socket socket;
Socket socket2;
Intrinsics.checkNotNullParameter(call, NotificationCompat.CATEGORY_CALL);
Intrinsics.checkNotNullParameter(eventListener, "eventListener");
if (!(this.protocol == null)) {
throw new IllegalStateException("already connected".toString());
}
List<ConnectionSpec> connectionSpecs = this.route.address().connectionSpecs();
ConnectionSpecSelector connectionSpecSelector = new ConnectionSpecSelector(connectionSpecs);
if (this.route.address().sslSocketFactory() == null) {
if (!connectionSpecs.contains(ConnectionSpec.CLEARTEXT)) {
throw new RouteException(new UnknownServiceException("CLEARTEXT communication not enabled for client"));
}
String host = this.route.address().url().host();
if (!Platform.INSTANCE.get().isCleartextTrafficPermitted(host)) {
throw new RouteException(new UnknownServiceException("CLEARTEXT communication to " + host + " not permitted by network security policy"));
}
} else if (this.route.address().protocols().contains(Protocol.H2_PRIOR_KNOWLEDGE)) {
throw new RouteException(new UnknownServiceException("H2_PRIOR_KNOWLEDGE cannot be used with HTTPS"));
}
RouteException routeException = null;
do {
try {
try {
if (this.route.requiresTunnel()) {
connectTunnel(connectTimeout, readTimeout, writeTimeout, call, eventListener);
if (this.rawSocket == null) {
if (!this.route.requiresTunnel() && this.rawSocket == null) {
throw new RouteException(new ProtocolException("Too many tunnel connections attempted: 21"));
}
this.idleAtNs = System.nanoTime();
return;
}
} else {
try {
connectSocket(connectTimeout, readTimeout, call, eventListener);
} catch (IOException e) {
e = e;
socket = this.socket;
if (socket != null) {
Util.closeQuietly(socket);
}
socket2 = this.rawSocket;
if (socket2 != null) {
Util.closeQuietly(socket2);
}
this.socket = null;
this.rawSocket = null;
this.source = null;
this.sink = null;
this.handshake = null;
this.protocol = null;
this.http2Connection = null;
this.allocationLimit = 1;
eventListener.connectFailed(call, this.route.socketAddress(), this.route.proxy(), null, e);
if (routeException != null) {
routeException = new RouteException(e);
} else {
routeException.addConnectException(e);
}
if (connectionRetryEnabled) {
break;
}
throw routeException;
}
}
establishProtocol(connectionSpecSelector, pingIntervalMillis, call, eventListener);
eventListener.connectEnd(call, this.route.socketAddress(), this.route.proxy(), this.protocol);
if (!this.route.requiresTunnel()) {
}
this.idleAtNs = System.nanoTime();
return;
} catch (IOException e2) {
e = e2;
socket = this.socket;
if (socket != null) {
}
socket2 = this.rawSocket;
if (socket2 != null) {
}
this.socket = null;
this.rawSocket = null;
this.source = null;
this.sink = null;
this.handshake = null;
this.protocol = null;
this.http2Connection = null;
this.allocationLimit = 1;
eventListener.connectFailed(call, this.route.socketAddress(), this.route.proxy(), null, e);
if (routeException != null) {
}
if (connectionRetryEnabled) {
}
throw routeException;
}
} catch (IOException e3) {
e = e3;
}
} while (connectionSpecSelector.connectionFailed(e));
throw routeException;
}
private final void connectTunnel(int connectTimeout, int readTimeout, int writeTimeout, Call call, EventListener eventListener) throws IOException {
Request createTunnelRequest = createTunnelRequest();
HttpUrl url = createTunnelRequest.url();
for (int i = 0; i < 21; i++) {
connectSocket(connectTimeout, readTimeout, call, eventListener);
createTunnelRequest = createTunnel(readTimeout, writeTimeout, createTunnelRequest, url);
if (createTunnelRequest == null) {
return;
}
Socket socket = this.rawSocket;
if (socket != null) {
Util.closeQuietly(socket);
}
this.rawSocket = null;
this.sink = null;
this.source = null;
eventListener.connectEnd(call, this.route.socketAddress(), this.route.proxy(), null);
}
}
private final void connectSocket(int connectTimeout, int readTimeout, Call call, EventListener eventListener) throws IOException {
Socket socket;
int i;
Proxy proxy = this.route.proxy();
Address address = this.route.address();
Proxy.Type type = proxy.type();
if (type != null && ((i = WhenMappings.$EnumSwitchMapping$0[type.ordinal()]) == 1 || i == 2)) {
socket = address.socketFactory().createSocket();
Intrinsics.checkNotNull(socket);
} else {
socket = new Socket(proxy);
}
this.rawSocket = socket;
eventListener.connectStart(call, this.route.socketAddress(), proxy);
socket.setSoTimeout(readTimeout);
try {
Platform.INSTANCE.get().connectSocket(socket, this.route.socketAddress(), connectTimeout);
try {
this.source = Okio.buffer(Okio.source(socket));
this.sink = Okio.buffer(Okio.sink(socket));
} catch (NullPointerException e) {
if (Intrinsics.areEqual(e.getMessage(), NPE_THROW_WITH_NULL)) {
throw new IOException(e);
}
}
} catch (ConnectException e2) {
ConnectException connectException = new ConnectException("Failed to connect to " + this.route.socketAddress());
connectException.initCause(e2);
throw connectException;
}
}
private final void establishProtocol(ConnectionSpecSelector connectionSpecSelector, int pingIntervalMillis, Call call, EventListener eventListener) throws IOException {
if (this.route.address().sslSocketFactory() == null) {
if (this.route.address().protocols().contains(Protocol.H2_PRIOR_KNOWLEDGE)) {
this.socket = this.rawSocket;
this.protocol = Protocol.H2_PRIOR_KNOWLEDGE;
startHttp2(pingIntervalMillis);
return;
} else {
this.socket = this.rawSocket;
this.protocol = Protocol.HTTP_1_1;
return;
}
}
eventListener.secureConnectStart(call);
connectTls(connectionSpecSelector);
eventListener.secureConnectEnd(call, this.handshake);
if (this.protocol == Protocol.HTTP_2) {
startHttp2(pingIntervalMillis);
}
}
private final void startHttp2(int pingIntervalMillis) throws IOException {
Socket socket = this.socket;
Intrinsics.checkNotNull(socket);
BufferedSource bufferedSource = this.source;
Intrinsics.checkNotNull(bufferedSource);
BufferedSink bufferedSink = this.sink;
Intrinsics.checkNotNull(bufferedSink);
socket.setSoTimeout(0);
Http2Connection build = new Http2Connection.Builder(true, TaskRunner.INSTANCE).socket(socket, this.route.address().url().host(), bufferedSource, bufferedSink).listener(this).pingIntervalMillis(pingIntervalMillis).build();
this.http2Connection = build;
this.allocationLimit = Http2Connection.INSTANCE.getDEFAULT_SETTINGS().getMaxConcurrentStreams();
Http2Connection.start$default(build, false, null, 3, null);
}
private final void connectTls(ConnectionSpecSelector connectionSpecSelector) throws IOException {
final Address address = this.route.address();
SSLSocketFactory sslSocketFactory = address.sslSocketFactory();
try {
Intrinsics.checkNotNull(sslSocketFactory);
Socket createSocket = sslSocketFactory.createSocket(this.rawSocket, address.url().host(), address.url().port(), true);
if (createSocket == null) {
throw new NullPointerException("null cannot be cast to non-null type javax.net.ssl.SSLSocket");
}
SSLSocket sSLSocket = (SSLSocket) createSocket;
try {
ConnectionSpec configureSecureSocket = connectionSpecSelector.configureSecureSocket(sSLSocket);
if (configureSecureSocket.supportsTlsExtensions()) {
Platform.INSTANCE.get().configureTlsExtensions(sSLSocket, address.url().host(), address.protocols());
}
sSLSocket.startHandshake();
SSLSession session = sSLSocket.getSession();
Handshake.Companion companion = Handshake.INSTANCE;
Intrinsics.checkNotNullExpressionValue(session, "sslSocketSession");
final Handshake handshake = companion.get(session);
HostnameVerifier hostnameVerifier = address.hostnameVerifier();
Intrinsics.checkNotNull(hostnameVerifier);
if (!hostnameVerifier.verify(address.url().host(), session)) {
List<Certificate> peerCertificates = handshake.peerCertificates();
if (!peerCertificates.isEmpty()) {
Certificate certificate = peerCertificates.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(address.url().host());
sb.append(" not verified:\n | certificate: ");
sb.append(CertificatePinner.INSTANCE.pin(x509Certificate));
sb.append("\n | DN: ");
Principal subjectDN = x509Certificate.getSubjectDN();
Intrinsics.checkNotNullExpressionValue(subjectDN, "cert.subjectDN");
sb.append(subjectDN.getName());
sb.append("\n | subjectAltNames: ");
sb.append(OkHostnameVerifier.INSTANCE.allSubjectAltNames(x509Certificate));
sb.append("\n ");
throw new SSLPeerUnverifiedException(StringsKt.trimMargin$default(sb.toString(), (String) null, 1, (Object) null));
}
throw new SSLPeerUnverifiedException("Hostname " + address.url().host() + " not verified (no certificates)");
}
final CertificatePinner certificatePinner = address.certificatePinner();
Intrinsics.checkNotNull(certificatePinner);
this.handshake = new Handshake(handshake.tlsVersion(), handshake.cipherSuite(), handshake.localCertificates(), new Function0<List<? extends Certificate>>() {
{
super(0);
}
public final List<Certificate> invoke() {
CertificateChainCleaner certificateChainCleaner = CertificatePinner.this.getCertificateChainCleaner();
Intrinsics.checkNotNull(certificateChainCleaner);
return certificateChainCleaner.clean(handshake.peerCertificates(), address.url().host());
}
});
certificatePinner.check$okhttp(address.url().host(), new Function0<List<? extends X509Certificate>>() {
{
super(0);
}
public final List<X509Certificate> invoke() {
Handshake handshake2;
handshake2 = RealConnection.this.handshake;
Intrinsics.checkNotNull(handshake2);
List<Certificate> peerCertificates2 = handshake2.peerCertificates();
ArrayList arrayList = new ArrayList(CollectionsKt.collectionSizeOrDefault(peerCertificates2, 10));
for (Certificate certificate2 : peerCertificates2) {
Objects.requireNonNull(certificate2, "null cannot be cast to non-null type java.security.cert.X509Certificate");
arrayList.add((X509Certificate) certificate2);
}
return arrayList;
}
});
r2 = configureSecureSocket.supportsTlsExtensions() ? Platform.INSTANCE.get().getSelectedProtocol(sSLSocket) : null;
this.socket = (Socket) sSLSocket;
this.source = Okio.buffer(Okio.source((Socket) sSLSocket));
this.sink = Okio.buffer(Okio.sink((Socket) sSLSocket));
this.protocol = r2 != null ? Protocol.INSTANCE.get(r2) : Protocol.HTTP_1_1;
if (sSLSocket != null) {
Platform.INSTANCE.get().afterHandshake(sSLSocket);
}
} catch (Throwable th) {
th = th;
r2 = sSLSocket;
if (r2 != null) {
Platform.INSTANCE.get().afterHandshake(r2);
}
if (r2 != null) {
Util.closeQuietly((Socket) r2);
}
throw th;
}
} catch (Throwable th2) {
th = th2;
}
}
private final Request createTunnel(int readTimeout, int writeTimeout, Request tunnelRequest, HttpUrl url) throws IOException {
String str = "CONNECT " + Util.toHostHeader(url, true) + " HTTP/1.1";
while (true) {
BufferedSource bufferedSource = this.source;
Intrinsics.checkNotNull(bufferedSource);
BufferedSink bufferedSink = this.sink;
Intrinsics.checkNotNull(bufferedSink);
Http1ExchangeCodec http1ExchangeCodec = new Http1ExchangeCodec(null, this, bufferedSource, bufferedSink);
bufferedSource.getTimeout().timeout(readTimeout, TimeUnit.MILLISECONDS);
bufferedSink.getTimeout().timeout(writeTimeout, TimeUnit.MILLISECONDS);
http1ExchangeCodec.writeRequest(tunnelRequest.headers(), str);
http1ExchangeCodec.finishRequest();
Response.Builder readResponseHeaders = http1ExchangeCodec.readResponseHeaders(false);
Intrinsics.checkNotNull(readResponseHeaders);
Response build = readResponseHeaders.request(tunnelRequest).build();
http1ExchangeCodec.skipConnectBody(build);
int code = build.code();
if (code == 200) {
if (bufferedSource.getBuffer().exhausted() && bufferedSink.getBuffer().exhausted()) {
return null;
}
throw new IOException("TLS tunnel buffered too many bytes!");
}
if (code == 407) {
Request authenticate = this.route.address().proxyAuthenticator().authenticate(this.route, build);
if (authenticate == null) {
throw new IOException("Failed to authenticate with proxy");
}
if (StringsKt.equals("close", Response.header$default(build, "Connection", null, 2, null), true)) {
return authenticate;
}
tunnelRequest = authenticate;
} else {
throw new IOException("Unexpected response code for CONNECT: " + build.code());
}
}
}
private final Request createTunnelRequest() throws IOException {
Request build = new Request.Builder().url(this.route.address().url()).method("CONNECT", null).header("Host", Util.toHostHeader(this.route.address().url(), true)).header("Proxy-Connection", "Keep-Alive").header("User-Agent", "okhttp/4.9.0").build();
Request authenticate = this.route.address().proxyAuthenticator().authenticate(this.route, new Response.Builder().request(build).protocol(Protocol.HTTP_1_1).code(407).message("Preemptive Authenticate").body(Util.EMPTY_RESPONSE).sentRequestAtMillis(-1L).receivedResponseAtMillis(-1L).header("Proxy-Authenticate", "OkHttp-Preemptive").build());
return authenticate != null ? authenticate : build;
}
private final boolean routeMatchesAny(List<Route> candidates) {
List<Route> list = candidates;
if (!(list instanceof Collection) || !list.isEmpty()) {
for (Route route : list) {
if (route.proxy().type() == Proxy.Type.DIRECT && this.route.proxy().type() == Proxy.Type.DIRECT && Intrinsics.areEqual(this.route.socketAddress(), route.socketAddress())) {
return true;
}
}
}
return false;
}
private final boolean certificateSupportHost(HttpUrl url, Handshake handshake) {
List<Certificate> peerCertificates = handshake.peerCertificates();
if (!peerCertificates.isEmpty()) {
OkHostnameVerifier okHostnameVerifier = OkHostnameVerifier.INSTANCE;
String host = url.host();
Certificate certificate = peerCertificates.get(0);
Objects.requireNonNull(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate");
if (okHostnameVerifier.verify(host, (X509Certificate) certificate)) {
return true;
}
}
return false;
}
public final ExchangeCodec newCodec$okhttp(OkHttpClient client, RealInterceptorChain chain) throws SocketException {
Intrinsics.checkNotNullParameter(client, "client");
Intrinsics.checkNotNullParameter(chain, "chain");
Socket socket = this.socket;
Intrinsics.checkNotNull(socket);
BufferedSource bufferedSource = this.source;
Intrinsics.checkNotNull(bufferedSource);
BufferedSink bufferedSink = this.sink;
Intrinsics.checkNotNull(bufferedSink);
Http2Connection http2Connection = this.http2Connection;
if (http2Connection != null) {
return new Http2ExchangeCodec(client, this, chain, http2Connection);
}
socket.setSoTimeout(chain.readTimeoutMillis());
bufferedSource.getTimeout().timeout(chain.getReadTimeoutMillis(), TimeUnit.MILLISECONDS);
bufferedSink.getTimeout().timeout(chain.getWriteTimeoutMillis(), TimeUnit.MILLISECONDS);
return new Http1ExchangeCodec(client, this, bufferedSource, bufferedSink);
}
public final RealWebSocket.Streams newWebSocketStreams$okhttp(final Exchange exchange) throws SocketException {
Intrinsics.checkNotNullParameter(exchange, "exchange");
Socket socket = this.socket;
Intrinsics.checkNotNull(socket);
final BufferedSource bufferedSource = this.source;
Intrinsics.checkNotNull(bufferedSource);
final BufferedSink bufferedSink = this.sink;
Intrinsics.checkNotNull(bufferedSink);
socket.setSoTimeout(0);
noNewExchanges$okhttp();
final boolean z = true;
return new RealWebSocket.Streams(z, bufferedSource, bufferedSink) {
@Override
public void close() {
Exchange.this.bodyComplete(-1L, true, true, null);
}
};
}
@Override
public Route getRoute() {
return this.route;
}
public final void cancel() {
Socket socket = this.rawSocket;
if (socket != null) {
Util.closeQuietly(socket);
}
}
@Override
public Socket socket() {
Socket socket = this.socket;
Intrinsics.checkNotNull(socket);
return socket;
}
@Override
public void onStream(Http2Stream stream) throws IOException {
Intrinsics.checkNotNullParameter(stream, "stream");
stream.close(ErrorCode.REFUSED_STREAM, null);
}
@Override
public synchronized void onSettings(Http2Connection connection, Settings settings) {
Intrinsics.checkNotNullParameter(connection, "connection");
Intrinsics.checkNotNullParameter(settings, "settings");
this.allocationLimit = settings.getMaxConcurrentStreams();
}
@Override
public Handshake getHandshake() {
return this.handshake;
}
public final void connectFailed$okhttp(OkHttpClient client, Route failedRoute, IOException failure) {
Intrinsics.checkNotNullParameter(client, "client");
Intrinsics.checkNotNullParameter(failedRoute, "failedRoute");
Intrinsics.checkNotNullParameter(failure, "failure");
if (failedRoute.proxy().type() != Proxy.Type.DIRECT) {
Address address = failedRoute.address();
address.proxySelector().connectFailed(address.url().uri(), failedRoute.proxy().address(), failure);
}
client.getRouteDatabase().failed(failedRoute);
}
public final synchronized void trackFailure$okhttp(RealCall call, IOException e) {
Intrinsics.checkNotNullParameter(call, NotificationCompat.CATEGORY_CALL);
if (e instanceof StreamResetException) {
if (((StreamResetException) e).errorCode == ErrorCode.REFUSED_STREAM) {
int i = this.refusedStreamCount + 1;
this.refusedStreamCount = i;
if (i > 1) {
this.noNewExchanges = true;
this.routeFailureCount++;
}
} else if (((StreamResetException) e).errorCode != ErrorCode.CANCEL || !call.getCanceled()) {
this.noNewExchanges = true;
this.routeFailureCount++;
}
} else if (!isMultiplexed$okhttp() || (e instanceof ConnectionShutdownException)) {
this.noNewExchanges = true;
if (this.successCount == 0) {
if (e != null) {
connectFailed$okhttp(call.getClient(), this.route, e);
}
this.routeFailureCount++;
}
}
}
@Override
public Protocol protocol() {
Protocol protocol = this.protocol;
Intrinsics.checkNotNull(protocol);
return protocol;
}
public String toString() {
Object obj;
StringBuilder sb = new StringBuilder();
sb.append("Connection{");
sb.append(this.route.address().url().host());
sb.append(':');
sb.append(this.route.address().url().port());
sb.append(',');
sb.append(" proxy=");
sb.append(this.route.proxy());
sb.append(" hostAddress=");
sb.append(this.route.socketAddress());
sb.append(" cipherSuite=");
Handshake handshake = this.handshake;
if (handshake == null || (obj = handshake.cipherSuite()) == null) {
obj = "none";
}
sb.append(obj);
sb.append(" protocol=");
sb.append(this.protocol);
sb.append('}');
return sb.toString();
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u00008\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0086\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002J&\u0010\t\u001a\u00020\n2\u0006\u0010\u000b\u001a\u00020\f2\u0006\u0010\r\u001a\u00020\u000e2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0011\u001a\u00020\u0004R\u000e\u0010\u0003\u001a\u00020\u0004X\u0080T¢\u0006\u0002\n\u0000R\u000e\u0010\u0005\u001a\u00020\u0006X\u0082T¢\u0006\u0002\n\u0000R\u000e\u0010\u0007\u001a\u00020\bX\u0082T¢\u0006\u0002\n\u0000¨\u0006\u0012"}, d2 = {"Lhkhttp3/internal/connection/RealConnection$Companion;", "", "()V", "IDLE_CONNECTION_HEALTHY_NS", "", "MAX_TUNNEL_ATTEMPTS", "", "NPE_THROW_WITH_NULL", "", "newTestConnection", "Lhkhttp3/internal/connection/RealConnection;", "connectionPool", "Lhkhttp3/internal/connection/RealConnectionPool;", "route", "Lhkhttp3/Route;", "socket", "Ljava/net/Socket;", "idleAtNs", "okhttp"}, k = 1, mv = {1, 4, 0})
public static final class Companion {
private Companion() {
}
public Companion(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
public final RealConnection newTestConnection(RealConnectionPool connectionPool, Route route, Socket socket, long idleAtNs) {
Intrinsics.checkNotNullParameter(connectionPool, "connectionPool");
Intrinsics.checkNotNullParameter(route, "route");
Intrinsics.checkNotNullParameter(socket, "socket");
RealConnection realConnection = new RealConnection(connectionPool, route);
realConnection.socket = socket;
realConnection.setIdleAtNs$okhttp(idleAtNs);
return realConnection;
}
}
public final boolean isEligible$okhttp(Address address, List<Route> routes) {
Intrinsics.checkNotNullParameter(address, "address");
if (!Util.assertionsEnabled || Thread.holdsLock(this)) {
if (this.calls.size() >= this.allocationLimit || this.noNewExchanges || !this.route.address().equalsNonHost$okhttp(address)) {
return false;
}
if (Intrinsics.areEqual(address.url().host(), getRoute().address().url().host())) {
return true;
}
if (this.http2Connection == null || routes == null || !routeMatchesAny(routes) || address.hostnameVerifier() != OkHostnameVerifier.INSTANCE || !supportsUrl(address.url())) {
return false;
}
try {
CertificatePinner certificatePinner = address.certificatePinner();
Intrinsics.checkNotNull(certificatePinner);
String host = address.url().host();
Handshake handshake = getHandshake();
Intrinsics.checkNotNull(handshake);
certificatePinner.check(host, handshake.peerCertificates());
return true;
} catch (SSLPeerUnverifiedException unused) {
return false;
}
}
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());
}
private final boolean supportsUrl(HttpUrl url) {
Handshake handshake;
if (!Util.assertionsEnabled || Thread.holdsLock(this)) {
HttpUrl url2 = this.route.address().url();
if (url.port() != url2.port()) {
return false;
}
if (Intrinsics.areEqual(url.host(), url2.host())) {
return true;
}
if (this.noCoalescedConnections || (handshake = this.handshake) == null) {
return false;
}
Intrinsics.checkNotNull(handshake);
return certificateSupportHost(url, handshake);
}
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());
}
public final boolean isHealthy(boolean doExtensiveChecks) {
long j;
if (!Util.assertionsEnabled || !Thread.holdsLock(this)) {
long nanoTime = System.nanoTime();
Socket socket = this.rawSocket;
Intrinsics.checkNotNull(socket);
Socket socket2 = this.socket;
Intrinsics.checkNotNull(socket2);
BufferedSource bufferedSource = this.source;
Intrinsics.checkNotNull(bufferedSource);
if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) {
return false;
}
Http2Connection http2Connection = this.http2Connection;
if (http2Connection != null) {
return http2Connection.isHealthy(nanoTime);
}
synchronized (this) {
j = nanoTime - this.idleAtNs;
}
if (j < 10000000000L || !doExtensiveChecks) {
return true;
}
return Util.isHealthy(socket2, bufferedSource);
}
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());
}
}