package okhttp3.internal.connection; import j.h0; import j.k0.p; import j.n; import j.p0.c.a; import j.p0.d.j; import j.p0.d.r; import j.p0.d.s; import j.u0.q; import j.w; 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 l.g; import l.h; import okhttp3.Address; import okhttp3.Call; import okhttp3.CertificatePinner; import okhttp3.Connection; import okhttp3.ConnectionSpec; 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.CertificateChainCleaner; import okhttp3.internal.tls.OkHostnameVerifier; import okhttp3.internal.ws.RealWebSocket; /* JADX INFO: compiled from: RealConnection.kt */ /* JADX INFO: loaded from: classes.dex */ @n(bv = {1, 0, 3}, d1 = {"\u0000ì\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0005\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\u0000\n\u0002\u0010 \n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010!\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0010\t\n\u0002\b\u0015\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\t\u0018\u0000 \u009b\u00012\u00020\u00012\u00020\u0002:\u0002\u009b\u0001B\u0019\u0012\u0006\u0010s\u001a\u00020r\u0012\u0006\u0010V\u001a\u00020\u0015¢\u0006\u0006\b\u0099\u0001\u0010\u009a\u0001J\r\u0010\u0004\u001a\u00020\u0003¢\u0006\u0004\b\u0004\u0010\u0005JE\u0010\u0011\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\b\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\u00062\u0006\u0010\n\u001a\u00020\u00062\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u000e\u001a\u00020\r2\u0006\u0010\u0010\u001a\u00020\u000f¢\u0006\u0004\b\u0011\u0010\u0012J'\u0010\u001b\u001a\u00020\u00032\u0006\u0010\u0014\u001a\u00020\u00132\u0006\u0010\u0016\u001a\u00020\u00152\u0006\u0010\u0018\u001a\u00020\u0017H\u0000¢\u0006\u0004\b\u0019\u0010\u001aJ/\u0010\u001c\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\b\u001a\u00020\u00062\u0006\u0010\u000e\u001a\u00020\r2\u0006\u0010\u0010\u001a\u00020\u000fH\u0002¢\u0006\u0004\b\u001c\u0010\u001dJ\u0017\u0010 \u001a\u00020\u00032\u0006\u0010\u001f\u001a\u00020\u001eH\u0002¢\u0006\u0004\b \u0010!J7\u0010\"\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\b\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\u00062\u0006\u0010\u000e\u001a\u00020\r2\u0006\u0010\u0010\u001a\u00020\u000fH\u0002¢\u0006\u0004\b\"\u0010#J1\u0010(\u001a\u0004\u0018\u00010$2\u0006\u0010\b\u001a\u00020\u00062\u0006\u0010\t\u001a\u00020\u00062\u0006\u0010%\u001a\u00020$2\u0006\u0010'\u001a\u00020&H\u0002¢\u0006\u0004\b(\u0010)J\u000f\u0010*\u001a\u00020$H\u0002¢\u0006\u0004\b*\u0010+J/\u0010,\u001a\u00020\u00032\u0006\u0010\u001f\u001a\u00020\u001e2\u0006\u0010\n\u001a\u00020\u00062\u0006\u0010\u000e\u001a\u00020\r2\u0006\u0010\u0010\u001a\u00020\u000fH\u0002¢\u0006\u0004\b,\u0010-J\u0011\u0010/\u001a\u0004\u0018\u00010.H\u0016¢\u0006\u0004\b/\u00100J'\u00107\u001a\u00020\u000b2\u0006\u00102\u001a\u0002012\u000e\u00104\u001a\n\u0012\u0004\u0012\u00020\u0015\u0018\u000103H\u0000¢\u0006\u0004\b5\u00106J\u0015\u00109\u001a\u00020\u000b2\u0006\u00108\u001a\u00020\u000b¢\u0006\u0004\b9\u0010:J\u001f\u0010@\u001a\u00020=2\u0006\u0010\u0014\u001a\u00020\u00132\u0006\u0010<\u001a\u00020;H\u0000¢\u0006\u0004\b>\u0010?J\u0017\u0010F\u001a\u00020C2\u0006\u0010B\u001a\u00020AH\u0000¢\u0006\u0004\bD\u0010EJ\r\u0010G\u001a\u00020\u0003¢\u0006\u0004\bG\u0010\u0005J\r\u0010H\u001a\u00020\u0003¢\u0006\u0004\bH\u0010\u0005J\u001f\u0010M\u001a\u00020\u00032\u0006\u0010J\u001a\u00020I2\u0006\u0010L\u001a\u00020KH\u0016¢\u0006\u0004\bM\u0010NJ\u0017\u0010Q\u001a\u00020\u00032\u0006\u0010P\u001a\u00020OH\u0016¢\u0006\u0004\bQ\u0010RJ\u000f\u0010T\u001a\u00020SH\u0016¢\u0006\u0004\bT\u0010UJ\u000f\u0010V\u001a\u00020\u0015H\u0016¢\u0006\u0004\bV\u0010WJ\u001d\u0010Y\u001a\u00020\u000b2\f\u0010X\u001a\b\u0012\u0004\u0012\u00020\u001503H\u0002¢\u0006\u0004\bY\u0010ZJ\u000f\u0010\\\u001a\u00020[H\u0016¢\u0006\u0004\b\\\u0010]J\u0017\u0010^\u001a\u00020\u00032\u0006\u0010\n\u001a\u00020\u0006H\u0002¢\u0006\u0004\b^\u0010_J\u0015\u0010`\u001a\u00020\u000b2\u0006\u0010'\u001a\u00020&¢\u0006\u0004\b`\u0010aJ\u000f\u0010c\u001a\u00020bH\u0016¢\u0006\u0004\bc\u0010dJ!\u0010i\u001a\u00020\u00032\u0006\u0010\u000e\u001a\u00020e2\b\u0010f\u001a\u0004\u0018\u00010\u0017H\u0000¢\u0006\u0004\bg\u0010hR\u0016\u0010j\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bj\u0010kR%\u0010n\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020e0m0l8\u0006@\u0006¢\u0006\f\n\u0004\bn\u0010o\u001a\u0004\bp\u0010qR\u0019\u0010s\u001a\u00020r8\u0006@\u0006¢\u0006\f\n\u0004\bs\u0010t\u001a\u0004\bu\u0010vR\u0018\u0010/\u001a\u0004\u0018\u00010.8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b/\u0010wR\u0018\u0010x\u001a\u0004\u0018\u00010I8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bx\u0010yR#\u0010{\u001a\u00020z8\u0000@\u0000X\u0080\u000e¢\u0006\u0013\n\u0004\b{\u0010|\u001a\u0004\b}\u0010~\"\u0005\b\u007f\u0010\u0080\u0001R\u0016\u0010\u0081\u0001\u001a\u00020\u000b8F@\u0006¢\u0006\b\u001a\u0006\b\u0081\u0001\u0010\u0082\u0001R\u0017\u0010G\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\u0007\n\u0005\bG\u0010\u0083\u0001R'\u0010H\u001a\u00020\u000b8\u0006@\u0006X\u0086\u000e¢\u0006\u0017\n\u0005\bH\u0010\u0083\u0001\u001a\u0006\b\u0084\u0001\u0010\u0082\u0001\"\u0006\b\u0085\u0001\u0010\u0086\u0001R\u0019\u0010T\u001a\u0004\u0018\u00010S8\u0002@\u0002X\u0082\u000e¢\u0006\u0007\n\u0005\bT\u0010\u0087\u0001R\u001b\u0010\u0088\u0001\u001a\u0004\u0018\u00010[8\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0088\u0001\u0010\u0089\u0001R\u0018\u0010\u008a\u0001\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0007\n\u0005\b\u008a\u0001\u0010kR\u0017\u0010V\u001a\u00020\u00158\u0002@\u0002X\u0082\u0004¢\u0006\u0007\n\u0005\bV\u0010\u008b\u0001R'\u0010\u008c\u0001\u001a\u00020\u00068\u0000@\u0000X\u0080\u000e¢\u0006\u0016\n\u0005\b\u008c\u0001\u0010k\u001a\u0006\b\u008d\u0001\u0010\u008e\u0001\"\u0005\b\u008f\u0001\u0010_R\u001c\u0010\u0091\u0001\u001a\u0005\u0018\u00010\u0090\u00018\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0091\u0001\u0010\u0092\u0001R\u0019\u0010\\\u001a\u0004\u0018\u00010[8\u0002@\u0002X\u0082\u000e¢\u0006\u0007\n\u0005\b\\\u0010\u0089\u0001R\u001c\u0010\u0094\u0001\u001a\u0005\u0018\u00010\u0093\u00018\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0094\u0001\u0010\u0095\u0001R'\u0010\u0096\u0001\u001a\u00020\u00068\u0000@\u0000X\u0080\u000e¢\u0006\u0016\n\u0005\b\u0096\u0001\u0010k\u001a\u0006\b\u0097\u0001\u0010\u008e\u0001\"\u0005\b\u0098\u0001\u0010_¨\u0006\u009c\u0001"}, d2 = {"Lokhttp3/internal/connection/RealConnection;", "Lokhttp3/Connection;", "okhttp3/internal/http2/Http2Connection$Listener", HttpUrl.FRAGMENT_ENCODE_SET, "cancel", "()V", HttpUrl.FRAGMENT_ENCODE_SET, "connectTimeout", "readTimeout", "writeTimeout", "pingIntervalMillis", HttpUrl.FRAGMENT_ENCODE_SET, "connectionRetryEnabled", "Lokhttp3/Call;", "call", "Lokhttp3/EventListener;", "eventListener", "connect", "(IIIIZLokhttp3/Call;Lokhttp3/EventListener;)V", "Lokhttp3/OkHttpClient;", "client", "Lokhttp3/Route;", "failedRoute", "Ljava/io/IOException;", "failure", "connectFailed$okhttp", "(Lokhttp3/OkHttpClient;Lokhttp3/Route;Ljava/io/IOException;)V", "connectFailed", "connectSocket", "(IILokhttp3/Call;Lokhttp3/EventListener;)V", "Lokhttp3/internal/connection/ConnectionSpecSelector;", "connectionSpecSelector", "connectTls", "(Lokhttp3/internal/connection/ConnectionSpecSelector;)V", "connectTunnel", "(IIILokhttp3/Call;Lokhttp3/EventListener;)V", "Lokhttp3/Request;", "tunnelRequest", "Lokhttp3/HttpUrl;", "url", "createTunnel", "(IILokhttp3/Request;Lokhttp3/HttpUrl;)Lokhttp3/Request;", "createTunnelRequest", "()Lokhttp3/Request;", "establishProtocol", "(Lokhttp3/internal/connection/ConnectionSpecSelector;ILokhttp3/Call;Lokhttp3/EventListener;)V", "Lokhttp3/Handshake;", "handshake", "()Lokhttp3/Handshake;", "Lokhttp3/Address;", "address", HttpUrl.FRAGMENT_ENCODE_SET, "routes", "isEligible$okhttp", "(Lokhttp3/Address;Ljava/util/List;)Z", "isEligible", "doExtensiveChecks", "isHealthy", "(Z)Z", "Lokhttp3/internal/http/RealInterceptorChain;", "chain", "Lokhttp3/internal/http/ExchangeCodec;", "newCodec$okhttp", "(Lokhttp3/OkHttpClient;Lokhttp3/internal/http/RealInterceptorChain;)Lokhttp3/internal/http/ExchangeCodec;", "newCodec", "Lokhttp3/internal/connection/Exchange;", "exchange", "Lokhttp3/internal/ws/RealWebSocket$Streams;", "newWebSocketStreams$okhttp", "(Lokhttp3/internal/connection/Exchange;)Lokhttp3/internal/ws/RealWebSocket$Streams;", "newWebSocketStreams", "noCoalescedConnections", "noNewExchanges", "Lokhttp3/internal/http2/Http2Connection;", "connection", "Lokhttp3/internal/http2/Settings;", "settings", "onSettings", "(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Settings;)V", "Lokhttp3/internal/http2/Http2Stream;", "stream", "onStream", "(Lokhttp3/internal/http2/Http2Stream;)V", "Lokhttp3/Protocol;", "protocol", "()Lokhttp3/Protocol;", "route", "()Lokhttp3/Route;", "candidates", "routeMatchesAny", "(Ljava/util/List;)Z", "Ljava/net/Socket;", "socket", "()Ljava/net/Socket;", "startHttp2", "(I)V", "supportsUrl", "(Lokhttp3/HttpUrl;)Z", HttpUrl.FRAGMENT_ENCODE_SET, "toString", "()Ljava/lang/String;", "Lokhttp3/internal/connection/RealCall;", "e", "trackFailure$okhttp", "(Lokhttp3/internal/connection/RealCall;Ljava/io/IOException;)V", "trackFailure", "allocationLimit", "I", HttpUrl.FRAGMENT_ENCODE_SET, "Ljava/lang/ref/Reference;", "calls", "Ljava/util/List;", "getCalls", "()Ljava/util/List;", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/internal/connection/RealConnectionPool;", "getConnectionPool", "()Lokhttp3/internal/connection/RealConnectionPool;", "Lokhttp3/Handshake;", "http2Connection", "Lokhttp3/internal/http2/Http2Connection;", HttpUrl.FRAGMENT_ENCODE_SET, "idleAtNs", "J", "getIdleAtNs$okhttp", "()J", "setIdleAtNs$okhttp", "(J)V", "isMultiplexed", "()Z", "Z", "getNoNewExchanges", "setNoNewExchanges", "(Z)V", "Lokhttp3/Protocol;", "rawSocket", "Ljava/net/Socket;", "refusedStreamCount", "Lokhttp3/Route;", "routeFailureCount", "getRouteFailureCount$okhttp", "()I", "setRouteFailureCount$okhttp", "Lokio/BufferedSink;", "sink", "Lokio/BufferedSink;", "Lokio/BufferedSource;", "source", "Lokio/BufferedSource;", "successCount", "getSuccessCount$okhttp", "setSuccessCount$okhttp", "", "(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Route;)V", "Companion", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class RealConnection extends Http2Connection.Listener implements Connection { public static final Companion Companion = 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 g sink; private Socket socket; private h source; private int successCount; /* JADX INFO: compiled from: RealConnection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u00004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0005\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\u0014\u0010\u0015J-\u0010\n\u001a\u00020\t2\u0006\u0010\u0002\u001a\u00020\u00012\u0006\u0010\u0004\u001a\u00020\u00032\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b\n\u0010\u000bR\u0016\u0010\f\u001a\u00020\u00078\u0000@\u0000X\u0080T¢\u0006\u0006\n\u0004\b\f\u0010\rR\u0016\u0010\u000f\u001a\u00020\u000e8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u000f\u0010\u0010R\u0016\u0010\u0012\u001a\u00020\u00118\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0012\u0010\u0013¨\u0006\u0016"}, d2 = {"Lokhttp3/internal/connection/RealConnection$Companion;", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/Route;", "route", "Ljava/net/Socket;", "socket", HttpUrl.FRAGMENT_ENCODE_SET, "idleAtNanos", "Lokhttp3/internal/connection/RealConnection;", "newTestConnection", "(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Route;Ljava/net/Socket;J)Lokhttp3/internal/connection/RealConnection;", "IDLE_CONNECTION_HEALTHY_NS", "J", HttpUrl.FRAGMENT_ENCODE_SET, "MAX_TUNNEL_ATTEMPTS", "I", HttpUrl.FRAGMENT_ENCODE_SET, "NPE_THROW_WITH_NULL", "Ljava/lang/String;", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static final class Companion { private Companion() { } public final RealConnection newTestConnection(RealConnectionPool realConnectionPool, Route route, Socket socket, long j2) { r.g(realConnectionPool, "connectionPool"); r.g(route, "route"); r.g(socket, "socket"); RealConnection realConnection = new RealConnection(realConnectionPool, route); realConnection.socket = socket; realConnection.setIdleAtNs$okhttp(j2); return realConnection; } public /* synthetic */ Companion(j jVar) { this(); } } @n(bv = {1, 0, 3}, d1 = {}, d2 = {}, k = 3, mv = {1, 1, 16}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) 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; $EnumSwitchMapping$0[Proxy.Type.HTTP.ordinal()] = 2; } } /* JADX INFO: renamed from: okhttp3.internal.connection.RealConnection$connectTls$1, reason: invalid class name */ /* JADX INFO: compiled from: RealConnection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000\f\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0000\u0010\u0000\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001H\n¢\u0006\u0002\b\u0003"}, d2 = {"", HttpUrl.FRAGMENT_ENCODE_SET, "Ljava/security/cert/Certificate;", "invoke"}, k = 3, mv = {1, 1, 16}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) static final class AnonymousClass1 extends s implements a> { final /* synthetic */ Address $address; final /* synthetic */ CertificatePinner $certificatePinner; final /* synthetic */ Handshake $unverifiedHandshake; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ AnonymousClass1(CertificatePinner certificatePinner, Handshake handshake, Address address) { super(0); this.$certificatePinner = certificatePinner; this.$unverifiedHandshake = handshake; this.$address = address; } @Override // j.p0.c.a public final List invoke() { CertificateChainCleaner certificateChainCleaner$okhttp = this.$certificatePinner.getCertificateChainCleaner$okhttp(); if (certificateChainCleaner$okhttp != null) { return certificateChainCleaner$okhttp.clean(this.$unverifiedHandshake.peerCertificates(), this.$address.url().host()); } r.p(); throw null; } } /* JADX INFO: renamed from: okhttp3.internal.connection.RealConnection$connectTls$2, reason: invalid class name */ /* JADX INFO: compiled from: RealConnection.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000\f\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0000\u0010\u0000\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001H\n¢\u0006\u0002\b\u0003"}, d2 = {"", HttpUrl.FRAGMENT_ENCODE_SET, "Ljava/security/cert/X509Certificate;", "invoke"}, k = 3, mv = {1, 1, 16}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) static final class AnonymousClass2 extends s implements a> { AnonymousClass2() { super(0); } @Override // j.p0.c.a public final List invoke() { Handshake handshake = RealConnection.this.handshake; if (handshake == null) { r.p(); throw null; } List listPeerCertificates = handshake.peerCertificates(); ArrayList arrayList = new ArrayList(p.p(listPeerCertificates, 10)); for (Certificate certificate : listPeerCertificates) { if (certificate == null) { throw new w("null cannot be cast to non-null type java.security.cert.X509Certificate"); } arrayList.add((X509Certificate) certificate); } return arrayList; } } public RealConnection(RealConnectionPool realConnectionPool, Route route) { r.g(realConnectionPool, "connectionPool"); r.g(route, "route"); this.connectionPool = realConnectionPool; this.route = route; this.allocationLimit = 1; this.calls = new ArrayList(); this.idleAtNs = Long.MAX_VALUE; } private final void connectSocket(int i2, int i3, Call call, EventListener eventListener) throws IOException { Socket socket; int i4; Proxy proxy = this.route.proxy(); Address address = this.route.address(); Proxy.Type type = proxy.type(); if (type != null && ((i4 = WhenMappings.$EnumSwitchMapping$0[type.ordinal()]) == 1 || i4 == 2)) { socket = address.socketFactory().createSocket(); if (socket == null) { r.p(); throw null; } } else { socket = new Socket(proxy); } this.rawSocket = socket; eventListener.connectStart(call, this.route.socketAddress(), proxy); socket.setSoTimeout(i3); try { Platform.Companion.get().connectSocket(socket, this.route.socketAddress(), i2); try { this.source = l.p.d(l.p.l(socket)); this.sink = l.p.c(l.p.h(socket)); } catch (NullPointerException e) { if (r.a(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; } } /* JADX WARN: Type inference fix 'apply assigned field type' failed java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593) at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35) at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94) */ private final void connectTls(ConnectionSpecSelector connectionSpecSelector) throws Throwable { Address address = this.route.address(); SSLSocketFactory sslSocketFactory = address.sslSocketFactory(); SSLSocket sSLSocket = null; try { if (sslSocketFactory == null) { r.p(); throw null; } Socket socketCreateSocket = sslSocketFactory.createSocket(this.rawSocket, address.url().host(), address.url().port(), true); if (socketCreateSocket == null) { throw new w("null cannot be cast to non-null type javax.net.ssl.SSLSocket"); } SSLSocket sSLSocket2 = (SSLSocket) socketCreateSocket; try { ConnectionSpec connectionSpecConfigureSecureSocket = connectionSpecSelector.configureSecureSocket(sSLSocket2); if (connectionSpecConfigureSecureSocket.supportsTlsExtensions()) { Platform.Companion.get().configureTlsExtensions(sSLSocket2, address.url().host(), address.protocols()); } sSLSocket2.startHandshake(); SSLSession session = sSLSocket2.getSession(); Handshake.Companion companion = Handshake.Companion; r.b(session, "sslSocketSession"); Handshake handshake = companion.get(session); HostnameVerifier hostnameVerifier = address.hostnameVerifier(); if (hostnameVerifier == null) { r.p(); throw null; } if (hostnameVerifier.verify(address.url().host(), session)) { CertificatePinner certificatePinner = address.certificatePinner(); if (certificatePinner == null) { r.p(); throw null; } this.handshake = new Handshake(handshake.tlsVersion(), handshake.cipherSuite(), handshake.localCertificates(), new AnonymousClass1(certificatePinner, handshake, address)); certificatePinner.check$okhttp(address.url().host(), new AnonymousClass2()); String selectedProtocol = connectionSpecConfigureSecureSocket.supportsTlsExtensions() ? Platform.Companion.get().getSelectedProtocol(sSLSocket2) : null; this.socket = sSLSocket2; this.source = l.p.d(l.p.l(sSLSocket2)); this.sink = l.p.c(l.p.h(sSLSocket2)); this.protocol = selectedProtocol != null ? Protocol.Companion.get(selectedProtocol) : Protocol.HTTP_1_1; if (sSLSocket2 != null) { Platform.Companion.get().afterHandshake(sSLSocket2); return; } return; } List listPeerCertificates = handshake.peerCertificates(); if (!(!listPeerCertificates.isEmpty())) { throw new SSLPeerUnverifiedException("Hostname " + address.url().host() + " not verified (no certificates)"); } Certificate certificate = listPeerCertificates.get(0); if (certificate == null) { throw new w("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.Companion.pin(x509Certificate)); sb.append("\n | DN: "); Principal subjectDN = x509Certificate.getSubjectDN(); r.b(subjectDN, "cert.subjectDN"); sb.append(subjectDN.getName()); sb.append("\n | subjectAltNames: "); sb.append(OkHostnameVerifier.INSTANCE.allSubjectAltNames(x509Certificate)); sb.append("\n "); throw new SSLPeerUnverifiedException(j.u0.j.h(sb.toString(), null, 1, null)); } catch (Throwable th) { th = th; sSLSocket = sSLSocket2; if (sSLSocket != null) { Platform.Companion.get().afterHandshake(sSLSocket); } if (sSLSocket != null) { Util.closeQuietly((Socket) sSLSocket); } throw th; } } catch (Throwable th2) { th = th2; } } private final void connectTunnel(int i2, int i3, int i4, Call call, EventListener eventListener) throws IOException { Request requestCreateTunnelRequest = createTunnelRequest(); HttpUrl httpUrlUrl = requestCreateTunnelRequest.url(); for (int i5 = 0; i5 < 21; i5++) { connectSocket(i2, i3, call, eventListener); requestCreateTunnelRequest = createTunnel(i3, i4, requestCreateTunnelRequest, httpUrlUrl); if (requestCreateTunnelRequest == 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 Request createTunnel(int i2, int i3, Request request, HttpUrl httpUrl) throws IOException { String str = "CONNECT " + Util.toHostHeader(httpUrl, true) + " HTTP/1.1"; while (true) { h hVar = this.source; if (hVar == null) { r.p(); throw null; } g gVar = this.sink; if (gVar == null) { r.p(); throw null; } Http1ExchangeCodec http1ExchangeCodec = new Http1ExchangeCodec(null, this, hVar, gVar); hVar.timeout().timeout(i2, TimeUnit.MILLISECONDS); gVar.timeout().timeout(i3, TimeUnit.MILLISECONDS); http1ExchangeCodec.writeRequest(request.headers(), str); http1ExchangeCodec.finishRequest(); Response.Builder responseHeaders = http1ExchangeCodec.readResponseHeaders(false); if (responseHeaders == null) { r.p(); throw null; } Response responseBuild = responseHeaders.request(request).build(); http1ExchangeCodec.skipConnectBody(responseBuild); int iCode = responseBuild.code(); if (iCode == 200) { if (hVar.a().E() && gVar.a().E()) { return null; } throw new IOException("TLS tunnel buffered too many bytes!"); } if (iCode != 407) { throw new IOException("Unexpected response code for CONNECT: " + responseBuild.code()); } Request requestAuthenticate = this.route.address().proxyAuthenticator().authenticate(this.route, responseBuild); if (requestAuthenticate == null) { throw new IOException("Failed to authenticate with proxy"); } if (q.q("close", Response.header$default(responseBuild, "Connection", null, 2, null), true)) { return requestAuthenticate; } request = requestAuthenticate; } } private final Request createTunnelRequest() throws IOException { Request requestBuild = 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", Version.userAgent).build(); Request requestAuthenticate = this.route.address().proxyAuthenticator().authenticate(this.route, new Response.Builder().request(requestBuild).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 requestAuthenticate != null ? requestAuthenticate : requestBuild; } private final void establishProtocol(ConnectionSpecSelector connectionSpecSelector, int i2, Call call, EventListener eventListener) throws Throwable { if (this.route.address().sslSocketFactory() != null) { eventListener.secureConnectStart(call); connectTls(connectionSpecSelector); eventListener.secureConnectEnd(call, this.handshake); if (this.protocol == Protocol.HTTP_2) { startHttp2(i2); return; } return; } if (!this.route.address().protocols().contains(Protocol.H2_PRIOR_KNOWLEDGE)) { this.socket = this.rawSocket; this.protocol = Protocol.HTTP_1_1; } else { this.socket = this.rawSocket; this.protocol = Protocol.H2_PRIOR_KNOWLEDGE; startHttp2(i2); } } private final boolean routeMatchesAny(List list) { if (!(list instanceof Collection) || !list.isEmpty()) { for (Route route : list) { if (route.proxy().type() == Proxy.Type.DIRECT && this.route.proxy().type() == Proxy.Type.DIRECT && r.a(this.route.socketAddress(), route.socketAddress())) { return true; } } } return false; } private final void startHttp2(int i2) throws IOException { Socket socket = this.socket; if (socket == null) { r.p(); throw null; } h hVar = this.source; if (hVar == null) { r.p(); throw null; } g gVar = this.sink; if (gVar == null) { r.p(); throw null; } socket.setSoTimeout(0); Http2Connection http2ConnectionBuild = new Http2Connection.Builder(true, TaskRunner.INSTANCE).socket(socket, this.route.address().url().host(), hVar, gVar).listener(this).pingIntervalMillis(i2).build(); this.http2Connection = http2ConnectionBuild; this.allocationLimit = Http2Connection.Companion.getDEFAULT_SETTINGS().getMaxConcurrentStreams(); Http2Connection.start$default(http2ConnectionBuild, false, 1, null); } public final void cancel() { Socket socket = this.rawSocket; if (socket != null) { Util.closeQuietly(socket); } } /* JADX WARN: Removed duplicated region for block: B:49:0x0108 */ /* JADX WARN: Removed duplicated region for block: B:52:0x010f */ /* JADX WARN: Removed duplicated region for block: B:55:0x0139 */ /* JADX WARN: Removed duplicated region for block: B:56:0x013f */ /* JADX WARN: Removed duplicated region for block: B:58:0x0144 */ /* JADX WARN: Removed duplicated region for block: B:74:0x014c A[SYNTHETIC] */ /* 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) throws java.lang.Throwable { /* Method dump skipped, instruction units count: 358 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"); } public final void connectFailed$okhttp(OkHttpClient okHttpClient, Route route, IOException iOException) { r.g(okHttpClient, "client"); r.g(route, "failedRoute"); r.g(iOException, "failure"); if (route.proxy().type() != Proxy.Type.DIRECT) { Address address = route.address(); address.proxySelector().connectFailed(address.url().uri(), route.proxy().address(), iOException); } okHttpClient.getRouteDatabase().failed(route); } public final List> getCalls() { return this.calls; } public final RealConnectionPool getConnectionPool() { return this.connectionPool; } public final long getIdleAtNs$okhttp() { return this.idleAtNs; } public final boolean getNoNewExchanges() { return this.noNewExchanges; } public final int getRouteFailureCount$okhttp() { return this.routeFailureCount; } public final int getSuccessCount$okhttp() { return this.successCount; } @Override // okhttp3.Connection public Handshake handshake() { return this.handshake; } public final boolean isEligible$okhttp(Address address, List list) { r.g(address, "address"); if (this.calls.size() >= this.allocationLimit || this.noNewExchanges || !this.route.address().equalsNonHost$okhttp(address)) { return false; } if (r.a(address.url().host(), route().address().url().host())) { return true; } if (this.http2Connection == null || list == null || !routeMatchesAny(list) || address.hostnameVerifier() != OkHostnameVerifier.INSTANCE || !supportsUrl(address.url())) { return false; } try { CertificatePinner certificatePinner = address.certificatePinner(); if (certificatePinner == null) { r.p(); throw null; } String strHost = address.url().host(); Handshake handshake = handshake(); if (handshake != null) { certificatePinner.check(strHost, handshake.peerCertificates()); return true; } r.p(); throw null; } catch (SSLPeerUnverifiedException unused) { return false; } } public final boolean isHealthy(boolean z) { long jNanoTime = System.nanoTime(); Socket socket = this.socket; if (socket == null) { r.p(); throw null; } h hVar = this.source; if (hVar == null) { r.p(); throw null; } if (socket.isClosed() || socket.isInputShutdown() || socket.isOutputShutdown()) { return false; } Http2Connection http2Connection = this.http2Connection; if (http2Connection != null) { return http2Connection.isHealthy(jNanoTime); } if (jNanoTime - this.idleAtNs < IDLE_CONNECTION_HEALTHY_NS || !z) { return true; } return Util.isHealthy(socket, hVar); } public final boolean isMultiplexed() { return this.http2Connection != null; } public final ExchangeCodec newCodec$okhttp(OkHttpClient okHttpClient, RealInterceptorChain realInterceptorChain) throws SocketException { r.g(okHttpClient, "client"); r.g(realInterceptorChain, "chain"); Socket socket = this.socket; if (socket == null) { r.p(); throw null; } h hVar = this.source; if (hVar == null) { r.p(); throw null; } g gVar = this.sink; if (gVar == null) { r.p(); throw null; } Http2Connection http2Connection = this.http2Connection; if (http2Connection != null) { return new Http2ExchangeCodec(okHttpClient, this, realInterceptorChain, http2Connection); } socket.setSoTimeout(realInterceptorChain.readTimeoutMillis()); hVar.timeout().timeout(realInterceptorChain.getReadTimeoutMillis$okhttp(), TimeUnit.MILLISECONDS); gVar.timeout().timeout(realInterceptorChain.getWriteTimeoutMillis$okhttp(), TimeUnit.MILLISECONDS); return new Http1ExchangeCodec(okHttpClient, this, hVar, gVar); } public final RealWebSocket.Streams newWebSocketStreams$okhttp(final Exchange exchange) throws SocketException { r.g(exchange, "exchange"); Socket socket = this.socket; if (socket == null) { r.p(); throw null; } final h hVar = this.source; if (hVar == null) { r.p(); throw null; } final g gVar = this.sink; if (gVar == null) { r.p(); throw null; } socket.setSoTimeout(0); noNewExchanges(); final boolean z = true; return new RealWebSocket.Streams(z, hVar, gVar) { // from class: okhttp3.internal.connection.RealConnection$newWebSocketStreams$1 @Override // java.io.Closeable, java.lang.AutoCloseable public void close() { exchange.bodyComplete(-1L, true, true, null); } }; } public final void noCoalescedConnections() { RealConnectionPool realConnectionPool = this.connectionPool; if (!Util.assertionsEnabled || !Thread.holdsLock(realConnectionPool)) { synchronized (this.connectionPool) { this.noCoalescedConnections = true; h0 h0Var = h0.a; } return; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(realConnectionPool); throw new AssertionError(sb.toString()); } public final void noNewExchanges() { RealConnectionPool realConnectionPool = this.connectionPool; if (!Util.assertionsEnabled || !Thread.holdsLock(realConnectionPool)) { synchronized (this.connectionPool) { this.noNewExchanges = true; h0 h0Var = h0.a; } return; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(realConnectionPool); throw new AssertionError(sb.toString()); } @Override // okhttp3.internal.http2.Http2Connection.Listener public void onSettings(Http2Connection http2Connection, Settings settings) { r.g(http2Connection, "connection"); r.g(settings, "settings"); synchronized (this.connectionPool) { this.allocationLimit = settings.getMaxConcurrentStreams(); h0 h0Var = h0.a; } } @Override // okhttp3.internal.http2.Http2Connection.Listener public void onStream(Http2Stream http2Stream) throws IOException { r.g(http2Stream, "stream"); http2Stream.close(ErrorCode.REFUSED_STREAM, null); } @Override // okhttp3.Connection public Protocol protocol() { Protocol protocol = this.protocol; if (protocol != null) { return protocol; } r.p(); throw null; } @Override // okhttp3.Connection public Route route() { return this.route; } public final void setIdleAtNs$okhttp(long j2) { this.idleAtNs = j2; } public final void setNoNewExchanges(boolean z) { this.noNewExchanges = z; } public final void setRouteFailureCount$okhttp(int i2) { this.routeFailureCount = i2; } public final void setSuccessCount$okhttp(int i2) { this.successCount = i2; } @Override // okhttp3.Connection public Socket socket() { Socket socket = this.socket; if (socket != null) { return socket; } r.p(); throw null; } public final boolean supportsUrl(HttpUrl httpUrl) { r.g(httpUrl, "url"); HttpUrl httpUrlUrl = this.route.address().url(); if (httpUrl.port() != httpUrlUrl.port()) { return false; } if (r.a(httpUrl.host(), httpUrlUrl.host())) { return true; } if (this.noCoalescedConnections || this.handshake == null) { return false; } OkHostnameVerifier okHostnameVerifier = OkHostnameVerifier.INSTANCE; String strHost = httpUrl.host(); Handshake handshake = this.handshake; if (handshake == null) { r.p(); throw null; } Certificate certificate = handshake.peerCertificates().get(0); if (certificate != null) { return okHostnameVerifier.verify(strHost, (X509Certificate) certificate); } throw new w("null cannot be cast to non-null type java.security.cert.X509Certificate"); } public String toString() { Object objCipherSuite; 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 || (objCipherSuite = handshake.cipherSuite()) == null) { objCipherSuite = "none"; } sb.append(objCipherSuite); sb.append(" protocol="); sb.append(this.protocol); sb.append('}'); return sb.toString(); } public final void trackFailure$okhttp(RealCall realCall, IOException iOException) { r.g(realCall, "call"); RealConnectionPool realConnectionPool = this.connectionPool; if (Util.assertionsEnabled && Thread.holdsLock(realConnectionPool)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(realConnectionPool); throw new AssertionError(sb.toString()); } synchronized (this.connectionPool) { if (iOException instanceof StreamResetException) { if (((StreamResetException) iOException).errorCode == ErrorCode.REFUSED_STREAM) { int i2 = this.refusedStreamCount + 1; this.refusedStreamCount = i2; if (i2 > 1) { this.noNewExchanges = true; this.routeFailureCount++; } } else if (((StreamResetException) iOException).errorCode != ErrorCode.CANCEL || !realCall.isCanceled()) { this.noNewExchanges = true; this.routeFailureCount++; } } else if (!isMultiplexed() || (iOException instanceof ConnectionShutdownException)) { this.noNewExchanges = true; if (this.successCount == 0) { if (iOException != null) { connectFailed$okhttp(realCall.getClient(), this.route, iOException); } this.routeFailureCount++; } } h0 h0Var = h0.a; } } }