StreamAllocation.smali
.class public final Lokhttp3/internal/connection/StreamAllocation;
.super Ljava/lang/Object;
.source "StreamAllocation.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lokhttp3/internal/connection/StreamAllocation$StreamAllocationReference;
}
.end annotation
# static fields
.field static final synthetic $assertionsDisabled:Z
# instance fields
.field public final address:Lokhttp3/Address;
.field public final call:Lokhttp3/Call;
.field private final callStackTrace:Ljava/lang/Object;
.field private canceled:Z
.field private codec:Lokhttp3/internal/http/HttpCodec;
.field private connection:Lokhttp3/internal/connection/RealConnection;
.field private final connectionPool:Lokhttp3/ConnectionPool;
.field public final eventListener:Lokhttp3/EventListener;
.field private refusedStreamCount:I
.field private released:Z
.field private reportedAcquired:Z
.field private route:Lokhttp3/Route;
.field private routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
.field private final routeSelector:Lokhttp3/internal/connection/RouteSelector;
# direct methods
.method static constructor <clinit>()V
.registers 0
return-void
.end method
.method public constructor <init>(Lokhttp3/ConnectionPool;Lokhttp3/Address;Lokhttp3/Call;Lokhttp3/EventListener;Ljava/lang/Object;)V
.registers 7
.line 96
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 97
iput-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
.line 98
iput-object p2, p0, Lokhttp3/internal/connection/StreamAllocation;->address:Lokhttp3/Address;
.line 99
iput-object p3, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
.line 100
iput-object p4, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
.line 101
new-instance p1, Lokhttp3/internal/connection/RouteSelector;
invoke-direct {p0}, Lokhttp3/internal/connection/StreamAllocation;->routeDatabase()Lokhttp3/internal/connection/RouteDatabase;
move-result-object v0
invoke-direct {p1, p2, v0, p3, p4}, Lokhttp3/internal/connection/RouteSelector;-><init>(Lokhttp3/Address;Lokhttp3/internal/connection/RouteDatabase;Lokhttp3/Call;Lokhttp3/EventListener;)V
iput-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
.line 102
iput-object p5, p0, Lokhttp3/internal/connection/StreamAllocation;->callStackTrace:Ljava/lang/Object;
return-void
.end method
.method private deallocate(ZZZ)Ljava/net/Socket;
.registers 5
const/4 v0, 0x0
if-eqz p3, :cond_5
.line 384
iput-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
:cond_5
const/4 p3, 0x1
if-eqz p2, :cond_a
.line 387
iput-boolean p3, p0, Lokhttp3/internal/connection/StreamAllocation;->released:Z
.line 390
:cond_a
iget-object p2, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz p2, :cond_4e
if-eqz p1, :cond_12
.line 392
iput-boolean p3, p2, Lokhttp3/internal/connection/RealConnection;->noNewStreams:Z
.line 394
:cond_12
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
if-nez p1, :cond_4e
iget-boolean p1, p0, Lokhttp3/internal/connection/StreamAllocation;->released:Z
if-nez p1, :cond_20
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
iget-boolean p1, p1, Lokhttp3/internal/connection/RealConnection;->noNewStreams:Z
if-eqz p1, :cond_4e
.line 395
:cond_20
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
invoke-direct {p0, p1}, Lokhttp3/internal/connection/StreamAllocation;->release(Lokhttp3/internal/connection/RealConnection;)V
.line 396
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
iget-object p1, p1, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
invoke-interface {p1}, Ljava/util/List;->isEmpty()Z
move-result p1
if-eqz p1, :cond_4a
.line 397
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
invoke-static {}, Ljava/lang/System;->nanoTime()J
move-result-wide p2
iput-wide p2, p1, Lokhttp3/internal/connection/RealConnection;->idleAtNanos:J
.line 398
sget-object p1, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
iget-object p2, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
iget-object p3, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
invoke-virtual {p1, p2, p3}, Lokhttp3/internal/Internal;->connectionBecameIdle(Lokhttp3/ConnectionPool;Lokhttp3/internal/connection/RealConnection;)Z
move-result p1
if-eqz p1, :cond_4a
.line 399
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
invoke-virtual {p1}, Lokhttp3/internal/connection/RealConnection;->socket()Ljava/net/Socket;
move-result-object p1
goto :goto_4b
:cond_4a
move-object p1, v0
.line 402
:goto_4b
iput-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
move-object v0, p1
:cond_4e
return-object v0
.end method
.method private findConnection(IIIIZ)Lokhttp3/internal/connection/RealConnection;
.registers 24
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
move-object/from16 v1, p0
.line 167
iget-object v2, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v2
.line 168
:try_start_5
iget-boolean v0, v1, Lokhttp3/internal/connection/StreamAllocation;->released:Z
if-nez v0, :cond_12b
.line 169
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
if-nez v0, :cond_123
.line 170
iget-boolean v0, v1, Lokhttp3/internal/connection/StreamAllocation;->canceled:Z
if-nez v0, :cond_11b
.line 174
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
.line 175
invoke-direct/range {p0 .. p0}, Lokhttp3/internal/connection/StreamAllocation;->releaseIfNoNewStreams()Ljava/net/Socket;
move-result-object v3
.line 176
iget-object v4, v1, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
const/4 v5, 0x0
if-eqz v4, :cond_1e
move-object v0, v5
goto :goto_1f
:cond_1e
move-object v4, v5
.line 181
:goto_1f
iget-boolean v6, v1, Lokhttp3/internal/connection/StreamAllocation;->reportedAcquired:Z
if-nez v6, :cond_24
move-object v0, v5
:cond_24
const/4 v6, 0x1
const/4 v7, 0x0
if-nez v4, :cond_3c
.line 188
sget-object v8, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
iget-object v9, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
iget-object v10, v1, Lokhttp3/internal/connection/StreamAllocation;->address:Lokhttp3/Address;
invoke-virtual {v8, v9, v10, v1, v5}, Lokhttp3/internal/Internal;->get(Lokhttp3/ConnectionPool;Lokhttp3/Address;Lokhttp3/internal/connection/StreamAllocation;Lokhttp3/Route;)Lokhttp3/internal/connection/RealConnection;
.line 189
iget-object v8, v1, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz v8, :cond_39
move-object v4, v8
const/4 v9, 0x1
move-object v8, v5
goto :goto_3e
.line 193
:cond_39
iget-object v8, v1, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
goto :goto_3d
:cond_3c
move-object v8, v5
:goto_3d
const/4 v9, 0x0
.line 196
:goto_3e
monitor-exit v2
:try_end_3f
.catchall {:try_start_5 .. :try_end_3f} :catchall_133
.line 197
invoke-static {v3}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
if-eqz v0, :cond_4b
.line 200
iget-object v2, v1, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v3, v1, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {v2, v3, v0}, Lokhttp3/EventListener;->connectionReleased(Lokhttp3/Call;Lokhttp3/Connection;)V
:cond_4b
if-eqz v9, :cond_54
.line 203
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v2, v1, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {v0, v2, v4}, Lokhttp3/EventListener;->connectionAcquired(Lokhttp3/Call;Lokhttp3/Connection;)V
:cond_54
if-eqz v4, :cond_57
return-object v4
:cond_57
if-nez v8, :cond_6d
.line 212
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
if-eqz v0, :cond_63
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector$Selection;->hasNext()Z
move-result v0
if-nez v0, :cond_6d
.line 214
:cond_63
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector;->next()Lokhttp3/internal/connection/RouteSelector$Selection;
move-result-object v0
iput-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
const/4 v0, 0x1
goto :goto_6e
:cond_6d
const/4 v0, 0x0
.line 217
:goto_6e
iget-object v3, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v3
.line 218
:try_start_71
iget-boolean v2, v1, Lokhttp3/internal/connection/StreamAllocation;->canceled:Z
if-nez v2, :cond_110
if-eqz v0, :cond_9f
.line 223
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector$Selection;->getAll()Ljava/util/List;
move-result-object v0
.line 224
invoke-interface {v0}, Ljava/util/List;->size()I
move-result v2
const/4 v10, 0x0
:goto_82
if-ge v10, v2, :cond_9f
.line 225
invoke-interface {v0, v10}, Ljava/util/List;->get(I)Ljava/lang/Object;
move-result-object v11
check-cast v11, Lokhttp3/Route;
.line 226
sget-object v12, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
iget-object v13, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
iget-object v14, v1, Lokhttp3/internal/connection/StreamAllocation;->address:Lokhttp3/Address;
invoke-virtual {v12, v13, v14, v1, v11}, Lokhttp3/internal/Internal;->get(Lokhttp3/ConnectionPool;Lokhttp3/Address;Lokhttp3/internal/connection/StreamAllocation;Lokhttp3/Route;)Lokhttp3/internal/connection/RealConnection;
.line 227
iget-object v12, v1, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz v12, :cond_9c
.line 230
iput-object v11, v1, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
move-object v4, v12
const/4 v9, 0x1
goto :goto_9f
:cond_9c
add-int/lit8 v10, v10, 0x1
goto :goto_82
:cond_9f
:goto_9f
if-nez v9, :cond_b7
if-nez v8, :cond_a9
.line 238
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector$Selection;->next()Lokhttp3/Route;
move-result-object v8
.line 243
:cond_a9
iput-object v8, v1, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
.line 244
iput v7, v1, Lokhttp3/internal/connection/StreamAllocation;->refusedStreamCount:I
.line 245
new-instance v4, Lokhttp3/internal/connection/RealConnection;
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
invoke-direct {v4, v0, v8}, Lokhttp3/internal/connection/RealConnection;-><init>(Lokhttp3/ConnectionPool;Lokhttp3/Route;)V
.line 246
invoke-virtual {v1, v4, v7}, Lokhttp3/internal/connection/StreamAllocation;->acquire(Lokhttp3/internal/connection/RealConnection;Z)V
.line 248
:cond_b7
monitor-exit v3
:try_end_b8
.catchall {:try_start_71 .. :try_end_b8} :catchall_118
if-eqz v9, :cond_c2
.line 252
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v2, v1, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {v0, v2, v4}, Lokhttp3/EventListener;->connectionAcquired(Lokhttp3/Call;Lokhttp3/Connection;)V
return-object v4
.line 257
:cond_c2
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
iget-object v2, v1, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
move-object v10, v4
move/from16 v11, p1
move/from16 v12, p2
move/from16 v13, p3
move/from16 v14, p4
move/from16 v15, p5
move-object/from16 v16, v0
move-object/from16 v17, v2
invoke-virtual/range {v10 .. v17}, Lokhttp3/internal/connection/RealConnection;->connect(IIIIZLokhttp3/Call;Lokhttp3/EventListener;)V
.line 259
invoke-direct/range {p0 .. p0}, Lokhttp3/internal/connection/StreamAllocation;->routeDatabase()Lokhttp3/internal/connection/RouteDatabase;
move-result-object v0
invoke-virtual {v4}, Lokhttp3/internal/connection/RealConnection;->route()Lokhttp3/Route;
move-result-object v2
invoke-virtual {v0, v2}, Lokhttp3/internal/connection/RouteDatabase;->connected(Lokhttp3/Route;)V
.line 262
iget-object v2, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v2
.line 263
:try_start_e6
iput-boolean v6, v1, Lokhttp3/internal/connection/StreamAllocation;->reportedAcquired:Z
.line 266
sget-object v0, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
iget-object v3, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
invoke-virtual {v0, v3, v4}, Lokhttp3/internal/Internal;->put(Lokhttp3/ConnectionPool;Lokhttp3/internal/connection/RealConnection;)V
.line 270
invoke-virtual {v4}, Lokhttp3/internal/connection/RealConnection;->isMultiplexed()Z
move-result v0
if-eqz v0, :cond_101
.line 271
sget-object v0, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
iget-object v3, v1, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
iget-object v4, v1, Lokhttp3/internal/connection/StreamAllocation;->address:Lokhttp3/Address;
invoke-virtual {v0, v3, v4, v1}, Lokhttp3/internal/Internal;->deduplicate(Lokhttp3/ConnectionPool;Lokhttp3/Address;Lokhttp3/internal/connection/StreamAllocation;)Ljava/net/Socket;
move-result-object v5
.line 272
iget-object v4, v1, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
.line 274
:cond_101
monitor-exit v2
:try_end_102
.catchall {:try_start_e6 .. :try_end_102} :catchall_10d
.line 275
invoke-static {v5}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
.line 277
iget-object v0, v1, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v2, v1, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {v0, v2, v4}, Lokhttp3/EventListener;->connectionAcquired(Lokhttp3/Call;Lokhttp3/Connection;)V
return-object v4
:catchall_10d
move-exception v0
.line 274
:try_start_10e
monitor-exit v2
:try_end_10f
.catchall {:try_start_10e .. :try_end_10f} :catchall_10d
throw v0
.line 218
:cond_110
:try_start_110
new-instance v0, Ljava/io/IOException;
const-string v2, "Canceled"
invoke-direct {v0, v2}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw v0
:catchall_118
move-exception v0
.line 248
monitor-exit v3
:try_end_11a
.catchall {:try_start_110 .. :try_end_11a} :catchall_118
throw v0
.line 170
:cond_11b
:try_start_11b
new-instance v0, Ljava/io/IOException;
const-string v3, "Canceled"
invoke-direct {v0, v3}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw v0
.line 169
:cond_123
new-instance v0, Ljava/lang/IllegalStateException;
const-string v3, "codec != null"
invoke-direct {v0, v3}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.line 168
:cond_12b
new-instance v0, Ljava/lang/IllegalStateException;
const-string v3, "released"
invoke-direct {v0, v3}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
:catchall_133
move-exception v0
.line 196
monitor-exit v2
:try_end_135
.catchall {:try_start_11b .. :try_end_135} :catchall_133
goto :goto_137
:goto_136
throw v0
:goto_137
goto :goto_136
.end method
.method private findHealthyConnection(IIIIZZ)Lokhttp3/internal/connection/RealConnection;
.registers 10
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
.line 135
:goto_0
invoke-direct/range {p0 .. p5}, Lokhttp3/internal/connection/StreamAllocation;->findConnection(IIIIZ)Lokhttp3/internal/connection/RealConnection;
move-result-object v0
.line 139
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v1
.line 140
:try_start_7
iget v2, v0, Lokhttp3/internal/connection/RealConnection;->successCount:I
if-nez v2, :cond_d
.line 141
monitor-exit v1
return-object v0
.line 143
:cond_d
monitor-exit v1
:try_end_e
.catchall {:try_start_7 .. :try_end_e} :catchall_19
.line 147
invoke-virtual {v0, p6}, Lokhttp3/internal/connection/RealConnection;->isHealthy(Z)Z
move-result v1
if-nez v1, :cond_18
.line 148
invoke-virtual {p0}, Lokhttp3/internal/connection/StreamAllocation;->noNewStreams()V
goto :goto_0
:cond_18
return-object v0
:catchall_19
move-exception p1
.line 143
:try_start_1a
monitor-exit v1
:try_end_1b
.catchall {:try_start_1a .. :try_end_1b} :catchall_19
goto :goto_1d
:goto_1c
throw p1
:goto_1d
goto :goto_1c
.end method
.method private release(Lokhttp3/internal/connection/RealConnection;)V
.registers 5
.line 478
iget-object v0, p1, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
invoke-interface {v0}, Ljava/util/List;->size()I
move-result v0
const/4 v1, 0x0
:goto_7
if-ge v1, v0, :cond_20
.line 479
iget-object v2, p1, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
invoke-interface {v2, v1}, Ljava/util/List;->get(I)Ljava/lang/Object;
move-result-object v2
check-cast v2, Ljava/lang/ref/Reference;
.line 480
invoke-virtual {v2}, Ljava/lang/ref/Reference;->get()Ljava/lang/Object;
move-result-object v2
if-ne v2, p0, :cond_1d
.line 481
iget-object p1, p1, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
invoke-interface {p1, v1}, Ljava/util/List;->remove(I)Ljava/lang/Object;
return-void
:cond_1d
add-int/lit8 v1, v1, 0x1
goto :goto_7
.line 485
:cond_20
new-instance p1, Ljava/lang/IllegalStateException;
invoke-direct {p1}, Ljava/lang/IllegalStateException;-><init>()V
goto :goto_27
:goto_26
throw p1
:goto_27
goto :goto_26
.end method
.method private releaseIfNoNewStreams()Ljava/net/Socket;
.registers 3
.line 289
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz v0, :cond_f
.line 290
iget-boolean v0, v0, Lokhttp3/internal/connection/RealConnection;->noNewStreams:Z
if-eqz v0, :cond_f
const/4 v0, 0x1
const/4 v1, 0x0
.line 291
invoke-direct {p0, v1, v1, v0}, Lokhttp3/internal/connection/StreamAllocation;->deallocate(ZZZ)Ljava/net/Socket;
move-result-object v0
return-object v0
:cond_f
const/4 v0, 0x0
return-object v0
.end method
.method private routeDatabase()Lokhttp3/internal/connection/RouteDatabase;
.registers 3
.line 333
sget-object v0, Lokhttp3/internal/Internal;->instance:Lokhttp3/internal/Internal;
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
invoke-virtual {v0, v1}, Lokhttp3/internal/Internal;->routeDatabase(Lokhttp3/ConnectionPool;)Lokhttp3/internal/connection/RouteDatabase;
move-result-object v0
return-object v0
.end method
# virtual methods
.method public acquire(Lokhttp3/internal/connection/RealConnection;Z)V
.registers 4
.line 469
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-nez v0, :cond_15
.line 471
iput-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
.line 472
iput-boolean p2, p0, Lokhttp3/internal/connection/StreamAllocation;->reportedAcquired:Z
.line 473
iget-object p1, p1, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
new-instance p2, Lokhttp3/internal/connection/StreamAllocation$StreamAllocationReference;
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->callStackTrace:Ljava/lang/Object;
invoke-direct {p2, p0, v0}, Lokhttp3/internal/connection/StreamAllocation$StreamAllocationReference;-><init>(Lokhttp3/internal/connection/StreamAllocation;Ljava/lang/Object;)V
invoke-interface {p1, p2}, Ljava/util/List;->add(Ljava/lang/Object;)Z
return-void
.line 469
:cond_15
new-instance p1, Ljava/lang/IllegalStateException;
invoke-direct {p1}, Ljava/lang/IllegalStateException;-><init>()V
throw p1
.end method
.method public cancel()V
.registers 4
.line 411
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v0
const/4 v1, 0x1
.line 412
:try_start_4
iput-boolean v1, p0, Lokhttp3/internal/connection/StreamAllocation;->canceled:Z
.line 413
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
.line 414
iget-object v2, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
.line 415
monitor-exit v0
:try_end_b
.catchall {:try_start_4 .. :try_end_b} :catchall_17
if-eqz v1, :cond_11
.line 417
invoke-interface {v1}, Lokhttp3/internal/http/HttpCodec;->cancel()V
goto :goto_16
:cond_11
if-eqz v2, :cond_16
.line 419
invoke-virtual {v2}, Lokhttp3/internal/connection/RealConnection;->cancel()V
:cond_16
:goto_16
return-void
:catchall_17
move-exception v1
.line 415
:try_start_18
monitor-exit v0
:try_end_19
.catchall {:try_start_18 .. :try_end_19} :catchall_17
throw v1
.end method
.method public codec()Lokhttp3/internal/http/HttpCodec;
.registers 3
.line 327
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v0
.line 328
:try_start_3
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
monitor-exit v0
return-object v1
:catchall_7
move-exception v1
.line 329
monitor-exit v0
:try_end_9
.catchall {:try_start_3 .. :try_end_9} :catchall_7
throw v1
.end method
.method public declared-synchronized connection()Lokhttp3/internal/connection/RealConnection;
.registers 2
monitor-enter p0
.line 341
:try_start_1
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return-object v0
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method public hasMoreRoutes()Z
.registers 2
.line 512
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
if-nez v0, :cond_19
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->routeSelection:Lokhttp3/internal/connection/RouteSelector$Selection;
if-eqz v0, :cond_e
.line 513
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector$Selection;->hasNext()Z
move-result v0
if-nez v0, :cond_19
:cond_e
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
.line 514
invoke-virtual {v0}, Lokhttp3/internal/connection/RouteSelector;->hasNext()Z
move-result v0
if-eqz v0, :cond_17
goto :goto_19
:cond_17
const/4 v0, 0x0
goto :goto_1a
:cond_19
:goto_19
const/4 v0, 0x1
:goto_1a
return v0
.end method
.method public newStream(Lokhttp3/OkHttpClient;Lokhttp3/Interceptor$Chain;Z)Lokhttp3/internal/http/HttpCodec;
.registers 11
.line 107
invoke-interface {p2}, Lokhttp3/Interceptor$Chain;->connectTimeoutMillis()I
move-result v1
.line 108
invoke-interface {p2}, Lokhttp3/Interceptor$Chain;->readTimeoutMillis()I
move-result v2
.line 109
invoke-interface {p2}, Lokhttp3/Interceptor$Chain;->writeTimeoutMillis()I
move-result v3
.line 110
invoke-virtual {p1}, Lokhttp3/OkHttpClient;->pingIntervalMillis()I
move-result v4
.line 111
invoke-virtual {p1}, Lokhttp3/OkHttpClient;->retryOnConnectionFailure()Z
move-result v5
move-object v0, p0
move v6, p3
.line 114
:try_start_16
invoke-direct/range {v0 .. v6}, Lokhttp3/internal/connection/StreamAllocation;->findHealthyConnection(IIIIZZ)Lokhttp3/internal/connection/RealConnection;
move-result-object p3
.line 116
invoke-virtual {p3, p1, p2, p0}, Lokhttp3/internal/connection/RealConnection;->newCodec(Lokhttp3/OkHttpClient;Lokhttp3/Interceptor$Chain;Lokhttp3/internal/connection/StreamAllocation;)Lokhttp3/internal/http/HttpCodec;
move-result-object p1
.line 118
iget-object p2, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter p2
:try_end_21
.catch Ljava/io/IOException; {:try_start_16 .. :try_end_21} :catch_28
.line 119
:try_start_21
iput-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
.line 120
monitor-exit p2
return-object p1
:catchall_25
move-exception p1
.line 121
monitor-exit p2
:try_end_27
.catchall {:try_start_21 .. :try_end_27} :catchall_25
:try_start_27
throw p1
:try_end_28
.catch Ljava/io/IOException; {:try_start_27 .. :try_end_28} :catch_28
:catch_28
move-exception p1
.line 123
new-instance p2, Lokhttp3/internal/connection/RouteException;
invoke-direct {p2, p1}, Lokhttp3/internal/connection/RouteException;-><init>(Ljava/io/IOException;)V
throw p2
.end method
.method public noNewStreams()V
.registers 5
.line 362
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v0
.line 363
:try_start_3
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
const/4 v2, 0x1
const/4 v3, 0x0
.line 364
invoke-direct {p0, v2, v3, v3}, Lokhttp3/internal/connection/StreamAllocation;->deallocate(ZZZ)Ljava/net/Socket;
move-result-object v2
.line 365
iget-object v3, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz v3, :cond_10
const/4 v1, 0x0
.line 366
:cond_10
monitor-exit v0
:try_end_11
.catchall {:try_start_3 .. :try_end_11} :catchall_1e
.line 367
invoke-static {v2}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
if-eqz v1, :cond_1d
.line 369
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v2, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {v0, v2, v1}, Lokhttp3/EventListener;->connectionReleased(Lokhttp3/Call;Lokhttp3/Connection;)V
:cond_1d
return-void
:catchall_1e
move-exception v1
.line 366
:try_start_1f
monitor-exit v0
:try_end_20
.catchall {:try_start_1f .. :try_end_20} :catchall_1e
throw v1
.end method
.method public release()V
.registers 5
.line 347
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v0
.line 348
:try_start_3
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
const/4 v2, 0x1
const/4 v3, 0x0
.line 349
invoke-direct {p0, v3, v2, v3}, Lokhttp3/internal/connection/StreamAllocation;->deallocate(ZZZ)Ljava/net/Socket;
move-result-object v2
.line 350
iget-object v3, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz v3, :cond_10
const/4 v1, 0x0
.line 351
:cond_10
monitor-exit v0
:try_end_11
.catchall {:try_start_3 .. :try_end_11} :catchall_1e
.line 352
invoke-static {v2}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
if-eqz v1, :cond_1d
.line 354
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v2, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {v0, v2, v1}, Lokhttp3/EventListener;->connectionReleased(Lokhttp3/Call;Lokhttp3/Connection;)V
:cond_1d
return-void
:catchall_1e
move-exception v1
.line 351
:try_start_1f
monitor-exit v0
:try_end_20
.catchall {:try_start_1f .. :try_end_20} :catchall_1e
throw v1
.end method
.method public releaseAndAcquire(Lokhttp3/internal/connection/RealConnection;)Ljava/net/Socket;
.registers 5
.line 498
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
if-nez v0, :cond_26
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
iget-object v0, v0, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
invoke-interface {v0}, Ljava/util/List;->size()I
move-result v0
const/4 v1, 0x1
if-ne v0, v1, :cond_26
.line 501
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
iget-object v0, v0, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
const/4 v2, 0x0
invoke-interface {v0, v2}, Ljava/util/List;->get(I)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/ref/Reference;
.line 502
invoke-direct {p0, v1, v2, v2}, Lokhttp3/internal/connection/StreamAllocation;->deallocate(ZZZ)Ljava/net/Socket;
move-result-object v1
.line 505
iput-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
.line 506
iget-object p1, p1, Lokhttp3/internal/connection/RealConnection;->allocations:Ljava/util/List;
invoke-interface {p1, v0}, Ljava/util/List;->add(Ljava/lang/Object;)Z
return-object v1
.line 498
:cond_26
new-instance p1, Ljava/lang/IllegalStateException;
invoke-direct {p1}, Ljava/lang/IllegalStateException;-><init>()V
throw p1
.end method
.method public route()Lokhttp3/Route;
.registers 2
.line 337
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
return-object v0
.end method
.method public streamFailed(Ljava/io/IOException;)V
.registers 8
.line 428
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter v0
.line 429
:try_start_3
instance-of v1, p1, Lokhttp3/internal/http2/StreamResetException;
const/4 v2, 0x0
const/4 v3, 0x0
const/4 v4, 0x1
if-eqz v1, :cond_24
.line 430
check-cast p1, Lokhttp3/internal/http2/StreamResetException;
.line 431
iget-object v1, p1, Lokhttp3/internal/http2/StreamResetException;->errorCode:Lokhttp3/internal/http2/ErrorCode;
sget-object v5, Lokhttp3/internal/http2/ErrorCode;->REFUSED_STREAM:Lokhttp3/internal/http2/ErrorCode;
if-ne v1, v5, :cond_17
.line 432
iget v1, p0, Lokhttp3/internal/connection/StreamAllocation;->refusedStreamCount:I
add-int/2addr v1, v4
iput v1, p0, Lokhttp3/internal/connection/StreamAllocation;->refusedStreamCount:I
.line 436
:cond_17
iget-object p1, p1, Lokhttp3/internal/http2/StreamResetException;->errorCode:Lokhttp3/internal/http2/ErrorCode;
sget-object v1, Lokhttp3/internal/http2/ErrorCode;->REFUSED_STREAM:Lokhttp3/internal/http2/ErrorCode;
if-ne p1, v1, :cond_21
iget p1, p0, Lokhttp3/internal/connection/StreamAllocation;->refusedStreamCount:I
if-le p1, v4, :cond_47
.line 438
:cond_21
iput-object v3, p0, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
goto :goto_45
.line 440
:cond_24
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz v1, :cond_47
.line 441
invoke-virtual {v1}, Lokhttp3/internal/connection/RealConnection;->isMultiplexed()Z
move-result v1
if-eqz v1, :cond_32
instance-of v1, p1, Lokhttp3/internal/http2/ConnectionShutdownException;
if-eqz v1, :cond_47
.line 445
:cond_32
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
iget v1, v1, Lokhttp3/internal/connection/RealConnection;->successCount:I
if-nez v1, :cond_45
.line 446
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
if-eqz v1, :cond_43
if-eqz p1, :cond_43
.line 447
iget-object v5, p0, Lokhttp3/internal/connection/StreamAllocation;->routeSelector:Lokhttp3/internal/connection/RouteSelector;
invoke-virtual {v5, v1, p1}, Lokhttp3/internal/connection/RouteSelector;->connectFailed(Lokhttp3/Route;Ljava/io/IOException;)V
.line 449
:cond_43
iput-object v3, p0, Lokhttp3/internal/connection/StreamAllocation;->route:Lokhttp3/Route;
:cond_45
:goto_45
const/4 p1, 0x1
goto :goto_48
:cond_47
const/4 p1, 0x0
.line 452
:goto_48
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
.line 453
invoke-direct {p0, p1, v2, v4}, Lokhttp3/internal/connection/StreamAllocation;->deallocate(ZZZ)Ljava/net/Socket;
move-result-object p1
.line 454
iget-object v2, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-nez v2, :cond_58
iget-boolean v2, p0, Lokhttp3/internal/connection/StreamAllocation;->reportedAcquired:Z
if-nez v2, :cond_57
goto :goto_58
:cond_57
move-object v3, v1
.line 455
:cond_58
:goto_58
monitor-exit v0
:try_end_59
.catchall {:try_start_3 .. :try_end_59} :catchall_66
.line 457
invoke-static {p1}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
if-eqz v3, :cond_65
.line 459
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {p1, v0, v3}, Lokhttp3/EventListener;->connectionReleased(Lokhttp3/Call;Lokhttp3/Connection;)V
:cond_65
return-void
:catchall_66
move-exception p1
.line 455
:try_start_67
monitor-exit v0
:try_end_68
.catchall {:try_start_67 .. :try_end_68} :catchall_66
throw p1
.end method
.method public streamFinished(ZLokhttp3/internal/http/HttpCodec;JLjava/io/IOException;)V
.registers 8
.line 297
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object v1, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {v0, v1, p3, p4}, Lokhttp3/EventListener;->responseBodyEnd(Lokhttp3/Call;J)V
.line 302
iget-object p3, p0, Lokhttp3/internal/connection/StreamAllocation;->connectionPool:Lokhttp3/ConnectionPool;
monitor-enter p3
if-eqz p2, :cond_49
.line 303
:try_start_c
iget-object p4, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
if-ne p2, p4, :cond_49
const/4 p2, 0x1
if-nez p1, :cond_1a
.line 307
iget-object p4, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
iget v0, p4, Lokhttp3/internal/connection/RealConnection;->successCount:I
add-int/2addr v0, p2
iput v0, p4, Lokhttp3/internal/connection/RealConnection;->successCount:I
.line 309
:cond_1a
iget-object p4, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
const/4 v0, 0x0
.line 310
invoke-direct {p0, p1, v0, p2}, Lokhttp3/internal/connection/StreamAllocation;->deallocate(ZZZ)Ljava/net/Socket;
move-result-object p1
.line 311
iget-object p2, p0, Lokhttp3/internal/connection/StreamAllocation;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz p2, :cond_26
const/4 p4, 0x0
.line 312
:cond_26
iget-boolean p2, p0, Lokhttp3/internal/connection/StreamAllocation;->released:Z
.line 313
monitor-exit p3
:try_end_29
.catchall {:try_start_c .. :try_end_29} :catchall_6a
.line 314
invoke-static {p1}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
if-eqz p4, :cond_35
.line 316
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object p3, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {p1, p3, p4}, Lokhttp3/EventListener;->connectionReleased(Lokhttp3/Call;Lokhttp3/Connection;)V
:cond_35
if-eqz p5, :cond_3f
.line 320
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object p2, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {p1, p2, p5}, Lokhttp3/EventListener;->callFailed(Lokhttp3/Call;Ljava/io/IOException;)V
goto :goto_48
:cond_3f
if-eqz p2, :cond_48
.line 322
iget-object p1, p0, Lokhttp3/internal/connection/StreamAllocation;->eventListener:Lokhttp3/EventListener;
iget-object p2, p0, Lokhttp3/internal/connection/StreamAllocation;->call:Lokhttp3/Call;
invoke-virtual {p1, p2}, Lokhttp3/EventListener;->callEnd(Lokhttp3/Call;)V
:cond_48
:goto_48
return-void
.line 304
:cond_49
:try_start_49
new-instance p1, Ljava/lang/IllegalStateException;
new-instance p4, Ljava/lang/StringBuilder;
invoke-direct {p4}, Ljava/lang/StringBuilder;-><init>()V
const-string p5, "expected "
invoke-virtual {p4, p5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object p5, p0, Lokhttp3/internal/connection/StreamAllocation;->codec:Lokhttp3/internal/http/HttpCodec;
invoke-virtual {p4, p5}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
const-string p5, " but was "
invoke-virtual {p4, p5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p4, p2}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {p4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p2
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:catchall_6a
move-exception p1
.line 313
monitor-exit p3
:try_end_6c
.catchall {:try_start_49 .. :try_end_6c} :catchall_6a
throw p1
.end method
.method public toString()Ljava/lang/String;
.registers 2
.line 518
invoke-virtual {p0}, Lokhttp3/internal/connection/StreamAllocation;->connection()Lokhttp3/internal/connection/RealConnection;
move-result-object v0
if-eqz v0, :cond_b
.line 519
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->toString()Ljava/lang/String;
move-result-object v0
goto :goto_11
:cond_b
iget-object v0, p0, Lokhttp3/internal/connection/StreamAllocation;->address:Lokhttp3/Address;
invoke-virtual {v0}, Lokhttp3/Address;->toString()Ljava/lang/String;
move-result-object v0
:goto_11
return-object v0
.end method