package okhttp3.internal.connection; import androidx.media3.container.NalUnitUtil; import androidx.media3.exoplayer.rtsp.RtspHeaders; import com.google.android.gms.common.internal.ImagesContract; import defpackage.cr4; import defpackage.eu6; import defpackage.ko9; import defpackage.kp6; import defpackage.n89; import defpackage.pq6; import defpackage.qq3; import defpackage.rh0; import defpackage.sh0; import defpackage.u55; import defpackage.uz1; import defpackage.vw2; import defpackage.vx8; import defpackage.y41; 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.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 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; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000î\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\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\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \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\u0005\n\u0002\u0018\u0002\n\u0002\b\u0003\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\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0016\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0010!\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\t\n\u0002\b\n\u0018\u0000  \u00012\u00020\u00012\u00020\u0002:\u0002 \u0001B\u0017\u0012\u0006\u0010\u0004\u001a\u00020\u0003\u0012\u0006\u0010\u0006\u001a\u00020\u0005¢\u0006\u0004\b\u0007\u0010\bJ\u000f\u0010\f\u001a\u00020\tH\u0000¢\u0006\u0004\b\n\u0010\u000bJ\u000f\u0010\u000e\u001a\u00020\tH\u0000¢\u0006\u0004\b\r\u0010\u000bJ\u000f\u0010\u0010\u001a\u00020\tH\u0000¢\u0006\u0004\b\u000f\u0010\u000bJE\u0010\u001c\u001a\u00020\t2\u0006\u0010\u0012\u001a\u00020\u00112\u0006\u0010\u0013\u001a\u00020\u00112\u0006\u0010\u0014\u001a\u00020\u00112\u0006\u0010\u0015\u001a\u00020\u00112\u0006\u0010\u0017\u001a\u00020\u00162\u0006\u0010\u0019\u001a\u00020\u00182\u0006\u0010\u001b\u001a\u00020\u001a¢\u0006\u0004\b\u001c\u0010\u001dJ'\u0010$\u001a\u00020\u00162\u0006\u0010\u001f\u001a\u00020\u001e2\u000e\u0010!\u001a\n\u0012\u0004\u0012\u00020\u0005\u0018\u00010 H\u0000¢\u0006\u0004\b\"\u0010#J\u001f\u0010,\u001a\u00020)2\u0006\u0010&\u001a\u00020%2\u0006\u0010(\u001a\u00020'H\u0000¢\u0006\u0004\b*\u0010+J\u0017\u00102\u001a\u00020/2\u0006\u0010.\u001a\u00020-H\u0000¢\u0006\u0004\b0\u00101J\u000f\u0010\u0006\u001a\u00020\u0005H\u0016¢\u0006\u0004\b\u0006\u00103J\r\u00104\u001a\u00020\t¢\u0006\u0004\b4\u0010\u000bJ\u000f\u00106\u001a\u000205H\u0016¢\u0006\u0004\b6\u00107J\u0015\u00109\u001a\u00020\u00162\u0006\u00108\u001a\u00020\u0016¢\u0006\u0004\b9\u0010:J\u0017\u0010=\u001a\u00020\t2\u0006\u0010<\u001a\u00020;H\u0016¢\u0006\u0004\b=\u0010>J\u001f\u0010C\u001a\u00020\t2\u0006\u0010@\u001a\u00020?2\u0006\u0010B\u001a\u00020AH\u0016¢\u0006\u0004\bC\u0010DJ\u0011\u0010F\u001a\u0004\u0018\u00010EH\u0016¢\u0006\u0004\bF\u0010GJ'\u0010M\u001a\u00020\t2\u0006\u0010&\u001a\u00020%2\u0006\u0010H\u001a\u00020\u00052\u0006\u0010J\u001a\u00020IH\u0000¢\u0006\u0004\bK\u0010LJ!\u0010R\u001a\u00020\t2\u0006\u0010\u0019\u001a\u00020N2\b\u0010O\u001a\u0004\u0018\u00010IH\u0000¢\u0006\u0004\bP\u0010QJ\u000f\u0010T\u001a\u00020SH\u0016¢\u0006\u0004\bT\u0010UJ\u000f\u0010W\u001a\u00020VH\u0016¢\u0006\u0004\bW\u0010XJ7\u0010Y\u001a\u00020\t2\u0006\u0010\u0012\u001a\u00020\u00112\u0006\u0010\u0013\u001a\u00020\u00112\u0006\u0010\u0014\u001a\u00020\u00112\u0006\u0010\u0019\u001a\u00020\u00182\u0006\u0010\u001b\u001a\u00020\u001aH\u0002¢\u0006\u0004\bY\u0010ZJ/\u0010[\u001a\u00020\t2\u0006\u0010\u0012\u001a\u00020\u00112\u0006\u0010\u0013\u001a\u00020\u00112\u0006\u0010\u0019\u001a\u00020\u00182\u0006\u0010\u001b\u001a\u00020\u001aH\u0002¢\u0006\u0004\b[\u0010\\J/\u0010_\u001a\u00020\t2\u0006\u0010^\u001a\u00020]2\u0006\u0010\u0015\u001a\u00020\u00112\u0006\u0010\u0019\u001a\u00020\u00182\u0006\u0010\u001b\u001a\u00020\u001aH\u0002¢\u0006\u0004\b_\u0010`J\u0017\u0010a\u001a\u00020\t2\u0006\u0010\u0015\u001a\u00020\u0011H\u0002¢\u0006\u0004\ba\u0010bJ\u0017\u0010c\u001a\u00020\t2\u0006\u0010^\u001a\u00020]H\u0002¢\u0006\u0004\bc\u0010dJ1\u0010i\u001a\u0004\u0018\u00010e2\u0006\u0010\u0013\u001a\u00020\u00112\u0006\u0010\u0014\u001a\u00020\u00112\u0006\u0010f\u001a\u00020e2\u0006\u0010h\u001a\u00020gH\u0002¢\u0006\u0004\bi\u0010jJ\u000f\u0010k\u001a\u00020eH\u0002¢\u0006\u0004\bk\u0010lJ\u001d\u0010n\u001a\u00020\u00162\f\u0010m\u001a\b\u0012\u0004\u0012\u00020\u00050 H\u0002¢\u0006\u0004\bn\u0010oJ\u0017\u0010p\u001a\u00020\u00162\u0006\u0010h\u001a\u00020gH\u0002¢\u0006\u0004\bp\u0010qJ\u001f\u0010r\u001a\u00020\u00162\u0006\u0010h\u001a\u00020g2\u0006\u0010F\u001a\u00020EH\u0002¢\u0006\u0004\br\u0010sR\u0017\u0010\u0004\u001a\u00020\u00038\u0006¢\u0006\f\n\u0004\b\u0004\u0010t\u001a\u0004\bu\u0010vR\u0014\u0010\u0006\u001a\u00020\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0006\u0010wR\u0018\u0010x\u001a\u0004\u0018\u0001058\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bx\u0010yR\u0018\u00106\u001a\u0004\u0018\u0001058\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b6\u0010yR\u0018\u0010F\u001a\u0004\u0018\u00010E8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bF\u0010zR\u0018\u0010T\u001a\u0004\u0018\u00010S8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bT\u0010{R\u0018\u0010|\u001a\u0004\u0018\u00010?8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b|\u0010}R\u0019\u0010\u007f\u001a\u0004\u0018\u00010~8\u0002@\u0002X\u0082\u000e¢\u0006\u0007\n\u0005\b\u007f\u0010\u0080\u0001R\u001c\u0010\u0082\u0001\u001a\u0005\u0018\u00010\u0081\u00018\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0082\u0001\u0010\u0083\u0001R'\u0010\f\u001a\u00020\u00168\u0006@\u0006X\u0086\u000e¢\u0006\u0017\n\u0005\b\f\u0010\u0084\u0001\u001a\u0006\b\u0085\u0001\u0010\u0086\u0001\"\u0006\b\u0087\u0001\u0010\u0088\u0001R\u0017\u0010\u000e\u001a\u00020\u00168\u0002@\u0002X\u0082\u000e¢\u0006\u0007\n\u0005\b\u000e\u0010\u0084\u0001R(\u0010\u0089\u0001\u001a\u00020\u00118\u0000@\u0000X\u0080\u000e¢\u0006\u0017\n\u0006\b\u0089\u0001\u0010\u008a\u0001\u001a\u0006\b\u008b\u0001\u0010\u008c\u0001\"\u0005\b\u008d\u0001\u0010bR\u0019\u0010\u008e\u0001\u001a\u00020\u00118\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u008e\u0001\u0010\u008a\u0001R\u0019\u0010\u008f\u0001\u001a\u00020\u00118\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u008f\u0001\u0010\u008a\u0001R\u0019\u0010\u0090\u0001\u001a\u00020\u00118\u0002@\u0002X\u0082\u000e¢\u0006\b\n\u0006\b\u0090\u0001\u0010\u008a\u0001R*\u0010\u0093\u0001\u001a\u0010\u0012\u000b\u0012\t\u0012\u0004\u0012\u00020N0\u0092\u00010\u0091\u00018\u0006¢\u0006\u0010\n\u0006\b\u0093\u0001\u0010\u0094\u0001\u001a\u0006\b\u0095\u0001\u0010\u0096\u0001R*\u0010\u0098\u0001\u001a\u00030\u0097\u00018\u0000@\u0000X\u0080\u000e¢\u0006\u0018\n\u0006\b\u0098\u0001\u0010\u0099\u0001\u001a\u0006\b\u009a\u0001\u0010\u009b\u0001\"\u0006\b\u009c\u0001\u0010\u009d\u0001R\u0017\u0010\u009f\u0001\u001a\u00020\u00168@X\u0080\u0004¢\u0006\b\u001a\u0006\b\u009e\u0001\u0010\u0086\u0001¨\u0006¡\u0001"}, d2 = {"Lokhttp3/internal/connection/RealConnection;", "Lokhttp3/internal/http2/Http2Connection$Listener;", "Lokhttp3/Connection;", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/Route;", "route", "", "(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Route;)V", "Le6a;", "noNewExchanges$okhttp", "()V", "noNewExchanges", "noCoalescedConnections$okhttp", "noCoalescedConnections", "incrementSuccessCount$okhttp", "incrementSuccessCount", "", "connectTimeout", "readTimeout", "writeTimeout", "pingIntervalMillis", "", "connectionRetryEnabled", "Lokhttp3/Call;", "call", "Lokhttp3/EventListener;", "eventListener", "connect", "(IIIIZLokhttp3/Call;Lokhttp3/EventListener;)V", "Lokhttp3/Address;", "address", "", "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", "()Lokhttp3/Route;", "cancel", "Ljava/net/Socket;", "socket", "()Ljava/net/Socket;", "doExtensiveChecks", "isHealthy", "(Z)Z", "Lokhttp3/internal/http2/Http2Stream;", "stream", "onStream", "(Lokhttp3/internal/http2/Http2Stream;)V", "Lokhttp3/internal/http2/Http2Connection;", "connection", "Lokhttp3/internal/http2/Settings;", "settings", "onSettings", "(Lokhttp3/internal/http2/Http2Connection;Lokhttp3/internal/http2/Settings;)V", "Lokhttp3/Handshake;", "handshake", "()Lokhttp3/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;", "protocol", "()Lokhttp3/Protocol;", "", "toString", "()Ljava/lang/String;", "connectTunnel", "(IIILokhttp3/Call;Lokhttp3/EventListener;)V", "connectSocket", "(IILokhttp3/Call;Lokhttp3/EventListener;)V", "Lokhttp3/internal/connection/ConnectionSpecSelector;", "connectionSpecSelector", "establishProtocol", "(Lokhttp3/internal/connection/ConnectionSpecSelector;ILokhttp3/Call;Lokhttp3/EventListener;)V", "startHttp2", "(I)V", "connectTls", "(Lokhttp3/internal/connection/ConnectionSpecSelector;)V", "Lokhttp3/Request;", "tunnelRequest", "Lokhttp3/HttpUrl;", ImagesContract.URL, "createTunnel", "(IILokhttp3/Request;Lokhttp3/HttpUrl;)Lokhttp3/Request;", "createTunnelRequest", "()Lokhttp3/Request;", "candidates", "routeMatchesAny", "(Ljava/util/List;)Z", "supportsUrl", "(Lokhttp3/HttpUrl;)Z", "certificateSupportHost", "(Lokhttp3/HttpUrl;Lokhttp3/Handshake;)Z", "Lokhttp3/internal/connection/RealConnectionPool;", "getConnectionPool", "()Lokhttp3/internal/connection/RealConnectionPool;", "Lokhttp3/Route;", "rawSocket", "Ljava/net/Socket;", "Lokhttp3/Handshake;", "Lokhttp3/Protocol;", "http2Connection", "Lokhttp3/internal/http2/Http2Connection;", "Lsh0;", "source", "Lsh0;", "Lrh0;", "sink", "Lrh0;", "Z", "getNoNewExchanges", "()Z", "setNoNewExchanges", "(Z)V", "routeFailureCount", "I", "getRouteFailureCount$okhttp", "()I", "setRouteFailureCount$okhttp", "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", "Companion", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class RealConnection extends Http2Connection.Listener implements Connection { /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */ @kp6 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; @kp6 private static final String NPE_THROW_WITH_NULL = "throw with null exception"; private int allocationLimit; @kp6 private final List> calls; @kp6 private final RealConnectionPool connectionPool; @pq6 private Handshake handshake; @pq6 private Http2Connection http2Connection; private long idleAtNs; private boolean noCoalescedConnections; private boolean noNewExchanges; @pq6 private Protocol protocol; @pq6 private Socket rawSocket; private int refusedStreamCount; @kp6 private final Route route; private int routeFailureCount; @pq6 private rh0 sink; @pq6 private Socket socket; @pq6 private sh0 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 = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class Companion { public /* synthetic */ Companion(uz1 uz1Var) { this(); } @kp6 public final RealConnection newTestConnection(@kp6 RealConnectionPool connectionPool, @kp6 Route route, @kp6 Socket socket, long idleAtNs) { cr4.g(connectionPool, "connectionPool"); cr4.g(route, "route"); cr4.g(socket, "socket"); RealConnection realConnection = new RealConnection(connectionPool, route); realConnection.socket = socket; realConnection.setIdleAtNs$okhttp(idleAtNs); return realConnection; } private Companion() { } } @Metadata(k = 3, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) 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; } } /* JADX INFO: renamed from: okhttp3.internal.connection.RealConnection$connectTls$1, reason: invalid class name */ @Metadata(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 = {"", "", "Ljava/security/cert/Certificate;", "invoke"}, k = 3, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class AnonymousClass1 extends u55 implements qq3> { 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) */ public AnonymousClass1(CertificatePinner certificatePinner, Handshake handshake, Address address) { super(0); this.$certificatePinner = certificatePinner; this.$unverifiedHandshake = handshake; this.$address = address; } @Override // defpackage.qq3 @kp6 public final List invoke() { CertificateChainCleaner certificateChainCleaner$okhttp = this.$certificatePinner.getCertificateChainCleaner(); cr4.d(certificateChainCleaner$okhttp); return certificateChainCleaner$okhttp.clean(this.$unverifiedHandshake.peerCertificates(), this.$address.url().host()); } } /* JADX INFO: renamed from: okhttp3.internal.connection.RealConnection$connectTls$2, reason: invalid class name */ @Metadata(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 = {"", "", "Ljava/security/cert/X509Certificate;", "invoke"}, k = 3, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public static final class AnonymousClass2 extends u55 implements qq3> { public AnonymousClass2() { super(0); } @Override // defpackage.qq3 @kp6 public final List invoke() { Handshake handshake = RealConnection.this.handshake; cr4.d(handshake); List listPeerCertificates = handshake.peerCertificates(); ArrayList arrayList = new ArrayList(y41.p(listPeerCertificates, 10)); for (Certificate certificate : listPeerCertificates) { cr4.e(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate"); arrayList.add((X509Certificate) certificate); } return arrayList; } } public RealConnection(@kp6 RealConnectionPool realConnectionPool, @kp6 Route route) { cr4.g(realConnectionPool, "connectionPool"); cr4.g(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); cr4.e(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 connectTimeout, int readTimeout, Call call, EventListener eventListener) throws IOException { Socket socketCreateSocket; Proxy proxy = this.route.proxy(); Address address = this.route.address(); Proxy.Type type = proxy.type(); int i = type == null ? -1 : WhenMappings.$EnumSwitchMapping$0[type.ordinal()]; if (i == 1 || i == 2) { socketCreateSocket = address.socketFactory().createSocket(); cr4.d(socketCreateSocket); } else { socketCreateSocket = new Socket(proxy); } this.rawSocket = socketCreateSocket; eventListener.connectStart(call, this.route.socketAddress(), proxy); socketCreateSocket.setSoTimeout(readTimeout); try { Platform.INSTANCE.get().connectSocket(socketCreateSocket, this.route.socketAddress(), connectTimeout); try { this.source = eu6.d(eu6.j(socketCreateSocket)); this.sink = eu6.c(eu6.f(socketCreateSocket)); } catch (NullPointerException e) { if (cr4.b(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 { cr4.d(sslSocketFactory); Socket socketCreateSocket = sslSocketFactory.createSocket(this.rawSocket, address.url().host(), address.url().port(), true); cr4.e(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; cr4.f(session, "sslSocketSession"); Handshake handshake = companion.get(session); HostnameVerifier hostnameVerifier = address.hostnameVerifier(); cr4.d(hostnameVerifier); if (hostnameVerifier.verify(address.url().host(), session)) { CertificatePinner certificatePinner = address.certificatePinner(); cr4.d(certificatePinner); 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.INSTANCE.get().getSelectedProtocol(sSLSocket2) : null; this.socket = sSLSocket2; this.source = eu6.d(eu6.j(sSLSocket2)); this.sink = eu6.c(eu6.f(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); cr4.e(certificate, "null cannot be cast to non-null type java.security.cert.X509Certificate"); X509Certificate x509Certificate = (X509Certificate) certificate; throw new SSLPeerUnverifiedException(n89.bj("\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 connectTimeout, int readTimeout, int writeTimeout, Call call, EventListener eventListener) throws IOException { Request requestCreateTunnelRequest = createTunnelRequest(); HttpUrl httpUrlUrl = requestCreateTunnelRequest.url(); for (int i = 0; i < 21; i++) { connectSocket(connectTimeout, readTimeout, call, eventListener); requestCreateTunnelRequest = createTunnel(readTimeout, writeTimeout, 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) { sh0 sh0Var = this.source; cr4.d(sh0Var); rh0 rh0Var = this.sink; cr4.d(rh0Var); Http1ExchangeCodec http1ExchangeCodec = new Http1ExchangeCodec(null, this, sh0Var, rh0Var); TimeUnit timeUnit = TimeUnit.MILLISECONDS; sh0Var.getTimeout().timeout(readTimeout, timeUnit); rh0Var.getB().timeout(writeTimeout, timeUnit); http1ExchangeCodec.writeRequest(tunnelRequest.headers(), str); http1ExchangeCodec.finishRequest(); Response.Builder responseHeaders = http1ExchangeCodec.readResponseHeaders(false); cr4.d(responseHeaders); Response responseBuild = responseHeaders.request(tunnelRequest).build(); http1ExchangeCodec.skipConnectBody(responseBuild); int iCode = responseBuild.code(); if (iCode == 200) { if (sh0Var.getB().j() && rh0Var.getB().j()) { 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 ("close".equalsIgnoreCase(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 pingIntervalMillis, 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(pingIntervalMillis); 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(pingIntervalMillis); } } 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 && cr4.b(this.route.socketAddress(), route.socketAddress())) { return true; } } return false; } private final void startHttp2(int pingIntervalMillis) throws IOException { Socket socket = this.socket; cr4.d(socket); sh0 sh0Var = this.source; cr4.d(sh0Var); rh0 rh0Var = this.sink; cr4.d(rh0Var); socket.setSoTimeout(0); Http2Connection http2ConnectionBuild = new Http2Connection.Builder(true, TaskRunner.INSTANCE).socket(socket, this.route.address().url().host(), sh0Var, rh0Var).listener(this).pingIntervalMillis(pingIntervalMillis).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 (cr4.b(url.host(), httpUrlUrl.host())) { return true; } if (!this.noCoalescedConnections && (handshake = this.handshake) != null) { cr4.d(handshake); if (certificateSupportHost(url, handshake)) { return true; } } return false; } public final void cancel() { Socket socket = this.rawSocket; if (socket != null) { Util.closeQuietly(socket); } } /* JADX WARN: Code restructure failed: missing block: B:36:0x00c9, code lost: if (r12.route.requiresTunnel() == false) goto L42; */ /* JADX WARN: Code restructure failed: missing block: B:38:0x00cd, code lost: if (r12.rawSocket == null) goto L40; */ /* JADX WARN: Code restructure failed: missing block: B:41:0x00dc, code lost: throw new okhttp3.internal.connection.RouteException(new java.net.ProtocolException("Too many tunnel connections attempted: 21")); */ /* JADX WARN: Code restructure failed: missing block: B:42:0x00dd, code lost: r12.idleAtNs = java.lang.System.nanoTime(); */ /* JADX WARN: Code restructure failed: missing block: B:43:0x00e3, code lost: return; */ /* JADX WARN: Removed duplicated region for block: B:50:0x00ed */ /* JADX WARN: Removed duplicated region for block: B:53:0x00f4 */ /* JADX WARN: Removed duplicated region for block: B:56:0x011a */ /* JADX WARN: Removed duplicated region for block: B:57:0x0120 */ /* JADX WARN: Removed duplicated region for block: B:59:0x0125 */ /* JADX WARN: Removed duplicated region for block: B:77:0x0131 A[SYNTHETIC] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void connect(int connectTimeout, int readTimeout, int writeTimeout, int pingIntervalMillis, boolean connectionRetryEnabled, @kp6 Call call, @kp6 EventListener eventListener) throws Throwable { Socket socket; Socket socket2; Call call2 = call; EventListener eventListener2 = eventListener; cr4.g(call2, "call"); cr4.g(eventListener2, "eventListener"); if (this.protocol != null) { throw new IllegalStateException("already connected"); } 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(vw2.ab("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; while (true) { try { if (this.route.requiresTunnel()) { EventListener eventListener3 = eventListener2; Call call3 = call2; try { connectTunnel(connectTimeout, readTimeout, writeTimeout, call3, eventListener3); call2 = call3; eventListener2 = eventListener3; } catch (IOException e) { e = e; call2 = call3; eventListener2 = eventListener3; } try { if (this.rawSocket == null) { break; } } catch (IOException e2) { e = e2; IOException iOException = e; 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; eventListener2.connectFailed(call2, this.route.socketAddress(), this.route.proxy(), null, iOException); if (routeException != null) { } if (connectionRetryEnabled) { } } } else { connectSocket(connectTimeout, readTimeout, call2, eventListener2); } } catch (IOException e3) { e = e3; } try { establishProtocol(connectionSpecSelector, pingIntervalMillis, call2, eventListener2); eventListener2.connectEnd(call2, this.route.socketAddress(), this.route.proxy(), this.protocol); break; } catch (IOException e4) { e = e4; IOException iOException2 = e; socket = this.socket; if (socket != null) { Util.closeQuietly(socket); } socket2 = this.rawSocket; if (socket2 != null) { Util.closeQuietly(socket2); } this.socket = null; this.rawSocket = null; this.source = null; this.sink = null; this.handshake = null; this.protocol = null; this.http2Connection = null; this.allocationLimit = 1; eventListener2.connectFailed(call2, this.route.socketAddress(), this.route.proxy(), null, iOException2); if (routeException != null) { routeException = new RouteException(iOException2); } else { routeException.addConnectException(iOException2); } if (connectionRetryEnabled) { throw routeException; } if (!connectionSpecSelector.connectionFailed(iOException2)) { throw routeException; } call2 = call; eventListener2 = eventListener; } call2 = call; eventListener2 = eventListener; } } public final void connectFailed$okhttp(@kp6 OkHttpClient client, @kp6 Route failedRoute, @kp6 IOException failure) { cr4.g(client, "client"); cr4.g(failedRoute, "failedRoute"); cr4.g(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); } @kp6 public final List> getCalls() { return this.calls; } @kp6 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 @pq6 /* 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(@kp6 Address address, @pq6 List routes) { cr4.g(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 (cr4.b(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(); cr4.d(certificatePinner); String strHost = address.url().host(); Handshake handshake = getHandshake(); cr4.d(handshake); certificatePinner.check(strHost, handshake.peerCertificates()); return true; } catch (SSLPeerUnverifiedException unused) { return false; } } public final boolean isHealthy(boolean doExtensiveChecks) { long j; 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; cr4.d(socket); Socket socket2 = this.socket; cr4.d(socket2); sh0 sh0Var = this.source; cr4.d(sh0Var); if (socket.isClosed() || socket2.isClosed() || socket2.isInputShutdown() || socket2.isOutputShutdown()) { return false; } Http2Connection http2Connection = this.http2Connection; if (http2Connection != null) { return http2Connection.isHealthy(jNanoTime); } synchronized (this) { j = jNanoTime - this.idleAtNs; } if (j < IDLE_CONNECTION_HEALTHY_NS || !doExtensiveChecks) { return true; } return Util.isHealthy(socket2, sh0Var); } public final boolean isMultiplexed$okhttp() { return this.http2Connection != null; } @kp6 public final ExchangeCodec newCodec$okhttp(@kp6 OkHttpClient client, @kp6 RealInterceptorChain chain) throws SocketException { cr4.g(client, "client"); cr4.g(chain, "chain"); Socket socket = this.socket; cr4.d(socket); sh0 sh0Var = this.source; cr4.d(sh0Var); rh0 rh0Var = this.sink; cr4.d(rh0Var); Http2Connection http2Connection = this.http2Connection; if (http2Connection != null) { return new Http2ExchangeCodec(client, this, chain, http2Connection); } socket.setSoTimeout(chain.readTimeoutMillis()); ko9 b = sh0Var.getTimeout(); long readTimeoutMillis$okhttp = chain.getReadTimeoutMillis(); TimeUnit timeUnit = TimeUnit.MILLISECONDS; b.timeout(readTimeoutMillis$okhttp, timeUnit); rh0Var.getB().timeout(chain.getWriteTimeoutMillis(), timeUnit); return new Http1ExchangeCodec(client, this, sh0Var, rh0Var); } @kp6 public final RealWebSocket.Streams newWebSocketStreams$okhttp(@kp6 final Exchange exchange) throws SocketException { cr4.g(exchange, "exchange"); Socket socket = this.socket; cr4.d(socket); final sh0 sh0Var = this.source; cr4.d(sh0Var); final rh0 rh0Var = this.sink; cr4.d(rh0Var); socket.setSoTimeout(0); noNewExchanges$okhttp(); return new RealWebSocket.Streams(sh0Var, rh0Var) { // 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(@kp6 Http2Connection connection, @kp6 Settings settings) { cr4.g(connection, "connection"); cr4.g(settings, "settings"); this.allocationLimit = settings.getMaxConcurrentStreams(); } @Override // okhttp3.internal.http2.Http2Connection.Listener public void onStream(@kp6 Http2Stream stream) throws IOException { cr4.g(stream, "stream"); stream.close(ErrorCode.REFUSED_STREAM, null); } @Override // okhttp3.Connection @kp6 public Protocol protocol() { Protocol protocol = this.protocol; cr4.d(protocol); return protocol; } @Override // okhttp3.Connection @kp6 /* JADX INFO: renamed from: route, reason: from getter */ public Route getRoute() { return this.route; } public final void setIdleAtNs$okhttp(long j) { this.idleAtNs = j; } public final void setNoNewExchanges(boolean z) { this.noNewExchanges = z; } public final void setRouteFailureCount$okhttp(int i) { this.routeFailureCount = i; } @Override // okhttp3.Connection @kp6 public Socket socket() { Socket socket = this.socket; cr4.d(socket); return socket; } @kp6 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(@kp6 RealCall call, @pq6 IOException e) { try { cr4.g(call, "call"); if (e instanceof StreamResetException) { if (((StreamResetException) e).errorCode == ErrorCode.REFUSED_STREAM) { int i = this.refusedStreamCount + 1; this.refusedStreamCount = i; if (i > 1) { this.noNewExchanges = true; this.routeFailureCount++; } } else if (((StreamResetException) e).errorCode != ErrorCode.CANCEL || !call.getCanceled()) { this.noNewExchanges = true; this.routeFailureCount++; } } else if (!isMultiplexed$okhttp() || (e instanceof ConnectionShutdownException)) { this.noNewExchanges = true; if (this.successCount == 0) { if (e != null) { connectFailed$okhttp(call.getClient(), this.route, e); } this.routeFailureCount++; } } } catch (Throwable th) { throw th; } } }