package okhttp3.internal.connection; import androidx.media3.exoplayer.rtsp.RtspHeaders; import com.google.android.gms.measurement.internal.u1; import com.pichillilorenzo.flutter_inappwebview_android.credential_database.URLProtectionSpaceContract; 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.cert.Certificate; import java.security.cert.X509Certificate; import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.concurrent.TimeUnit; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.SSLPeerUnverifiedException; import javax.net.ssl.SSLSession; import javax.net.ssl.SSLSocket; import javax.net.ssl.SSLSocketFactory; import kotlin.Metadata; import kotlin.collections.i; import kotlin.jvm.internal.SourceDebugExtension; import kotlin.jvm.internal.d; import kotlin.text.h; import nb.g; 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.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; import okio.BufferedSink; import okio.BufferedSource; import okio.Okio; import okio.Timeout; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; import sd.a; import tv.danmaku.ijk.media.player.IjkMediaPlayer; /* JADX INFO: loaded from: classes.dex */ @Metadata(d1 = {"\u0000ê\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\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\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\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\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\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\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0010\n\u0002\u0010!\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\t\n\u0002\b\f\u0018\u0000 \u008e\u00012\u00020\u00012\u00020\u0002:\u0002\u008e\u0001B\u0019\u0012\u0006\u0010^\u001a\u00020]\u0012\u0006\u0010-\u001a\u00020\u001a¢\u0006\u0006\b\u008c\u0001\u0010\u008d\u0001J\u000f\u0010\u0006\u001a\u00020\u0003H\u0000¢\u0006\u0004\b\u0004\u0010\u0005J\u000f\u0010\b\u001a\u00020\u0003H\u0000¢\u0006\u0004\b\u0007\u0010\u0005J\u000f\u0010\n\u001a\u00020\u0003H\u0000¢\u0006\u0004\b\t\u0010\u0005J>\u0010\u0016\u001a\u00020\u00032\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\r\u001a\u00020\u000b2\u0006\u0010\u000e\u001a\u00020\u000b2\u0006\u0010\u000f\u001a\u00020\u000b2\u0006\u0010\u0011\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00122\u0006\u0010\u0015\u001a\u00020\u0014J'\u0010\u001e\u001a\u00020\u00102\u0006\u0010\u0018\u001a\u00020\u00172\u000e\u0010\u001b\u001a\n\u0012\u0004\u0012\u00020\u001a\u0018\u00010\u0019H\u0000¢\u0006\u0004\b\u001c\u0010\u001dJ\u001f\u0010&\u001a\u00020#2\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010\"\u001a\u00020!H\u0000¢\u0006\u0004\b$\u0010%J\u0017\u0010,\u001a\u00020)2\u0006\u0010(\u001a\u00020'H\u0000¢\u0006\u0004\b*\u0010+J\b\u0010-\u001a\u00020\u001aH\u0016J\u0006\u0010.\u001a\u00020\u0003J\b\u00100\u001a\u00020/H\u0016J\u000e\u00102\u001a\u00020\u00102\u0006\u00101\u001a\u00020\u0010J\u0010\u00105\u001a\u00020\u00032\u0006\u00104\u001a\u000203H\u0016J\u0018\u0010:\u001a\u00020\u00032\u0006\u00107\u001a\u0002062\u0006\u00109\u001a\u000208H\u0016J\n\u0010<\u001a\u0004\u0018\u00010;H\u0016J'\u0010B\u001a\u00020\u00032\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010=\u001a\u00020\u001a2\u0006\u0010?\u001a\u00020>H\u0000¢\u0006\u0004\b@\u0010AJ!\u0010G\u001a\u00020\u00032\u0006\u0010\u0013\u001a\u00020C2\b\u0010D\u001a\u0004\u0018\u00010>H\u0000¢\u0006\u0004\bE\u0010FJ\b\u0010I\u001a\u00020HH\u0016J\b\u0010K\u001a\u00020JH\u0016J0\u0010L\u001a\u00020\u00032\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\r\u001a\u00020\u000b2\u0006\u0010\u000e\u001a\u00020\u000b2\u0006\u0010\u0013\u001a\u00020\u00122\u0006\u0010\u0015\u001a\u00020\u0014H\u0002J(\u0010M\u001a\u00020\u00032\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\r\u001a\u00020\u000b2\u0006\u0010\u0013\u001a\u00020\u00122\u0006\u0010\u0015\u001a\u00020\u0014H\u0002J(\u0010P\u001a\u00020\u00032\u0006\u0010O\u001a\u00020N2\u0006\u0010\u000f\u001a\u00020\u000b2\u0006\u0010\u0013\u001a\u00020\u00122\u0006\u0010\u0015\u001a\u00020\u0014H\u0002J\u0010\u0010Q\u001a\u00020\u00032\u0006\u0010\u000f\u001a\u00020\u000bH\u0002J\u0010\u0010R\u001a\u00020\u00032\u0006\u0010O\u001a\u00020NH\u0002J*\u0010W\u001a\u0004\u0018\u00010S2\u0006\u0010\r\u001a\u00020\u000b2\u0006\u0010\u000e\u001a\u00020\u000b2\u0006\u0010T\u001a\u00020S2\u0006\u0010V\u001a\u00020UH\u0002J\b\u0010X\u001a\u00020SH\u0002J\u0016\u0010Z\u001a\u00020\u00102\f\u0010Y\u001a\b\u0012\u0004\u0012\u00020\u001a0\u0019H\u0002J\u0010\u0010[\u001a\u00020\u00102\u0006\u0010V\u001a\u00020UH\u0002J\u0018\u0010\\\u001a\u00020\u00102\u0006\u0010V\u001a\u00020U2\u0006\u0010<\u001a\u00020;H\u0002R\u0017\u0010^\u001a\u00020]8\u0006¢\u0006\f\n\u0004\b^\u0010_\u001a\u0004\b`\u0010aR\u0014\u0010-\u001a\u00020\u001a8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b-\u0010bR\u0018\u0010c\u001a\u0004\u0018\u00010/8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bc\u0010dR\u0018\u00100\u001a\u0004\u0018\u00010/8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b0\u0010dR\u0018\u0010<\u001a\u0004\u0018\u00010;8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b<\u0010eR\u0018\u0010I\u001a\u0004\u0018\u00010H8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bI\u0010fR\u0018\u0010g\u001a\u0004\u0018\u0001068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bg\u0010hR\u0018\u0010j\u001a\u0004\u0018\u00010i8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bj\u0010kR\u0018\u0010m\u001a\u0004\u0018\u00010l8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bm\u0010nR\"\u0010\u0006\u001a\u00020\u00108\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0006\u0010o\u001a\u0004\bp\u0010q\"\u0004\br\u0010sR\u0016\u0010\b\u001a\u00020\u00108\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\b\u0010oR\"\u0010t\u001a\u00020\u000b8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bt\u0010u\u001a\u0004\bv\u0010w\"\u0004\bx\u0010yR\u0016\u0010z\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bz\u0010uR\u0016\u0010{\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b{\u0010uR\u0016\u0010|\u001a\u00020\u000b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b|\u0010uR&\u0010\u007f\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020C0~0}8\u0006¢\u0006\u000f\n\u0005\b\u007f\u0010\u0080\u0001\u001a\u0006\b\u0081\u0001\u0010\u0082\u0001R*\u0010\u0084\u0001\u001a\u00030\u0083\u00018\u0000@\u0000X\u0080\u000e¢\u0006\u0018\n\u0006\b\u0084\u0001\u0010\u0085\u0001\u001a\u0006\b\u0086\u0001\u0010\u0087\u0001\"\u0006\b\u0088\u0001\u0010\u0089\u0001R\u0016\u0010\u008b\u0001\u001a\u00020\u00108@X\u0080\u0004¢\u0006\u0007\u001a\u0005\b\u008a\u0001\u0010q¨\u0006\u008f\u0001"}, d2 = {"Lokhttp3/internal/connection/RealConnection;", "Lokhttp3/internal/http2/Http2Connection$Listener;", "Lokhttp3/Connection;", "Lkd/e;", "noNewExchanges$okhttp", "()V", "noNewExchanges", "noCoalescedConnections$okhttp", "noCoalescedConnections", "incrementSuccessCount$okhttp", "incrementSuccessCount", "", "connectTimeout", "readTimeout", "writeTimeout", "pingIntervalMillis", "", "connectionRetryEnabled", "Lokhttp3/Call;", "call", "Lokhttp3/EventListener;", "eventListener", "connect", "Lokhttp3/Address;", "address", "", "Lokhttp3/Route;", "routes", "isEligible$okhttp", "(Lokhttp3/Address;Ljava/util/List;)Z", "isEligible", "Lokhttp3/OkHttpClient;", "client", "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", "route", "cancel", "Ljava/net/Socket;", "socket", "doExtensiveChecks", "isHealthy", "Lokhttp3/internal/http2/Http2Stream;", "stream", "onStream", "Lokhttp3/internal/http2/Http2Connection;", "connection", "Lokhttp3/internal/http2/Settings;", "settings", "onSettings", "Lokhttp3/Handshake;", "handshake", "failedRoute", "Ljava/io/IOException;", "failure", "connectFailed$okhttp", "(Lokhttp3/OkHttpClient;Lokhttp3/Route;Ljava/io/IOException;)V", "connectFailed", "Lokhttp3/internal/connection/RealCall;", "e", "trackFailure$okhttp", "(Lokhttp3/internal/connection/RealCall;Ljava/io/IOException;)V", "trackFailure", "Lokhttp3/Protocol;", URLProtectionSpaceContract.FeedEntry.COLUMN_NAME_PROTOCOL, "", "toString", "connectTunnel", "connectSocket", "Lokhttp3/internal/connection/ConnectionSpecSelector;", "connectionSpecSelector", "establishProtocol", "startHttp2", "connectTls", "Lokhttp3/Request;", "tunnelRequest", "Lokhttp3/HttpUrl;", IjkMediaPlayer.OnNativeInvokeListener.ARG_URL, "createTunnel", "createTunnelRequest", "candidates", "routeMatchesAny", "supportsUrl", "certificateSupportHost", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/internal/connection/RealConnectionPool;", "getConnectionPool", "()Lokhttp3/internal/connection/RealConnectionPool;", "Lokhttp3/Route;", "rawSocket", "Ljava/net/Socket;", "Lokhttp3/Handshake;", "Lokhttp3/Protocol;", "http2Connection", "Lokhttp3/internal/http2/Http2Connection;", "Lokio/BufferedSource;", "source", "Lokio/BufferedSource;", "Lokio/BufferedSink;", "sink", "Lokio/BufferedSink;", "Z", "getNoNewExchanges", "()Z", "setNoNewExchanges", "(Z)V", "routeFailureCount", "I", "getRouteFailureCount$okhttp", "()I", "setRouteFailureCount$okhttp", "(I)V", "successCount", "refusedStreamCount", "allocationLimit", "", "Ljava/lang/ref/Reference;", "calls", "Ljava/util/List;", "getCalls", "()Ljava/util/List;", "", "idleAtNs", "J", "getIdleAtNs$okhttp", "()J", "setIdleAtNs$okhttp", "(J)V", "isMultiplexed$okhttp", "isMultiplexed", "", "(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Route;)V", "Companion", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nRealConnection.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 Util.kt\nokhttp3/internal/Util\n+ 4 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n*L\n1#1,765:1\n1#2:766\n608#3,4:767\n608#3,4:774\n615#3,4:778\n1747#4,3:771\n*S KotlinDebug\n*F\n+ 1 RealConnection.kt\nokhttp3/internal/connection/RealConnection\n*L\n529#1:767,4\n582#1:774,4\n648#1:778,4\n574#1:771,3\n*E\n"}) public final class RealConnection extends Http2Connection.Listener implements Connection { /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */ @NotNull 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; @NotNull private static final String NPE_THROW_WITH_NULL = "throw with null exception"; private int allocationLimit; @NotNull private final List> calls; @NotNull private final RealConnectionPool connectionPool; @Nullable private Handshake handshake; @Nullable private Http2Connection http2Connection; private long idleAtNs; private boolean noCoalescedConnections; private boolean noNewExchanges; @Nullable private Protocol protocol; @Nullable private Socket rawSocket; private int refusedStreamCount; @NotNull private final Route route; private int routeFailureCount; @Nullable private BufferedSink sink; @Nullable private Socket socket; @Nullable private BufferedSource source; private int successCount; @Metadata(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;", "idleAtNs", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static final class Companion { private Companion() { } public /* synthetic */ Companion(d dVar) { this(); } @NotNull public final RealConnection newTestConnection(@NotNull RealConnectionPool connectionPool, @NotNull Route route, @NotNull Socket socket, long idleAtNs) { g.i(connectionPool, "connectionPool"); g.i(route, "route"); g.i(socket, "socket"); RealConnection realConnection = new RealConnection(connectionPool, route); realConnection.socket = socket; realConnection.setIdleAtNs$okhttp(idleAtNs); return realConnection; } } @Metadata(k = 3, mv = {1, 8, 0}, xi = 48) public /* synthetic */ class WhenMappings { public static final /* synthetic */ int[] $EnumSwitchMapping$0; static { int[] iArr = new int[Proxy.Type.values().length]; try { iArr[Proxy.Type.DIRECT.ordinal()] = 1; } catch (NoSuchFieldError unused) { } try { iArr[Proxy.Type.HTTP.ordinal()] = 2; } catch (NoSuchFieldError unused2) { } $EnumSwitchMapping$0 = iArr; } } public RealConnection(@NotNull RealConnectionPool realConnectionPool, @NotNull Route route) { g.i(realConnectionPool, "connectionPool"); g.i(route, "route"); this.connectionPool = realConnectionPool; this.route = route; this.allocationLimit = 1; this.calls = new ArrayList(); this.idleAtNs = Long.MAX_VALUE; } private final boolean certificateSupportHost(HttpUrl url, Handshake handshake) { List listPeerCertificates = handshake.peerCertificates(); if (!listPeerCertificates.isEmpty()) { OkHostnameVerifier okHostnameVerifier = OkHostnameVerifier.INSTANCE; String strHost = url.host(); Certificate certificate = listPeerCertificates.get(0); g.g(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate"); if (okHostnameVerifier.verify(strHost, (X509Certificate) certificate)) { return true; } } return false; } private final void connectSocket(int i10, int i11, Call call, EventListener eventListener) throws IOException { Socket socketCreateSocket; Proxy proxy = this.route.proxy(); Address address = this.route.address(); Proxy.Type type = proxy.type(); int i12 = type == null ? -1 : WhenMappings.$EnumSwitchMapping$0[type.ordinal()]; if (i12 == 1 || i12 == 2) { socketCreateSocket = address.socketFactory().createSocket(); g.f(socketCreateSocket); } else { socketCreateSocket = new Socket(proxy); } this.rawSocket = socketCreateSocket; eventListener.connectStart(call, this.route.socketAddress(), proxy); socketCreateSocket.setSoTimeout(i11); try { Platform.INSTANCE.get().connectSocket(socketCreateSocket, this.route.socketAddress(), i10); try { this.source = Okio.buffer(Okio.source(socketCreateSocket)); this.sink = Okio.buffer(Okio.sink(socketCreateSocket)); } catch (NullPointerException e10) { if (g.c(e10.getMessage(), NPE_THROW_WITH_NULL)) { throw new IOException(e10); } } } catch (ConnectException e11) { ConnectException connectException = new ConnectException("Failed to connect to " + this.route.socketAddress()); connectException.initCause(e11); 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 { final Address address = this.route.address(); SSLSocketFactory sslSocketFactory = address.sslSocketFactory(); SSLSocket sSLSocket = null; try { g.f(sslSocketFactory); Socket socketCreateSocket = sslSocketFactory.createSocket(this.rawSocket, address.url().host(), address.url().port(), true); g.g(socketCreateSocket, "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.INSTANCE.get().configureTlsExtensions(sSLSocket2, address.url().host(), address.protocols()); } sSLSocket2.startHandshake(); SSLSession session = sSLSocket2.getSession(); Handshake.Companion companion = Handshake.INSTANCE; g.h(session, "sslSocketSession"); final Handshake handshake = companion.get(session); HostnameVerifier hostnameVerifier = address.hostnameVerifier(); g.f(hostnameVerifier); if (hostnameVerifier.verify(address.url().host(), session)) { final CertificatePinner certificatePinner = address.certificatePinner(); g.f(certificatePinner); this.handshake = new Handshake(handshake.tlsVersion(), handshake.cipherSuite(), handshake.localCertificates(), new a() { // from class: okhttp3.internal.connection.RealConnection.connectTls.1 /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ { super(0); } @Override // sd.a @NotNull public final List invoke() { CertificateChainCleaner certificateChainCleaner = certificatePinner.getCertificateChainCleaner(); g.f(certificateChainCleaner); return certificateChainCleaner.clean(handshake.peerCertificates(), address.url().host()); } }); certificatePinner.check$okhttp(address.url().host(), new a() { // from class: okhttp3.internal.connection.RealConnection.connectTls.2 { super(0); } @Override // sd.a @NotNull public final List invoke() { Handshake handshake2 = RealConnection.this.handshake; g.f(handshake2); List listPeerCertificates = handshake2.peerCertificates(); ArrayList arrayList = new ArrayList(i.Z0(10, listPeerCertificates)); for (Certificate certificate : listPeerCertificates) { g.g(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate"); arrayList.add((X509Certificate) certificate); } return arrayList; } }); String selectedProtocol = connectionSpecConfigureSecureSocket.supportsTlsExtensions() ? Platform.INSTANCE.get().getSelectedProtocol(sSLSocket2) : null; this.socket = sSLSocket2; this.source = Okio.buffer(Okio.source(sSLSocket2)); this.sink = Okio.buffer(Okio.sink(sSLSocket2)); this.protocol = selectedProtocol != null ? Protocol.INSTANCE.get(selectedProtocol) : Protocol.HTTP_1_1; Platform.INSTANCE.get().afterHandshake(sSLSocket2); return; } List listPeerCertificates = handshake.peerCertificates(); if (!(!listPeerCertificates.isEmpty())) { throw new SSLPeerUnverifiedException("Hostname " + address.url().host() + " not verified (no certificates)"); } Certificate certificate = listPeerCertificates.get(0); g.g(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate"); X509Certificate x509Certificate = (X509Certificate) certificate; throw new SSLPeerUnverifiedException(kotlin.text.d.Y("\n |Hostname " + address.url().host() + " not verified:\n | certificate: " + CertificatePinner.INSTANCE.pin(x509Certificate) + "\n | DN: " + x509Certificate.getSubjectDN().getName() + "\n | subjectAltNames: " + OkHostnameVerifier.INSTANCE.allSubjectAltNames(x509Certificate) + "\n ")); } catch (Throwable th) { th = th; sSLSocket = sSLSocket2; if (sSLSocket != null) { Platform.INSTANCE.get().afterHandshake(sSLSocket); } if (sSLSocket != null) { Util.closeQuietly((Socket) sSLSocket); } throw th; } } catch (Throwable th2) { th = th2; } } private final void connectTunnel(int i10, int i11, int i12, Call call, EventListener eventListener) throws IOException { Request requestCreateTunnelRequest = createTunnelRequest(); HttpUrl httpUrlUrl = requestCreateTunnelRequest.url(); for (int i13 = 0; i13 < 21; i13++) { connectSocket(i10, i11, call, eventListener); requestCreateTunnelRequest = createTunnel(i11, i12, 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 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; g.f(bufferedSource); BufferedSink bufferedSink = this.sink; g.f(bufferedSink); Http1ExchangeCodec http1ExchangeCodec = new Http1ExchangeCodec(null, this, bufferedSource, bufferedSink); TimeUnit timeUnit = TimeUnit.MILLISECONDS; bufferedSource.getTimeout().timeout(readTimeout, timeUnit); bufferedSink.getTimeout().timeout(writeTimeout, timeUnit); http1ExchangeCodec.writeRequest(tunnelRequest.headers(), str); http1ExchangeCodec.finishRequest(); Response.Builder responseHeaders = http1ExchangeCodec.readResponseHeaders(false); g.f(responseHeaders); Response responseBuild = responseHeaders.request(tunnelRequest).build(); http1ExchangeCodec.skipConnectBody(responseBuild); int iCode = responseBuild.code(); if (iCode == 200) { if (bufferedSource.getBuffer().exhausted() && bufferedSink.getBuffer().exhausted()) { 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 (h.c0("close", Response.header$default(responseBuild, RtspHeaders.CONNECTION, null, 2, null))) { return requestAuthenticate; } tunnelRequest = 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(RtspHeaders.USER_AGENT, Util.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(RtspHeaders.PROXY_AUTHENTICATE, "OkHttp-Preemptive").build()); return requestAuthenticate == null ? requestBuild : requestAuthenticate; } private final void establishProtocol(ConnectionSpecSelector connectionSpecSelector, int i10, 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(i10); return; } return; } List listProtocols = this.route.address().protocols(); Protocol protocol = Protocol.H2_PRIOR_KNOWLEDGE; if (!listProtocols.contains(protocol)) { this.socket = this.rawSocket; this.protocol = Protocol.HTTP_1_1; } else { this.socket = this.rawSocket; this.protocol = protocol; startHttp2(i10); } } private final boolean routeMatchesAny(List candidates) { List list = candidates; if ((list instanceof Collection) && list.isEmpty()) { return false; } for (Route route : list) { Proxy.Type type = route.proxy().type(); Proxy.Type type2 = Proxy.Type.DIRECT; if (type == type2 && this.route.proxy().type() == type2 && g.c(this.route.socketAddress(), route.socketAddress())) { return true; } } return false; } private final void startHttp2(int i10) throws IOException { Socket socket = this.socket; g.f(socket); BufferedSource bufferedSource = this.source; g.f(bufferedSource); BufferedSink bufferedSink = this.sink; g.f(bufferedSink); socket.setSoTimeout(0); Http2Connection http2ConnectionBuild = new Http2Connection.Builder(true, TaskRunner.INSTANCE).socket(socket, this.route.address().url().host(), bufferedSource, bufferedSink).listener(this).pingIntervalMillis(i10).build(); this.http2Connection = http2ConnectionBuild; this.allocationLimit = Http2Connection.INSTANCE.getDEFAULT_SETTINGS().getMaxConcurrentStreams(); Http2Connection.start$default(http2ConnectionBuild, false, null, 3, null); } private final boolean supportsUrl(HttpUrl url) { Handshake handshake; if (Util.assertionsEnabled && !Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this); } HttpUrl httpUrlUrl = this.route.address().url(); if (url.port() != httpUrlUrl.port()) { return false; } if (g.c(url.host(), httpUrlUrl.host())) { return true; } if (this.noCoalescedConnections || (handshake = this.handshake) == null) { return false; } g.f(handshake); return certificateSupportHost(url, handshake); } public final void cancel() { Socket socket = this.rawSocket; if (socket != null) { Util.closeQuietly(socket); } } /* JADX WARN: Removed duplicated region for block: B:47:0x00f6 */ /* JADX WARN: Removed duplicated region for block: B:50:0x00fd */ /* JADX WARN: Removed duplicated region for block: B:53:0x0128 */ /* JADX WARN: Removed duplicated region for block: B:54:0x012e */ /* JADX WARN: Removed duplicated region for block: B:56:0x0133 */ /* JADX WARN: Removed duplicated region for block: B:72:0x013b A[SYNTHETIC] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void connect(int i10, int i11, int i12, int i13, boolean z10, @NotNull Call call, @NotNull EventListener eventListener) throws Throwable { Socket socket; Socket socket2; g.i(call, "call"); g.i(eventListener, "eventListener"); if (this.protocol != null) { throw new IllegalStateException("already connected".toString()); } List listConnectionSpecs = this.route.address().connectionSpecs(); ConnectionSpecSelector connectionSpecSelector = new ConnectionSpecSelector(listConnectionSpecs); if (this.route.address().sslSocketFactory() == null) { if (!listConnectionSpecs.contains(ConnectionSpec.CLEARTEXT)) { throw new RouteException(new UnknownServiceException("CLEARTEXT communication not enabled for client")); } String strHost = this.route.address().url().host(); if (!Platform.INSTANCE.get().isCleartextTrafficPermitted(strHost)) { throw new RouteException(new UnknownServiceException(u1.k("CLEARTEXT communication to ", strHost, " 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 { } catch (IOException e10) { e = e10; } try { if (this.route.requiresTunnel()) { connectTunnel(i10, i11, i12, 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(i10, i11, call, eventListener); } catch (IOException e11) { e = e11; 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 (z10) { throw routeException; } } } establishProtocol(connectionSpecSelector, i13, call, eventListener); eventListener.connectEnd(call, this.route.socketAddress(), this.route.proxy(), this.protocol); if (!this.route.requiresTunnel()) { } this.idleAtNs = System.nanoTime(); return; } catch (IOException e12) { e = e12; 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 (z10) { } } } while (connectionSpecSelector.connectionFailed(e)); throw routeException; } public final void connectFailed$okhttp(@NotNull OkHttpClient client, @NotNull Route failedRoute, @NotNull IOException failure) { g.i(client, "client"); g.i(failedRoute, "failedRoute"); g.i(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); } @NotNull public final List> getCalls() { return this.calls; } @NotNull public final RealConnectionPool getConnectionPool() { return this.connectionPool; } /* JADX INFO: renamed from: getIdleAtNs$okhttp, reason: from getter */ public final long getIdleAtNs() { return this.idleAtNs; } public final boolean getNoNewExchanges() { return this.noNewExchanges; } /* JADX INFO: renamed from: getRouteFailureCount$okhttp, reason: from getter */ public final int getRouteFailureCount() { return this.routeFailureCount; } @Override // okhttp3.Connection @Nullable /* JADX INFO: renamed from: handshake, reason: from getter */ public Handshake getHandshake() { return this.handshake; } public final synchronized void incrementSuccessCount$okhttp() { this.successCount++; } public final boolean isEligible$okhttp(@NotNull Address address, @Nullable List routes) { g.i(address, "address"); if (Util.assertionsEnabled && !Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this); } if (this.calls.size() >= this.allocationLimit || this.noNewExchanges || !this.route.address().equalsNonHost$okhttp(address)) { return false; } if (g.c(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(); g.f(certificatePinner); String strHost = address.url().host(); Handshake handshake = getHandshake(); g.f(handshake); certificatePinner.check(strHost, handshake.peerCertificates()); return true; } catch (SSLPeerUnverifiedException unused) { return false; } } public final boolean isHealthy(boolean doExtensiveChecks) { long j10; if (Util.assertionsEnabled && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } long jNanoTime = System.nanoTime(); Socket socket = this.rawSocket; g.f(socket); Socket socket2 = this.socket; g.f(socket2); BufferedSource bufferedSource = this.source; g.f(bufferedSource); if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) { return false; } Http2Connection http2Connection = this.http2Connection; if (http2Connection != null) { return http2Connection.isHealthy(jNanoTime); } synchronized (this) { j10 = jNanoTime - this.idleAtNs; } if (j10 < IDLE_CONNECTION_HEALTHY_NS || !doExtensiveChecks) { return true; } return Util.isHealthy(socket2, bufferedSource); } public final boolean isMultiplexed$okhttp() { return this.http2Connection != null; } @NotNull public final ExchangeCodec newCodec$okhttp(@NotNull OkHttpClient client, @NotNull RealInterceptorChain chain) throws SocketException { g.i(client, "client"); g.i(chain, "chain"); Socket socket = this.socket; g.f(socket); BufferedSource bufferedSource = this.source; g.f(bufferedSource); BufferedSink bufferedSink = this.sink; g.f(bufferedSink); Http2Connection http2Connection = this.http2Connection; if (http2Connection != null) { return new Http2ExchangeCodec(client, this, chain, http2Connection); } socket.setSoTimeout(chain.readTimeoutMillis()); Timeout timeout = bufferedSource.getTimeout(); long readTimeoutMillis$okhttp = chain.getReadTimeoutMillis(); TimeUnit timeUnit = TimeUnit.MILLISECONDS; timeout.timeout(readTimeoutMillis$okhttp, timeUnit); bufferedSink.getTimeout().timeout(chain.getWriteTimeoutMillis(), timeUnit); return new Http1ExchangeCodec(client, this, bufferedSource, bufferedSink); } @NotNull public final RealWebSocket.Streams newWebSocketStreams$okhttp(@NotNull final Exchange exchange) throws SocketException { g.i(exchange, "exchange"); Socket socket = this.socket; g.f(socket); final BufferedSource bufferedSource = this.source; g.f(bufferedSource); final BufferedSink bufferedSink = this.sink; g.f(bufferedSink); socket.setSoTimeout(0); noNewExchanges$okhttp(); return new RealWebSocket.Streams(bufferedSource, bufferedSink) { // 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 synchronized void noCoalescedConnections$okhttp() { this.noCoalescedConnections = true; } public final synchronized void noNewExchanges$okhttp() { this.noNewExchanges = true; } @Override // okhttp3.internal.http2.Http2Connection.Listener public synchronized void onSettings(@NotNull Http2Connection http2Connection, @NotNull Settings settings) { g.i(http2Connection, "connection"); g.i(settings, "settings"); this.allocationLimit = settings.getMaxConcurrentStreams(); } @Override // okhttp3.internal.http2.Http2Connection.Listener public void onStream(@NotNull Http2Stream http2Stream) throws IOException { g.i(http2Stream, "stream"); http2Stream.close(ErrorCode.REFUSED_STREAM, null); } @Override // okhttp3.Connection @NotNull public Protocol protocol() { Protocol protocol = this.protocol; g.f(protocol); return protocol; } @Override // okhttp3.Connection @NotNull /* JADX INFO: renamed from: route, reason: from getter */ public Route getRoute() { return this.route; } public final void setIdleAtNs$okhttp(long j10) { this.idleAtNs = j10; } public final void setNoNewExchanges(boolean z10) { this.noNewExchanges = z10; } public final void setRouteFailureCount$okhttp(int i10) { this.routeFailureCount = i10; } @Override // okhttp3.Connection @NotNull public Socket socket() { Socket socket = this.socket; g.f(socket); return socket; } @NotNull public String toString() { Object objCipherSuite; StringBuilder sb = new StringBuilder("Connection{"); sb.append(this.route.address().url().host()); sb.append(':'); sb.append(this.route.address().url().port()); 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 synchronized void trackFailure$okhttp(@NotNull RealCall call, @Nullable IOException e10) { try { g.i(call, "call"); if (e10 instanceof StreamResetException) { if (((StreamResetException) e10).errorCode == ErrorCode.REFUSED_STREAM) { int i10 = this.refusedStreamCount + 1; this.refusedStreamCount = i10; if (i10 > 1) { this.noNewExchanges = true; this.routeFailureCount++; } } else if (((StreamResetException) e10).errorCode != ErrorCode.CANCEL || !call.getCanceled()) { this.noNewExchanges = true; this.routeFailureCount++; } } else if (!isMultiplexed$okhttp() || (e10 instanceof ConnectionShutdownException)) { this.noNewExchanges = true; if (this.successCount == 0) { if (e10 != null) { connectFailed$okhttp(call.getClient(), this.route, e10); } this.routeFailureCount++; } } } catch (Throwable th) { throw th; } } }