.class public final Lokhttp3/internal/connection/RealConnectionPool; .super Ljava/lang/Object; .source "RealConnectionPool.kt" # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lokhttp3/internal/connection/RealConnectionPool$Companion; } .end annotation .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nRealConnectionPool.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealConnectionPool.kt\nokhttp3/internal/connection/RealConnectionPool\n+ 2 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n+ 3 Util.kt\nokhttp3/internal/Util\n*L\n1#1,232:1\n1526#2,4:233\n573#3,4:237\n573#3,4:241\n573#3,4:245\n*E\n*S KotlinDebug\n*F\n+ 1 RealConnectionPool.kt\nokhttp3/internal/connection/RealConnectionPool\n*L\n55#1,4:233\n76#1,4:237\n88#1,4:241\n99#1,4:245\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = { 0x1, 0x0, 0x3 } d1 = { "\u0000c\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0008\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\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\u0008\u0007\n\u0002\u0010\u0002\n\u0002\u0008\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\u0008\u001a\u00020\t\u00a2\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\u000cX\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u0010\u0010\r\u001a\u00020\u000eX\u0082\u0004\u00a2\u0006\u0004\n\u0002\u0010\u000fR\u0014\u0010\u0010\u001a\u0008\u0012\u0004\u0012\u00020\u00120\u0011X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0013\u001a\u00020\u0007X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0004\u001a\u00020\u0005X\u0082\u0004\u00a2\u0006\u0002\n\u0000\u00a8\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/ArrayDeque;", "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 = 0x1 mv = { 0x1, 0x1, 0x10 } .end annotation # static fields .field public static final Companion:Lokhttp3/internal/connection/RealConnectionPool$Companion; # instance fields .field private final cleanupQueue:Lokhttp3/internal/concurrent/TaskQueue; .field private final cleanupTask:Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1; .field private final connections:Ljava/util/ArrayDeque; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/ArrayDeque<", "Lokhttp3/internal/connection/RealConnection;", ">;" } .end annotation .end field .field private final keepAliveDurationNs:J .field private final maxIdleConnections:I # direct methods .method static constructor ()V .registers 2 new-instance v0, Lokhttp3/internal/connection/RealConnectionPool$Companion; const/4 v1, 0x0 invoke-direct {v0, v1}, Lokhttp3/internal/connection/RealConnectionPool$Companion;->(Lkotlin/jvm/internal/DefaultConstructorMarker;)V sput-object v0, Lokhttp3/internal/connection/RealConnectionPool;->Companion:Lokhttp3/internal/connection/RealConnectionPool$Companion; return-void .end method .method public constructor (Lokhttp3/internal/concurrent/TaskRunner;IJLjava/util/concurrent/TimeUnit;)V .registers 8 const-string v0, "taskRunner" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V const-string v0, "timeUnit" invoke-static {p5, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 33 invoke-direct {p0}, Ljava/lang/Object;->()V iput p2, p0, Lokhttp3/internal/connection/RealConnectionPool;->maxIdleConnections:I .line 40 invoke-virtual {p5, p3, p4}, Ljava/util/concurrent/TimeUnit;->toNanos(J)J move-result-wide v0 iput-wide v0, p0, Lokhttp3/internal/connection/RealConnectionPool;->keepAliveDurationNs:J .line 42 invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskRunner;->newQueue()Lokhttp3/internal/concurrent/TaskQueue; move-result-object p1 iput-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupQueue:Lokhttp3/internal/concurrent/TaskQueue; .line 43 new-instance p1, Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1; new-instance p2, Ljava/lang/StringBuilder; invoke-direct {p2}, Ljava/lang/StringBuilder;->()V sget-object p5, Lokhttp3/internal/Util;->okHttpName:Ljava/lang/String; invoke-virtual {p2, p5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object p2 const-string p5, " ConnectionPool" invoke-virtual {p2, p5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object p2 invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p2 invoke-direct {p1, p0, p2}, Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1;->(Lokhttp3/internal/connection/RealConnectionPool;Ljava/lang/String;)V iput-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupTask:Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1; .line 47 new-instance p1, Ljava/util/ArrayDeque; invoke-direct {p1}, Ljava/util/ArrayDeque;->()V iput-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; const-wide/16 p1, 0x0 cmp-long p1, p3, p1 if-lez p1, :cond_46 const/4 p1, 0x1 goto :goto_47 :cond_46 const/4 p1, 0x0 :goto_47 if-eqz p1, :cond_4a return-void .line 51 :cond_4a new-instance p1, Ljava/lang/StringBuilder; const-string p2, "keepAliveDuration <= 0: " invoke-direct {p1, p2}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V invoke-virtual {p1, p3, p4}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder; move-result-object p1 invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 new-instance p2, Ljava/lang/IllegalArgumentException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p2, p1}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V check-cast p2, Ljava/lang/Throwable; throw p2 .end method .method private final pruneAndGetAllocationCount(Lokhttp3/internal/connection/RealConnection;J)I .registers 10 .line 199 invoke-virtual {p1}, Lokhttp3/internal/connection/RealConnection;->getCalls()Ljava/util/List; move-result-object v0 const/4 v1, 0x0 move v2, v1 .line 201 :cond_6 :goto_6 invoke-interface {v0}, Ljava/util/List;->size()I move-result v3 if-ge v2, v3, :cond_69 .line 202 invoke-interface {v0, v2}, Ljava/util/List;->get(I)Ljava/lang/Object; move-result-object v3 check-cast v3, Ljava/lang/ref/Reference; .line 204 invoke-virtual {v3}, Ljava/lang/ref/Reference;->get()Ljava/lang/Object; move-result-object v4 if-eqz v4, :cond_1b add-int/lit8 v2, v2, 0x1 goto :goto_6 :cond_1b if-eqz v3, :cond_61 .line 210 check-cast v3, Lokhttp3/internal/connection/RealCall$CallReference; .line 211 new-instance v4, Ljava/lang/StringBuilder; const-string v5, "A connection to " invoke-direct {v4, v5}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V invoke-virtual {p1}, Lokhttp3/internal/connection/RealConnection;->route()Lokhttp3/Route; move-result-object v5 invoke-virtual {v5}, Lokhttp3/Route;->address()Lokhttp3/Address; move-result-object v5 invoke-virtual {v5}, Lokhttp3/Address;->url()Lokhttp3/HttpUrl; move-result-object v5 invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; move-result-object v4 const-string v5, " was leaked. Did you forget to close a response body?" invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v4 invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v4 .line 213 sget-object v5, Lokhttp3/internal/platform/Platform;->Companion:Lokhttp3/internal/platform/Platform$Companion; invoke-virtual {v5}, Lokhttp3/internal/platform/Platform$Companion;->get()Lokhttp3/internal/platform/Platform; move-result-object v5 invoke-virtual {v3}, Lokhttp3/internal/connection/RealCall$CallReference;->getCallStackTrace()Ljava/lang/Object; move-result-object v3 invoke-virtual {v5, v4, v3}, Lokhttp3/internal/platform/Platform;->logCloseableLeak(Ljava/lang/String;Ljava/lang/Object;)V .line 215 invoke-interface {v0, v2}, Ljava/util/List;->remove(I)Ljava/lang/Object; const/4 v3, 0x1 .line 216 invoke-virtual {p1, v3}, Lokhttp3/internal/connection/RealConnection;->setNoNewExchanges(Z)V .line 219 invoke-interface {v0}, Ljava/util/List;->isEmpty()Z move-result v3 if-eqz v3, :cond_6 .line 220 iget-wide v2, p0, Lokhttp3/internal/connection/RealConnectionPool;->keepAliveDurationNs:J sub-long/2addr p2, v2 invoke-virtual {p1, p2, p3}, Lokhttp3/internal/connection/RealConnection;->setIdleAtNs$okhttp(J)V return v1 .line 210 :cond_61 new-instance p1, Lkotlin/TypeCastException; const-string p2, "null cannot be cast to non-null type okhttp3.internal.connection.RealCall.CallReference" invoke-direct {p1, p2}, Lkotlin/TypeCastException;->(Ljava/lang/String;)V throw p1 .line 225 :cond_69 invoke-interface {v0}, Ljava/util/List;->size()I move-result p1 return p1 .end method # virtual methods .method public final callAcquirePooledConnection(Lokhttp3/Address;Lokhttp3/internal/connection/RealCall;Ljava/util/List;Z)Z .registers 8 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lokhttp3/Address;", "Lokhttp3/internal/connection/RealCall;", "Ljava/util/List<", "Lokhttp3/Route;", ">;Z)Z" } .end annotation const-string v0, "address" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V const-string v0, "call" invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 237 sget-boolean v0, Lokhttp3/internal/Util;->assertionsEnabled:Z if-eqz v0, :cond_43 invoke-static {p0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z move-result v0 if-eqz v0, :cond_15 goto :goto_43 .line 238 :cond_15 new-instance p1, Ljava/lang/AssertionError; new-instance p2, Ljava/lang/StringBuilder; const-string p3, "Thread " invoke-direct {p2, p3}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object p3 const-string p4, "Thread.currentThread()" invoke-static {p3, p4}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V invoke-virtual {p3}, Ljava/lang/Thread;->getName()Ljava/lang/String; move-result-object p3 invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object p2 const-string p3, " MUST hold lock on " invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object p2 invoke-virtual {p2, p0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; move-result-object p2 invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p2 invoke-direct {p1, p2}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V check-cast p1, Ljava/lang/Throwable; throw p1 .line 78 :cond_43 :goto_43 iget-object v0, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {v0}, Ljava/util/ArrayDeque;->iterator()Ljava/util/Iterator; move-result-object v0 :goto_49 invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z move-result v1 if-eqz v1, :cond_6f invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v1 check-cast v1, Lokhttp3/internal/connection/RealConnection; if-eqz p4, :cond_5e .line 79 invoke-virtual {v1}, Lokhttp3/internal/connection/RealConnection;->isMultiplexed()Z move-result v2 if-nez v2, :cond_5e goto :goto_49 .line 80 :cond_5e invoke-virtual {v1, p1, p3}, Lokhttp3/internal/connection/RealConnection;->isEligible$okhttp(Lokhttp3/Address;Ljava/util/List;)Z move-result v2 if-nez v2, :cond_65 goto :goto_49 .line 81 :cond_65 const-string p1, "connection" invoke-static {v1, p1}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V invoke-virtual {p2, v1}, Lokhttp3/internal/connection/RealCall;->acquireConnectionNoEvents(Lokhttp3/internal/connection/RealConnection;)V const/4 p1, 0x1 return p1 :cond_6f const/4 p1, 0x0 return p1 .end method .method public final cleanup(J)J .registers 13 const/4 v0, 0x0 .line 141 move-object v1, v0 check-cast v1, Lokhttp3/internal/connection/RealConnection; .line 145 monitor-enter p0 .line 146 :try_start_5 iget-object v1, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {v1}, Ljava/util/ArrayDeque;->iterator()Ljava/util/Iterator; move-result-object v1 const/4 v2, 0x0 const-wide/high16 v3, -0x8000000000000000L move-wide v4, v3 move v3, v2 :cond_10 :goto_10 invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z move-result v6 if-eqz v6, :cond_39 invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v6 check-cast v6, Lokhttp3/internal/connection/RealConnection; .line 148 const-string v7, "connection" invoke-static {v6, v7}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V invoke-direct {p0, v6, p1, p2}, Lokhttp3/internal/connection/RealConnectionPool;->pruneAndGetAllocationCount(Lokhttp3/internal/connection/RealConnection;J)I move-result v7 if-lez v7, :cond_2a add-int/lit8 v3, v3, 0x1 goto :goto_10 :cond_2a add-int/lit8 v2, v2, 0x1 .line 156 invoke-virtual {v6}, Lokhttp3/internal/connection/RealConnection;->getIdleAtNs$okhttp()J move-result-wide v7 sub-long v7, p1, v7 cmp-long v9, v7, v4 if-lez v9, :cond_10 move-object v0, v6 move-wide v4, v7 goto :goto_10 .line 165 :cond_39 iget-wide p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->keepAliveDurationNs:J cmp-long v1, v4, p1 if-gez v1, :cond_51 iget v1, p0, Lokhttp3/internal/connection/RealConnectionPool;->maxIdleConnections:I :try_end_41 .catchall {:try_start_5 .. :try_end_41} :catchall_75 if-le v2, v1, :cond_44 goto :goto_51 :cond_44 if-lez v2, :cond_49 sub-long/2addr p1, v4 .line 173 monitor-exit p0 return-wide p1 :cond_49 if-lez v3, :cond_4d .line 178 monitor-exit p0 return-wide p1 .line 182 :cond_4d monitor-exit p0 const-wide/16 p1, -0x1 return-wide p1 .line 168 :cond_51 :goto_51 :try_start_51 iget-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {p1, v0}, Ljava/util/ArrayDeque;->remove(Ljava/lang/Object;)Z .line 169 iget-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {p1}, Ljava/util/ArrayDeque;->isEmpty()Z move-result p1 if-eqz p1, :cond_63 iget-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupQueue:Lokhttp3/internal/concurrent/TaskQueue; invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->cancelAll()V .line 185 :cond_63 sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit; :try_end_65 .catchall {:try_start_51 .. :try_end_65} :catchall_75 .line 145 monitor-exit p0 if-nez v0, :cond_6b .line 187 invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V :cond_6b invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->socket()Ljava/net/Socket; move-result-object p1 invoke-static {p1}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V const-wide/16 p1, 0x0 return-wide p1 :catchall_75 move-exception p1 .line 145 monitor-exit p0 throw p1 .end method .method public final connectionBecameIdle(Lokhttp3/internal/connection/RealConnection;)Z .registers 9 const-string v0, "connection" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 245 sget-boolean v0, Lokhttp3/internal/Util;->assertionsEnabled:Z if-eqz v0, :cond_3e invoke-static {p0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z move-result v0 if-eqz v0, :cond_10 goto :goto_3e .line 246 :cond_10 new-instance p1, Ljava/lang/AssertionError; new-instance v0, Ljava/lang/StringBuilder; const-string v1, "Thread " invoke-direct {v0, v1}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object v1 const-string v2, "Thread.currentThread()" invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V invoke-virtual {v1}, Ljava/lang/Thread;->getName()Ljava/lang/String; move-result-object v1 invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v0 const-string v1, " MUST hold lock on " invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0, p0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {p1, v0}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V check-cast p1, Ljava/lang/Throwable; throw p1 .line 101 :cond_3e :goto_3e invoke-virtual {p1}, Lokhttp3/internal/connection/RealConnection;->getNoNewExchanges()Z move-result v0 if-nez v0, :cond_59 iget v0, p0, Lokhttp3/internal/connection/RealConnectionPool;->maxIdleConnections:I if-nez v0, :cond_49 goto :goto_59 .line 106 :cond_49 iget-object v1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupQueue:Lokhttp3/internal/concurrent/TaskQueue; iget-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupTask:Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1; move-object v2, p1 check-cast v2, Lokhttp3/internal/concurrent/Task; const/4 v5, 0x2 const/4 v6, 0x0 const-wide/16 v3, 0x0 invoke-static/range {v1 .. v6}, Lokhttp3/internal/concurrent/TaskQueue;->schedule$default(Lokhttp3/internal/concurrent/TaskQueue;Lokhttp3/internal/concurrent/Task;JILjava/lang/Object;)V const/4 p1, 0x0 goto :goto_6c .line 102 :cond_59 :goto_59 iget-object v0, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {v0, p1}, Ljava/util/ArrayDeque;->remove(Ljava/lang/Object;)Z .line 103 iget-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {p1}, Ljava/util/ArrayDeque;->isEmpty()Z move-result p1 if-eqz p1, :cond_6b iget-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupQueue:Lokhttp3/internal/concurrent/TaskQueue; invoke-virtual {p1}, Lokhttp3/internal/concurrent/TaskQueue;->cancelAll()V :cond_6b const/4 p1, 0x1 :goto_6c return p1 .end method .method public final declared-synchronized connectionCount()I .registers 2 monitor-enter p0 .line 59 :try_start_1 iget-object v0, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {v0}, Ljava/util/ArrayDeque;->size()I move-result v0 :try_end_7 .catchall {:try_start_1 .. :try_end_7} :catchall_9 monitor-exit p0 return v0 :catchall_9 move-exception v0 :try_start_a monitor-exit p0 :try_end_b .catchall {:try_start_a .. :try_end_b} :catchall_9 throw v0 .end method .method public final evictAll()V .registers 5 .line 112 new-instance v0, Ljava/util/ArrayList; invoke-direct {v0}, Ljava/util/ArrayList;->()V check-cast v0, Ljava/util/List; .line 113 monitor-enter p0 .line 114 :try_start_8 iget-object v1, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {v1}, Ljava/util/ArrayDeque;->iterator()Ljava/util/Iterator; move-result-object v1 const-string v2, "connections.iterator()" invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 115 :cond_13 :goto_13 invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z move-result v2 if-eqz v2, :cond_39 .line 116 invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v2 check-cast v2, Lokhttp3/internal/connection/RealConnection; .line 117 invoke-virtual {v2}, Lokhttp3/internal/connection/RealConnection;->getCalls()Ljava/util/List; move-result-object v3 invoke-interface {v3}, Ljava/util/List;->isEmpty()Z move-result v3 if-eqz v3, :cond_13 const/4 v3, 0x1 .line 118 invoke-virtual {v2, v3}, Lokhttp3/internal/connection/RealConnection;->setNoNewExchanges(Z)V .line 119 const-string v3, "connection" invoke-static {v2, v3}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V invoke-interface {v0, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 120 invoke-interface {v1}, Ljava/util/Iterator;->remove()V goto :goto_13 .line 123 :cond_39 iget-object v1, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {v1}, Ljava/util/ArrayDeque;->isEmpty()Z move-result v1 if-eqz v1, :cond_46 iget-object v1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupQueue:Lokhttp3/internal/concurrent/TaskQueue; invoke-virtual {v1}, Lokhttp3/internal/concurrent/TaskQueue;->cancelAll()V .line 124 :cond_46 sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit; :try_end_48 .catchall {:try_start_8 .. :try_end_48} :catchall_62 .line 113 monitor-exit p0 .line 126 invoke-interface {v0}, Ljava/util/List;->iterator()Ljava/util/Iterator; move-result-object v0 :goto_4d invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z move-result v1 if-eqz v1, :cond_61 invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v1 check-cast v1, Lokhttp3/internal/connection/RealConnection; .line 127 invoke-virtual {v1}, Lokhttp3/internal/connection/RealConnection;->socket()Ljava/net/Socket; move-result-object v1 invoke-static {v1}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V goto :goto_4d :cond_61 return-void :catchall_62 move-exception v0 .line 113 monitor-exit p0 throw v0 .end method .method public final declared-synchronized idleConnectionCount()I .registers 4 monitor-enter p0 .line 55 :try_start_1 iget-object v0, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; check-cast v0, Ljava/lang/Iterable; .line 233 instance-of v1, v0, Ljava/util/Collection; const/4 v2, 0x0 if-eqz v1, :cond_14 move-object v1, v0 check-cast v1, Ljava/util/Collection; invoke-interface {v1}, Ljava/util/Collection;->isEmpty()Z move-result v1 if-eqz v1, :cond_14 goto :goto_36 .line 235 :cond_14 invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator; move-result-object v0 :cond_18 :goto_18 invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z move-result v1 if-eqz v1, :cond_36 invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v1 check-cast v1, Lokhttp3/internal/connection/RealConnection; .line 55 invoke-virtual {v1}, Lokhttp3/internal/connection/RealConnection;->getCalls()Ljava/util/List; move-result-object v1 invoke-interface {v1}, Ljava/util/List;->isEmpty()Z move-result v1 if-eqz v1, :cond_18 add-int/lit8 v2, v2, 0x1 if-gez v2, :cond_18 invoke-static {}, Lkotlin/collections/CollectionsKt;->throwCountOverflow()V :try_end_35 .catchall {:try_start_1 .. :try_end_35} :catchall_38 goto :goto_18 .line 236 :cond_36 :goto_36 monitor-exit p0 return v2 :catchall_38 move-exception v0 :try_start_39 monitor-exit p0 :try_end_3a .catchall {:try_start_39 .. :try_end_3a} :catchall_38 throw v0 .end method .method public final put(Lokhttp3/internal/connection/RealConnection;)V .registers 9 const-string v0, "connection" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V .line 241 sget-boolean v0, Lokhttp3/internal/Util;->assertionsEnabled:Z if-eqz v0, :cond_3e invoke-static {p0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z move-result v0 if-eqz v0, :cond_10 goto :goto_3e .line 242 :cond_10 new-instance p1, Ljava/lang/AssertionError; new-instance v0, Ljava/lang/StringBuilder; const-string v1, "Thread " invoke-direct {v0, v1}, Ljava/lang/StringBuilder;->(Ljava/lang/String;)V invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread; move-result-object v1 const-string v2, "Thread.currentThread()" invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V invoke-virtual {v1}, Ljava/lang/Thread;->getName()Ljava/lang/String; move-result-object v1 invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v0 const-string v1, " MUST hold lock on " invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0, p0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; move-result-object v0 invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {p1, v0}, Ljava/lang/AssertionError;->(Ljava/lang/Object;)V check-cast p1, Ljava/lang/Throwable; throw p1 .line 90 :cond_3e :goto_3e iget-object v0, p0, Lokhttp3/internal/connection/RealConnectionPool;->connections:Ljava/util/ArrayDeque; invoke-virtual {v0, p1}, Ljava/util/ArrayDeque;->add(Ljava/lang/Object;)Z .line 91 iget-object v1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupQueue:Lokhttp3/internal/concurrent/TaskQueue; iget-object p1, p0, Lokhttp3/internal/connection/RealConnectionPool;->cleanupTask:Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1; move-object v2, p1 check-cast v2, Lokhttp3/internal/concurrent/Task; const/4 v5, 0x2 const/4 v6, 0x0 const-wide/16 v3, 0x0 invoke-static/range {v1 .. v6}, Lokhttp3/internal/concurrent/TaskQueue;->schedule$default(Lokhttp3/internal/concurrent/TaskQueue;Lokhttp3/internal/concurrent/Task;JILjava/lang/Object;)V return-void .end method