package okhttp3.internal.connection; import androidx.core.app.NotificationCompat; import com.home.db.GroupDevice; 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.SSLPeerUnverifiedException; import kotlin.Metadata; import kotlin.TypeCastException; import kotlin.Unit; import kotlin.jvm.internal.DefaultConstructorMarker; import kotlin.jvm.internal.Intrinsics; import kotlin.jvm.internal.LongCompanionObject; import kotlin.text.StringsKt; import okhttp3.Address; import okhttp3.Call; import okhttp3.CertificatePinner; import okhttp3.Connection; import okhttp3.EventListener; import okhttp3.Handshake; import okhttp3.HttpUrl; import okhttp3.OkHttpClient; import okhttp3.Protocol; import okhttp3.Request; import okhttp3.Response; import okhttp3.Route; import okhttp3.internal.Util; import okhttp3.internal.Version; import okhttp3.internal.concurrent.TaskRunner; import okhttp3.internal.http.ExchangeCodec; import okhttp3.internal.http.RealInterceptorChain; import okhttp3.internal.http1.Http1ExchangeCodec; import okhttp3.internal.http2.ConnectionShutdownException; import okhttp3.internal.http2.ErrorCode; import okhttp3.internal.http2.Http2Connection; import okhttp3.internal.http2.Http2ExchangeCodec; import okhttp3.internal.http2.Http2Stream; import okhttp3.internal.http2.Settings; import okhttp3.internal.http2.StreamResetException; import okhttp3.internal.platform.Platform; import okhttp3.internal.tls.OkHostnameVerifier; import okhttp3.internal.ws.RealWebSocket; import okio.BufferedSink; import okio.BufferedSource; import okio.Okio; import org.apache.http.HttpStatus; import org.apache.http.protocol.HTTP; /* compiled from: RealConnection.kt */ @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\u0007\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\u0004\n\u0002\u0010\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\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\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\u0004\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 w2\u00020\u00012\u00020\u0002:\u0001wB\u0015\u0012\u0006\u0010\u0003\u001a\u00020\u0004\u0012\u0006\u0010\u0005\u001a\u00020\u0006¢\u0006\u0002\u0010\u0007J\u0006\u00106\u001a\u000207J>\u00108\u001a\u0002072\u0006\u00109\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\u00020?2\u0006\u0010@\u001a\u00020AJ%\u0010B\u001a\u0002072\u0006\u0010C\u001a\u00020D2\u0006\u0010E\u001a\u00020\u00062\u0006\u0010F\u001a\u00020GH\u0000¢\u0006\u0002\bHJ(\u0010I\u001a\u0002072\u0006\u00109\u001a\u00020\t2\u0006\u0010:\u001a\u00020\t2\u0006\u0010>\u001a\u00020?2\u0006\u0010@\u001a\u00020AH\u0002J\u0010\u0010J\u001a\u0002072\u0006\u0010K\u001a\u00020LH\u0002J0\u0010M\u001a\u0002072\u0006\u00109\u001a\u00020\t2\u0006\u0010:\u001a\u00020\t2\u0006\u0010;\u001a\u00020\t2\u0006\u0010>\u001a\u00020?2\u0006\u0010@\u001a\u00020AH\u0002J*\u0010N\u001a\u0004\u0018\u00010O2\u0006\u0010:\u001a\u00020\t2\u0006\u0010;\u001a\u00020\t2\u0006\u0010P\u001a\u00020O2\u0006\u0010Q\u001a\u00020RH\u0002J\b\u0010S\u001a\u00020OH\u0002J(\u0010T\u001a\u0002072\u0006\u0010K\u001a\u00020L2\u0006\u0010<\u001a\u00020\t2\u0006\u0010>\u001a\u00020?2\u0006\u0010@\u001a\u00020AH\u0002J\n\u0010\u0012\u001a\u0004\u0018\u00010\u0013H\u0016J%\u0010U\u001a\u00020\u001d2\u0006\u0010V\u001a\u00020W2\u000e\u0010X\u001a\n\u0012\u0004\u0012\u00020\u0006\u0018\u00010YH\u0000¢\u0006\u0002\bZJ\u000e\u0010[\u001a\u00020\u001d2\u0006\u0010\\\u001a\u00020\u001dJ\u001d\u0010]\u001a\u00020^2\u0006\u0010C\u001a\u00020D2\u0006\u0010_\u001a\u00020`H\u0000¢\u0006\u0002\baJ\u0015\u0010b\u001a\u00020c2\u0006\u0010d\u001a\u00020eH\u0000¢\u0006\u0002\bfJ\u0006\u0010\u001f\u001a\u000207J\u0006\u0010 \u001a\u000207J\u0018\u0010g\u001a\u0002072\u0006\u0010h\u001a\u00020\u00152\u0006\u0010i\u001a\u00020jH\u0016J\u0010\u0010k\u001a\u0002072\u0006\u0010l\u001a\u00020mH\u0016J\b\u0010$\u001a\u00020%H\u0016J\b\u0010\u0005\u001a\u00020\u0006H\u0016J\u0016\u0010n\u001a\u00020\u001d2\f\u0010o\u001a\b\u0012\u0004\u0012\u00020\u00060YH\u0002J\b\u00100\u001a\u00020'H\u0016J\u0010\u0010p\u001a\u0002072\u0006\u0010<\u001a\u00020\tH\u0002J\u000e\u0010q\u001a\u00020\u001d2\u0006\u0010Q\u001a\u00020RJ\b\u0010r\u001a\u00020sH\u0016J\u001f\u0010t\u001a\u0002072\u0006\u0010>\u001a\u00020\r2\b\u0010u\u001a\u0004\u0018\u00010GH\u0000¢\u0006\u0002\bvR\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\u0011\u0010\u001c\u001a\u00020\u001d8F¢\u0006\u0006\u001a\u0004\b\u001c\u0010\u001eR\u000e\u0010\u001f\u001a\u00020\u001dX\u0082\u000e¢\u0006\u0002\n\u0000R\u001a\u0010 \u001a\u00020\u001dX\u0086\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b!\u0010\u001e\"\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\u00010/X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u00100\u001a\u0004\u0018\u00010'X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u00101\u001a\u0004\u0018\u000102X\u0082\u000e¢\u0006\u0002\n\u0000R\u001a\u00103\u001a\u00020\tX\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b4\u0010+\"\u0004\b5\u0010-¨\u0006x"}, d2 = {"Lokhttp3/internal/connection/RealConnection;", "Lokhttp3/internal/http2/Http2Connection$Listener;", "Lokhttp3/Connection;", "connectionPool", "Lokhttp3/internal/connection/RealConnectionPool;", "route", "Lokhttp3/Route;", "(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Route;)V", "allocationLimit", "", "calls", "", "Ljava/lang/ref/Reference;", "Lokhttp3/internal/connection/RealCall;", "getCalls", "()Ljava/util/List;", "getConnectionPool", "()Lokhttp3/internal/connection/RealConnectionPool;", "handshake", "Lokhttp3/Handshake;", "http2Connection", "Lokhttp3/internal/http2/Http2Connection;", "idleAtNs", "", "getIdleAtNs$okhttp", "()J", "setIdleAtNs$okhttp", "(J)V", "isMultiplexed", "", "()Z", "noCoalescedConnections", "noNewExchanges", "getNoNewExchanges", "setNoNewExchanges", "(Z)V", "protocol", "Lokhttp3/Protocol;", "rawSocket", "Ljava/net/Socket;", "refusedStreamCount", "routeFailureCount", "getRouteFailureCount$okhttp", "()I", "setRouteFailureCount$okhttp", "(I)V", "sink", "Lokio/BufferedSink;", "socket", "source", "Lokio/BufferedSource;", "successCount", "getSuccessCount$okhttp", "setSuccessCount$okhttp", "cancel", "", "connect", "connectTimeout", "readTimeout", "writeTimeout", "pingIntervalMillis", "connectionRetryEnabled", NotificationCompat.CATEGORY_CALL, "Lokhttp3/Call;", "eventListener", "Lokhttp3/EventListener;", "connectFailed", "client", "Lokhttp3/OkHttpClient;", "failedRoute", "failure", "Ljava/io/IOException;", "connectFailed$okhttp", "connectSocket", "connectTls", "connectionSpecSelector", "Lokhttp3/internal/connection/ConnectionSpecSelector;", "connectTunnel", "createTunnel", "Lokhttp3/Request;", "tunnelRequest", "url", "Lokhttp3/HttpUrl;", "createTunnelRequest", "establishProtocol", "isEligible", GroupDevice.ADDRESSNUM, "Lokhttp3/Address;", "routes", "", "isEligible$okhttp", "isHealthy", "doExtensiveChecks", "newCodec", "Lokhttp3/internal/http/ExchangeCodec;", "chain", "Lokhttp3/internal/http/RealInterceptorChain;", "newCodec$okhttp", "newWebSocketStreams", "Lokhttp3/internal/ws/RealWebSocket$Streams;", "exchange", "Lokhttp3/internal/connection/Exchange;", "newWebSocketStreams$okhttp", "onSettings", "connection", "settings", "Lokhttp3/internal/http2/Settings;", "onStream", "stream", "Lokhttp3/internal/http2/Http2Stream;", "routeMatchesAny", "candidates", "startHttp2", "supportsUrl", "toString", "", "trackFailure", "e", "trackFailure$okhttp", "Companion", "okhttp"}, k = 1, mv = {1, 1, 16}) /* loaded from: classes2.dex */ public final class RealConnection extends Http2Connection.Listener implements Connection { /* renamed from: Companion, reason: from kotlin metadata */ 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> 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, 1, 16}) /* loaded from: classes2.dex */ public final /* synthetic */ class WhenMappings { public static final /* synthetic */ 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 connectionPool, Route route) { Intrinsics.checkParameterIsNotNull(connectionPool, "connectionPool"); Intrinsics.checkParameterIsNotNull(route, "route"); this.connectionPool = connectionPool; 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; } /* renamed from: getRouteFailureCount$okhttp, reason: from getter */ public final int getRouteFailureCount() { return this.routeFailureCount; } public final void setRouteFailureCount$okhttp(int i) { this.routeFailureCount = i; } /* renamed from: getSuccessCount$okhttp, reason: from getter */ public final int getSuccessCount() { return this.successCount; } public final void setSuccessCount$okhttp(int i) { this.successCount = i; } public final List> getCalls() { return this.calls; } /* renamed from: getIdleAtNs$okhttp, reason: from getter */ public final long getIdleAtNs() { return this.idleAtNs; } public final void setIdleAtNs$okhttp(long j) { this.idleAtNs = j; } public final boolean isMultiplexed() { return this.http2Connection != null; } public final void noNewExchanges() { RealConnectionPool realConnectionPool = this.connectionPool; if (!Util.assertionsEnabled || !Thread.holdsLock(realConnectionPool)) { synchronized (this.connectionPool) { this.noNewExchanges = true; Unit unit = Unit.INSTANCE; } return; } StringBuilder sb = new StringBuilder("Thread "); Thread currentThread = Thread.currentThread(); Intrinsics.checkExpressionValueIsNotNull(currentThread, "Thread.currentThread()"); throw new AssertionError(sb.append(currentThread.getName()).append(" MUST NOT hold lock on ").append(realConnectionPool).toString()); } public final void noCoalescedConnections() { RealConnectionPool realConnectionPool = this.connectionPool; if (!Util.assertionsEnabled || !Thread.holdsLock(realConnectionPool)) { synchronized (this.connectionPool) { this.noCoalescedConnections = true; Unit unit = Unit.INSTANCE; } return; } StringBuilder sb = new StringBuilder("Thread "); Thread currentThread = Thread.currentThread(); Intrinsics.checkExpressionValueIsNotNull(currentThread, "Thread.currentThread()"); throw new AssertionError(sb.append(currentThread.getName()).append(" MUST NOT hold lock on ").append(realConnectionPool).toString()); } /* JADX WARN: Removed duplicated region for block: B:37:0x0116 */ /* JADX WARN: Removed duplicated region for block: B:40:0x011d */ /* JADX WARN: Removed duplicated region for block: B:43:0x0159 */ /* JADX WARN: Removed duplicated region for block: B:45:0x0164 */ /* JADX WARN: Removed duplicated region for block: B:51:0x016c A[EDGE_INSN: B:51:0x016c->B:48:0x016c BREAK A[LOOP:0: B:15:0x00a4->B:50:?], SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:52:0x015f */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final void connect(int r17, int r18, int r19, int r20, boolean r21, okhttp3.Call r22, okhttp3.EventListener r23) { /* Method dump skipped, instructions count: 398 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.connection.RealConnection.connect(int, int, int, int, boolean, okhttp3.Call, okhttp3.EventListener):void"); } 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(); if (socket == null) { Intrinsics.throwNpe(); } } 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; if (socket == null) { Intrinsics.throwNpe(); } BufferedSource bufferedSource = this.source; if (bufferedSource == null) { Intrinsics.throwNpe(); } BufferedSink bufferedSink = this.sink; if (bufferedSink == null) { Intrinsics.throwNpe(); } 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, 1, null); } /* JADX WARN: Removed duplicated region for block: B:44:0x01a7 */ /* JADX WARN: Removed duplicated region for block: B:46:0x01b2 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ private final void connectTls(okhttp3.internal.connection.ConnectionSpecSelector r11) throws java.io.IOException { /* Method dump skipped, instructions count: 440 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.connection.RealConnection.connectTls(okhttp3.internal.connection.ConnectionSpecSelector):void"); } 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; if (bufferedSource == null) { Intrinsics.throwNpe(); } BufferedSink bufferedSink = this.sink; if (bufferedSink == null) { Intrinsics.throwNpe(); } 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); if (readResponseHeaders == null) { Intrinsics.throwNpe(); } 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", HTTP.CONN_KEEP_ALIVE).header("User-Agent", Version.userAgent).build(); Request authenticate = this.route.address().proxyAuthenticator().authenticate(this.route, new Response.Builder().request(build).protocol(Protocol.HTTP_1_1).code(HttpStatus.SC_PROXY_AUTHENTICATION_REQUIRED).message("Preemptive Authenticate").body(Util.EMPTY_RESPONSE).sentRequestAtMillis(-1L).receivedResponseAtMillis(-1L).header("Proxy-Authenticate", "OkHttp-Preemptive").build()); return authenticate != null ? authenticate : build; } public final boolean isEligible$okhttp(Address address, List routes) { Intrinsics.checkParameterIsNotNull(address, "address"); 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(); if (certificatePinner == null) { Intrinsics.throwNpe(); } String host = address.url().host(); Handshake handshake = getHandshake(); if (handshake == null) { Intrinsics.throwNpe(); } certificatePinner.check(host, handshake.peerCertificates()); return true; } catch (SSLPeerUnverifiedException unused) { return false; } } private final boolean routeMatchesAny(List candidates) { List list = candidates; if ((list instanceof Collection) && list.isEmpty()) { return false; } 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; } public final boolean supportsUrl(HttpUrl url) { Intrinsics.checkParameterIsNotNull(url, "url"); 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 || this.handshake == null) { return false; } OkHostnameVerifier okHostnameVerifier = OkHostnameVerifier.INSTANCE; String host = url.host(); Handshake handshake = this.handshake; if (handshake == null) { Intrinsics.throwNpe(); } Certificate certificate = handshake.peerCertificates().get(0); if (certificate != null) { return okHostnameVerifier.verify(host, (X509Certificate) certificate); } throw new TypeCastException("null cannot be cast to non-null type java.security.cert.X509Certificate"); } public final ExchangeCodec newCodec$okhttp(OkHttpClient client, RealInterceptorChain chain) throws SocketException { Intrinsics.checkParameterIsNotNull(client, "client"); Intrinsics.checkParameterIsNotNull(chain, "chain"); Socket socket = this.socket; if (socket == null) { Intrinsics.throwNpe(); } BufferedSource bufferedSource = this.source; if (bufferedSource == null) { Intrinsics.throwNpe(); } BufferedSink bufferedSink = this.sink; if (bufferedSink == null) { Intrinsics.throwNpe(); } 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.checkParameterIsNotNull(exchange, "exchange"); Socket socket = this.socket; if (socket == null) { Intrinsics.throwNpe(); } final BufferedSource bufferedSource = this.source; if (bufferedSource == null) { Intrinsics.throwNpe(); } final BufferedSink bufferedSink = this.sink; if (bufferedSink == null) { Intrinsics.throwNpe(); } socket.setSoTimeout(0); noNewExchanges(); final boolean z = true; return new RealWebSocket.Streams(z, bufferedSource, bufferedSink) { // from class: okhttp3.internal.connection.RealConnection$newWebSocketStreams$1 @Override // java.io.Closeable, java.lang.AutoCloseable public void close() { Exchange.this.bodyComplete(-1L, true, true, null); } }; } @Override // okhttp3.Connection /* renamed from: route, reason: from getter */ public Route getRoute() { return this.route; } public final void cancel() { Socket socket = this.rawSocket; if (socket != null) { Util.closeQuietly(socket); } } @Override // okhttp3.Connection public Socket socket() { Socket socket = this.socket; if (socket == null) { Intrinsics.throwNpe(); } return socket; } public final boolean isHealthy(boolean doExtensiveChecks) { long nanoTime = System.nanoTime(); Socket socket = this.socket; if (socket == null) { Intrinsics.throwNpe(); } BufferedSource bufferedSource = this.source; if (bufferedSource == null) { Intrinsics.throwNpe(); } if (socket.isClosed() || socket.isInputShutdown() || socket.isOutputShutdown()) { return false; } Http2Connection http2Connection = this.http2Connection; if (http2Connection != null) { return http2Connection.isHealthy(nanoTime); } if (nanoTime - this.idleAtNs < IDLE_CONNECTION_HEALTHY_NS || !doExtensiveChecks) { return true; } return Util.isHealthy(socket, bufferedSource); } @Override // okhttp3.internal.http2.Http2Connection.Listener public void onStream(Http2Stream stream) throws IOException { Intrinsics.checkParameterIsNotNull(stream, "stream"); stream.close(ErrorCode.REFUSED_STREAM, null); } @Override // okhttp3.internal.http2.Http2Connection.Listener public void onSettings(Http2Connection connection, Settings settings) { Intrinsics.checkParameterIsNotNull(connection, "connection"); Intrinsics.checkParameterIsNotNull(settings, "settings"); synchronized (this.connectionPool) { this.allocationLimit = settings.getMaxConcurrentStreams(); Unit unit = Unit.INSTANCE; } } @Override // okhttp3.Connection /* renamed from: handshake, reason: from getter */ public Handshake getHandshake() { return this.handshake; } public final void connectFailed$okhttp(OkHttpClient client, Route failedRoute, IOException failure) { Intrinsics.checkParameterIsNotNull(client, "client"); Intrinsics.checkParameterIsNotNull(failedRoute, "failedRoute"); Intrinsics.checkParameterIsNotNull(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 void trackFailure$okhttp(RealCall call, IOException e) { Intrinsics.checkParameterIsNotNull(call, "call"); RealConnectionPool realConnectionPool = this.connectionPool; if (!Util.assertionsEnabled || !Thread.holdsLock(realConnectionPool)) { synchronized (this.connectionPool) { 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.isCanceled()) { this.noNewExchanges = true; this.routeFailureCount++; } } else if (!isMultiplexed() || (e instanceof ConnectionShutdownException)) { this.noNewExchanges = true; if (this.successCount == 0) { if (e != null) { connectFailed$okhttp(call.getClient(), this.route, e); } this.routeFailureCount++; } } Unit unit = Unit.INSTANCE; } return; } StringBuilder sb = new StringBuilder("Thread "); Thread currentThread = Thread.currentThread(); Intrinsics.checkExpressionValueIsNotNull(currentThread, "Thread.currentThread()"); throw new AssertionError(sb.append(currentThread.getName()).append(" MUST NOT hold lock on ").append(realConnectionPool).toString()); } @Override // okhttp3.Connection public Protocol protocol() { Protocol protocol = this.protocol; if (protocol == null) { Intrinsics.throwNpe(); } return protocol; } public String toString() { Object obj; StringBuilder append = new StringBuilder("Connection{").append(this.route.address().url().host()).append(':').append(this.route.address().url().port()).append(", proxy=").append(this.route.proxy()).append(" hostAddress=").append(this.route.socketAddress()).append(" cipherSuite="); Handshake handshake = this.handshake; if (handshake == null || (obj = handshake.cipherSuite()) == null) { obj = "none"; } return append.append(obj).append(" protocol=").append(this.protocol).append('}').toString(); } /* compiled from: RealConnection.kt */ @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 = {"Lokhttp3/internal/connection/RealConnection$Companion;", "", "()V", "IDLE_CONNECTION_HEALTHY_NS", "", "MAX_TUNNEL_ATTEMPTS", "", "NPE_THROW_WITH_NULL", "", "newTestConnection", "Lokhttp3/internal/connection/RealConnection;", "connectionPool", "Lokhttp3/internal/connection/RealConnectionPool;", "route", "Lokhttp3/Route;", "socket", "Ljava/net/Socket;", "idleAtNanos", "okhttp"}, k = 1, mv = {1, 1, 16}) /* loaded from: classes2.dex */ public static final class Companion { private Companion() { } public /* synthetic */ Companion(DefaultConstructorMarker defaultConstructorMarker) { this(); } public final RealConnection newTestConnection(RealConnectionPool connectionPool, Route route, Socket socket, long idleAtNanos) { Intrinsics.checkParameterIsNotNull(connectionPool, "connectionPool"); Intrinsics.checkParameterIsNotNull(route, "route"); Intrinsics.checkParameterIsNotNull(socket, "socket"); RealConnection realConnection = new RealConnection(connectionPool, route); realConnection.socket = socket; realConnection.setIdleAtNs$okhttp(idleAtNanos); return realConnection; } } }