package okhttp3.internal.connection; import androidx.media3.container.NalUnitUtil; import com.google.android.gms.common.internal.ImagesContract; import defpackage.cr2; import defpackage.cr4; import defpackage.kp6; import defpackage.pq6; import defpackage.tv; import defpackage.vx8; import defpackage.y41; 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 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; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000§\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\t\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\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\n\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\u0014*\u0001`\u0018\u00002\u00020\u0001:\u0002z{B\u001f\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004\u0012\u0006\u0010\u0007\u001a\u00020\u0006¢\u0006\u0004\b\b\u0010\tJ\u000f\u0010\u000b\u001a\u00020\nH\u0016¢\u0006\u0004\b\u000b\u0010\fJ\u000f\u0010\r\u001a\u00020\u0000H\u0016¢\u0006\u0004\b\r\u0010\u000eJ\u000f\u0010\u000f\u001a\u00020\u0004H\u0016¢\u0006\u0004\b\u000f\u0010\u0010J\u000f\u0010\u0012\u001a\u00020\u0011H\u0016¢\u0006\u0004\b\u0012\u0010\u0013J\u000f\u0010\u0014\u001a\u00020\u0006H\u0016¢\u0006\u0004\b\u0014\u0010\u0015J\u000f\u0010\u0017\u001a\u00020\u0016H\u0016¢\u0006\u0004\b\u0017\u0010\u0018J\u0017\u0010\u001b\u001a\u00020\u00112\u0006\u0010\u001a\u001a\u00020\u0019H\u0016¢\u0006\u0004\b\u001b\u0010\u001cJ\u000f\u0010\u001d\u001a\u00020\u0006H\u0016¢\u0006\u0004\b\u001d\u0010\u0015J\u000f\u0010\u001f\u001a\u00020\u0016H\u0000¢\u0006\u0004\b\u001e\u0010\u0018J\u001d\u0010!\u001a\u00020\u00112\u0006\u0010\u000f\u001a\u00020\u00042\u0006\u0010 \u001a\u00020\u0006¢\u0006\u0004\b!\u0010\"J\u0017\u0010(\u001a\u00020%2\u0006\u0010$\u001a\u00020#H\u0000¢\u0006\u0004\b&\u0010'J\u0015\u0010+\u001a\u00020\u00112\u0006\u0010*\u001a\u00020)¢\u0006\u0004\b+\u0010,J;\u00105\u001a\u00028\u0000\"\n\b\u0000\u0010.*\u0004\u0018\u00010-2\u0006\u0010/\u001a\u00020%2\u0006\u00100\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u00062\u0006\u00102\u001a\u00028\u0000H\u0000¢\u0006\u0004\b3\u00104J\u001b\u00108\u001a\u0004\u0018\u00010-2\b\u00102\u001a\u0004\u0018\u00010-H\u0000¢\u0006\u0004\b6\u00107J\u0011\u0010<\u001a\u0004\u0018\u000109H\u0000¢\u0006\u0004\b:\u0010;J\r\u0010=\u001a\u00020\u0011¢\u0006\u0004\b=\u0010\u0013J\u0017\u0010A\u001a\u00020\u00112\u0006\u0010>\u001a\u00020\u0006H\u0000¢\u0006\u0004\b?\u0010@J\r\u0010B\u001a\u00020\u0006¢\u0006\u0004\bB\u0010\u0015J\u000f\u0010F\u001a\u00020CH\u0000¢\u0006\u0004\bD\u0010EJ\u000f\u0010G\u001a\u00020\u0011H\u0002¢\u0006\u0004\bG\u0010\u0013J#\u0010H\u001a\u00028\u0000\"\n\b\u0000\u0010.*\u0004\u0018\u00010-2\u0006\u00102\u001a\u00028\u0000H\u0002¢\u0006\u0004\bH\u00107J#\u0010J\u001a\u00028\u0000\"\n\b\u0000\u0010.*\u0004\u0018\u00010-2\u0006\u0010I\u001a\u00028\u0000H\u0002¢\u0006\u0004\bJ\u00107J\u0017\u0010N\u001a\u00020M2\u0006\u0010L\u001a\u00020KH\u0002¢\u0006\u0004\bN\u0010OJ\u000f\u0010P\u001a\u00020CH\u0002¢\u0006\u0004\bP\u0010ER\u0017\u0010\u0003\u001a\u00020\u00028\u0006¢\u0006\f\n\u0004\b\u0003\u0010Q\u001a\u0004\bR\u0010SR\u0017\u0010\u0005\u001a\u00020\u00048\u0006¢\u0006\f\n\u0004\b\u0005\u0010T\u001a\u0004\bU\u0010\u0010R\u0017\u0010\u0007\u001a\u00020\u00068\u0006¢\u0006\f\n\u0004\b\u0007\u0010V\u001a\u0004\bW\u0010\u0015R\u0014\u0010Y\u001a\u00020X8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bY\u0010ZR\u001a\u0010\\\u001a\u00020[8\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\\\u0010]\u001a\u0004\b^\u0010_R\u0014\u0010\u000b\u001a\u00020`8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000b\u0010aR\u0014\u0010c\u001a\u00020b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bc\u0010dR\u0018\u0010f\u001a\u0004\u0018\u00010e8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bf\u0010gR\u0018\u0010i\u001a\u0004\u0018\u00010h8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bi\u0010jR(\u0010*\u001a\u0004\u0018\u00010)2\b\u0010k\u001a\u0004\u0018\u00010)8\u0006@BX\u0086\u000e¢\u0006\f\n\u0004\b*\u0010l\u001a\u0004\bm\u0010nR\u0016\u0010=\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b=\u0010VR(\u0010o\u001a\u0004\u0018\u00010%2\b\u0010k\u001a\u0004\u0018\u00010%8\u0000@BX\u0080\u000e¢\u0006\f\n\u0004\bo\u0010p\u001a\u0004\bq\u0010rR\u0016\u0010s\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bs\u0010VR\u0016\u0010t\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bt\u0010VR\u0016\u0010u\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bu\u0010VR\u0016\u0010v\u001a\u00020\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bv\u0010VR\u0018\u0010/\u001a\u0004\u0018\u00010%8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b/\u0010pR$\u0010w\u001a\u0004\u0018\u00010)8\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\bw\u0010l\u001a\u0004\bx\u0010n\"\u0004\by\u0010,¨\u0006|"}, d2 = {"Lokhttp3/internal/connection/RealCall;", "Lokhttp3/Call;", "Lokhttp3/OkHttpClient;", "client", "Lokhttp3/Request;", "originalRequest", "", "forWebSocket", "", "(Lokhttp3/OkHttpClient;Lokhttp3/Request;Z)V", "Ltv;", "timeout", "()Ltv;", "clone", "()Lokhttp3/internal/connection/RealCall;", "request", "()Lokhttp3/Request;", "Le6a;", "cancel", "()V", "isCanceled", "()Z", "Lokhttp3/Response;", "execute", "()Lokhttp3/Response;", "Lokhttp3/Callback;", "responseCallback", "enqueue", "(Lokhttp3/Callback;)V", "isExecuted", "getResponseWithInterceptorChain$okhttp", "getResponseWithInterceptorChain", "newExchangeFinder", "enterNetworkInterceptorExchange", "(Lokhttp3/Request;Z)V", "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", "(Lokhttp3/internal/connection/RealConnection;)V", "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;", ImagesContract.URL, "Lokhttp3/Address;", "createAddress", "(Lokhttp3/HttpUrl;)Lokhttp3/Address;", "toLoggableString", "Lokhttp3/OkHttpClient;", "getClient", "()Lokhttp3/OkHttpClient;", "Lokhttp3/Request;", "getOriginalRequest", "Z", "getForWebSocket", "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", "AsyncCall", "CallReference", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class RealCall implements Call { @pq6 private Object callStackTrace; private volatile boolean canceled; @kp6 private final OkHttpClient client; @pq6 private RealConnection connection; @kp6 private final RealConnectionPool connectionPool; @pq6 private volatile RealConnection connectionToCancel; @kp6 private final EventListener eventListener; @pq6 private volatile Exchange exchange; @pq6 private ExchangeFinder exchangeFinder; @kp6 private final AtomicBoolean executed; private boolean expectMoreExchanges; private final boolean forWebSocket; @pq6 private Exchange interceptorScopedExchange; @kp6 private final Request originalRequest; private boolean requestBodyOpen; private boolean responseBodyOpen; @kp6 private final AnonymousClass1 timeout; private boolean timeoutEarlyExit; @Metadata(d1 = {"\u0000>\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0080\u0004\u0018\u00002\u00020\u0001B\u000f\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0019\u0010\t\u001a\u00020\b2\n\u0010\u0007\u001a\u00060\u0000R\u00020\u0006¢\u0006\u0004\b\t\u0010\nJ\u0015\u0010\r\u001a\u00020\b2\u0006\u0010\f\u001a\u00020\u000b¢\u0006\u0004\b\r\u0010\u000eJ\u000f\u0010\u000f\u001a\u00020\bH\u0016¢\u0006\u0004\b\u000f\u0010\u0010R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u0011R$\u0010\u0014\u001a\u00020\u00122\u0006\u0010\u0013\u001a\u00020\u00128\u0006@BX\u0086\u000e¢\u0006\f\n\u0004\b\u0014\u0010\u0015\u001a\u0004\b\u0016\u0010\u0017R\u0011\u0010\u001b\u001a\u00020\u00188F¢\u0006\u0006\u001a\u0004\b\u0019\u0010\u001aR\u0011\u0010\u001f\u001a\u00020\u001c8F¢\u0006\u0006\u001a\u0004\b\u001d\u0010\u001eR\u0011\u0010\"\u001a\u00020\u00068F¢\u0006\u0006\u001a\u0004\b \u0010!¨\u0006#"}, d2 = {"Lokhttp3/internal/connection/RealCall$AsyncCall;", "Ljava/lang/Runnable;", "Lokhttp3/Callback;", "responseCallback", "", "(Lokhttp3/internal/connection/RealCall;Lokhttp3/Callback;)V", "Lokhttp3/internal/connection/RealCall;", "other", "Le6a;", "reuseCallsPerHostFrom", "(Lokhttp3/internal/connection/RealCall$AsyncCall;)V", "Ljava/util/concurrent/ExecutorService;", "executorService", "executeOn", "(Ljava/util/concurrent/ExecutorService;)V", "run", "()V", "Lokhttp3/Callback;", "Ljava/util/concurrent/atomic/AtomicInteger;", "", "callsPerHost", "Ljava/util/concurrent/atomic/AtomicInteger;", "getCallsPerHost", "()Ljava/util/concurrent/atomic/AtomicInteger;", "", "getHost", "()Ljava/lang/String;", "host", "Lokhttp3/Request;", "getRequest", "()Lokhttp3/Request;", "request", "getCall", "()Lokhttp3/internal/connection/RealCall;", "call", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class AsyncCall implements Runnable { @kp6 private volatile AtomicInteger callsPerHost; @kp6 private final Callback responseCallback; final /* synthetic */ RealCall this$0; public AsyncCall(@kp6 RealCall realCall, Callback callback) { cr4.g(callback, "responseCallback"); this.this$0 = realCall; this.responseCallback = callback; this.callsPerHost = new AtomicInteger(0); } public final void executeOn(@kp6 ExecutorService executorService) { cr4.g(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 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; } } @kp6 /* JADX INFO: renamed from: getCall, reason: from getter */ public final RealCall getThis$0() { return this.this$0; } @kp6 public final AtomicInteger getCallsPerHost() { return this.callsPerHost; } @kp6 public final String getHost() { return this.this$0.getOriginalRequest().url().host(); } @kp6 public final Request getRequest() { return this.this$0.getOriginalRequest(); } public final void reuseCallsPerHostFrom(@kp6 AsyncCall other) { cr4.g(other, "other"); this.callsPerHost = other.callsPerHost; } @Override // java.lang.Runnable public void run() { OkHttpClient client; 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 z = false; try { try { try { this.responseCallback.onResponse(realCall, realCall.getResponseWithInterceptorChain$okhttp()); client = realCall.getClient(); } catch (IOException e) { e = e; z = true; if (z) { Platform.INSTANCE.get().log("Callback failure for " + realCall.toLoggableString(), 4, e); } else { this.responseCallback.onFailure(realCall, e); } client = realCall.getClient(); } catch (Throwable th) { th = th; z = true; realCall.cancel(); if (!z) { IOException iOException = new IOException("canceled due to " + th); cr2.a(iOException, th); this.responseCallback.onFailure(realCall, iOException); } throw th; } } catch (Throwable th2) { realCall.getClient().dispatcher().finished$okhttp(this); throw th2; } } catch (IOException e2) { e = e2; } catch (Throwable th3) { th = th3; } client.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 = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class CallReference extends WeakReference { @pq6 private final Object callStackTrace; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public CallReference(@kp6 RealCall realCall, @pq6 Object obj) { super(realCall); cr4.g(realCall, "referent"); this.callStackTrace = obj; } @pq6 public final Object getCallStackTrace() { return this.callStackTrace; } } /* JADX WARN: Type inference failed for: r4v5, types: [ko9, okhttp3.internal.connection.RealCall$timeout$1] */ public RealCall(@kp6 OkHttpClient okHttpClient, @kp6 Request request, boolean z) { cr4.g(okHttpClient, "client"); cr4.g(request, "originalRequest"); this.client = okHttpClient; this.originalRequest = request; this.forWebSocket = z; this.connectionPool = okHttpClient.connectionPool().getDelegate(); this.eventListener = okHttpClient.eventListenerFactory().create(this); ?? r4 = new tv() { // from class: okhttp3.internal.connection.RealCall.timeout.1 @Override // defpackage.tv public void timedOut() { RealCall.this.cancel(); } }; r4.timeout(okHttpClient.callTimeoutMillis(), TimeUnit.MILLISECONDS); this.timeout = r4; 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 e) { Socket socketReleaseConnectionNoEvents$okhttp; boolean z = Util.assertionsEnabled; if (z && Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST NOT hold lock on " + this); } RealConnection realConnection = this.connection; if (realConnection != null) { if (z && 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."); } } E e2 = (E) timeoutExit(e); if (e == null) { this.eventListener.callEnd(this); return e2; } EventListener eventListener = this.eventListener; cr4.d(e2); eventListener.callFailed(this, e2); return e2; } 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(@kp6 RealConnection connection) { cr4.g(connection, "connection"); if (!Util.assertionsEnabled || Thread.holdsLock(connection)) { if (this.connection != null) { throw new IllegalStateException("Check failed."); } this.connection = connection; connection.getCalls().add(new CallReference(this, this.callStackTrace)); return; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + connection); } @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(@kp6 Callback responseCallback) { cr4.g(responseCallback, "responseCallback"); if (!this.executed.compareAndSet(false, true)) { throw new IllegalStateException("Already Executed"); } callStart(); this.client.dispatcher().enqueue$okhttp(new AsyncCall(this, responseCallback)); } public final void enterNetworkInterceptorExchange(@kp6 Request request, boolean newExchangeFinder) { cr4.g(request, "request"); if (this.interceptorScopedExchange != null) { throw new IllegalStateException("Check failed."); } 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()"); } if (this.requestBodyOpen) { throw new IllegalStateException("Check failed."); } } catch (Throwable th) { throw th; } } if (newExchangeFinder) { this.exchangeFinder = new ExchangeFinder(this.connectionPool, createAddress(request.url()), this, this.eventListener); } } @Override // okhttp3.Call @kp6 public Response execute() { if (!this.executed.compareAndSet(false, true)) { throw new IllegalStateException("Already Executed"); } 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"); } } if (closeExchange && (exchange = this.exchange) != null) { exchange.detachWithViolence(); } this.interceptorScopedExchange = null; } @kp6 public final OkHttpClient getClient() { return this.client; } @pq6 public final RealConnection getConnection() { return this.connection; } @pq6 public final RealConnection getConnectionToCancel() { return this.connectionToCancel; } @kp6 /* JADX INFO: renamed from: getEventListener$okhttp, reason: from getter */ public final EventListener getEventListener() { return this.eventListener; } public final boolean getForWebSocket() { return this.forWebSocket; } @pq6 /* JADX INFO: renamed from: getInterceptorScopedExchange$okhttp, reason: from getter */ public final Exchange getInterceptorScopedExchange() { return this.interceptorScopedExchange; } @kp6 public final Request getOriginalRequest() { return this.originalRequest; } /* JADX WARN: Removed duplicated region for block: B:19:0x009d */ @kp6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Response getResponseWithInterceptorChain$okhttp() throws IOException { ArrayList arrayList = new ArrayList(); y41.i(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) { y41.i(this.client.networkInterceptors(), arrayList); } arrayList.add(new CallServerInterceptor(this.forWebSocket)); boolean z = false; try { 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 e) { z = true; IOException iOExceptionNoMoreExchanges$okhttp = noMoreExchanges$okhttp(e); cr4.e(iOExceptionNoMoreExchanges$okhttp, "null cannot be cast to non-null type kotlin.Throwable"); throw iOExceptionNoMoreExchanges$okhttp; } } catch (Throwable th) { if (!z) { } throw th; } if (!z) { noMoreExchanges$okhttp(null); } throw th; } @kp6 public final Exchange initExchange$okhttp(@kp6 RealInterceptorChain chain) throws IOException { cr4.g(chain, "chain"); synchronized (this) { try { if (!this.expectMoreExchanges) { throw new IllegalStateException("released"); } if (this.responseBodyOpen) { throw new IllegalStateException("Check failed."); } if (this.requestBodyOpen) { throw new IllegalStateException("Check failed."); } } catch (Throwable th) { throw th; } } ExchangeFinder exchangeFinder = this.exchangeFinder; cr4.d(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(@kp6 Exchange exchange, boolean requestDone, boolean responseDone, E e) { boolean z; boolean z2; cr4.g(exchange, "exchange"); if (exchange.equals(this.exchange)) { synchronized (this) { z = false; if (requestDone) { try { if (!this.requestBodyOpen) { if (responseDone || !this.responseBodyOpen) { z2 = false; } } if (requestDone) { this.requestBodyOpen = false; } if (responseDone) { this.responseBodyOpen = false; } boolean z3 = this.requestBodyOpen; boolean z4 = (z3 || this.responseBodyOpen) ? false : true; if (!z3 && !this.responseBodyOpen) { if (!this.expectMoreExchanges) { z = true; } } z2 = z; z = z4; } catch (Throwable th) { throw th; } } else { if (responseDone) { } z2 = false; } } if (z) { this.exchange = null; RealConnection realConnection = this.connection; if (realConnection != null) { realConnection.incrementSuccessCount$okhttp(); } } if (z2) { return (E) callDone(e); } } return e; } @pq6 public final IOException noMoreExchanges$okhttp(@pq6 IOException e) { boolean z; synchronized (this) { z = false; if (this.expectMoreExchanges) { this.expectMoreExchanges = false; if (!this.requestBodyOpen) { if (!this.responseBodyOpen) { z = true; } } } } return z ? callDone(e) : e; } @kp6 public final String redactedUrl$okhttp() { return this.originalRequest.url().redact(); } @pq6 public final Socket releaseConnectionNoEvents$okhttp() { RealConnection realConnection = this.connection; cr4.d(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 i = 0; while (true) { if (!it.hasNext()) { i = -1; break; } if (cr4.b(it.next().get(), this)) { break; } i++; } if (i == -1) { throw new IllegalStateException("Check failed."); } calls.remove(i); this.connection = null; if (calls.isEmpty()) { realConnection.setIdleAtNs$okhttp(System.nanoTime()); if (this.connectionPool.connectionBecameIdle(realConnection)) { return realConnection.socket(); } } return null; } @Override // okhttp3.Call @kp6 public Request request() { return this.originalRequest; } public final boolean retryAfterFailure() { ExchangeFinder exchangeFinder = this.exchangeFinder; cr4.d(exchangeFinder); return exchangeFinder.retryAfterFailure(); } public final void setConnectionToCancel(@pq6 RealConnection realConnection) { this.connectionToCancel = realConnection; } public final void timeoutEarlyExit() { if (this.timeoutEarlyExit) { throw new IllegalStateException("Check failed."); } this.timeoutEarlyExit = true; exit(); } @Override // okhttp3.Call @kp6 public tv timeout() { return this.timeout; } @Override // okhttp3.Call @kp6 public RealCall clone() { return new RealCall(this.client, this.originalRequest, this.forWebSocket); } }