package okhttp3.internal.connection; import com.google.android.gms.measurement.internal.u1; import defpackage.e; import java.lang.ref.Reference; import java.net.Socket; import java.util.Collection; import java.util.Iterator; import java.util.List; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.TimeUnit; import kotlin.Metadata; import kotlin.jvm.internal.SourceDebugExtension; import kotlin.jvm.internal.d; import nb.g; import okhttp3.Address; import okhttp3.ConnectionPool; import okhttp3.Route; import okhttp3.internal.Util; import okhttp3.internal.concurrent.Task; import okhttp3.internal.concurrent.TaskQueue; import okhttp3.internal.concurrent.TaskRunner; import okhttp3.internal.connection.RealCall; import okhttp3.internal.platform.Platform; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; /* JADX INFO: loaded from: classes.dex */ @Metadata(d1 = {"\u0000i\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005*\u0001 \u0018\u0000 -2\u00020\u0001:\u0001-B'\u0012\u0006\u0010'\u001a\u00020&\u0012\u0006\u0010\u0019\u001a\u00020\u0006\u0012\u0006\u0010(\u001a\u00020\u0004\u0012\u0006\u0010*\u001a\u00020)¢\u0006\u0004\b+\u0010,J\u0018\u0010\u0007\u001a\u00020\u00062\u0006\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0005\u001a\u00020\u0004H\u0002J\u0006\u0010\b\u001a\u00020\u0006J\u0006\u0010\t\u001a\u00020\u0006J.\u0010\u0013\u001a\u00020\u00112\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010\r\u001a\u00020\f2\u000e\u0010\u0010\u001a\n\u0012\u0004\u0012\u00020\u000f\u0018\u00010\u000e2\u0006\u0010\u0012\u001a\u00020\u0011J\u000e\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0003\u001a\u00020\u0002J\u000e\u0010\u0016\u001a\u00020\u00112\u0006\u0010\u0003\u001a\u00020\u0002J\u0006\u0010\u0017\u001a\u00020\u0014J\u000e\u0010\u0018\u001a\u00020\u00042\u0006\u0010\u0005\u001a\u00020\u0004R\u0014\u0010\u0019\u001a\u00020\u00068\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0019\u0010\u001aR\u0014\u0010\u001b\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001b\u0010\u001cR\u0014\u0010\u001e\u001a\u00020\u001d8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001e\u0010\u001fR\u0014\u0010!\u001a\u00020 8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b!\u0010\"R\u001a\u0010$\u001a\b\u0012\u0004\u0012\u00020\u00020#8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b$\u0010%¨\u0006."}, d2 = {"Lokhttp3/internal/connection/RealConnectionPool;", "", "Lokhttp3/internal/connection/RealConnection;", "connection", "", "now", "", "pruneAndGetAllocationCount", "idleConnectionCount", "connectionCount", "Lokhttp3/Address;", "address", "Lokhttp3/internal/connection/RealCall;", "call", "", "Lokhttp3/Route;", "routes", "", "requireMultiplexed", "callAcquirePooledConnection", "Lkd/e;", "put", "connectionBecameIdle", "evictAll", "cleanup", "maxIdleConnections", "I", "keepAliveDurationNs", "J", "Lokhttp3/internal/concurrent/TaskQueue;", "cleanupQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "okhttp3/internal/connection/RealConnectionPool$cleanupTask$1", "cleanupTask", "Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1;", "Ljava/util/concurrent/ConcurrentLinkedQueue;", "connections", "Ljava/util/concurrent/ConcurrentLinkedQueue;", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "keepAliveDuration", "Ljava/util/concurrent/TimeUnit;", "timeUnit", "", "(Lokhttp3/internal/concurrent/TaskRunner;IJLjava/util/concurrent/TimeUnit;)V", "Companion", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nRealConnectionPool.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealConnectionPool.kt\nokhttp3/internal/connection/RealConnectionPool\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n+ 4 Util.kt\nokhttp3/internal/Util\n*L\n1#1,250:1\n1#2:251\n1774#3,4:252\n608#4,4:256\n608#4,4:260\n608#4,4:264\n*S KotlinDebug\n*F\n+ 1 RealConnectionPool.kt\nokhttp3/internal/connection/RealConnectionPool\n*L\n60#1:252,4\n95#1:256,4\n106#1:260,4\n215#1:264,4\n*E\n"}) public final class RealConnectionPool { /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */ @NotNull public static final Companion INSTANCE = new Companion(null); @NotNull private final TaskQueue cleanupQueue; @NotNull private final RealConnectionPool$cleanupTask$1 cleanupTask; @NotNull private final ConcurrentLinkedQueue connections; private final long keepAliveDurationNs; private final int maxIdleConnections; @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\b\u0086\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002J\u000e\u0010\u0003\u001a\u00020\u00042\u0006\u0010\u0005\u001a\u00020\u0006¨\u0006\u0007"}, d2 = {"Lokhttp3/internal/connection/RealConnectionPool$Companion;", "", "()V", "get", "Lokhttp3/internal/connection/RealConnectionPool;", "connectionPool", "Lokhttp3/ConnectionPool;", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = 48) public static final class Companion { private Companion() { } public /* synthetic */ Companion(d dVar) { this(); } @NotNull public final RealConnectionPool get(@NotNull ConnectionPool connectionPool) { g.i(connectionPool, "connectionPool"); return connectionPool.getDelegate(); } } /* JADX WARN: Type inference failed for: r4v2, types: [okhttp3.internal.connection.RealConnectionPool$cleanupTask$1] */ public RealConnectionPool(@NotNull TaskRunner taskRunner, int i10, long j10, @NotNull TimeUnit timeUnit) { g.i(taskRunner, "taskRunner"); g.i(timeUnit, "timeUnit"); this.maxIdleConnections = i10; this.keepAliveDurationNs = timeUnit.toNanos(j10); this.cleanupQueue = taskRunner.newQueue(); final String strO = e.o(new StringBuilder(), Util.okHttpName, " ConnectionPool"); this.cleanupTask = new Task(strO) { // from class: okhttp3.internal.connection.RealConnectionPool$cleanupTask$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { return this.this$0.cleanup(System.nanoTime()); } }; this.connections = new ConcurrentLinkedQueue<>(); if (j10 <= 0) { throw new IllegalArgumentException(u1.i("keepAliveDuration <= 0: ", j10).toString()); } } private final int pruneAndGetAllocationCount(RealConnection connection, long now) { if (Util.assertionsEnabled && !Thread.holdsLock(connection)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + connection); } List> calls = connection.getCalls(); int i10 = 0; while (i10 < calls.size()) { Reference reference = calls.get(i10); if (reference.get() != null) { i10++; } else { Platform.INSTANCE.get().logCloseableLeak("A connection to " + connection.getRoute().address().url() + " was leaked. Did you forget to close a response body?", ((RealCall.CallReference) reference).getCallStackTrace()); calls.remove(i10); connection.setNoNewExchanges(true); if (calls.isEmpty()) { connection.setIdleAtNs$okhttp(now - this.keepAliveDurationNs); return 0; } } } return calls.size(); } /* JADX WARN: Removed duplicated region for block: B:28:0x0033 A[SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:30:0x0039 A[SYNTHETIC] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final boolean callAcquirePooledConnection(@NotNull Address address, @NotNull RealCall call, @Nullable List routes, boolean requireMultiplexed) { g.i(address, "address"); g.i(call, "call"); for (RealConnection realConnection : this.connections) { g.h(realConnection, "connection"); synchronized (realConnection) { if (requireMultiplexed) { try { if (!realConnection.isMultiplexed$okhttp()) { continue; } else if (!realConnection.isEligible$okhttp(address, routes)) { call.acquireConnectionNoEvents(realConnection); return true; } } catch (Throwable th) { throw th; } } else if (!realConnection.isEligible$okhttp(address, routes)) { } } } return false; } public final long cleanup(long now) { int i10 = 0; long j10 = Long.MIN_VALUE; RealConnection realConnection = null; int i11 = 0; for (RealConnection realConnection2 : this.connections) { g.h(realConnection2, "connection"); synchronized (realConnection2) { if (pruneAndGetAllocationCount(realConnection2, now) > 0) { i11++; } else { i10++; long idleAtNs = now - realConnection2.getIdleAtNs(); if (idleAtNs > j10) { realConnection = realConnection2; j10 = idleAtNs; } } } } long j11 = this.keepAliveDurationNs; if (j10 < j11 && i10 <= this.maxIdleConnections) { if (i10 > 0) { return j11 - j10; } if (i11 > 0) { return j11; } return -1L; } g.f(realConnection); synchronized (realConnection) { if (!realConnection.getCalls().isEmpty()) { return 0L; } if (realConnection.getIdleAtNs() + j10 != now) { return 0L; } realConnection.setNoNewExchanges(true); this.connections.remove(realConnection); Util.closeQuietly(realConnection.socket()); if (this.connections.isEmpty()) { this.cleanupQueue.cancelAll(); } return 0L; } } public final boolean connectionBecameIdle(@NotNull RealConnection connection) { g.i(connection, "connection"); if (Util.assertionsEnabled && !Thread.holdsLock(connection)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + connection); } if (!connection.getNoNewExchanges() && this.maxIdleConnections != 0) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); return false; } connection.setNoNewExchanges(true); this.connections.remove(connection); if (this.connections.isEmpty()) { this.cleanupQueue.cancelAll(); } return true; } public final int connectionCount() { return this.connections.size(); } public final void evictAll() { Socket socket; Iterator it = this.connections.iterator(); g.h(it, "connections.iterator()"); while (it.hasNext()) { RealConnection next = it.next(); g.h(next, "connection"); synchronized (next) { if (next.getCalls().isEmpty()) { it.remove(); next.setNoNewExchanges(true); socket = next.socket(); } else { socket = null; } } if (socket != null) { Util.closeQuietly(socket); } } if (this.connections.isEmpty()) { this.cleanupQueue.cancelAll(); } } public final int idleConnectionCount() { boolean zIsEmpty; ConcurrentLinkedQueue concurrentLinkedQueue = this.connections; int i10 = 0; if (!(concurrentLinkedQueue instanceof Collection) || !concurrentLinkedQueue.isEmpty()) { for (RealConnection realConnection : concurrentLinkedQueue) { g.h(realConnection, "it"); synchronized (realConnection) { zIsEmpty = realConnection.getCalls().isEmpty(); } if (zIsEmpty && (i10 = i10 + 1) < 0) { throw new ArithmeticException("Count overflow has happened."); } } } return i10; } public final void put(@NotNull RealConnection realConnection) { g.i(realConnection, "connection"); if (!Util.assertionsEnabled || Thread.holdsLock(realConnection)) { this.connections.add(realConnection); TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } else { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + realConnection); } } }