package okhttp3.internal.connection; import j.h0; import j.n; import j.p0.d.c0; import j.p0.d.r; 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.Iterator; import java.util.concurrent.ExecutorService; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.SSLSocketFactory; import l.d; import okhttp3.Address; import okhttp3.Call; import okhttp3.Callback; import okhttp3.CertificatePinner; import okhttp3.Connection; 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.http.ExchangeCodec; import okhttp3.internal.http.RealInterceptorChain; import okhttp3.internal.platform.Platform; /* JADX INFO: compiled from: RealCall.kt */ /* JADX INFO: loaded from: classes.dex */ @n(bv = {1, 0, 3}, d1 = {"\u0000\u009f\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\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\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\u0000\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\b\u0007*\u0001q\u0018\u00002\u00020\u0001:\u0002uvB\u001f\u0012\u0006\u0010S\u001a\u00020R\u0012\u0006\u0010n\u001a\u00020\u0015\u0012\u0006\u0010h\u001a\u00020\u0017¢\u0006\u0004\bs\u0010tJ\u0015\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0005\u0010\u0006J\u000f\u0010\u0007\u001a\u00020\u0004H\u0002¢\u0006\u0004\b\u0007\u0010\bJ\u000f\u0010\t\u001a\u00020\u0004H\u0016¢\u0006\u0004\b\t\u0010\bJ\u000f\u0010\n\u001a\u00020\u0000H\u0016¢\u0006\u0004\b\n\u0010\u000bJ\u0017\u0010\u000f\u001a\u00020\u000e2\u0006\u0010\r\u001a\u00020\fH\u0002¢\u0006\u0004\b\u000f\u0010\u0010J\u0017\u0010\u0013\u001a\u00020\u00042\u0006\u0010\u0012\u001a\u00020\u0011H\u0016¢\u0006\u0004\b\u0013\u0010\u0014J\u001d\u0010\u0019\u001a\u00020\u00042\u0006\u0010\u0016\u001a\u00020\u00152\u0006\u0010\u0018\u001a\u00020\u0017¢\u0006\u0004\b\u0019\u0010\u001aJ\u000f\u0010\u001c\u001a\u00020\u001bH\u0016¢\u0006\u0004\b\u001c\u0010\u001dJ\u0017\u0010!\u001a\u00020\u00042\u0006\u0010\u001e\u001a\u00020\u0017H\u0000¢\u0006\u0004\b\u001f\u0010 J\u000f\u0010#\u001a\u00020\u001bH\u0000¢\u0006\u0004\b\"\u0010\u001dJ\u0017\u0010)\u001a\u00020&2\u0006\u0010%\u001a\u00020$H\u0000¢\u0006\u0004\b'\u0010(J\u000f\u0010*\u001a\u00020\u0017H\u0016¢\u0006\u0004\b*\u0010+J\u000f\u0010,\u001a\u00020\u0017H\u0016¢\u0006\u0004\b,\u0010+J+\u00101\u001a\u00028\u0000\"\n\b\u0000\u0010.*\u0004\u0018\u00010-2\u0006\u0010/\u001a\u00028\u00002\u0006\u00100\u001a\u00020\u0017H\u0002¢\u0006\u0004\b1\u00102J;\u00108\u001a\u00028\u0000\"\n\b\u0000\u0010.*\u0004\u0018\u00010-2\u0006\u00103\u001a\u00020&2\u0006\u00104\u001a\u00020\u00172\u0006\u00105\u001a\u00020\u00172\u0006\u0010/\u001a\u00028\u0000H\u0000¢\u0006\u0004\b6\u00107J\u001b\u0010;\u001a\u0004\u0018\u00010-2\b\u0010/\u001a\u0004\u0018\u00010-H\u0000¢\u0006\u0004\b9\u0010:J\u000f\u0010?\u001a\u00020J\u0011\u0010C\u001a\u0004\u0018\u00010@H\u0000¢\u0006\u0004\bA\u0010BJ\u000f\u0010\u0016\u001a\u00020\u0015H\u0016¢\u0006\u0004\b\u0016\u0010DJ\r\u0010E\u001a\u00020\u0017¢\u0006\u0004\bE\u0010+J\u000f\u0010G\u001a\u00020FH\u0016¢\u0006\u0004\bG\u0010HJ\r\u0010I\u001a\u00020\u0004¢\u0006\u0004\bI\u0010\bJ#\u0010K\u001a\u00028\u0000\"\n\b\u0000\u0010.*\u0004\u0018\u00010-2\u0006\u0010J\u001a\u00028\u0000H\u0002¢\u0006\u0004\bK\u0010:J\u000f\u0010L\u001a\u00020R\u0018\u0010N\u001a\u0004\u0018\u00010M8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bN\u0010OR\u0016\u0010P\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bP\u0010QR\u0019\u0010S\u001a\u00020R8\u0006@\u0006¢\u0006\f\n\u0004\bS\u0010T\u001a\u0004\bU\u0010VR$\u0010\u0003\u001a\u0004\u0018\u00010\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0003\u0010W\u001a\u0004\bX\u0010Y\"\u0004\bZ\u0010\u0006R\u0016\u0010\\\u001a\u00020[8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\\\u0010]R\u0016\u0010_\u001a\u00020^8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b_\u0010`R\u0018\u00103\u001a\u0004\u0018\u00010&8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b3\u0010aR\u0018\u0010c\u001a\u0004\u0018\u00010b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bc\u0010dR\u0016\u0010e\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\be\u0010QR\u0016\u0010f\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bf\u0010QR\u0016\u0010g\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bg\u0010QR\u0019\u0010h\u001a\u00020\u00178\u0006@\u0006¢\u0006\f\n\u0004\bh\u0010Q\u001a\u0004\bi\u0010+R(\u0010k\u001a\u0004\u0018\u00010&2\b\u0010j\u001a\u0004\u0018\u00010&8\u0000@BX\u0080\u000e¢\u0006\f\n\u0004\bk\u0010a\u001a\u0004\bl\u0010mR\u0016\u0010;\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b;\u0010QR\u0019\u0010n\u001a\u00020\u00158\u0006@\u0006¢\u0006\f\n\u0004\bn\u0010o\u001a\u0004\bp\u0010DR\u0016\u0010G\u001a\u00020q8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bG\u0010rR\u0016\u0010I\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bI\u0010Q¨\u0006w"}, d2 = {"Lokhttp3/internal/connection/RealCall;", "Lokhttp3/Call;", "Lokhttp3/internal/connection/RealConnection;", "connection", HttpUrl.FRAGMENT_ENCODE_SET, "acquireConnectionNoEvents", "(Lokhttp3/internal/connection/RealConnection;)V", "callStart", "()V", "cancel", "clone", "()Lokhttp3/internal/connection/RealCall;", "Lokhttp3/HttpUrl;", "url", "Lokhttp3/Address;", "createAddress", "(Lokhttp3/HttpUrl;)Lokhttp3/Address;", "Lokhttp3/Callback;", "responseCallback", "enqueue", "(Lokhttp3/Callback;)V", "Lokhttp3/Request;", "request", HttpUrl.FRAGMENT_ENCODE_SET, "newExchangeFinder", "enterNetworkInterceptorExchange", "(Lokhttp3/Request;Z)V", "Lokhttp3/Response;", "execute", "()Lokhttp3/Response;", "closeExchange", "exitNetworkInterceptorExchange$okhttp", "(Z)V", "exitNetworkInterceptorExchange", "getResponseWithInterceptorChain$okhttp", "getResponseWithInterceptorChain", "Lokhttp3/internal/http/RealInterceptorChain;", "chain", "Lokhttp3/internal/connection/Exchange;", "initExchange$okhttp", "(Lokhttp3/internal/http/RealInterceptorChain;)Lokhttp3/internal/connection/Exchange;", "initExchange", "isCanceled", "()Z", "isExecuted", "Ljava/io/IOException;", "E", "e", "force", "maybeReleaseConnection", "(Ljava/io/IOException;Z)Ljava/io/IOException;", "exchange", "requestDone", "responseDone", "messageDone$okhttp", "(Lokhttp3/internal/connection/Exchange;ZZLjava/io/IOException;)Ljava/io/IOException;", "messageDone", "noMoreExchanges$okhttp", "(Ljava/io/IOException;)Ljava/io/IOException;", "noMoreExchanges", HttpUrl.FRAGMENT_ENCODE_SET, "redactedUrl$okhttp", "()Ljava/lang/String;", "redactedUrl", "Ljava/net/Socket;", "releaseConnectionNoEvents$okhttp", "()Ljava/net/Socket;", "releaseConnectionNoEvents", "()Lokhttp3/Request;", "retryAfterFailure", "Lokio/AsyncTimeout;", "timeout", "()Lokio/AsyncTimeout;", "timeoutEarlyExit", "cause", "timeoutExit", "toLoggableString", HttpUrl.FRAGMENT_ENCODE_SET, "callStackTrace", "Ljava/lang/Object;", "canceled", "Z", "Lokhttp3/OkHttpClient;", "client", "Lokhttp3/OkHttpClient;", "getClient", "()Lokhttp3/OkHttpClient;", "Lokhttp3/internal/connection/RealConnection;", "getConnection", "()Lokhttp3/internal/connection/RealConnection;", "setConnection", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/internal/connection/RealConnectionPool;", "Lokhttp3/EventListener;", "eventListener", "Lokhttp3/EventListener;", "Lokhttp3/internal/connection/Exchange;", "Lokhttp3/internal/connection/ExchangeFinder;", "exchangeFinder", "Lokhttp3/internal/connection/ExchangeFinder;", "exchangeRequestDone", "exchangeResponseDone", "executed", "forWebSocket", "getForWebSocket", "", "interceptorScopedExchange", "getInterceptorScopedExchange$okhttp", "()Lokhttp3/internal/connection/Exchange;", "originalRequest", "Lokhttp3/Request;", "getOriginalRequest", "okhttp3/internal/connection/RealCall$timeout$1", "Lokhttp3/internal/connection/RealCall$timeout$1;", "", "(Lokhttp3/OkHttpClient;Lokhttp3/Request;Z)V", "AsyncCall", "CallReference", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class RealCall implements Call { private Object callStackTrace; private boolean canceled; private final OkHttpClient client; private RealConnection connection; private final RealConnectionPool connectionPool; private final EventListener eventListener; private Exchange exchange; private ExchangeFinder exchangeFinder; private boolean exchangeRequestDone; private boolean exchangeResponseDone; private boolean executed; private final boolean forWebSocket; private Exchange interceptorScopedExchange; private boolean noMoreExchanges; private final Request originalRequest; private final AnonymousClass1 timeout; private boolean timeoutEarlyExit; /* JADX INFO: compiled from: RealCall.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000>\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0080\u0004\u0018\u00002\u00020\u0001B\u000f\u0012\u0006\u0010\u001f\u001a\u00020\u001e¢\u0006\u0004\b!\u0010\"J\u0015\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0005\u0010\u0006J\u0019\u0010\t\u001a\u00020\u00042\n\u0010\b\u001a\u00060\u0000R\u00020\u0007¢\u0006\u0004\b\t\u0010\nJ\u000f\u0010\u000b\u001a\u00020\u0004H\u0016¢\u0006\u0004\b\u000b\u0010\fR\u0013\u0010\u000f\u001a\u00020\u00078F@\u0006¢\u0006\u0006\u001a\u0004\b\r\u0010\u000eR$\u0010\u0012\u001a\u00020\u00102\u0006\u0010\u0011\u001a\u00020\u00108\u0006@BX\u0086\u000e¢\u0006\f\n\u0004\b\u0012\u0010\u0013\u001a\u0004\b\u0014\u0010\u0015R\u0013\u0010\u0019\u001a\u00020\u00168F@\u0006¢\u0006\u0006\u001a\u0004\b\u0017\u0010\u0018R\u0013\u0010\u001d\u001a\u00020\u001a8F@\u0006¢\u0006\u0006\u001a\u0004\b\u001b\u0010\u001cR\u0016\u0010\u001f\u001a\u00020\u001e8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001f\u0010 ¨\u0006#"}, d2 = {"Lokhttp3/internal/connection/RealCall$AsyncCall;", "Ljava/lang/Runnable;", "Ljava/util/concurrent/ExecutorService;", "executorService", HttpUrl.FRAGMENT_ENCODE_SET, "executeOn", "(Ljava/util/concurrent/ExecutorService;)V", "Lokhttp3/internal/connection/RealCall;", "other", "reuseCallsPerHostFrom", "(Lokhttp3/internal/connection/RealCall$AsyncCall;)V", "run", "()V", "getCall", "()Lokhttp3/internal/connection/RealCall;", "call", "Ljava/util/concurrent/atomic/AtomicInteger;", "", "callsPerHost", "Ljava/util/concurrent/atomic/AtomicInteger;", "getCallsPerHost", "()Ljava/util/concurrent/atomic/AtomicInteger;", HttpUrl.FRAGMENT_ENCODE_SET, "getHost", "()Ljava/lang/String;", "host", "Lokhttp3/Request;", "getRequest", "()Lokhttp3/Request;", "request", "Lokhttp3/Callback;", "responseCallback", "Lokhttp3/Callback;", "", "(Lokhttp3/internal/connection/RealCall;Lokhttp3/Callback;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class AsyncCall implements Runnable { private volatile AtomicInteger callsPerHost; private final Callback responseCallback; final /* synthetic */ RealCall this$0; public AsyncCall(RealCall realCall, Callback callback) { r.g(callback, "responseCallback"); this.this$0 = realCall; this.responseCallback = callback; this.callsPerHost = new AtomicInteger(0); } public final void executeOn(ExecutorService executorService) { r.g(executorService, "executorService"); Dispatcher dispatcher = this.this$0.getClient().dispatcher(); if (Util.assertionsEnabled && Thread.holdsLock(dispatcher)) { 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(dispatcher); throw new AssertionError(sb.toString()); } try { try { executorService.execute(this); } catch (RejectedExecutionException e) { InterruptedIOException interruptedIOException = new InterruptedIOException("executor rejected"); interruptedIOException.initCause(e); 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; } } public final RealCall getCall() { return this.this$0; } public final AtomicInteger getCallsPerHost() { return this.callsPerHost; } public final String getHost() { return this.this$0.getOriginalRequest().url().host(); } public final Request getRequest() { return this.this$0.getOriginalRequest(); } public final void reuseCallsPerHostFrom(AsyncCall asyncCall) { r.g(asyncCall, "other"); this.callsPerHost = asyncCall.callsPerHost; } @Override // java.lang.Runnable public void run() { boolean z; Throwable th; IOException e; Dispatcher dispatcher; String str = "OkHttp " + this.this$0.redactedUrl$okhttp(); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "currentThread"); String name = threadCurrentThread.getName(); threadCurrentThread.setName(str); try { try { enter(); try { z = true; } catch (IOException e2) { z = false; e = e2; } catch (Throwable th2) { z = false; th = th2; } try { this.responseCallback.onResponse(this.this$0, this.this$0.getResponseWithInterceptorChain$okhttp()); dispatcher = this.this$0.getClient().dispatcher(); } catch (IOException e3) { e = e3; if (z) { Platform.Companion.get().log("Callback failure for " + this.this$0.toLoggableString(), 4, e); } else { this.responseCallback.onFailure(this.this$0, e); } dispatcher = this.this$0.getClient().dispatcher(); } catch (Throwable th3) { th = th3; this.this$0.cancel(); if (!z) { IOException iOException = new IOException("canceled due to " + th); iOException.addSuppressed(th); this.responseCallback.onFailure(this.this$0, iOException); } throw th; } dispatcher.finished$okhttp(this); } catch (Throwable th4) { this.this$0.getClient().dispatcher().finished$okhttp(this); throw th4; } } finally { threadCurrentThread.setName(name); } } } /* JADX INFO: compiled from: RealCall.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0000\u0018\u00002\u00020\u0001B\u0019\u0012\u0006\u0010\b\u001a\u00020\u0007\u0012\b\u0010\u0003\u001a\u0004\u0018\u00010\u0002¢\u0006\u0004\b\t\u0010\nR\u001b\u0010\u0003\u001a\u0004\u0018\u00010\u00028\u0006@\u0006¢\u0006\f\n\u0004\b\u0003\u0010\u0004\u001a\u0004\b\u0005\u0010\u0006¨\u0006\u000b"}, d2 = {"Lokhttp3/internal/connection/RealCall$CallReference;", "Ljava/lang/ref/WeakReference;", HttpUrl.FRAGMENT_ENCODE_SET, "callStackTrace", "Ljava/lang/Object;", "getCallStackTrace", "()Ljava/lang/Object;", "Lokhttp3/internal/connection/RealCall;", "referent", "", "(Lokhttp3/internal/connection/RealCall;Ljava/lang/Object;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static final class CallReference extends WeakReference { private final Object callStackTrace; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public CallReference(RealCall realCall, Object obj) { super(realCall); r.g(realCall, "referent"); this.callStackTrace = obj; } public final Object getCallStackTrace() { return this.callStackTrace; } } /* JADX WARN: Type inference failed for: r2v6, types: [l.b0, okhttp3.internal.connection.RealCall$timeout$1] */ public RealCall(OkHttpClient okHttpClient, Request request, boolean z) { r.g(okHttpClient, "client"); r.g(request, "originalRequest"); this.client = okHttpClient; this.originalRequest = request; this.forWebSocket = z; this.connectionPool = okHttpClient.connectionPool().getDelegate$okhttp(); this.eventListener = this.client.eventListenerFactory().create(this); ?? r2 = new d() { // from class: okhttp3.internal.connection.RealCall.timeout.1 @Override // l.d protected void timedOut() { RealCall.this.cancel(); } }; r2.timeout(this.client.callTimeoutMillis(), TimeUnit.MILLISECONDS); this.timeout = r2; } private final void callStart() { this.callStackTrace = Platform.Companion.get().getStackTraceForCloseable("response.body().close()"); this.eventListener.callStart(this); } private final Address createAddress(HttpUrl httpUrl) { SSLSocketFactory sSLSocketFactory; HostnameVerifier hostnameVerifier; CertificatePinner certificatePinner; if (httpUrl.isHttps()) { SSLSocketFactory sslSocketFactory = this.client.sslSocketFactory(); hostnameVerifier = this.client.hostnameVerifier(); sSLSocketFactory = sslSocketFactory; certificatePinner = this.client.certificatePinner(); } else { sSLSocketFactory = null; hostnameVerifier = null; certificatePinner = null; } return new Address(httpUrl.host(), httpUrl.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()); } /* JADX WARN: Type inference failed for: r4v3, types: [T, okhttp3.internal.connection.RealConnection] */ /* 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 maybeReleaseConnection(E e, boolean z) { boolean z2; Socket socketReleaseConnectionNoEvents$okhttp; boolean z3; c0 c0Var = new c0(); synchronized (this.connectionPool) { if (z) { try { z2 = this.exchange == null; } finally { } } if (!z2) { throw new IllegalStateException("cannot release connection while it is in use".toString()); } c0Var.b = this.connection; socketReleaseConnectionNoEvents$okhttp = (this.connection != null && this.exchange == null && (z || this.noMoreExchanges)) ? releaseConnectionNoEvents$okhttp() : null; if (this.connection != null) { c0Var.b = null; } z3 = this.noMoreExchanges && this.exchange == null; h0 h0Var = h0.a; } if (socketReleaseConnectionNoEvents$okhttp != null) { Util.closeQuietly(socketReleaseConnectionNoEvents$okhttp); } T t = c0Var.b; if (((Connection) t) != null) { EventListener eventListener = this.eventListener; Connection connection = (Connection) t; if (connection == null) { r.p(); throw null; } eventListener.connectionReleased(this, connection); } if (z3) { boolean z4 = e != null; e = (E) timeoutExit(e); if (z4) { EventListener eventListener2 = this.eventListener; if (e == null) { r.p(); throw null; } eventListener2.callFailed(this, e); } else { this.eventListener.callEnd(this); } } return e; } private final E timeoutExit(E e) { if (this.timeoutEarlyExit || !exit()) { return e; } InterruptedIOException interruptedIOException = new InterruptedIOException("timeout"); if (e != null) { interruptedIOException.initCause(e); } return interruptedIOException; } /* JADX INFO: Access modifiers changed from: private */ public final String toLoggableString() { StringBuilder sb = new StringBuilder(); sb.append(isCanceled() ? "canceled " : HttpUrl.FRAGMENT_ENCODE_SET); sb.append(this.forWebSocket ? "web socket" : "call"); sb.append(" to "); sb.append(redactedUrl$okhttp()); return sb.toString(); } public final void acquireConnectionNoEvents(RealConnection realConnection) { r.g(realConnection, "connection"); RealConnectionPool realConnectionPool = this.connectionPool; if (!Util.assertionsEnabled || Thread.holdsLock(realConnectionPool)) { if (!(this.connection == null)) { throw new IllegalStateException("Check failed.".toString()); } this.connection = realConnection; realConnection.getCalls().add(new CallReference(this, this.callStackTrace)); return; } 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()); } @Override // okhttp3.Call public void cancel() { RealConnection realConnectionConnectingConnection; synchronized (this.connectionPool) { if (this.canceled) { return; } this.canceled = true; Exchange exchange = this.exchange; ExchangeFinder exchangeFinder = this.exchangeFinder; if (exchangeFinder == null || (realConnectionConnectingConnection = exchangeFinder.connectingConnection()) == null) { realConnectionConnectingConnection = this.connection; } h0 h0Var = h0.a; if (exchange != null) { exchange.cancel(); } else if (realConnectionConnectingConnection != null) { realConnectionConnectingConnection.cancel(); } this.eventListener.canceled(this); } } @Override // okhttp3.Call public void enqueue(Callback callback) { r.g(callback, "responseCallback"); synchronized (this) { if (!(!this.executed)) { throw new IllegalStateException("Already Executed".toString()); } this.executed = true; h0 h0Var = h0.a; } callStart(); this.client.dispatcher().enqueue$okhttp(new AsyncCall(this, callback)); } public final void enterNetworkInterceptorExchange(Request request, boolean z) { r.g(request, "request"); if (!(this.interceptorScopedExchange == null)) { throw new IllegalStateException("Check failed.".toString()); } if (!(this.exchange == null)) { throw new IllegalStateException("cannot make a new request because the previous response is still open: please call response.close()".toString()); } if (z) { this.exchangeFinder = new ExchangeFinder(this.connectionPool, createAddress(request.url()), this, this.eventListener); } } @Override // okhttp3.Call public Response execute() { synchronized (this) { if (!(!this.executed)) { throw new IllegalStateException("Already Executed".toString()); } this.executed = true; h0 h0Var = h0.a; } 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 z) { if (!(!this.noMoreExchanges)) { throw new IllegalStateException("released".toString()); } if (z) { Exchange exchange = this.exchange; if (exchange != null) { exchange.detachWithViolence(); } if (!(this.exchange == null)) { throw new IllegalStateException("Check failed.".toString()); } } this.interceptorScopedExchange = null; } public final OkHttpClient getClient() { return this.client; } public final RealConnection getConnection() { return this.connection; } public final boolean getForWebSocket() { return this.forWebSocket; } public final Exchange getInterceptorScopedExchange$okhttp() { return this.interceptorScopedExchange; } public final Request getOriginalRequest() { return this.originalRequest; } /* JADX WARN: Removed duplicated region for block: B:24:0x00a3 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final okhttp3.Response getResponseWithInterceptorChain$okhttp() throws java.lang.Throwable { /* r11 = this; java.util.ArrayList r2 = new java.util.ArrayList r2.() okhttp3.OkHttpClient r0 = r11.client java.util.List r0 = r0.interceptors() j.k0.m.t(r2, r0) okhttp3.internal.http.RetryAndFollowUpInterceptor r0 = new okhttp3.internal.http.RetryAndFollowUpInterceptor okhttp3.OkHttpClient r1 = r11.client r0.(r1) r2.add(r0) okhttp3.internal.http.BridgeInterceptor r0 = new okhttp3.internal.http.BridgeInterceptor okhttp3.OkHttpClient r1 = r11.client okhttp3.CookieJar r1 = r1.cookieJar() r0.(r1) r2.add(r0) okhttp3.internal.cache.CacheInterceptor r0 = new okhttp3.internal.cache.CacheInterceptor okhttp3.OkHttpClient r1 = r11.client okhttp3.Cache r1 = r1.cache() r0.(r1) r2.add(r0) okhttp3.internal.connection.ConnectInterceptor r0 = okhttp3.internal.connection.ConnectInterceptor.INSTANCE r2.add(r0) boolean r0 = r11.forWebSocket if (r0 != 0) goto L46 okhttp3.OkHttpClient r0 = r11.client java.util.List r0 = r0.networkInterceptors() j.k0.m.t(r2, r0) L46: okhttp3.internal.http.CallServerInterceptor r0 = new okhttp3.internal.http.CallServerInterceptor boolean r1 = r11.forWebSocket r0.(r1) r2.add(r0) okhttp3.internal.http.RealInterceptorChain r9 = new okhttp3.internal.http.RealInterceptorChain r3 = 0 r4 = 0 okhttp3.Request r5 = r11.originalRequest okhttp3.OkHttpClient r0 = r11.client int r6 = r0.connectTimeoutMillis() okhttp3.OkHttpClient r0 = r11.client int r7 = r0.readTimeoutMillis() okhttp3.OkHttpClient r0 = r11.client int r8 = r0.writeTimeoutMillis() r0 = r9 r1 = r11 r0.(r1, r2, r3, r4, r5, r6, r7, r8) r0 = 0 r1 = 0 okhttp3.Request r2 = r11.originalRequest // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c okhttp3.Response r2 = r9.proceed(r2) // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c boolean r3 = r11.isCanceled() // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c if (r3 != 0) goto L7f r11.noMoreExchanges$okhttp(r1) return r2 L7f: okhttp3.internal.Util.closeQuietly(r2) // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c java.io.IOException r2 = new java.io.IOException // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c java.lang.String r3 = "Canceled" r2.(r3) // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c throw r2 // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c L8a: r2 = move-exception goto La1 L8c: r0 = move-exception r2 = 1 java.io.IOException r0 = r11.noMoreExchanges$okhttp(r0) // Catch: java.lang.Throwable -> L9d if (r0 != 0) goto L9c j.w r0 = new j.w // Catch: java.lang.Throwable -> L9d java.lang.String r3 = "null cannot be cast to non-null type kotlin.Throwable" r0.(r3) // Catch: java.lang.Throwable -> L9d throw r0 // Catch: java.lang.Throwable -> L9d L9c: throw r0 // Catch: java.lang.Throwable -> L9d L9d: r0 = move-exception r10 = r2 r2 = r0 r0 = r10 La1: if (r0 != 0) goto La6 r11.noMoreExchanges$okhttp(r1) La6: throw r2 */ throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.connection.RealCall.getResponseWithInterceptorChain$okhttp():okhttp3.Response"); } public final Exchange initExchange$okhttp(RealInterceptorChain realInterceptorChain) { r.g(realInterceptorChain, "chain"); synchronized (this.connectionPool) { boolean z = true; if (!(!this.noMoreExchanges)) { throw new IllegalStateException("released".toString()); } if (this.exchange != null) { z = false; } if (!z) { throw new IllegalStateException("Check failed.".toString()); } h0 h0Var = h0.a; } ExchangeFinder exchangeFinder = this.exchangeFinder; if (exchangeFinder == null) { r.p(); throw null; } ExchangeCodec exchangeCodecFind = exchangeFinder.find(this.client, realInterceptorChain); EventListener eventListener = this.eventListener; ExchangeFinder exchangeFinder2 = this.exchangeFinder; if (exchangeFinder2 == null) { r.p(); throw null; } Exchange exchange = new Exchange(this, eventListener, exchangeFinder2, exchangeCodecFind); this.interceptorScopedExchange = exchange; synchronized (this.connectionPool) { this.exchange = exchange; this.exchangeRequestDone = false; this.exchangeResponseDone = false; } return exchange; } @Override // okhttp3.Call public boolean isCanceled() { boolean z; synchronized (this.connectionPool) { z = this.canceled; } return z; } @Override // okhttp3.Call public synchronized boolean isExecuted() { return this.executed; } public final E messageDone$okhttp(Exchange exchange, boolean z, boolean z2, E e) { boolean z3; r.g(exchange, "exchange"); synchronized (this.connectionPool) { boolean z4 = true; if (!r.a(exchange, this.exchange)) { return e; } if (z) { z3 = !this.exchangeRequestDone; this.exchangeRequestDone = true; } else { z3 = false; } if (z2) { if (!this.exchangeResponseDone) { z3 = true; } this.exchangeResponseDone = true; } if (this.exchangeRequestDone && this.exchangeResponseDone && z3) { Exchange exchange2 = this.exchange; if (exchange2 == null) { r.p(); throw null; } RealConnection connection$okhttp = exchange2.getConnection$okhttp(); connection$okhttp.setSuccessCount$okhttp(connection$okhttp.getSuccessCount$okhttp() + 1); this.exchange = null; } else { z4 = false; } h0 h0Var = h0.a; return z4 ? (E) maybeReleaseConnection(e, false) : e; } } public final IOException noMoreExchanges$okhttp(IOException iOException) { synchronized (this.connectionPool) { this.noMoreExchanges = true; h0 h0Var = h0.a; } return maybeReleaseConnection(iOException, false); } public final String redactedUrl$okhttp() { return this.originalRequest.url().redact(); } public final Socket releaseConnectionNoEvents$okhttp() { 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 hold lock on "); sb.append(realConnectionPool); throw new AssertionError(sb.toString()); } RealConnection realConnection = this.connection; if (realConnection == null) { r.p(); throw null; } Iterator> it = realConnection.getCalls().iterator(); int i2 = 0; while (true) { if (!it.hasNext()) { i2 = -1; break; } if (r.a(it.next().get(), this)) { break; } i2++; } if (!(i2 != -1)) { throw new IllegalStateException("Check failed.".toString()); } RealConnection realConnection2 = this.connection; if (realConnection2 == null) { r.p(); throw null; } realConnection2.getCalls().remove(i2); this.connection = null; if (realConnection2.getCalls().isEmpty()) { realConnection2.setIdleAtNs$okhttp(System.nanoTime()); if (this.connectionPool.connectionBecameIdle(realConnection2)) { return realConnection2.socket(); } } return null; } @Override // okhttp3.Call public Request request() { return this.originalRequest; } public final boolean retryAfterFailure() { ExchangeFinder exchangeFinder = this.exchangeFinder; if (exchangeFinder != null) { return exchangeFinder.retryAfterFailure(); } r.p(); throw null; } public final void setConnection(RealConnection realConnection) { this.connection = realConnection; } public final void timeoutEarlyExit() { if (!(!this.timeoutEarlyExit)) { throw new IllegalStateException("Check failed.".toString()); } this.timeoutEarlyExit = true; exit(); } @Override // okhttp3.Call public d timeout() { return this.timeout; } @Override // okhttp3.Call public RealCall clone() { return new RealCall(this.client, this.originalRequest, this.forWebSocket); } }