package okhttp3.n0.connection; import java.lang.ref.Reference; import java.net.Socket; import java.util.List; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.TimeUnit; import kotlin.Metadata; import kotlin.jvm.internal.o; import okhttp3.Address; import okhttp3.Route; import okhttp3.n0.c; import okhttp3.n0.concurrent.Task; import okhttp3.n0.concurrent.TaskQueue; import okhttp3.n0.concurrent.TaskRunner; import okhttp3.n0.connection.RealCall; import okhttp3.n0.platform.Platform; /* JADX INFO: renamed from: y.n0.g.i, reason: from Kotlin metadata */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000c\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0010\u0002\n\u0002\b\u0005*\u0001\u000e\u0018\u0000 (2\u00020\u0001:\u0001(B%\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u0012\u0006\u0010\u0006\u001a\u00020\u0007\u0012\u0006\u0010\b\u001a\u00020\t¢\u0006\u0002\u0010\nJ.\u0010\u0014\u001a\u00020\u00152\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u0018\u001a\u00020\u00192\u000e\u0010\u001a\u001a\n\u0012\u0004\u0012\u00020\u001c\u0018\u00010\u001b2\u0006\u0010\u001d\u001a\u00020\u0015J\u000e\u0010\u001e\u001a\u00020\u00072\u0006\u0010\u001f\u001a\u00020\u0007J\u000e\u0010 \u001a\u00020\u00152\u0006\u0010!\u001a\u00020\u0012J\u0006\u0010\"\u001a\u00020\u0005J\u0006\u0010#\u001a\u00020$J\u0006\u0010%\u001a\u00020\u0005J\u0018\u0010&\u001a\u00020\u00052\u0006\u0010!\u001a\u00020\u00122\u0006\u0010\u001f\u001a\u00020\u0007H\u0002J\u000e\u0010'\u001a\u00020$2\u0006\u0010!\u001a\u00020\u0012R\u000e\u0010\u000b\u001a\u00020\fX\u0082\u0004¢\u0006\u0002\n\u0000R\u0010\u0010\r\u001a\u00020\u000eX\u0082\u0004¢\u0006\u0004\n\u0002\u0010\u000fR\u0014\u0010\u0010\u001a\b\u0012\u0004\u0012\u00020\u00120\u0011X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0013\u001a\u00020\u0007X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0004\u001a\u00020\u0005X\u0082\u0004¢\u0006\u0002\n\u0000¨\u0006)"}, d2 = {"Lokhttp3/internal/connection/RealConnectionPool;", "", "taskRunner", "Lokhttp3/internal/concurrent/TaskRunner;", "maxIdleConnections", "", "keepAliveDuration", "", "timeUnit", "Ljava/util/concurrent/TimeUnit;", "(Lokhttp3/internal/concurrent/TaskRunner;IJLjava/util/concurrent/TimeUnit;)V", "cleanupQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "cleanupTask", "okhttp3/internal/connection/RealConnectionPool$cleanupTask$1", "Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1;", "connections", "Ljava/util/concurrent/ConcurrentLinkedQueue;", "Lokhttp3/internal/connection/RealConnection;", "keepAliveDurationNs", "callAcquirePooledConnection", "", "address", "Lokhttp3/Address;", "call", "Lokhttp3/internal/connection/RealCall;", "routes", "", "Lokhttp3/Route;", "requireMultiplexed", "cleanup", "now", "connectionBecameIdle", "connection", "connectionCount", "evictAll", "", "idleConnectionCount", "pruneAndGetAllocationCount", "put", "Companion", "okhttp"}, k = 1, mv = {1, 6, 0}, xi = 48) public final class RealConnectionPool { public final int a; /* JADX INFO: renamed from: b, reason: collision with root package name */ public final long f9808b; /* JADX INFO: renamed from: c, reason: collision with root package name */ public final TaskQueue f9809c; /* JADX INFO: renamed from: d, reason: collision with root package name */ public final a f9810d; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final ConcurrentLinkedQueue f9811e; /* JADX INFO: renamed from: y.n0.g.i$a */ @Metadata(d1 = {"\u0000\u0011\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000*\u0001\u0000\b\n\u0018\u00002\u00020\u0001J\b\u0010\u0002\u001a\u00020\u0003H\u0016¨\u0006\u0004"}, d2 = {"okhttp3/internal/connection/RealConnectionPool$cleanupTask$1", "Lokhttp3/internal/concurrent/Task;", "runOnce", "", "okhttp"}, k = 1, mv = {1, 6, 0}, xi = 48) public static final class a extends Task { public a(String str) { super(str, true); } @Override // okhttp3.n0.concurrent.Task public long a() { RealConnectionPool realConnectionPool = RealConnectionPool.this; long jNanoTime = System.nanoTime(); int i2 = 0; long j2 = Long.MIN_VALUE; RealConnection realConnection = null; int i3 = 0; for (RealConnection realConnection2 : realConnectionPool.f9811e) { o.e(realConnection2, "connection"); synchronized (realConnection2) { if (realConnectionPool.b(realConnection2, jNanoTime) > 0) { i3++; } else { i2++; long j3 = jNanoTime - realConnection2.f9803q; if (j3 > j2) { realConnection = realConnection2; j2 = j3; } } } } long j4 = realConnectionPool.f9808b; if (j2 < j4 && i2 <= realConnectionPool.a) { if (i2 > 0) { return j4 - j2; } if (i3 > 0) { return j4; } return -1L; } o.c(realConnection); synchronized (realConnection) { if (!(!realConnection.f9802p.isEmpty()) && realConnection.f9803q + j2 == jNanoTime) { realConnection.f9796j = true; realConnectionPool.f9811e.remove(realConnection); Socket socket = realConnection.f9790d; o.c(socket); c.f(socket); if (!realConnectionPool.f9811e.isEmpty()) { return 0L; } realConnectionPool.f9809c.a(); return 0L; } return 0L; } } } public RealConnectionPool(TaskRunner taskRunner, int i2, long j2, TimeUnit timeUnit) { o.f(taskRunner, "taskRunner"); o.f(timeUnit, "timeUnit"); this.a = i2; this.f9808b = timeUnit.toNanos(j2); this.f9809c = taskRunner.f(); this.f9810d = new a(o.l(c.f9718h, " ConnectionPool")); this.f9811e = new ConcurrentLinkedQueue<>(); if (!(j2 > 0)) { throw new IllegalArgumentException(o.l("keepAliveDuration <= 0: ", Long.valueOf(j2)).toString()); } } public final boolean a(Address address, RealCall realCall, List list, boolean z2) { o.f(address, "address"); o.f(realCall, "call"); for (RealConnection realConnection : this.f9811e) { o.e(realConnection, "connection"); synchronized (realConnection) { if (z2) { if (!realConnection.j()) { } } if (realConnection.h(address, list)) { realCall.c(realConnection); return true; } } } return false; } public final int b(RealConnection realConnection, long j2) { byte[] bArr = c.a; List> list = realConnection.f9802p; int i2 = 0; while (i2 < list.size()) { Reference reference = list.get(i2); if (reference.get() != null) { i2++; } else { StringBuilder sbF = g.a.a.a.a.F("A connection to "); sbF.append(realConnection.f9788b.a.f9541i); sbF.append(" was leaked. Did you forget to close a response body?"); String string = sbF.toString(); Platform.a aVar = Platform.a; Platform.f10049b.k(string, ((RealCall.b) reference).a); list.remove(i2); realConnection.f9796j = true; if (list.isEmpty()) { realConnection.f9803q = j2 - this.f9808b; return 0; } } } return list.size(); } }