package okhttp3.internal.connection; import com.pichillilorenzo.flutter_inappwebview_android.credential_database.URLProtectionSpaceContract; import java.io.IOException; import java.io.InterruptedIOException; import java.lang.ref.Reference; import java.lang.ref.WeakReference; import java.net.Socket; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.SSLSocketFactory; import kotlin.Metadata; import kotlin.a; import kotlin.collections.k; import kotlin.jvm.internal.SourceDebugExtension; import nb.g; import okhttp3.Address; import okhttp3.Call; import okhttp3.Callback; import okhttp3.CertificatePinner; import okhttp3.Dispatcher; import okhttp3.EventListener; import okhttp3.HttpUrl; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; import okhttp3.internal.Util; import okhttp3.internal.cache.CacheInterceptor; import okhttp3.internal.http.BridgeInterceptor; import okhttp3.internal.http.CallServerInterceptor; import okhttp3.internal.http.RealInterceptorChain; import okhttp3.internal.http.RetryAndFollowUpInterceptor; import okhttp3.internal.platform.Platform; import okio.AsyncTimeout; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; 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\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0010\u000e\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0017*\u0001W\u0018\u00002\u00020\u0001:\u0002tuB\u001f\u0012\u0006\u0010C\u001a\u00020B\u0012\u0006\u0010G\u001a\u00020\u0005\u0012\u0006\u0010K\u001a\u00020\t¢\u0006\u0004\br\u0010sJ\b\u0010\u0003\u001a\u00020\u0002H\u0016J\b\u0010\u0004\u001a\u00020\u0000H\u0016J\b\u0010\u0006\u001a\u00020\u0005H\u0016J\b\u0010\b\u001a\u00020\u0007H\u0016J\b\u0010\n\u001a\u00020\tH\u0016J\b\u0010\f\u001a\u00020\u000bH\u0016J\u0010\u0010\u000f\u001a\u00020\u00072\u0006\u0010\u000e\u001a\u00020\rH\u0016J\b\u0010\u0010\u001a\u00020\tH\u0016J\u000f\u0010\u0013\u001a\u00020\u000bH\u0000¢\u0006\u0004\b\u0011\u0010\u0012J\u0016\u0010\u0015\u001a\u00020\u00072\u0006\u0010\u0006\u001a\u00020\u00052\u0006\u0010\u0014\u001a\u00020\tJ\u0017\u0010\u001b\u001a\u00020\u00182\u0006\u0010\u0017\u001a\u00020\u0016H\u0000¢\u0006\u0004\b\u0019\u0010\u001aJ\u000e\u0010\u001e\u001a\u00020\u00072\u0006\u0010\u001d\u001a\u00020\u001cJ;\u0010'\u001a\u00028\u0000\"\n\b\u0000\u0010 *\u0004\u0018\u00010\u001f2\u0006\u0010!\u001a\u00020\u00182\u0006\u0010\"\u001a\u00020\t2\u0006\u0010#\u001a\u00020\t2\u0006\u0010$\u001a\u00028\u0000H\u0000¢\u0006\u0004\b%\u0010&J\u001b\u0010*\u001a\u0004\u0018\u00010\u001f2\b\u0010$\u001a\u0004\u0018\u00010\u001fH\u0000¢\u0006\u0004\b(\u0010)J\u0011\u0010.\u001a\u0004\u0018\u00010+H\u0000¢\u0006\u0004\b,\u0010-J\u0006\u0010/\u001a\u00020\u0007J\u0017\u00103\u001a\u00020\u00072\u0006\u00100\u001a\u00020\tH\u0000¢\u0006\u0004\b1\u00102J\u0006\u00104\u001a\u00020\tJ\u000f\u00108\u001a\u000205H\u0000¢\u0006\u0004\b6\u00107J\b\u00109\u001a\u00020\u0007H\u0002J#\u0010:\u001a\u00028\u0000\"\n\b\u0000\u0010 *\u0004\u0018\u00010\u001f2\u0006\u0010$\u001a\u00028\u0000H\u0002¢\u0006\u0004\b:\u0010)J#\u0010<\u001a\u00028\u0000\"\n\b\u0000\u0010 *\u0004\u0018\u00010\u001f2\u0006\u0010;\u001a\u00028\u0000H\u0002¢\u0006\u0004\b<\u0010)J\u0010\u0010@\u001a\u00020?2\u0006\u0010>\u001a\u00020=H\u0002J\b\u0010A\u001a\u000205H\u0002R\u0017\u0010C\u001a\u00020B8\u0006¢\u0006\f\n\u0004\bC\u0010D\u001a\u0004\bE\u0010FR\u0017\u0010G\u001a\u00020\u00058\u0006¢\u0006\f\n\u0004\bG\u0010H\u001a\u0004\bI\u0010JR\u0017\u0010K\u001a\u00020\t8\u0006¢\u0006\f\n\u0004\bK\u0010L\u001a\u0004\bM\u0010NR\u0014\u0010P\u001a\u00020O8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bP\u0010QR\u001a\u0010S\u001a\u00020R8\u0000X\u0080\u0004¢\u0006\f\n\u0004\bS\u0010T\u001a\u0004\bU\u0010VR\u0014\u0010\u0003\u001a\u00020W8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010XR\u0014\u0010Z\u001a\u00020Y8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bZ\u0010[R\u0018\u0010]\u001a\u0004\u0018\u00010\\8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b]\u0010^R\u0018\u0010`\u001a\u0004\u0018\u00010_8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b`\u0010aR(\u0010\u001d\u001a\u0004\u0018\u00010\u001c2\b\u0010b\u001a\u0004\u0018\u00010\u001c8\u0006@BX\u0086\u000e¢\u0006\f\n\u0004\b\u001d\u0010c\u001a\u0004\bd\u0010eR\u0016\u0010/\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b/\u0010LR(\u0010f\u001a\u0004\u0018\u00010\u00182\b\u0010b\u001a\u0004\u0018\u00010\u00188\u0000@BX\u0080\u000e¢\u0006\f\n\u0004\bf\u0010g\u001a\u0004\bh\u0010iR\u0016\u0010j\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bj\u0010LR\u0016\u0010k\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bk\u0010LR\u0016\u0010l\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bl\u0010LR\u0016\u0010m\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bm\u0010LR\u0018\u0010!\u001a\u0004\u0018\u00010\u00188\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b!\u0010gR$\u0010n\u001a\u0004\u0018\u00010\u001c8\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\bn\u0010c\u001a\u0004\bo\u0010e\"\u0004\bp\u0010q¨\u0006v"}, d2 = {"Lokhttp3/internal/connection/RealCall;", "Lokhttp3/Call;", "Lokio/AsyncTimeout;", "timeout", "clone", "Lokhttp3/Request;", "request", "Lkd/e;", "cancel", "", "isCanceled", "Lokhttp3/Response;", "execute", "Lokhttp3/Callback;", "responseCallback", "enqueue", "isExecuted", "getResponseWithInterceptorChain$okhttp", "()Lokhttp3/Response;", "getResponseWithInterceptorChain", "newExchangeFinder", "enterNetworkInterceptorExchange", "Lokhttp3/internal/http/RealInterceptorChain;", "chain", "Lokhttp3/internal/connection/Exchange;", "initExchange$okhttp", "(Lokhttp3/internal/http/RealInterceptorChain;)Lokhttp3/internal/connection/Exchange;", "initExchange", "Lokhttp3/internal/connection/RealConnection;", "connection", "acquireConnectionNoEvents", "Ljava/io/IOException;", "E", "exchange", "requestDone", "responseDone", "e", "messageDone$okhttp", "(Lokhttp3/internal/connection/Exchange;ZZLjava/io/IOException;)Ljava/io/IOException;", "messageDone", "noMoreExchanges$okhttp", "(Ljava/io/IOException;)Ljava/io/IOException;", "noMoreExchanges", "Ljava/net/Socket;", "releaseConnectionNoEvents$okhttp", "()Ljava/net/Socket;", "releaseConnectionNoEvents", "timeoutEarlyExit", "closeExchange", "exitNetworkInterceptorExchange$okhttp", "(Z)V", "exitNetworkInterceptorExchange", "retryAfterFailure", "", "redactedUrl$okhttp", "()Ljava/lang/String;", "redactedUrl", "callStart", "callDone", "cause", "timeoutExit", "Lokhttp3/HttpUrl;", IjkMediaPlayer.OnNativeInvokeListener.ARG_URL, "Lokhttp3/Address;", "createAddress", "toLoggableString", "Lokhttp3/OkHttpClient;", "client", "Lokhttp3/OkHttpClient;", "getClient", "()Lokhttp3/OkHttpClient;", "originalRequest", "Lokhttp3/Request;", "getOriginalRequest", "()Lokhttp3/Request;", "forWebSocket", "Z", "getForWebSocket", "()Z", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/internal/connection/RealConnectionPool;", "Lokhttp3/EventListener;", "eventListener", "Lokhttp3/EventListener;", "getEventListener$okhttp", "()Lokhttp3/EventListener;", "okhttp3/internal/connection/RealCall$timeout$1", "Lokhttp3/internal/connection/RealCall$timeout$1;", "Ljava/util/concurrent/atomic/AtomicBoolean;", "executed", "Ljava/util/concurrent/atomic/AtomicBoolean;", "", "callStackTrace", "Ljava/lang/Object;", "Lokhttp3/internal/connection/ExchangeFinder;", "exchangeFinder", "Lokhttp3/internal/connection/ExchangeFinder;", "", "Lokhttp3/internal/connection/RealConnection;", "getConnection", "()Lokhttp3/internal/connection/RealConnection;", "interceptorScopedExchange", "Lokhttp3/internal/connection/Exchange;", "getInterceptorScopedExchange$okhttp", "()Lokhttp3/internal/connection/Exchange;", "requestBodyOpen", "responseBodyOpen", "expectMoreExchanges", "canceled", "connectionToCancel", "getConnectionToCancel", "setConnectionToCancel", "(Lokhttp3/internal/connection/RealConnection;)V", "", "(Lokhttp3/OkHttpClient;Lokhttp3/Request;Z)V", "AsyncCall", "CallReference", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nRealCall.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealCall.kt\nokhttp3/internal/connection/RealCall\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,551:1\n1#2:552\n608#3,4:553\n615#3,4:557\n615#3,4:561\n608#3,4:565\n350#4,7:569\n*S KotlinDebug\n*F\n+ 1 RealCall.kt\nokhttp3/internal/connection/RealCall\n*L\n269#1:553,4\n344#1:557,4\n348#1:561,4\n375#1:565,4\n378#1:569,7\n*E\n"}) public final class RealCall implements Call { @Nullable private Object callStackTrace; private volatile boolean canceled; @NotNull private final OkHttpClient client; @Nullable private RealConnection connection; @NotNull private final RealConnectionPool connectionPool; @Nullable private volatile RealConnection connectionToCancel; @NotNull private final EventListener eventListener; @Nullable private volatile Exchange exchange; @Nullable private ExchangeFinder exchangeFinder; @NotNull private final AtomicBoolean executed; private boolean expectMoreExchanges; private final boolean forWebSocket; @Nullable private Exchange interceptorScopedExchange; @NotNull private final Request originalRequest; private boolean requestBodyOpen; private boolean responseBodyOpen; @NotNull private final AnonymousClass1 timeout; private boolean timeoutEarlyExit; @Metadata(d1 = {"\u0000<\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\t\b\u0080\u0004\u0018\u00002\u00020\u0001B\u000f\u0012\u0006\u0010\u000b\u001a\u00020\n¢\u0006\u0004\b\u001e\u0010\u001fJ\u0012\u0010\u0005\u001a\u00020\u00042\n\u0010\u0003\u001a\u00060\u0000R\u00020\u0002J\u000e\u0010\b\u001a\u00020\u00042\u0006\u0010\u0007\u001a\u00020\u0006J\b\u0010\t\u001a\u00020\u0004H\u0016R\u0014\u0010\u000b\u001a\u00020\n8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000b\u0010\fR$\u0010\u000f\u001a\u00020\r2\u0006\u0010\u000e\u001a\u00020\r8\u0006@BX\u0086\u000e¢\u0006\f\n\u0004\b\u000f\u0010\u0010\u001a\u0004\b\u0011\u0010\u0012R\u0011\u0010\u0016\u001a\u00020\u00138F¢\u0006\u0006\u001a\u0004\b\u0014\u0010\u0015R\u0011\u0010\u001a\u001a\u00020\u00178F¢\u0006\u0006\u001a\u0004\b\u0018\u0010\u0019R\u0011\u0010\u001d\u001a\u00020\u00028F¢\u0006\u0006\u001a\u0004\b\u001b\u0010\u001c¨\u0006 "}, d2 = {"Lokhttp3/internal/connection/RealCall$AsyncCall;", "Ljava/lang/Runnable;", "Lokhttp3/internal/connection/RealCall;", "other", "Lkd/e;", "reuseCallsPerHostFrom", "Ljava/util/concurrent/ExecutorService;", "executorService", "executeOn", "run", "Lokhttp3/Callback;", "responseCallback", "Lokhttp3/Callback;", "Ljava/util/concurrent/atomic/AtomicInteger;", "", "callsPerHost", "Ljava/util/concurrent/atomic/AtomicInteger;", "getCallsPerHost", "()Ljava/util/concurrent/atomic/AtomicInteger;", "", "getHost", "()Ljava/lang/String;", URLProtectionSpaceContract.FeedEntry.COLUMN_NAME_HOST, "Lokhttp3/Request;", "getRequest", "()Lokhttp3/Request;", "request", "getCall", "()Lokhttp3/internal/connection/RealCall;", "call", "", "(Lokhttp3/internal/connection/RealCall;Lokhttp3/Callback;)V", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nRealCall.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealCall.kt\nokhttp3/internal/connection/RealCall$AsyncCall\n+ 2 Util.kt\nokhttp3/internal/Util\n*L\n1#1,551:1\n615#2,4:552\n409#2,9:556\n*S KotlinDebug\n*F\n+ 1 RealCall.kt\nokhttp3/internal/connection/RealCall$AsyncCall\n*L\n494#1:552,4\n513#1:556,9\n*E\n"}) public final class AsyncCall implements Runnable { @NotNull private volatile AtomicInteger callsPerHost; @NotNull private final Callback responseCallback; final /* synthetic */ RealCall this$0; public AsyncCall(@NotNull RealCall realCall, Callback callback) { g.i(callback, "responseCallback"); this.this$0 = realCall; this.responseCallback = callback; this.callsPerHost = new AtomicInteger(0); } public final void executeOn(@NotNull ExecutorService executorService) { g.i(executorService, "executorService"); Dispatcher dispatcher = this.this$0.getClient().dispatcher(); if (Util.assertionsEnabled && Thread.holdsLock(dispatcher)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + dispatcher); } try { try { executorService.execute(this); } catch (RejectedExecutionException e10) { InterruptedIOException interruptedIOException = new InterruptedIOException("executor rejected"); interruptedIOException.initCause(e10); this.this$0.noMoreExchanges$okhttp(interruptedIOException); this.responseCallback.onFailure(this.this$0, interruptedIOException); this.this$0.getClient().dispatcher().finished$okhttp(this); } } catch (Throwable th) { this.this$0.getClient().dispatcher().finished$okhttp(this); throw th; } } @NotNull /* JADX INFO: renamed from: getCall, reason: from getter */ public final RealCall getThis$0() { return this.this$0; } @NotNull public final AtomicInteger getCallsPerHost() { return this.callsPerHost; } @NotNull public final String getHost() { return this.this$0.getOriginalRequest().url().host(); } @NotNull public final Request getRequest() { return this.this$0.getOriginalRequest(); } public final void reuseCallsPerHostFrom(@NotNull AsyncCall asyncCall) { g.i(asyncCall, "other"); this.callsPerHost = asyncCall.callsPerHost; } @Override // java.lang.Runnable public void run() { Dispatcher dispatcher; String str = "OkHttp " + this.this$0.redactedUrl$okhttp(); RealCall realCall = this.this$0; Thread threadCurrentThread = Thread.currentThread(); String name = threadCurrentThread.getName(); threadCurrentThread.setName(str); try { realCall.timeout.enter(); boolean z10 = false; try { try { try { this.responseCallback.onResponse(realCall, realCall.getResponseWithInterceptorChain$okhttp()); dispatcher = realCall.getClient().dispatcher(); } catch (IOException e10) { e = e10; z10 = true; if (z10) { Platform.INSTANCE.get().log("Callback failure for " + realCall.toLoggableString(), 4, e); } else { this.responseCallback.onFailure(realCall, e); } dispatcher = realCall.getClient().dispatcher(); } catch (Throwable th) { th = th; z10 = true; realCall.cancel(); if (!z10) { IOException iOException = new IOException("canceled due to " + th); a.a(iOException, th); this.responseCallback.onFailure(realCall, iOException); } throw th; } } catch (Throwable th2) { realCall.getClient().dispatcher().finished$okhttp(this); throw th2; } } catch (IOException e11) { e = e11; } catch (Throwable th3) { th = th3; } dispatcher.finished$okhttp(this); } finally { threadCurrentThread.setName(name); } } } @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0002\b\u0004\b\u0000\u0018\u00002\b\u0012\u0004\u0012\u00020\u00020\u0001B\u0017\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\b\u0010\u0004\u001a\u0004\u0018\u00010\u0005¢\u0006\u0002\u0010\u0006R\u0013\u0010\u0004\u001a\u0004\u0018\u00010\u0005¢\u0006\b\n\u0000\u001a\u0004\b\u0007\u0010\b¨\u0006\t"}, d2 = {"Lokhttp3/internal/connection/RealCall$CallReference;", "Ljava/lang/ref/WeakReference;", "Lokhttp3/internal/connection/RealCall;", "referent", "callStackTrace", "", "(Lokhttp3/internal/connection/RealCall;Ljava/lang/Object;)V", "getCallStackTrace", "()Ljava/lang/Object;", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static final class CallReference extends WeakReference { @Nullable private final Object callStackTrace; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public CallReference(@NotNull RealCall realCall, @Nullable Object obj) { super(realCall); g.i(realCall, "referent"); this.callStackTrace = obj; } @Nullable public final Object getCallStackTrace() { return this.callStackTrace; } } /* JADX WARN: Type inference failed for: r4v5, types: [okhttp3.internal.connection.RealCall$timeout$1, okio.Timeout] */ public RealCall(@NotNull OkHttpClient okHttpClient, @NotNull Request request, boolean z10) { g.i(okHttpClient, "client"); g.i(request, "originalRequest"); this.client = okHttpClient; this.originalRequest = request; this.forWebSocket = z10; this.connectionPool = okHttpClient.connectionPool().getDelegate(); this.eventListener = okHttpClient.eventListenerFactory().create(this); ?? r42 = new AsyncTimeout() { // from class: okhttp3.internal.connection.RealCall.timeout.1 @Override // okio.AsyncTimeout public void timedOut() { RealCall.this.cancel(); } }; r42.timeout(okHttpClient.callTimeoutMillis(), TimeUnit.MILLISECONDS); this.timeout = r42; this.executed = new AtomicBoolean(); this.expectMoreExchanges = true; } /* 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 E callDone(E e10) { Socket socketReleaseConnectionNoEvents$okhttp; boolean z10 = Util.assertionsEnabled; if (z10 && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } RealConnection realConnection = this.connection; if (realConnection != null) { if (z10 && Thread.holdsLock(realConnection)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + realConnection); } synchronized (realConnection) { socketReleaseConnectionNoEvents$okhttp = releaseConnectionNoEvents$okhttp(); } if (this.connection == null) { if (socketReleaseConnectionNoEvents$okhttp != null) { Util.closeQuietly(socketReleaseConnectionNoEvents$okhttp); } this.eventListener.connectionReleased(this, realConnection); } else if (socketReleaseConnectionNoEvents$okhttp != null) { throw new IllegalStateException("Check failed.".toString()); } } E e11 = (E) timeoutExit(e10); if (e10 != null) { EventListener eventListener = this.eventListener; g.f(e11); eventListener.callFailed(this, e11); } else { this.eventListener.callEnd(this); } return e11; } private final void callStart() { this.callStackTrace = Platform.INSTANCE.get().getStackTraceForCloseable("response.body().close()"); this.eventListener.callStart(this); } private final Address createAddress(HttpUrl url) { SSLSocketFactory sslSocketFactory; HostnameVerifier hostnameVerifier; CertificatePinner certificatePinner; if (url.getIsHttps()) { sslSocketFactory = this.client.sslSocketFactory(); hostnameVerifier = this.client.hostnameVerifier(); certificatePinner = this.client.certificatePinner(); } else { sslSocketFactory = null; hostnameVerifier = null; certificatePinner = null; } return new Address(url.host(), url.port(), this.client.dns(), this.client.socketFactory(), sslSocketFactory, hostnameVerifier, certificatePinner, this.client.proxyAuthenticator(), this.client.proxy(), this.client.protocols(), this.client.connectionSpecs(), this.client.proxySelector()); } private final E timeoutExit(E cause) { if (this.timeoutEarlyExit || !exit()) { return cause; } InterruptedIOException interruptedIOException = new InterruptedIOException("timeout"); if (cause != null) { interruptedIOException.initCause(cause); } return interruptedIOException; } /* JADX INFO: Access modifiers changed from: private */ public final String toLoggableString() { StringBuilder sb = new StringBuilder(); sb.append(getCanceled() ? "canceled " : ""); sb.append(this.forWebSocket ? "web socket" : "call"); sb.append(" to "); sb.append(redactedUrl$okhttp()); return sb.toString(); } public final void acquireConnectionNoEvents(@NotNull RealConnection realConnection) { g.i(realConnection, "connection"); if (!Util.assertionsEnabled || Thread.holdsLock(realConnection)) { if (this.connection != null) { throw new IllegalStateException("Check failed.".toString()); } this.connection = realConnection; realConnection.getCalls().add(new CallReference(this, this.callStackTrace)); return; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + realConnection); } @Override // okhttp3.Call public void cancel() { if (this.canceled) { return; } this.canceled = true; Exchange exchange = this.exchange; if (exchange != null) { exchange.cancel(); } RealConnection realConnection = this.connectionToCancel; if (realConnection != null) { realConnection.cancel(); } this.eventListener.canceled(this); } @Override // okhttp3.Call public void enqueue(@NotNull Callback callback) { g.i(callback, "responseCallback"); if (!this.executed.compareAndSet(false, true)) { throw new IllegalStateException("Already Executed".toString()); } callStart(); this.client.dispatcher().enqueue$okhttp(new AsyncCall(this, callback)); } public final void enterNetworkInterceptorExchange(@NotNull Request request, boolean z10) { g.i(request, "request"); if (this.interceptorScopedExchange != null) { throw new IllegalStateException("Check failed.".toString()); } synchronized (this) { try { if (!(!this.responseBodyOpen)) { throw new IllegalStateException("cannot make a new request because the previous response is still open: please call response.close()".toString()); } if (!(!this.requestBodyOpen)) { throw new IllegalStateException("Check failed.".toString()); } } catch (Throwable th) { throw th; } } if (z10) { this.exchangeFinder = new ExchangeFinder(this.connectionPool, createAddress(request.url()), this, this.eventListener); } } @Override // okhttp3.Call @NotNull public Response execute() { if (!this.executed.compareAndSet(false, true)) { throw new IllegalStateException("Already Executed".toString()); } enter(); callStart(); try { this.client.dispatcher().executed$okhttp(this); return getResponseWithInterceptorChain$okhttp(); } finally { this.client.dispatcher().finished$okhttp(this); } } public final void exitNetworkInterceptorExchange$okhttp(boolean closeExchange) { Exchange exchange; synchronized (this) { if (!this.expectMoreExchanges) { throw new IllegalStateException("released".toString()); } } if (closeExchange && (exchange = this.exchange) != null) { exchange.detachWithViolence(); } this.interceptorScopedExchange = null; } @NotNull public final OkHttpClient getClient() { return this.client; } @Nullable public final RealConnection getConnection() { return this.connection; } @Nullable public final RealConnection getConnectionToCancel() { return this.connectionToCancel; } @NotNull /* JADX INFO: renamed from: getEventListener$okhttp, reason: from getter */ public final EventListener getEventListener() { return this.eventListener; } public final boolean getForWebSocket() { return this.forWebSocket; } @Nullable /* JADX INFO: renamed from: getInterceptorScopedExchange$okhttp, reason: from getter */ public final Exchange getInterceptorScopedExchange() { return this.interceptorScopedExchange; } @NotNull public final Request getOriginalRequest() { return this.originalRequest; } /* JADX WARN: Removed duplicated region for block: B:21:0x00a2 */ @NotNull /* Code decompiled incorrectly, please refer to instructions dump. */ public final Response getResponseWithInterceptorChain$okhttp() throws Throwable { ArrayList arrayList = new ArrayList(); k.b1(this.client.interceptors(), arrayList); arrayList.add(new RetryAndFollowUpInterceptor(this.client)); arrayList.add(new BridgeInterceptor(this.client.cookieJar())); arrayList.add(new CacheInterceptor(this.client.cache())); arrayList.add(ConnectInterceptor.INSTANCE); if (!this.forWebSocket) { k.b1(this.client.networkInterceptors(), arrayList); } arrayList.add(new CallServerInterceptor(this.forWebSocket)); boolean z10 = false; try { Response responseProceed = new RealInterceptorChain(this, arrayList, 0, null, this.originalRequest, this.client.connectTimeoutMillis(), this.client.readTimeoutMillis(), this.client.writeTimeoutMillis()).proceed(this.originalRequest); if (getCanceled()) { Util.closeQuietly(responseProceed); throw new IOException("Canceled"); } noMoreExchanges$okhttp(null); return responseProceed; } catch (IOException e10) { try { IOException iOExceptionNoMoreExchanges$okhttp = noMoreExchanges$okhttp(e10); g.g(iOExceptionNoMoreExchanges$okhttp, "null cannot be cast to non-null type kotlin.Throwable"); throw iOExceptionNoMoreExchanges$okhttp; } catch (Throwable th) { th = th; z10 = true; if (!z10) { noMoreExchanges$okhttp(null); } throw th; } } catch (Throwable th2) { th = th2; if (!z10) { } throw th; } } @NotNull public final Exchange initExchange$okhttp(@NotNull RealInterceptorChain chain) throws IOException { g.i(chain, "chain"); synchronized (this) { try { if (!this.expectMoreExchanges) { throw new IllegalStateException("released".toString()); } if (!(!this.responseBodyOpen)) { throw new IllegalStateException("Check failed.".toString()); } if (!(!this.requestBodyOpen)) { throw new IllegalStateException("Check failed.".toString()); } } catch (Throwable th) { throw th; } } ExchangeFinder exchangeFinder = this.exchangeFinder; g.f(exchangeFinder); Exchange exchange = new Exchange(this, this.eventListener, exchangeFinder, exchangeFinder.find(this.client, chain)); this.interceptorScopedExchange = exchange; this.exchange = exchange; synchronized (this) { this.requestBodyOpen = true; this.responseBodyOpen = true; } if (this.canceled) { throw new IOException("Canceled"); } return exchange; } @Override // okhttp3.Call /* JADX INFO: renamed from: isCanceled, reason: from getter */ public boolean getCanceled() { return this.canceled; } @Override // okhttp3.Call public boolean isExecuted() { return this.executed.get(); } public final E messageDone$okhttp(@NotNull Exchange exchange, boolean requestDone, boolean responseDone, E e10) { boolean z10; boolean z11; g.i(exchange, "exchange"); if (!g.c(exchange, this.exchange)) { return e10; } synchronized (this) { z10 = false; if (requestDone) { try { if (!this.requestBodyOpen) { if (responseDone || !this.responseBodyOpen) { z11 = false; } } if (requestDone) { this.requestBodyOpen = false; } if (responseDone) { this.responseBodyOpen = false; } boolean z12 = this.requestBodyOpen; boolean z13 = (z12 || this.responseBodyOpen) ? false : true; if (!z12 && !this.responseBodyOpen) { if (!this.expectMoreExchanges) { z10 = true; } } z11 = z10; z10 = z13; } catch (Throwable th) { throw th; } } else { if (responseDone) { } z11 = false; } } if (z10) { this.exchange = null; RealConnection realConnection = this.connection; if (realConnection != null) { realConnection.incrementSuccessCount$okhttp(); } } return z11 ? (E) callDone(e10) : e10; } @Nullable public final IOException noMoreExchanges$okhttp(@Nullable IOException e10) { boolean z10; synchronized (this) { z10 = false; if (this.expectMoreExchanges) { this.expectMoreExchanges = false; if (!this.requestBodyOpen) { if (!this.responseBodyOpen) { z10 = true; } } } } return z10 ? callDone(e10) : e10; } @NotNull public final String redactedUrl$okhttp() { return this.originalRequest.url().redact(); } @Nullable public final Socket releaseConnectionNoEvents$okhttp() { RealConnection realConnection = this.connection; g.f(realConnection); if (Util.assertionsEnabled && !Thread.holdsLock(realConnection)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + realConnection); } List> calls = realConnection.getCalls(); Iterator> it = calls.iterator(); int i10 = 0; while (true) { if (!it.hasNext()) { i10 = -1; break; } if (g.c(it.next().get(), this)) { break; } i10++; } if (i10 == -1) { throw new IllegalStateException("Check failed.".toString()); } calls.remove(i10); this.connection = null; if (calls.isEmpty()) { realConnection.setIdleAtNs$okhttp(System.nanoTime()); if (this.connectionPool.connectionBecameIdle(realConnection)) { return realConnection.socket(); } } return null; } @Override // okhttp3.Call @NotNull public Request request() { return this.originalRequest; } public final boolean retryAfterFailure() { ExchangeFinder exchangeFinder = this.exchangeFinder; g.f(exchangeFinder); return exchangeFinder.retryAfterFailure(); } public final void setConnectionToCancel(@Nullable RealConnection realConnection) { this.connectionToCancel = realConnection; } @Override // okhttp3.Call @NotNull public AsyncTimeout timeout() { return this.timeout; } public final void timeoutEarlyExit() { if (!(!this.timeoutEarlyExit)) { throw new IllegalStateException("Check failed.".toString()); } this.timeoutEarlyExit = true; exit(); } @Override // okhttp3.Call @NotNull public RealCall clone() { return new RealCall(this.client, this.originalRequest, this.forWebSocket); } }