package okhttp3.internal.connection; import com.ifpdos.sdk.httpd.binder.aidl.RequestLine; import j.n; import j.p0.d.r; import java.io.IOException; import okhttp3.Address; import okhttp3.EventListener; import okhttp3.HttpUrl; import okhttp3.OkHttpClient; import okhttp3.Route; import okhttp3.internal.Util; import okhttp3.internal.connection.RouteSelector; import okhttp3.internal.http.ExchangeCodec; import okhttp3.internal.http.RealInterceptorChain; import okhttp3.internal.http2.ConnectionShutdownException; import okhttp3.internal.http2.ErrorCode; import okhttp3.internal.http2.StreamResetException; /* JADX INFO: compiled from: ExchangeFinder.kt */ /* JADX INFO: loaded from: classes.dex */ @n(bv = {1, 0, 3}, d1 = {"\u0000v\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\t\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\u0018\u0000B'\u0012\u0006\u0010)\u001a\u00020(\u0012\u0006\u0010 \u001a\u00020\u001f\u0012\u0006\u0010%\u001a\u00020$\u0012\u0006\u0010.\u001a\u00020-¢\u0006\u0004\b;\u0010", "(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Address;Lokhttp3/internal/connection/RealCall;Lokhttp3/EventListener;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class ExchangeFinder { private final Address address; private final RealCall call; private RealConnection connectingConnection; private final RealConnectionPool connectionPool; private int connectionShutdownCount; private final EventListener eventListener; private Route nextRouteToTry; private int otherFailureCount; private int refusedStreamCount; private RouteSelector.Selection routeSelection; private RouteSelector routeSelector; public ExchangeFinder(RealConnectionPool realConnectionPool, Address address, RealCall realCall, EventListener eventListener) { r.g(realConnectionPool, "connectionPool"); r.g(address, "address"); r.g(realCall, "call"); r.g(eventListener, "eventListener"); this.connectionPool = realConnectionPool; this.address = address; this.call = realCall; this.eventListener = eventListener; } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:35:0x0090 */ /* JADX WARN: Removed duplicated region for block: B:72:0x0100 */ /* JADX WARN: Type inference failed for: r3v4, types: [T, okhttp3.internal.connection.RealConnection] */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ private final okhttp3.internal.connection.RealConnection findConnection(int r19, int r20, int r21, int r22, boolean r23) throws java.lang.Throwable { /* Method dump skipped, instruction units count: 533 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.connection.ExchangeFinder.findConnection(int, int, int, int, boolean):okhttp3.internal.connection.RealConnection"); } private final RealConnection findHealthyConnection(int i2, int i3, int i4, int i5, boolean z, boolean z2) throws Throwable { while (true) { RealConnection realConnectionFindConnection = findConnection(i2, i3, i4, i5, z); if (realConnectionFindConnection.isHealthy(z2)) { return realConnectionFindConnection; } realConnectionFindConnection.noNewExchanges(); } } private final boolean retryCurrentRoute() { RealConnection connection; return this.refusedStreamCount <= 1 && this.connectionShutdownCount <= 1 && this.otherFailureCount <= 0 && (connection = this.call.getConnection()) != null && connection.getRouteFailureCount$okhttp() == 0 && Util.canReuseConnectionFor(connection.route().address().url(), this.address.url()); } public final RealConnection connectingConnection() { RealConnectionPool realConnectionPool = this.connectionPool; if (!Util.assertionsEnabled || Thread.holdsLock(realConnectionPool)) { return this.connectingConnection; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST hold lock on "); sb.append(realConnectionPool); throw new AssertionError(sb.toString()); } public final ExchangeCodec find(OkHttpClient okHttpClient, RealInterceptorChain realInterceptorChain) { r.g(okHttpClient, "client"); r.g(realInterceptorChain, "chain"); try { return findHealthyConnection(realInterceptorChain.getConnectTimeoutMillis$okhttp(), realInterceptorChain.getReadTimeoutMillis$okhttp(), realInterceptorChain.getWriteTimeoutMillis$okhttp(), okHttpClient.pingIntervalMillis(), okHttpClient.retryOnConnectionFailure(), !r.a(realInterceptorChain.getRequest$okhttp().method(), RequestLine.METHOD_GET)).newCodec$okhttp(okHttpClient, realInterceptorChain); } catch (IOException e) { trackFailure(e); throw new RouteException(e); } catch (RouteException e2) { trackFailure(e2.getLastConnectException()); throw e2; } } public final Address getAddress$okhttp() { return this.address; } public final boolean retryAfterFailure() { synchronized (this.connectionPool) { if (this.refusedStreamCount == 0 && this.connectionShutdownCount == 0 && this.otherFailureCount == 0) { return false; } if (this.nextRouteToTry != null) { return true; } if (retryCurrentRoute()) { RealConnection connection = this.call.getConnection(); if (connection != null) { this.nextRouteToTry = connection.route(); return true; } r.p(); throw null; } RouteSelector.Selection selection = this.routeSelection; if (selection != null && selection.hasNext()) { return true; } RouteSelector routeSelector = this.routeSelector; if (routeSelector == null) { return true; } return routeSelector.hasNext(); } } public final void trackFailure(IOException iOException) { r.g(iOException, "e"); 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) { this.nextRouteToTry = null; if ((iOException instanceof StreamResetException) && ((StreamResetException) iOException).errorCode == ErrorCode.REFUSED_STREAM) { this.refusedStreamCount++; } else if (iOException instanceof ConnectionShutdownException) { this.connectionShutdownCount++; } else { this.otherFailureCount++; } } } }