Rabbit-R1/original r1/smali/smali_classes3/okhttp3/internal/connection/ExchangeFinder.smali
2024-05-21 17:08:36 -04:00

1158 lines
34 KiB
Smali

.class public final Lokhttp3/internal/connection/ExchangeFinder;
.super Ljava/lang/Object;
.source "ExchangeFinder.kt"
# annotations
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000r\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0010\u0008\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0010\u000b\n\u0002\u0008\u0006\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\u0018\u00002\u00020\u0001B%\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\u0016\u0010\u0017\u001a\u00020\u00182\u0006\u0010\u0019\u001a\u00020\u001a2\u0006\u0010\u001b\u001a\u00020\u001cJ0\u0010\u001d\u001a\u00020\u001e2\u0006\u0010\u001f\u001a\u00020\u000e2\u0006\u0010 \u001a\u00020\u000e2\u0006\u0010!\u001a\u00020\u000e2\u0006\u0010\"\u001a\u00020\u000e2\u0006\u0010#\u001a\u00020$H\u0002J8\u0010%\u001a\u00020\u001e2\u0006\u0010\u001f\u001a\u00020\u000e2\u0006\u0010 \u001a\u00020\u000e2\u0006\u0010!\u001a\u00020\u000e2\u0006\u0010\"\u001a\u00020\u000e2\u0006\u0010#\u001a\u00020$2\u0006\u0010&\u001a\u00020$H\u0002J\u0006\u0010\'\u001a\u00020$J\n\u0010(\u001a\u0004\u0018\u00010\u0010H\u0002J\u000e\u0010)\u001a\u00020$2\u0006\u0010*\u001a\u00020+J\u000e\u0010,\u001a\u00020-2\u0006\u0010.\u001a\u00020/R\u0014\u0010\u0004\u001a\u00020\u0005X\u0080\u0004\u00a2\u0006\u0008\n\u0000\u001a\u0004\u0008\u000b\u0010\u000cR\u000e\u0010\u0006\u001a\u00020\u0007X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\r\u001a\u00020\u000eX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0008\u001a\u00020\tX\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u000f\u001a\u0004\u0018\u00010\u0010X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0011\u001a\u00020\u000eX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0012\u001a\u00020\u000eX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u0013\u001a\u0004\u0018\u00010\u0014X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u0015\u001a\u0004\u0018\u00010\u0016X\u0082\u000e\u00a2\u0006\u0002\n\u0000\u00a8\u00060"
}
d2 = {
"Lokhttp3/internal/connection/ExchangeFinder;",
"",
"connectionPool",
"Lokhttp3/internal/connection/RealConnectionPool;",
"address",
"Lokhttp3/Address;",
"call",
"Lokhttp3/internal/connection/RealCall;",
"eventListener",
"Lokhttp3/EventListener;",
"(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Address;Lokhttp3/internal/connection/RealCall;Lokhttp3/EventListener;)V",
"getAddress$okhttp",
"()Lokhttp3/Address;",
"connectionShutdownCount",
"",
"nextRouteToTry",
"Lokhttp3/Route;",
"otherFailureCount",
"refusedStreamCount",
"routeSelection",
"Lokhttp3/internal/connection/RouteSelector$Selection;",
"routeSelector",
"Lokhttp3/internal/connection/RouteSelector;",
"find",
"Lokhttp3/internal/http/ExchangeCodec;",
"client",
"Lokhttp3/OkHttpClient;",
"chain",
"Lokhttp3/internal/http/RealInterceptorChain;",
"findConnection",
"Lokhttp3/internal/connection/RealConnection;",
"connectTimeout",
"readTimeout",
"writeTimeout",
"pingIntervalMillis",
"connectionRetryEnabled",
"",
"findHealthyConnection",
"doExtensiveHealthChecks",
"retryAfterFailure",
"retryRoute",
"sameHostAndPort",
"url",
"Lokhttp3/HttpUrl;",
"trackFailure",
"",
"e",
"Ljava/io/IOException;",
"okhttp"
}
k = 0x1
mv = {
0x1,
0x4,
0x0
}
.end annotation
# instance fields
.field private final address:Lokhttp3/Address;
.field private final call:Lokhttp3/internal/connection/RealCall;
.field private final connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
.field private connectionShutdownCount:I
.field private final eventListener:Lokhttp3/EventListener;
.field private nextRouteToTry:Lokhttp3/Route;
.field private otherFailureCount:I
.field private refusedStreamCount:I
.field private routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
.field private routeSelector:Lokhttp3/internal/connection/RouteSelector;
# direct methods
.method public constructor <init>(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Address;Lokhttp3/internal/connection/RealCall;Lokhttp3/EventListener;)V
.locals 1
const-string v0, "connectionPool"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
const-string v0, "address"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
const-string v0, "call"
invoke-static {p3, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
const-string v0, "eventListener"
invoke-static {p4, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
.line 56
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
iput-object p1, p0, Lokhttp3/internal/connection/ExchangeFinder;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
iput-object p2, p0, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
iput-object p3, p0, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
iput-object p4, p0, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
return-void
.end method
.method private final findConnection(IIIIZ)Lokhttp3/internal/connection/RealConnection;
.locals 14
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
move-object v1, p0
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 150
invoke-virtual {v0}, Lokhttp3/internal/connection/RealCall;->isCanceled()Z
move-result v0
if-nez v0, :cond_e
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 153
invoke-virtual {v0}, Lokhttp3/internal/connection/RealCall;->getConnection()Lokhttp3/internal/connection/RealConnection;
move-result-object v2
const/4 v0, 0x1
const/4 v3, 0x0
const/4 v4, 0x0
if-eqz v2, :cond_6
.line 155
move-object v5, v4
check-cast v5, Ljava/net/Socket;
.line 156
monitor-enter v2
.line 157
:try_start_0
invoke-virtual {v2}, Lokhttp3/internal/connection/RealConnection;->getNoNewExchanges()Z
move-result v5
if-nez v5, :cond_1
invoke-virtual {v2}, 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 {p0, v5}, Lokhttp3/internal/connection/ExchangeFinder;->sameHostAndPort(Lokhttp3/HttpUrl;)Z
move-result v5
if-nez v5, :cond_0
goto :goto_0
:cond_0
move-object v5, v4
goto :goto_1
:cond_1
:goto_0
iget-object v5, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 158
invoke-virtual {v5}, Lokhttp3/internal/connection/RealCall;->releaseConnectionNoEvents$okhttp()Ljava/net/Socket;
move-result-object v5
.line 160
:goto_1
sget-object v6, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
.line 156
monitor-exit v2
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 164
invoke-virtual {v6}, Lokhttp3/internal/connection/RealCall;->getConnection()Lokhttp3/internal/connection/RealConnection;
move-result-object v6
if-eqz v6, :cond_4
if-nez v5, :cond_2
goto :goto_2
:cond_2
move v0, v3
:goto_2
if-eqz v0, :cond_3
return-object v2
:cond_3
const-string v0, "Check failed."
.line 165
new-instance v1, Ljava/lang/IllegalStateException;
invoke-virtual {v0}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object v0
invoke-direct {v1, v0}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast v1, Ljava/lang/Throwable;
throw v1
:cond_4
if-eqz v5, :cond_5
.line 170
invoke-static {v5}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
:cond_5
iget-object v5, v1, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 171
check-cast v6, Lokhttp3/Call;
check-cast v2, Lokhttp3/Connection;
invoke-virtual {v5, v6, v2}, Lokhttp3/EventListener;->connectionReleased(Lokhttp3/Call;Lokhttp3/Connection;)V
goto :goto_3
:catchall_0
move-exception v0
.line 156
monitor-exit v2
throw v0
:cond_6
:goto_3
iput v3, v1, Lokhttp3/internal/connection/ExchangeFinder;->refusedStreamCount:I
iput v3, v1, Lokhttp3/internal/connection/ExchangeFinder;->connectionShutdownCount:I
iput v3, v1, Lokhttp3/internal/connection/ExchangeFinder;->otherFailureCount:I
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
iget-object v5, v1, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 180
invoke-virtual {v2, v5, v6, v4, v3}, Lokhttp3/internal/connection/RealConnectionPool;->callAcquirePooledConnection(Lokhttp3/Address;Lokhttp3/internal/connection/RealCall;Ljava/util/List;Z)Z
move-result v2
if-eqz v2, :cond_7
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 181
invoke-virtual {v0}, Lokhttp3/internal/connection/RealCall;->getConnection()Lokhttp3/internal/connection/RealConnection;
move-result-object v0
invoke-static {v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNull(Ljava/lang/Object;)V
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
iget-object v1, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 182
check-cast v1, Lokhttp3/Call;
move-object v3, v0
check-cast v3, Lokhttp3/Connection;
invoke-virtual {v2, v1, v3}, Lokhttp3/EventListener;->connectionAcquired(Lokhttp3/Call;Lokhttp3/Connection;)V
return-object v0
:cond_7
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->nextRouteToTry:Lokhttp3/Route;
if-eqz v2, :cond_8
.line 191
move-object v3, v4
check-cast v3, Ljava/util/List;
.line 192
invoke-static {v2}, Lkotlin/jvm/internal/Intrinsics;->checkNotNull(Ljava/lang/Object;)V
.line 193
move-object v3, v4
check-cast v3, Lokhttp3/Route;
iput-object v4, v1, Lokhttp3/internal/connection/ExchangeFinder;->nextRouteToTry:Lokhttp3/Route;
:goto_4
move-object v5, v4
goto :goto_5
:cond_8
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
if-eqz v2, :cond_9
.line 194
invoke-static {v2}, Lkotlin/jvm/internal/Intrinsics;->checkNotNull(Ljava/lang/Object;)V
invoke-virtual {v2}, Lokhttp3/internal/connection/RouteSelector$Selection;->hasNext()Z
move-result v2
if-eqz v2, :cond_9
.line 196
move-object v2, v4
check-cast v2, Ljava/util/List;
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
.line 197
invoke-static {v2}, Lkotlin/jvm/internal/Intrinsics;->checkNotNull(Ljava/lang/Object;)V
invoke-virtual {v2}, Lokhttp3/internal/connection/RouteSelector$Selection;->next()Lokhttp3/Route;
move-result-object v2
goto :goto_4
:cond_9
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
if-nez v2, :cond_a
.line 202
new-instance v2, Lokhttp3/internal/connection/RouteSelector;
iget-object v5, v1, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
invoke-virtual {v6}, Lokhttp3/internal/connection/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object v6
invoke-virtual {v6}, Lokhttp3/OkHttpClient;->getRouteDatabase()Lokhttp3/internal/connection/RouteDatabase;
move-result-object v6
iget-object v7, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
check-cast v7, Lokhttp3/Call;
iget-object v8, v1, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
invoke-direct {v2, v5, v6, v7, v8}, Lokhttp3/internal/connection/RouteSelector;-><init>(Lokhttp3/Address;Lokhttp3/internal/connection/RouteDatabase;Lokhttp3/Call;Lokhttp3/EventListener;)V
iput-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
.line 205
:cond_a
invoke-virtual {v2}, Lokhttp3/internal/connection/RouteSelector;->next()Lokhttp3/internal/connection/RouteSelector$Selection;
move-result-object v2
iput-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
.line 207
invoke-virtual {v2}, Lokhttp3/internal/connection/RouteSelector$Selection;->getRoutes()Ljava/util/List;
move-result-object v5
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 209
invoke-virtual {v6}, Lokhttp3/internal/connection/RealCall;->isCanceled()Z
move-result v6
if-nez v6, :cond_d
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
iget-object v7, v1, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
iget-object v8, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 213
invoke-virtual {v6, v7, v8, v5, v3}, Lokhttp3/internal/connection/RealConnectionPool;->callAcquirePooledConnection(Lokhttp3/Address;Lokhttp3/internal/connection/RealCall;Ljava/util/List;Z)Z
move-result v3
if-eqz v3, :cond_b
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 214
invoke-virtual {v0}, Lokhttp3/internal/connection/RealCall;->getConnection()Lokhttp3/internal/connection/RealConnection;
move-result-object v0
invoke-static {v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNull(Ljava/lang/Object;)V
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
iget-object v1, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 215
check-cast v1, Lokhttp3/Call;
move-object v3, v0
check-cast v3, Lokhttp3/Connection;
invoke-virtual {v2, v1, v3}, Lokhttp3/EventListener;->connectionAcquired(Lokhttp3/Call;Lokhttp3/Connection;)V
return-object v0
.line 219
:cond_b
invoke-virtual {v2}, Lokhttp3/internal/connection/RouteSelector$Selection;->next()Lokhttp3/Route;
move-result-object v2
.line 223
:goto_5
new-instance v3, Lokhttp3/internal/connection/RealConnection;
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
invoke-direct {v3, v6, v2}, Lokhttp3/internal/connection/RealConnection;-><init>(Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Route;)V
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 224
invoke-virtual {v6, v3}, Lokhttp3/internal/connection/RealCall;->setConnectionToCancel(Lokhttp3/internal/connection/RealConnection;)V
:try_start_1
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 232
move-object v12, v6
check-cast v12, Lokhttp3/Call;
iget-object v13, v1, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
move-object v6, v3
move v7, p1
move/from16 v8, p2
move/from16 v9, p3
move/from16 v10, p4
move/from16 v11, p5
.line 226
invoke-virtual/range {v6 .. v13}, Lokhttp3/internal/connection/RealConnection;->connect(IIIIZLokhttp3/Call;Lokhttp3/EventListener;)V
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_2
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 236
move-object v7, v4
check-cast v7, Lokhttp3/internal/connection/RealConnection;
invoke-virtual {v6, v4}, Lokhttp3/internal/connection/RealCall;->setConnectionToCancel(Lokhttp3/internal/connection/RealConnection;)V
iget-object v4, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 238
invoke-virtual {v4}, Lokhttp3/internal/connection/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object v4
invoke-virtual {v4}, Lokhttp3/OkHttpClient;->getRouteDatabase()Lokhttp3/internal/connection/RouteDatabase;
move-result-object v4
invoke-virtual {v3}, Lokhttp3/internal/connection/RealConnection;->route()Lokhttp3/Route;
move-result-object v6
invoke-virtual {v4, v6}, Lokhttp3/internal/connection/RouteDatabase;->connected(Lokhttp3/Route;)V
iget-object v4, v1, Lokhttp3/internal/connection/ExchangeFinder;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
iget-object v6, v1, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
iget-object v7, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 242
invoke-virtual {v4, v6, v7, v5, v0}, Lokhttp3/internal/connection/RealConnectionPool;->callAcquirePooledConnection(Lokhttp3/Address;Lokhttp3/internal/connection/RealCall;Ljava/util/List;Z)Z
move-result v0
if-eqz v0, :cond_c
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 243
invoke-virtual {v0}, Lokhttp3/internal/connection/RealCall;->getConnection()Lokhttp3/internal/connection/RealConnection;
move-result-object v0
invoke-static {v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNull(Ljava/lang/Object;)V
iput-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->nextRouteToTry:Lokhttp3/Route;
.line 245
invoke-virtual {v3}, Lokhttp3/internal/connection/RealConnection;->socket()Ljava/net/Socket;
move-result-object v2
invoke-static {v2}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
iget-object v2, v1, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
iget-object v1, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 246
check-cast v1, Lokhttp3/Call;
move-object v3, v0
check-cast v3, Lokhttp3/Connection;
invoke-virtual {v2, v1, v3}, Lokhttp3/EventListener;->connectionAcquired(Lokhttp3/Call;Lokhttp3/Connection;)V
return-object v0
.line 250
:cond_c
monitor-enter v3
:try_start_2
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
.line 251
invoke-virtual {v0, v3}, Lokhttp3/internal/connection/RealConnectionPool;->put(Lokhttp3/internal/connection/RealConnection;)V
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 252
invoke-virtual {v0, v3}, Lokhttp3/internal/connection/RealCall;->acquireConnectionNoEvents(Lokhttp3/internal/connection/RealConnection;)V
.line 253
sget-object v0, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_2
.catchall {:try_start_2 .. :try_end_2} :catchall_1
.line 250
monitor-exit v3
iget-object v0, v1, Lokhttp3/internal/connection/ExchangeFinder;->eventListener:Lokhttp3/EventListener;
iget-object v1, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 255
check-cast v1, Lokhttp3/Call;
move-object v2, v3
check-cast v2, Lokhttp3/Connection;
invoke-virtual {v0, v1, v2}, Lokhttp3/EventListener;->connectionAcquired(Lokhttp3/Call;Lokhttp3/Connection;)V
return-object v3
:catchall_1
move-exception v0
.line 250
monitor-exit v3
throw v0
:catchall_2
move-exception v0
iget-object v1, v1, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 236
move-object v2, v4
check-cast v2, Lokhttp3/internal/connection/RealConnection;
invoke-virtual {v1, v4}, Lokhttp3/internal/connection/RealCall;->setConnectionToCancel(Lokhttp3/internal/connection/RealConnection;)V
throw v0
.line 209
:cond_d
new-instance v0, Ljava/io/IOException;
const-string v1, "Canceled"
invoke-direct {v0, v1}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
check-cast v0, Ljava/lang/Throwable;
throw v0
.line 150
:cond_e
new-instance v0, Ljava/io/IOException;
const-string v1, "Canceled"
invoke-direct {v0, v1}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
check-cast v0, Ljava/lang/Throwable;
throw v0
.end method
.method private final findHealthyConnection(IIIIZZ)Lokhttp3/internal/connection/RealConnection;
.locals 2
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
.line 106
:cond_0
:goto_0
invoke-direct/range {p0 .. p5}, Lokhttp3/internal/connection/ExchangeFinder;->findConnection(IIIIZ)Lokhttp3/internal/connection/RealConnection;
move-result-object v0
.line 115
invoke-virtual {v0, p6}, Lokhttp3/internal/connection/RealConnection;->isHealthy(Z)Z
move-result v1
if-eqz v1, :cond_1
return-object v0
.line 120
:cond_1
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->noNewExchanges$okhttp()V
iget-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->nextRouteToTry:Lokhttp3/Route;
if-eqz v0, :cond_2
goto :goto_0
:cond_2
iget-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
if-eqz v0, :cond_0
.line 126
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector$Selection;->hasNext()Z
move-result v0
if-eqz v0, :cond_3
goto :goto_0
:cond_3
iget-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
if-eqz v0, :cond_0
.line 129
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector;->hasNext()Z
move-result v0
if-eqz v0, :cond_4
goto :goto_0
.line 132
:cond_4
new-instance p0, Ljava/io/IOException;
const-string p1, "exhausted all routes"
invoke-direct {p0, p1}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
check-cast p0, Ljava/lang/Throwable;
throw p0
.end method
.method private final retryRoute()Lokhttp3/Route;
.locals 3
iget v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->refusedStreamCount:I
const/4 v1, 0x0
const/4 v2, 0x1
if-gt v0, v2, :cond_3
iget v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->connectionShutdownCount:I
if-gt v0, v2, :cond_3
iget v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->otherFailureCount:I
if-lez v0, :cond_0
goto :goto_0
:cond_0
iget-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->call:Lokhttp3/internal/connection/RealCall;
.line 310
invoke-virtual {v0}, Lokhttp3/internal/connection/RealCall;->getConnection()Lokhttp3/internal/connection/RealConnection;
move-result-object v0
if-eqz v0, :cond_3
.line 312
monitor-enter v0
.line 313
:try_start_0
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->getRouteFailureCount$okhttp()I
move-result v2
:try_end_0
.catchall {:try_start_0 .. :try_end_0} :catchall_0
if-eqz v2, :cond_1
monitor-exit v0
return-object v1
.line 314
:cond_1
:try_start_1
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->route()Lokhttp3/Route;
move-result-object v2
invoke-virtual {v2}, Lokhttp3/Route;->address()Lokhttp3/Address;
move-result-object v2
invoke-virtual {v2}, Lokhttp3/Address;->url()Lokhttp3/HttpUrl;
move-result-object v2
iget-object p0, p0, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
invoke-virtual {p0}, Lokhttp3/Address;->url()Lokhttp3/HttpUrl;
move-result-object p0
invoke-static {v2, p0}, Lokhttp3/internal/Util;->canReuseConnectionFor(Lokhttp3/HttpUrl;Lokhttp3/HttpUrl;)Z
move-result p0
:try_end_1
.catchall {:try_start_1 .. :try_end_1} :catchall_0
if-nez p0, :cond_2
monitor-exit v0
return-object v1
.line 315
:cond_2
:try_start_2
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->route()Lokhttp3/Route;
move-result-object p0
:try_end_2
.catchall {:try_start_2 .. :try_end_2} :catchall_0
monitor-exit v0
return-object p0
:catchall_0
move-exception p0
.line 312
monitor-exit v0
throw p0
:cond_3
:goto_0
return-object v1
.end method
# virtual methods
.method public final find(Lokhttp3/OkHttpClient;Lokhttp3/internal/http/RealInterceptorChain;)Lokhttp3/internal/http/ExchangeCodec;
.locals 8
const-string v0, "client"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
const-string v0, "chain"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
.line 75
:try_start_0
invoke-virtual {p2}, Lokhttp3/internal/http/RealInterceptorChain;->getConnectTimeoutMillis$okhttp()I
move-result v2
.line 76
invoke-virtual {p2}, Lokhttp3/internal/http/RealInterceptorChain;->getReadTimeoutMillis$okhttp()I
move-result v3
.line 77
invoke-virtual {p2}, Lokhttp3/internal/http/RealInterceptorChain;->getWriteTimeoutMillis$okhttp()I
move-result v4
.line 78
invoke-virtual {p1}, Lokhttp3/OkHttpClient;->pingIntervalMillis()I
move-result v5
.line 79
invoke-virtual {p1}, Lokhttp3/OkHttpClient;->retryOnConnectionFailure()Z
move-result v6
.line 80
invoke-virtual {p2}, Lokhttp3/internal/http/RealInterceptorChain;->getRequest$okhttp()Lokhttp3/Request;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/Request;->method()Ljava/lang/String;
move-result-object v0
const-string v1, "GET"
invoke-static {v0, v1}, Lkotlin/jvm/internal/Intrinsics;->areEqual(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v0
xor-int/lit8 v7, v0, 0x1
move-object v1, p0
.line 74
invoke-direct/range {v1 .. v7}, Lokhttp3/internal/connection/ExchangeFinder;->findHealthyConnection(IIIIZZ)Lokhttp3/internal/connection/RealConnection;
move-result-object v0
.line 82
invoke-virtual {v0, p1, p2}, Lokhttp3/internal/connection/RealConnection;->newCodec$okhttp(Lokhttp3/OkHttpClient;Lokhttp3/internal/http/RealInterceptorChain;)Lokhttp3/internal/http/ExchangeCodec;
move-result-object p0
:try_end_0
.catch Lokhttp3/internal/connection/RouteException; {:try_start_0 .. :try_end_0} :catch_1
.catch Ljava/io/IOException; {:try_start_0 .. :try_end_0} :catch_0
return-object p0
:catch_0
move-exception p1
.line 87
invoke-virtual {p0, p1}, Lokhttp3/internal/connection/ExchangeFinder;->trackFailure(Ljava/io/IOException;)V
.line 88
new-instance p0, Lokhttp3/internal/connection/RouteException;
invoke-direct {p0, p1}, Lokhttp3/internal/connection/RouteException;-><init>(Ljava/io/IOException;)V
check-cast p0, Ljava/lang/Throwable;
throw p0
:catch_1
move-exception p1
.line 84
invoke-virtual {p1}, Lokhttp3/internal/connection/RouteException;->getLastConnectException()Ljava/io/IOException;
move-result-object p2
invoke-virtual {p0, p2}, Lokhttp3/internal/connection/ExchangeFinder;->trackFailure(Ljava/io/IOException;)V
.line 85
check-cast p1, Ljava/lang/Throwable;
throw p1
.end method
.method public final getAddress$okhttp()Lokhttp3/Address;
.locals 0
iget-object p0, p0, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
return-object p0
.end method
.method public final retryAfterFailure()Z
.locals 2
iget v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->refusedStreamCount:I
if-nez v0, :cond_0
iget v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->connectionShutdownCount:I
if-nez v0, :cond_0
iget v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->otherFailureCount:I
if-nez v0, :cond_0
const/4 p0, 0x0
return p0
:cond_0
iget-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->nextRouteToTry:Lokhttp3/Route;
const/4 v1, 0x1
if-eqz v0, :cond_1
return v1
.line 283
:cond_1
invoke-direct {p0}, Lokhttp3/internal/connection/ExchangeFinder;->retryRoute()Lokhttp3/Route;
move-result-object v0
if-eqz v0, :cond_2
iput-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->nextRouteToTry:Lokhttp3/Route;
return v1
:cond_2
iget-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
if-eqz v0, :cond_3
.line 291
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector$Selection;->hasNext()Z
move-result v0
if-ne v0, v1, :cond_3
return v1
:cond_3
iget-object p0, p0, Lokhttp3/internal/connection/ExchangeFinder;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
if-eqz p0, :cond_4
.line 297
invoke-virtual {p0}, Lokhttp3/internal/connection/RouteSelector;->hasNext()Z
move-result p0
return p0
:cond_4
return v1
.end method
.method public final sameHostAndPort(Lokhttp3/HttpUrl;)Z
.locals 2
const-string v0, "url"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
iget-object p0, p0, Lokhttp3/internal/connection/ExchangeFinder;->address:Lokhttp3/Address;
.line 325
invoke-virtual {p0}, Lokhttp3/Address;->url()Lokhttp3/HttpUrl;
move-result-object p0
.line 326
invoke-virtual {p1}, Lokhttp3/HttpUrl;->port()I
move-result v0
invoke-virtual {p0}, Lokhttp3/HttpUrl;->port()I
move-result v1
if-ne v0, v1, :cond_0
invoke-virtual {p1}, Lokhttp3/HttpUrl;->host()Ljava/lang/String;
move-result-object p1
invoke-virtual {p0}, Lokhttp3/HttpUrl;->host()Ljava/lang/String;
move-result-object p0
invoke-static {p1, p0}, Lkotlin/jvm/internal/Intrinsics;->areEqual(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result p0
if-eqz p0, :cond_0
const/4 p0, 0x1
goto :goto_0
:cond_0
const/4 p0, 0x0
:goto_0
return p0
.end method
.method public final trackFailure(Ljava/io/IOException;)V
.locals 2
const-string v0, "e"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V
const/4 v0, 0x0
.line 260
move-object v1, v0
check-cast v1, Lokhttp3/Route;
iput-object v0, p0, Lokhttp3/internal/connection/ExchangeFinder;->nextRouteToTry:Lokhttp3/Route;
.line 261
instance-of v0, p1, Lokhttp3/internal/http2/StreamResetException;
if-eqz v0, :cond_0
move-object v0, p1
check-cast v0, Lokhttp3/internal/http2/StreamResetException;
iget-object v0, v0, Lokhttp3/internal/http2/StreamResetException;->errorCode:Lokhttp3/internal/http2/ErrorCode;
sget-object v1, Lokhttp3/internal/http2/ErrorCode;->REFUSED_STREAM:Lokhttp3/internal/http2/ErrorCode;
if-ne v0, v1, :cond_0
iget p1, p0, Lokhttp3/internal/connection/ExchangeFinder;->refusedStreamCount:I
add-int/lit8 p1, p1, 0x1
iput p1, p0, Lokhttp3/internal/connection/ExchangeFinder;->refusedStreamCount:I
goto :goto_0
.line 263
:cond_0
instance-of p1, p1, Lokhttp3/internal/http2/ConnectionShutdownException;
if-eqz p1, :cond_1
iget p1, p0, Lokhttp3/internal/connection/ExchangeFinder;->connectionShutdownCount:I
add-int/lit8 p1, p1, 0x1
iput p1, p0, Lokhttp3/internal/connection/ExchangeFinder;->connectionShutdownCount:I
goto :goto_0
:cond_1
iget p1, p0, Lokhttp3/internal/connection/ExchangeFinder;->otherFailureCount:I
add-int/lit8 p1, p1, 0x1
iput p1, p0, Lokhttp3/internal/connection/ExchangeFinder;->otherFailureCount:I
:goto_0
return-void
.end method