package okhttp3.internal.connection; import h.b; import h.i; import h.r; import h.x.d.k; import i.d; 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.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 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.http.RealInterceptorChain; import okhttp3.internal.platform.Platform; import org.snmp4j.util.SnmpConfigurator; /* JADX INFO: compiled from: RealCall.kt */ /* JADX INFO: loaded from: classes.dex */ @i(bv = {1, 0, 3}, d1 = {"\u0000§\u0001\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\t\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\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\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\r\n\u0002\b\u0007*\u0001v\u0018\u00002\u00020\u0001:\u0002z{B\u001f\u0012\u0006\u0010Q\u001a\u00020P\u0012\u0006\u0010q\u001a\u00020\u001a\u0012\u0006\u0010l\u001a\u00020\u001c¢\u0006\u0004\bx\u0010yJ\u0015\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0005\u0010\u0006J#\u0010\n\u001a\u00028\u0000\"\n\b\u0000\u0010\b*\u0004\u0018\u00010\u00072\u0006\u0010\t\u001a\u00028\u0000H\u0002¢\u0006\u0004\b\n\u0010\u000bJ\u000f\u0010\f\u001a\u00020\u0004H\u0002¢\u0006\u0004\b\f\u0010\rJ\u000f\u0010\u000e\u001a\u00020\u0004H\u0016¢\u0006\u0004\b\u000e\u0010\rJ\u000f\u0010\u000f\u001a\u00020\u0000H\u0016¢\u0006\u0004\b\u000f\u0010\u0010J\u0017\u0010\u0014\u001a\u00020\u00132\u0006\u0010\u0012\u001a\u00020\u0011H\u0002¢\u0006\u0004\b\u0014\u0010\u0015J\u0017\u0010\u0018\u001a\u00020\u00042\u0006\u0010\u0017\u001a\u00020\u0016H\u0016¢\u0006\u0004\b\u0018\u0010\u0019J\u001d\u0010\u001e\u001a\u00020\u00042\u0006\u0010\u001b\u001a\u00020\u001a2\u0006\u0010\u001d\u001a\u00020\u001c¢\u0006\u0004\b\u001e\u0010\u001fJ\u000f\u0010!\u001a\u00020 H\u0016¢\u0006\u0004\b!\u0010\"J\u0017\u0010&\u001a\u00020\u00042\u0006\u0010#\u001a\u00020\u001cH\u0000¢\u0006\u0004\b$\u0010%J\u000f\u0010(\u001a\u00020 H\u0000¢\u0006\u0004\b'\u0010\"J\u0017\u0010.\u001a\u00020+2\u0006\u0010*\u001a\u00020)H\u0000¢\u0006\u0004\b,\u0010-J\u000f\u0010/\u001a\u00020\u001cH\u0016¢\u0006\u0004\b/\u00100J\u000f\u00101\u001a\u00020\u001cH\u0016¢\u0006\u0004\b1\u00100J;\u00107\u001a\u00028\u0000\"\n\b\u0000\u0010\b*\u0004\u0018\u00010\u00072\u0006\u00102\u001a\u00020+2\u0006\u00103\u001a\u00020\u001c2\u0006\u00104\u001a\u00020\u001c2\u0006\u0010\t\u001a\u00028\u0000H\u0000¢\u0006\u0004\b5\u00106J\u001b\u00109\u001a\u0004\u0018\u00010\u00072\b\u0010\t\u001a\u0004\u0018\u00010\u0007H\u0000¢\u0006\u0004\b8\u0010\u000bJ\u000f\u0010=\u001a\u00020:H\u0000¢\u0006\u0004\b;\u0010H\u0000¢\u0006\u0004\b?\u0010@J\u000f\u0010\u001b\u001a\u00020\u001aH\u0016¢\u0006\u0004\b\u001b\u0010BJ\r\u0010C\u001a\u00020\u001c¢\u0006\u0004\bC\u00100J\u000f\u0010E\u001a\u00020DH\u0016¢\u0006\u0004\bE\u0010FJ\r\u0010G\u001a\u00020\u0004¢\u0006\u0004\bG\u0010\rJ#\u0010I\u001a\u00028\u0000\"\n\b\u0000\u0010\b*\u0004\u0018\u00010\u00072\u0006\u0010H\u001a\u00028\u0000H\u0002¢\u0006\u0004\bI\u0010\u000bJ\u000f\u0010J\u001a\u00020:H\u0002¢\u0006\u0004\bJ\u0010", "Lokhttp3/internal/connection/RealConnection;", "getConnection", "()Lokhttp3/internal/connection/RealConnection;", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionToCancel", "getConnectionToCancel", "setConnectionToCancel", "Lokhttp3/EventListener;", "eventListener", "Lokhttp3/EventListener;", "getEventListener$okhttp", "()Lokhttp3/EventListener;", "Lokhttp3/internal/connection/Exchange;", "Lokhttp3/internal/connection/ExchangeFinder;", "exchangeFinder", "Lokhttp3/internal/connection/ExchangeFinder;", "Ljava/util/concurrent/atomic/AtomicBoolean;", "executed", "Ljava/util/concurrent/atomic/AtomicBoolean;", "expectMoreExchanges", "forWebSocket", "getForWebSocket", "interceptorScopedExchange", "getInterceptorScopedExchange$okhttp", "()Lokhttp3/internal/connection/Exchange;", "originalRequest", "Lokhttp3/Request;", "getOriginalRequest", "requestBodyOpen", "responseBodyOpen", "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 = "", xi = 0, xs = "") public final class RealCall implements Call { private Object callStackTrace; private volatile boolean canceled; private final OkHttpClient client; private RealConnection connection; private final RealConnectionPool connectionPool; private volatile RealConnection connectionToCancel; private final EventListener eventListener; private volatile Exchange exchange; private ExchangeFinder exchangeFinder; private final AtomicBoolean executed; private boolean expectMoreExchanges; private final boolean forWebSocket; private Exchange interceptorScopedExchange; private final Request originalRequest; private boolean requestBodyOpen; private boolean responseBodyOpen; private final AnonymousClass1 timeout; private boolean timeoutEarlyExit; /* JADX INFO: compiled from: RealCall.kt */ @i(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", "", "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;", "", "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 = "", xi = 0, xs = "") 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) { k.d(callback, "responseCallback"); this.this$0 = realCall; this.responseCallback = callback; this.callsPerHost = new AtomicInteger(0); } public final void executeOn(ExecutorService executorService) { k.d(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(); k.c(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 e2) { InterruptedIOException interruptedIOException = new InterruptedIOException("executor rejected"); interruptedIOException.initCause(e2); 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) { k.d(asyncCall, "other"); this.callsPerHost = asyncCall.callsPerHost; } @Override // java.lang.Runnable public void run() { Throwable th; boolean z; IOException e2; Dispatcher dispatcher; String str = "OkHttp " + this.this$0.redactedUrl$okhttp(); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "currentThread"); String name = threadCurrentThread.getName(); threadCurrentThread.setName(str); try { try { enter(); try { z = true; } catch (IOException e3) { e2 = e3; z = false; } catch (Throwable th2) { th = th2; z = false; } try { this.responseCallback.onResponse(this.this$0, this.this$0.getResponseWithInterceptorChain$okhttp()); dispatcher = this.this$0.getClient().dispatcher(); } catch (IOException e4) { e2 = e4; if (z) { Platform.Companion.get().log("Callback failure for " + this.this$0.toLoggableString(), 4, e2); } else { this.responseCallback.onFailure(this.this$0, e2); } 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); b.a(iOException, 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 */ @i(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;", "", "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 = "", xi = 0, xs = "") 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); k.d(realCall, "referent"); this.callStackTrace = obj; } public final Object getCallStackTrace() { return this.callStackTrace; } } /* JADX WARN: Type inference failed for: r2v6, types: [i.e0, okhttp3.internal.connection.RealCall$timeout$1] */ public RealCall(OkHttpClient okHttpClient, Request request, boolean z) { k.d(okHttpClient, "client"); k.d(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 // i.d protected void timedOut() { RealCall.this.cancel(); } }; r2.timeout(this.client.callTimeoutMillis(), TimeUnit.MILLISECONDS); r rVar = r.a; this.timeout = r2; 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 e2) { Socket socketReleaseConnectionNoEvents$okhttp; if (Util.assertionsEnabled && Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST NOT hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } RealConnection realConnection = this.connection; if (realConnection != null) { if (Util.assertionsEnabled && Thread.holdsLock(realConnection)) { StringBuilder sb2 = new StringBuilder(); sb2.append("Thread "); Thread threadCurrentThread2 = Thread.currentThread(); k.c(threadCurrentThread2, "Thread.currentThread()"); sb2.append(threadCurrentThread2.getName()); sb2.append(" MUST NOT hold lock on "); sb2.append(realConnection); throw new AssertionError(sb2.toString()); } 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 e3 = (E) timeoutExit(e2); if (e2 != null) { EventListener eventListener = this.eventListener; k.b(e3); eventListener.callFailed(this, e3); } else { this.eventListener.callEnd(this); } return e3; } 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()); } private final E timeoutExit(E e2) { if (this.timeoutEarlyExit || !exit()) { return e2; } InterruptedIOException interruptedIOException = new InterruptedIOException("timeout"); if (e2 != null) { interruptedIOException.initCause(e2); } return interruptedIOException; } /* JADX INFO: Access modifiers changed from: private */ public final String toLoggableString() { StringBuilder sb = new StringBuilder(); sb.append(isCanceled() ? "canceled " : ""); sb.append(this.forWebSocket ? "web socket" : "call"); sb.append(" to "); sb.append(redactedUrl$okhttp()); return sb.toString(); } public final void acquireConnectionNoEvents(RealConnection realConnection) { k.d(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; } StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST hold lock on "); sb.append(realConnection); throw new AssertionError(sb.toString()); } @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(Callback callback) { k.d(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(Request request, boolean z) { k.d(request, "request"); if (!(this.interceptorScopedExchange == null)) { throw new IllegalStateException("Check failed.".toString()); } synchronized (this) { 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()); } r rVar = r.a; } if (z) { this.exchangeFinder = new ExchangeFinder(this.connectionPool, createAddress(request.url()), this, this.eventListener); } } @Override // okhttp3.Call 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 z) { Exchange exchange; synchronized (this) { if (!this.expectMoreExchanges) { throw new IllegalStateException("released".toString()); } r rVar = r.a; } if (z && (exchange = this.exchange) != null) { exchange.detachWithViolence(); } this.interceptorScopedExchange = null; } public final OkHttpClient getClient() { return this.client; } public final RealConnection getConnection() { return this.connection; } public final RealConnection getConnectionToCancel() { return this.connectionToCancel; } public final EventListener getEventListener$okhttp() { return this.eventListener; } 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:0x00a2 */ /* 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 { /* r10 = this; java.util.ArrayList r2 = new java.util.ArrayList r2.() okhttp3.OkHttpClient r0 = r10.client java.util.List r0 = r0.interceptors() h.s.k.q(r2, r0) okhttp3.internal.http.RetryAndFollowUpInterceptor r0 = new okhttp3.internal.http.RetryAndFollowUpInterceptor okhttp3.OkHttpClient r1 = r10.client r0.(r1) r2.add(r0) okhttp3.internal.http.BridgeInterceptor r0 = new okhttp3.internal.http.BridgeInterceptor okhttp3.OkHttpClient r1 = r10.client okhttp3.CookieJar r1 = r1.cookieJar() r0.(r1) r2.add(r0) okhttp3.internal.cache.CacheInterceptor r0 = new okhttp3.internal.cache.CacheInterceptor okhttp3.OkHttpClient r1 = r10.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 = r10.forWebSocket if (r0 != 0) goto L46 okhttp3.OkHttpClient r0 = r10.client java.util.List r0 = r0.networkInterceptors() h.s.k.q(r2, r0) L46: okhttp3.internal.http.CallServerInterceptor r0 = new okhttp3.internal.http.CallServerInterceptor boolean r1 = r10.forWebSocket r0.(r1) r2.add(r0) okhttp3.internal.http.RealInterceptorChain r9 = new okhttp3.internal.http.RealInterceptorChain r3 = 0 r4 = 0 okhttp3.Request r5 = r10.originalRequest okhttp3.OkHttpClient r0 = r10.client int r6 = r0.connectTimeoutMillis() okhttp3.OkHttpClient r0 = r10.client int r7 = r0.readTimeoutMillis() okhttp3.OkHttpClient r0 = r10.client int r8 = r0.writeTimeoutMillis() r0 = r9 r1 = r10 r0.(r1, r2, r3, r4, r5, r6, r7, r8) r0 = 0 r1 = 0 okhttp3.Request r2 = r10.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 = r10.isCanceled() // Catch: java.lang.Throwable -> L8a java.io.IOException -> L8c if (r3 != 0) goto L7f r10.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 La0 L8c: r0 = move-exception r2 = 1 java.io.IOException r0 = r10.noMoreExchanges$okhttp(r0) // Catch: java.lang.Throwable -> L9d if (r0 != 0) goto L9c java.lang.NullPointerException r0 = new java.lang.NullPointerException // 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 r2 = r0 r0 = 1 La0: if (r0 != 0) goto La5 r10.noMoreExchanges$okhttp(r1) La5: throw r2 */ throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.connection.RealCall.getResponseWithInterceptorChain$okhttp():okhttp3.Response"); } public final Exchange initExchange$okhttp(RealInterceptorChain realInterceptorChain) throws IOException { k.d(realInterceptorChain, "chain"); synchronized (this) { 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()); } r rVar = r.a; } ExchangeFinder exchangeFinder = this.exchangeFinder; k.b(exchangeFinder); Exchange exchange = new Exchange(this, this.eventListener, exchangeFinder, exchangeFinder.find(this.client, realInterceptorChain)); this.interceptorScopedExchange = exchange; this.exchange = exchange; synchronized (this) { this.requestBodyOpen = true; this.responseBodyOpen = true; r rVar2 = r.a; } if (this.canceled) { throw new IOException("Canceled"); } return exchange; } @Override // okhttp3.Call public boolean isCanceled() { return this.canceled; } @Override // okhttp3.Call public boolean isExecuted() { return this.executed.get(); } public final E messageDone$okhttp(Exchange exchange, boolean z, boolean z2, E e2) { boolean z3; k.d(exchange, "exchange"); boolean z4 = true; if (!k.a(exchange, this.exchange)) { return e2; } synchronized (this) { z3 = false; if (z) { try { if (!this.requestBodyOpen) { if (z2 || !this.responseBodyOpen) { z4 = false; } } if (z) { this.requestBodyOpen = false; } if (z2) { this.responseBodyOpen = false; } boolean z5 = (this.requestBodyOpen || this.responseBodyOpen) ? false : true; if (this.requestBodyOpen || this.responseBodyOpen || this.expectMoreExchanges) { z4 = false; } z3 = z5; } catch (Throwable th) { throw th; } } else { if (z2) { } z4 = false; } r rVar = r.a; } if (z3) { this.exchange = null; RealConnection realConnection = this.connection; if (realConnection != null) { realConnection.incrementSuccessCount$okhttp(); } } return z4 ? (E) callDone(e2) : e2; } public final IOException noMoreExchanges$okhttp(IOException iOException) { boolean z; synchronized (this) { z = false; if (this.expectMoreExchanges) { this.expectMoreExchanges = false; if (!this.requestBodyOpen && !this.responseBodyOpen) { z = true; } } r rVar = r.a; } return z ? callDone(iOException) : iOException; } public final String redactedUrl$okhttp() { return this.originalRequest.url().redact(); } public final Socket releaseConnectionNoEvents$okhttp() { RealConnection realConnection = this.connection; k.b(realConnection); if (Util.assertionsEnabled && !Thread.holdsLock(realConnection)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST hold lock on "); sb.append(realConnection); throw new AssertionError(sb.toString()); } List> calls = realConnection.getCalls(); Iterator> it = calls.iterator(); int i2 = 0; while (true) { if (!it.hasNext()) { i2 = -1; break; } if (k.a(it.next().get(), this)) { break; } i2++; } if (!(i2 != -1)) { throw new IllegalStateException("Check failed.".toString()); } calls.remove(i2); this.connection = null; if (calls.isEmpty()) { realConnection.setIdleAtNs$okhttp(System.nanoTime()); if (this.connectionPool.connectionBecameIdle(realConnection)) { return realConnection.socket(); } } return null; } @Override // okhttp3.Call public Request request() { return this.originalRequest; } public final boolean retryAfterFailure() { ExchangeFinder exchangeFinder = this.exchangeFinder; k.b(exchangeFinder); return exchangeFinder.retryAfterFailure(); } public final void setConnectionToCancel(RealConnection realConnection) { this.connectionToCancel = 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); } }