Transmitter.smali
.class public final Lokhttp3/internal/connection/Transmitter;
.super Ljava/lang/Object;
.source "Transmitter.kt"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lokhttp3/internal/connection/Transmitter$TransmitterReference;
}
.end annotation
.annotation system Ldalvik/annotation/SourceDebugExtension;
value = "SMAP\nTransmitter.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Transmitter.kt\nokhttp3/internal/connection/Transmitter\n+ 2 Util.kt\nokhttp3/internal/Util\n+ 3 _Collections.kt\nkotlin/collections/CollectionsKt___CollectionsKt\n*L\n1#1,344:1\n537#2,4:345\n537#2,4:349\n300#3,7:353\n*E\n*S KotlinDebug\n*F\n+ 1 Transmitter.kt\nokhttp3/internal/connection/Transmitter\n*L\n175#1,4:345\n187#1,4:349\n189#1,7:353\n*E\n"
.end annotation
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000\u007f\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0005\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\u0006\n\u0002\u0018\u0002\n\u0000\n\u0002\u0008\u0004\n\u0002\u0010\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u000b\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0006*\u0001 \u0018\u00002\u00020\u0001:\u0001FB\u0015\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u00a2\u0006\u0002\u0010\u0006J\u000e\u0010#\u001a\u00020$2\u0006\u0010\n\u001a\u00020\u000bJ\u0006\u0010%\u001a\u00020$J\u0006\u0010&\u001a\u00020\tJ\u0006\u0010\'\u001a\u00020$J\u0010\u0010(\u001a\u00020)2\u0006\u0010*\u001a\u00020+H\u0002J\u0006\u0010,\u001a\u00020$J;\u0010-\u001a\u0002H.\"\n\u0008\u0000\u0010.*\u0004\u0018\u00010/2\u0006\u0010\u0014\u001a\u00020\u00152\u0006\u00100\u001a\u00020\t2\u0006\u00101\u001a\u00020\t2\u0006\u00102\u001a\u0002H.H\u0000\u00a2\u0006\u0004\u00083\u00104J\u0006\u00105\u001a\u00020\tJ)\u00106\u001a\u0002H.\"\n\u0008\u0000\u0010.*\u0004\u0018\u00010/2\u0006\u00102\u001a\u0002H.2\u0006\u00107\u001a\u00020\tH\u0002\u00a2\u0006\u0002\u00108J\u001d\u00109\u001a\u00020\u00152\u0006\u0010:\u001a\u00020;2\u0006\u0010<\u001a\u00020\tH\u0000\u00a2\u0006\u0002\u0008=J\u0012\u0010\u001c\u001a\u0004\u0018\u00010/2\u0008\u00102\u001a\u0004\u0018\u00010/J\u000e\u0010>\u001a\u00020$2\u0006\u0010\u001d\u001a\u00020\u001eJ\u0008\u0010?\u001a\u0004\u0018\u00010@J\u0006\u0010\u001f\u001a\u00020AJ\u0006\u0010\"\u001a\u00020$J\u0006\u0010B\u001a\u00020$J!\u0010C\u001a\u0002H.\"\n\u0008\u0000\u0010.*\u0004\u0018\u00010/2\u0006\u0010D\u001a\u0002H.H\u0002\u00a2\u0006\u0002\u0010ER\u000e\u0010\u0004\u001a\u00020\u0005X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u0007\u001a\u0004\u0018\u00010\u0001X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0008\u001a\u00020\tX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u001c\u0010\n\u001a\u0004\u0018\u00010\u000bX\u0086\u000e\u00a2\u0006\u000e\n\u0000\u001a\u0004\u0008\u000c\u0010\r\"\u0004\u0008\u000e\u0010\u000fR\u000e\u0010\u0010\u001a\u00020\u0011X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0012\u001a\u00020\u0013X\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u0014\u001a\u0004\u0018\u00010\u0015X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u0016\u001a\u0004\u0018\u00010\u0017X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0018\u001a\u00020\tX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0019\u001a\u00020\tX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0011\u0010\u001a\u001a\u00020\t8F\u00a2\u0006\u0006\u001a\u0004\u0008\u001a\u0010\u001bR\u000e\u0010\u001c\u001a\u00020\tX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u001d\u001a\u0004\u0018\u00010\u001eX\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0010\u0010\u001f\u001a\u00020 X\u0082\u0004\u00a2\u0006\u0004\n\u0002\u0010!R\u000e\u0010\"\u001a\u00020\tX\u0082\u000e\u00a2\u0006\u0002\n\u0000\u00a8\u0006G"
}
d2 = {
"Lokhttp3/internal/connection/Transmitter;",
"",
"client",
"Lokhttp3/OkHttpClient;",
"call",
"Lokhttp3/Call;",
"(Lokhttp3/OkHttpClient;Lokhttp3/Call;)V",
"callStackTrace",
"canceled",
"",
"connection",
"Lokhttp3/internal/connection/RealConnection;",
"getConnection",
"()Lokhttp3/internal/connection/RealConnection;",
"setConnection",
"(Lokhttp3/internal/connection/RealConnection;)V",
"connectionPool",
"Lokhttp3/internal/connection/RealConnectionPool;",
"eventListener",
"Lokhttp3/EventListener;",
"exchange",
"Lokhttp3/internal/connection/Exchange;",
"exchangeFinder",
"Lokhttp3/internal/connection/ExchangeFinder;",
"exchangeRequestDone",
"exchangeResponseDone",
"isCanceled",
"()Z",
"noMoreExchanges",
"request",
"Lokhttp3/Request;",
"timeout",
"okhttp3/internal/connection/Transmitter$timeout$1",
"Lokhttp3/internal/connection/Transmitter$timeout$1;",
"timeoutEarlyExit",
"acquireConnectionNoEvents",
"",
"callStart",
"canRetry",
"cancel",
"createAddress",
"Lokhttp3/Address;",
"url",
"Lokhttp3/HttpUrl;",
"exchangeDoneDueToException",
"exchangeMessageDone",
"E",
"Ljava/io/IOException;",
"requestDone",
"responseDone",
"e",
"exchangeMessageDone$okhttp",
"(Lokhttp3/internal/connection/Exchange;ZZLjava/io/IOException;)Ljava/io/IOException;",
"hasExchange",
"maybeReleaseConnection",
"force",
"(Ljava/io/IOException;Z)Ljava/io/IOException;",
"newExchange",
"chain",
"Lokhttp3/Interceptor$Chain;",
"doExtensiveHealthChecks",
"newExchange$okhttp",
"prepareToConnect",
"releaseConnectionNoEvents",
"Ljava/net/Socket;",
"Lokio/Timeout;",
"timeoutEnter",
"timeoutExit",
"cause",
"(Ljava/io/IOException;)Ljava/io/IOException;",
"TransmitterReference",
"okhttp"
}
k = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# instance fields
.field private final call:Lokhttp3/Call;
.field private callStackTrace:Ljava/lang/Object;
.field private canceled:Z
.field private final client:Lokhttp3/OkHttpClient;
.field private connection:Lokhttp3/internal/connection/RealConnection;
.field private final connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
.field private final eventListener:Lokhttp3/EventListener;
.field private exchange:Lokhttp3/internal/connection/Exchange;
.field private exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
.field private exchangeRequestDone:Z
.field private exchangeResponseDone:Z
.field private noMoreExchanges:Z
.field private request:Lokhttp3/Request;
.field private final timeout:Lokhttp3/internal/connection/Transmitter$timeout$1;
.field private timeoutEarlyExit:Z
# direct methods
.method public constructor <init>(Lokhttp3/OkHttpClient;Lokhttp3/Call;)V
.registers 5
const-string v0, "client"
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 50
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
iput-object p2, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
.line 54
invoke-virtual {p1}, Lokhttp3/OkHttpClient;->connectionPool()Lokhttp3/ConnectionPool;
move-result-object p1
invoke-virtual {p1}, Lokhttp3/ConnectionPool;->getDelegate$okhttp()Lokhttp3/internal/connection/RealConnectionPool;
move-result-object p1
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
.line 55
iget-object p1, p0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {p1}, Lokhttp3/OkHttpClient;->eventListenerFactory()Lokhttp3/EventListener$Factory;
move-result-object p1
iget-object p2, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
invoke-interface {p1, p2}, Lokhttp3/EventListener$Factory;->create(Lokhttp3/Call;)Lokhttp3/EventListener;
move-result-object p1
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->eventListener:Lokhttp3/EventListener;
.line 56
new-instance p1, Lokhttp3/internal/connection/Transmitter$timeout$1;
invoke-direct {p1, p0}, Lokhttp3/internal/connection/Transmitter$timeout$1;-><init>(Lokhttp3/internal/connection/Transmitter;)V
.line 61
iget-object p2, p0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {p2}, Lokhttp3/OkHttpClient;->callTimeoutMillis()I
move-result p2
int-to-long v0, p2
sget-object p2, Ljava/util/concurrent/TimeUnit;->MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {p1, v0, v1, p2}, Lokhttp3/internal/connection/Transmitter$timeout$1;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
.line 60
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->timeout:Lokhttp3/internal/connection/Transmitter$timeout$1;
return-void
.end method
.method private final createAddress(Lokhttp3/HttpUrl;)Lokhttp3/Address;
.registers 19
move-object/from16 v0, p0
const/4 v1, 0x0
.line 139
move-object v2, v1
check-cast v2, Ljavax/net/ssl/SSLSocketFactory;
.line 140
move-object v3, v1
check-cast v3, Ljavax/net/ssl/HostnameVerifier;
.line 141
check-cast v1, Lokhttp3/CertificatePinner;
.line 142
invoke-virtual/range {p1 .. p1}, Lokhttp3/HttpUrl;->isHttps()Z
move-result v4
if-eqz v4, :cond_23
.line 143
iget-object v1, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v1}, Lokhttp3/OkHttpClient;->sslSocketFactory()Ljavax/net/ssl/SSLSocketFactory;
move-result-object v2
.line 144
iget-object v1, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v1}, Lokhttp3/OkHttpClient;->hostnameVerifier()Ljavax/net/ssl/HostnameVerifier;
move-result-object v3
.line 145
iget-object v1, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v1}, Lokhttp3/OkHttpClient;->certificatePinner()Lokhttp3/CertificatePinner;
move-result-object v1
:cond_23
move-object v11, v1
move-object v9, v2
move-object v10, v3
.line 148
new-instance v1, Lokhttp3/Address;
invoke-virtual/range {p1 .. p1}, Lokhttp3/HttpUrl;->host()Ljava/lang/String;
move-result-object v5
invoke-virtual/range {p1 .. p1}, Lokhttp3/HttpUrl;->port()I
move-result v6
iget-object v2, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v2}, Lokhttp3/OkHttpClient;->dns()Lokhttp3/Dns;
move-result-object v7
iget-object v2, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v2}, Lokhttp3/OkHttpClient;->socketFactory()Ljavax/net/SocketFactory;
move-result-object v8
.line 149
iget-object v2, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v2}, Lokhttp3/OkHttpClient;->proxyAuthenticator()Lokhttp3/Authenticator;
move-result-object v12
.line 150
iget-object v2, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v2}, Lokhttp3/OkHttpClient;->proxy()Ljava/net/Proxy;
move-result-object v13
iget-object v2, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v2}, Lokhttp3/OkHttpClient;->protocols()Ljava/util/List;
move-result-object v14
iget-object v2, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v2}, Lokhttp3/OkHttpClient;->connectionSpecs()Ljava/util/List;
move-result-object v15
iget-object v2, v0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v2}, Lokhttp3/OkHttpClient;->proxySelector()Ljava/net/ProxySelector;
move-result-object v16
move-object v4, v1
.line 148
invoke-direct/range {v4 .. v16}, Lokhttp3/Address;-><init>(Ljava/lang/String;ILokhttp3/Dns;Ljavax/net/SocketFactory;Ljavax/net/ssl/SSLSocketFactory;Ljavax/net/ssl/HostnameVerifier;Lokhttp3/CertificatePinner;Lokhttp3/Authenticator;Ljava/net/Proxy;Ljava/util/List;Ljava/util/List;Ljava/net/ProxySelector;)V
return-object v1
.end method
.method private final maybeReleaseConnection(Ljava/io/IOException;Z)Ljava/io/IOException;
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"<E:",
"Ljava/io/IOException;",
">(TE;Z)TE;"
}
.end annotation
.line 274
new-instance v0, Lkotlin/jvm/internal/Ref$ObjectRef;
invoke-direct {v0}, Lkotlin/jvm/internal/Ref$ObjectRef;-><init>()V
.line 276
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v1
const/4 v2, 0x0
const/4 v3, 0x1
if-eqz p2, :cond_16
.line 277
:try_start_c
iget-object v4, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
if-nez v4, :cond_11
goto :goto_16
:cond_11
const/4 v4, 0x0
goto :goto_17
:catchall_13
move-exception p1
goto/16 :goto_93
:cond_16
:goto_16
const/4 v4, 0x1
:goto_17
if-eqz v4, :cond_85
.line 278
iget-object v4, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
check-cast v4, Lokhttp3/Connection;
iput-object v4, v0, Lkotlin/jvm/internal/Ref$ObjectRef;->element:Ljava/lang/Object;
.line 279
iget-object v4, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
const/4 v5, 0x0
if-eqz v4, :cond_33
iget-object v4, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
if-nez v4, :cond_33
if-nez p2, :cond_2e
iget-boolean p2, p0, Lokhttp3/internal/connection/Transmitter;->noMoreExchanges:Z
if-eqz p2, :cond_33
.line 280
:cond_2e
invoke-virtual {p0}, Lokhttp3/internal/connection/Transmitter;->releaseConnectionNoEvents()Ljava/net/Socket;
move-result-object p2
goto :goto_34
:cond_33
move-object p2, v5
.line 284
:goto_34
iget-object v4, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
if-eqz v4, :cond_3c
check-cast v5, Lokhttp3/Connection;
iput-object v5, v0, Lkotlin/jvm/internal/Ref$ObjectRef;->element:Ljava/lang/Object;
.line 285
:cond_3c
iget-boolean v4, p0, Lokhttp3/internal/connection/Transmitter;->noMoreExchanges:Z
if-eqz v4, :cond_46
iget-object v4, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
if-nez v4, :cond_46
const/4 v4, 0x1
goto :goto_47
:cond_46
const/4 v4, 0x0
.line 286
:goto_47
sget-object v5, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_49
.catchall {:try_start_c .. :try_end_49} :catchall_13
.line 276
monitor-exit v1
if-eqz p2, :cond_4f
.line 287
invoke-static {p2}, Lokhttp3/internal/Util;->closeQuietly(Ljava/net/Socket;)V
.line 289
:cond_4f
iget-object p2, v0, Lkotlin/jvm/internal/Ref$ObjectRef;->element:Ljava/lang/Object;
check-cast p2, Lokhttp3/Connection;
if-eqz p2, :cond_65
.line 290
iget-object p2, p0, Lokhttp3/internal/connection/Transmitter;->eventListener:Lokhttp3/EventListener;
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
iget-object v0, v0, Lkotlin/jvm/internal/Ref$ObjectRef;->element:Ljava/lang/Object;
check-cast v0, Lokhttp3/Connection;
if-nez v0, :cond_62
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_62
invoke-virtual {p2, v1, v0}, Lokhttp3/EventListener;->connectionReleased(Lokhttp3/Call;Lokhttp3/Connection;)V
:cond_65
if-eqz v4, :cond_84
if-eqz p1, :cond_6a
const/4 v2, 0x1
.line 295
:cond_6a
invoke-direct {p0, p1}, Lokhttp3/internal/connection/Transmitter;->timeoutExit(Ljava/io/IOException;)Ljava/io/IOException;
move-result-object p1
if-eqz v2, :cond_7d
.line 297
iget-object p2, p0, Lokhttp3/internal/connection/Transmitter;->eventListener:Lokhttp3/EventListener;
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
if-nez p1, :cond_79
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_79
invoke-virtual {p2, v0, p1}, Lokhttp3/EventListener;->callFailed(Lokhttp3/Call;Ljava/io/IOException;)V
goto :goto_84
.line 299
:cond_7d
iget-object p2, p0, Lokhttp3/internal/connection/Transmitter;->eventListener:Lokhttp3/EventListener;
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
invoke-virtual {p2, v0}, Lokhttp3/EventListener;->callEnd(Lokhttp3/Call;)V
:cond_84
:goto_84
return-object p1
:cond_85
:try_start_85
const-string p1, "cannot release connection while it is in use"
.line 277
new-instance p2, Ljava/lang/IllegalStateException;
invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object p1
invoke-direct {p2, p1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast p2, Ljava/lang/Throwable;
throw p2
:try_end_93
.catchall {:try_start_85 .. :try_end_93} :catchall_13
.line 276
:goto_93
monitor-exit v1
throw p1
.end method
.method private final timeoutExit(Ljava/io/IOException;)Ljava/io/IOException;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<E:",
"Ljava/io/IOException;",
">(TE;)TE;"
}
.end annotation
.line 102
iget-boolean v0, p0, Lokhttp3/internal/connection/Transmitter;->timeoutEarlyExit:Z
if-eqz v0, :cond_5
return-object p1
.line 103
:cond_5
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->timeout:Lokhttp3/internal/connection/Transmitter$timeout$1;
invoke-virtual {v0}, Lokhttp3/internal/connection/Transmitter$timeout$1;->exit()Z
move-result v0
if-nez v0, :cond_e
return-object p1
.line 105
:cond_e
new-instance v0, Ljava/io/InterruptedIOException;
const-string v1, "timeout"
invoke-direct {v0, v1}, Ljava/io/InterruptedIOException;-><init>(Ljava/lang/String;)V
if-eqz p1, :cond_1c
.line 106
check-cast p1, Ljava/lang/Throwable;
invoke-virtual {v0, p1}, Ljava/io/InterruptedIOException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable;
.line 108
:cond_1c
check-cast v0, Ljava/io/IOException;
return-object v0
.end method
# virtual methods
.method public final acquireConnectionNoEvents(Lokhttp3/internal/connection/RealConnection;)V
.registers 6
const-string v0, "connection"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 175
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
.line 345
sget-boolean v1, Lokhttp3/internal/Util;->assertionsEnabled:Z
if-eqz v1, :cond_40
invoke-static {v0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z
move-result v1
if-eqz v1, :cond_12
goto :goto_40
.line 346
:cond_12
new-instance p1, Ljava/lang/AssertionError;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
const-string v2, "Thread "
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object v2
const-string v3, "Thread.currentThread()"
invoke-static {v2, v3}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
invoke-virtual {v2}, Ljava/lang/Thread;->getName()Ljava/lang/String;
move-result-object v2
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v2, " MUST hold lock on "
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-direct {p1, v0}, Ljava/lang/AssertionError;-><init>(Ljava/lang/Object;)V
check-cast p1, Ljava/lang/Throwable;
throw p1
.line 177
:cond_40
:goto_40
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
if-nez v0, :cond_46
const/4 v0, 0x1
goto :goto_47
:cond_46
const/4 v0, 0x0
:goto_47
if-eqz v0, :cond_5a
.line 178
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
.line 179
invoke-virtual {p1}, Lokhttp3/internal/connection/RealConnection;->getTransmitters()Ljava/util/List;
move-result-object p1
new-instance v0, Lokhttp3/internal/connection/Transmitter$TransmitterReference;
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->callStackTrace:Ljava/lang/Object;
invoke-direct {v0, p0, v1}, Lokhttp3/internal/connection/Transmitter$TransmitterReference;-><init>(Lokhttp3/internal/connection/Transmitter;Ljava/lang/Object;)V
invoke-interface {p1, v0}, Ljava/util/List;->add(Ljava/lang/Object;)Z
return-void
.line 177
:cond_5a
new-instance p1, Ljava/lang/IllegalStateException;
const-string v0, "Check failed."
invoke-virtual {v0}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object v0
invoke-direct {p1, v0}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast p1, Ljava/lang/Throwable;
throw p1
.end method
.method public final callStart()V
.registers 3
.line 112
sget-object v0, Lokhttp3/internal/platform/Platform;->Companion:Lokhttp3/internal/platform/Platform$Companion;
invoke-virtual {v0}, Lokhttp3/internal/platform/Platform$Companion;->get()Lokhttp3/internal/platform/Platform;
move-result-object v0
const-string v1, "response.body().close()"
invoke-virtual {v0, v1}, Lokhttp3/internal/platform/Platform;->getStackTraceForCloseable(Ljava/lang/String;)Ljava/lang/Object;
move-result-object v0
iput-object v0, p0, Lokhttp3/internal/connection/Transmitter;->callStackTrace:Ljava/lang/Object;
.line 113
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->eventListener:Lokhttp3/EventListener;
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
invoke-virtual {v0, v1}, Lokhttp3/EventListener;->callStart(Lokhttp3/Call;)V
return-void
.end method
.method public final canRetry()Z
.registers 2
.line 306
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
if-nez v0, :cond_7
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_7
invoke-virtual {v0}, Lokhttp3/internal/connection/ExchangeFinder;->hasStreamFailure()Z
move-result v0
if-eqz v0, :cond_1c
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
if-nez v0, :cond_14
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_14
invoke-virtual {v0}, Lokhttp3/internal/connection/ExchangeFinder;->hasRouteToTry()Z
move-result v0
if-eqz v0, :cond_1c
const/4 v0, 0x1
goto :goto_1d
:cond_1c
const/4 v0, 0x0
:goto_1d
return v0
.end method
.method public final cancel()V
.registers 5
.line 327
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v0
const/4 v1, 0x1
.line 328
:try_start_4
iput-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->canceled:Z
.line 329
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
.line 330
iget-object v2, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
if-eqz v2, :cond_13
invoke-virtual {v2}, Lokhttp3/internal/connection/ExchangeFinder;->connectingConnection()Lokhttp3/internal/connection/RealConnection;
move-result-object v2
if-eqz v2, :cond_13
goto :goto_15
:cond_13
iget-object v2, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
.line 331
:goto_15
sget-object v3, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_17
.catchall {:try_start_4 .. :try_end_17} :catchall_24
.line 327
monitor-exit v0
if-eqz v1, :cond_1e
.line 332
invoke-virtual {v1}, Lokhttp3/internal/connection/Exchange;->cancel()V
goto :goto_23
:cond_1e
if-eqz v2, :cond_23
invoke-virtual {v2}, Lokhttp3/internal/connection/RealConnection;->cancel()V
:cond_23
:goto_23
return-void
:catchall_24
move-exception v1
.line 327
monitor-exit v0
throw v1
.end method
.method public final exchangeDoneDueToException()V
.registers 4
.line 207
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v0
.line 208
:try_start_3
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
if-eqz v1, :cond_a
invoke-virtual {v1}, Lokhttp3/internal/connection/Exchange;->detachWithViolence()V
.line 209
:cond_a
iget-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->noMoreExchanges:Z
xor-int/lit8 v1, v1, 0x1
if-eqz v1, :cond_19
const/4 v1, 0x0
.line 210
check-cast v1, Lokhttp3/internal/connection/Exchange;
iput-object v1, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
.line 211
sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_17
.catchall {:try_start_3 .. :try_end_17} :catchall_27
.line 207
monitor-exit v0
return-void
:cond_19
:try_start_19
const-string v1, "Check failed."
.line 209
new-instance v2, Ljava/lang/IllegalStateException;
invoke-virtual {v1}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object v1
invoke-direct {v2, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast v2, Ljava/lang/Throwable;
throw v2
:try_end_27
.catchall {:try_start_19 .. :try_end_27} :catchall_27
:catchall_27
move-exception v1
.line 207
monitor-exit v0
throw v1
.end method
.method public final exchangeMessageDone$okhttp(Lokhttp3/internal/connection/Exchange;ZZLjava/io/IOException;)Ljava/io/IOException;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"<E:",
"Ljava/io/IOException;",
">(",
"Lokhttp3/internal/connection/Exchange;",
"ZZTE;)TE;"
}
.end annotation
const-string v0, "exchange"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 230
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v0
.line 231
:try_start_8
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
invoke-static {p1, v1}, Lkotlin/jvm/internal/Intrinsics;->areEqual(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result p1
:try_end_e
.catchall {:try_start_8 .. :try_end_e} :catchall_5a
const/4 v1, 0x1
xor-int/2addr p1, v1
if-eqz p1, :cond_14
.line 232
monitor-exit v0
return-object p4
:cond_14
const/4 p1, 0x0
if-eqz p2, :cond_1d
.line 236
:try_start_17
iget-boolean p2, p0, Lokhttp3/internal/connection/Transmitter;->exchangeRequestDone:Z
xor-int/2addr p2, v1
.line 237
iput-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->exchangeRequestDone:Z
goto :goto_1e
:cond_1d
const/4 p2, 0x0
:goto_1e
if-eqz p3, :cond_27
.line 240
iget-boolean p3, p0, Lokhttp3/internal/connection/Transmitter;->exchangeResponseDone:Z
if-nez p3, :cond_25
const/4 p2, 0x1
.line 241
:cond_25
iput-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->exchangeResponseDone:Z
.line 243
:cond_27
iget-boolean p3, p0, Lokhttp3/internal/connection/Transmitter;->exchangeRequestDone:Z
if-eqz p3, :cond_4f
iget-boolean p3, p0, Lokhttp3/internal/connection/Transmitter;->exchangeResponseDone:Z
if-eqz p3, :cond_4f
if-eqz p2, :cond_4f
.line 245
iget-object p2, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
if-nez p2, :cond_38
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_38
invoke-virtual {p2}, Lokhttp3/internal/connection/Exchange;->connection()Lokhttp3/internal/connection/RealConnection;
move-result-object p2
if-nez p2, :cond_41
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_41
invoke-virtual {p2}, Lokhttp3/internal/connection/RealConnection;->getSuccessCount$okhttp()I
move-result p3
add-int/2addr p3, v1
invoke-virtual {p2, p3}, Lokhttp3/internal/connection/RealConnection;->setSuccessCount$okhttp(I)V
const/4 p2, 0x0
.line 246
check-cast p2, Lokhttp3/internal/connection/Exchange;
iput-object p2, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
goto :goto_50
:cond_4f
const/4 v1, 0x0
.line 248
:goto_50
sget-object p2, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_52
.catchall {:try_start_17 .. :try_end_52} :catchall_5a
.line 230
monitor-exit v0
if-eqz v1, :cond_59
.line 250
invoke-direct {p0, p4, p1}, Lokhttp3/internal/connection/Transmitter;->maybeReleaseConnection(Ljava/io/IOException;Z)Ljava/io/IOException;
move-result-object p4
:cond_59
return-object p4
:catchall_5a
move-exception p1
.line 230
monitor-exit v0
throw p1
.end method
.method public final getConnection()Lokhttp3/internal/connection/RealConnection;
.registers 2
.line 70
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
return-object v0
.end method
.method public final hasExchange()Z
.registers 3
.line 310
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v0
.line 311
:try_start_3
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
:try_end_5
.catchall {:try_start_3 .. :try_end_5} :catchall_c
if-eqz v1, :cond_9
const/4 v1, 0x1
goto :goto_a
:cond_9
const/4 v1, 0x0
:goto_a
monitor-exit v0
return v1
:catchall_c
move-exception v1
.line 310
monitor-exit v0
throw v1
.end method
.method public final isCanceled()Z
.registers 3
.line 80
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v0
.line 81
:try_start_3
iget-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->canceled:Z
:try_end_5
.catchall {:try_start_3 .. :try_end_5} :catchall_7
monitor-exit v0
return v1
:catchall_7
move-exception v1
.line 80
monitor-exit v0
throw v1
.end method
.method public final newExchange$okhttp(Lokhttp3/Interceptor$Chain;Z)Lokhttp3/internal/connection/Exchange;
.registers 13
const-string v0, "chain"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 155
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v0
.line 156
:try_start_8
iget-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->noMoreExchanges:Z
const/4 v2, 0x1
xor-int/2addr v1, v2
if-eqz v1, :cond_55
.line 157
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
const/4 v3, 0x0
if-nez v1, :cond_14
goto :goto_15
:cond_14
const/4 v2, 0x0
:goto_15
if-eqz v2, :cond_47
.line 161
sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_19
.catchall {:try_start_8 .. :try_end_19} :catchall_63
.line 155
monitor-exit v0
.line 163
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
if-nez v0, :cond_21
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_21
iget-object v1, p0, Lokhttp3/internal/connection/Transmitter;->client:Lokhttp3/OkHttpClient;
invoke-virtual {v0, v1, p1, p2}, Lokhttp3/internal/connection/ExchangeFinder;->find(Lokhttp3/OkHttpClient;Lokhttp3/Interceptor$Chain;Z)Lokhttp3/internal/http/ExchangeCodec;
move-result-object v9
.line 164
new-instance p1, Lokhttp3/internal/connection/Exchange;
iget-object v6, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
iget-object v7, p0, Lokhttp3/internal/connection/Transmitter;->eventListener:Lokhttp3/EventListener;
iget-object v8, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
if-nez v8, :cond_34
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_34
move-object v4, p1
move-object v5, p0
invoke-direct/range {v4 .. v9}, Lokhttp3/internal/connection/Exchange;-><init>(Lokhttp3/internal/connection/Transmitter;Lokhttp3/Call;Lokhttp3/EventListener;Lokhttp3/internal/connection/ExchangeFinder;Lokhttp3/internal/http/ExchangeCodec;)V
.line 166
iget-object p2, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter p2
.line 167
:try_start_3c
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
.line 168
iput-boolean v3, p0, Lokhttp3/internal/connection/Transmitter;->exchangeRequestDone:Z
.line 169
iput-boolean v3, p0, Lokhttp3/internal/connection/Transmitter;->exchangeResponseDone:Z
:try_end_42
.catchall {:try_start_3c .. :try_end_42} :catchall_44
.line 170
monitor-exit p2
return-object p1
:catchall_44
move-exception p1
.line 166
monitor-exit p2
throw p1
:cond_47
:try_start_47
const-string p1, "cannot make a new request because the previous response is still open: please call response.close()"
.line 157
new-instance p2, Ljava/lang/IllegalStateException;
invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object p1
invoke-direct {p2, p1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast p2, Ljava/lang/Throwable;
throw p2
:cond_55
const-string p1, "released"
.line 156
new-instance p2, Ljava/lang/IllegalStateException;
invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object p1
invoke-direct {p2, p1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast p2, Ljava/lang/Throwable;
throw p2
:try_end_63
.catchall {:try_start_47 .. :try_end_63} :catchall_63
:catchall_63
move-exception p1
.line 155
monitor-exit v0
throw p1
.end method
.method public final noMoreExchanges(Ljava/io/IOException;)Ljava/io/IOException;
.registers 4
.line 256
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
monitor-enter v0
const/4 v1, 0x1
.line 257
:try_start_4
iput-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->noMoreExchanges:Z
.line 258
sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_8
.catchall {:try_start_4 .. :try_end_8} :catchall_f
.line 256
monitor-exit v0
const/4 v0, 0x0
.line 259
invoke-direct {p0, p1, v0}, Lokhttp3/internal/connection/Transmitter;->maybeReleaseConnection(Ljava/io/IOException;Z)Ljava/io/IOException;
move-result-object p1
return-object p1
:catchall_f
move-exception p1
.line 256
monitor-exit v0
throw p1
.end method
.method public final prepareToConnect(Lokhttp3/Request;)V
.registers 9
const-string v0, "request"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 121
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->request:Lokhttp3/Request;
if-eqz v0, :cond_4f
if-nez v0, :cond_e
.line 122
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_e
invoke-virtual {v0}, Lokhttp3/Request;->url()Lokhttp3/HttpUrl;
move-result-object v0
invoke-virtual {p1}, Lokhttp3/Request;->url()Lokhttp3/HttpUrl;
move-result-object v1
invoke-static {v0, v1}, Lokhttp3/internal/Util;->canReuseConnectionFor(Lokhttp3/HttpUrl;Lokhttp3/HttpUrl;)Z
move-result v0
if-eqz v0, :cond_2a
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
if-nez v0, :cond_23
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_23
invoke-virtual {v0}, Lokhttp3/internal/connection/ExchangeFinder;->hasRouteToTry()Z
move-result v0
if-eqz v0, :cond_2a
return-void
.line 125
:cond_2a
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->exchange:Lokhttp3/internal/connection/Exchange;
const/4 v1, 0x1
if-nez v0, :cond_31
const/4 v0, 0x1
goto :goto_32
:cond_31
const/4 v0, 0x0
:goto_32
if-eqz v0, :cond_41
.line 127
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
if-eqz v0, :cond_4f
const/4 v0, 0x0
.line 128
invoke-direct {p0, v0, v1}, Lokhttp3/internal/connection/Transmitter;->maybeReleaseConnection(Ljava/io/IOException;Z)Ljava/io/IOException;
.line 129
check-cast v0, Lokhttp3/internal/connection/ExchangeFinder;
iput-object v0, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
goto :goto_4f
.line 125
:cond_41
new-instance p1, Ljava/lang/IllegalStateException;
const-string v0, "Check failed."
invoke-virtual {v0}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object v0
invoke-direct {p1, v0}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast p1, Ljava/lang/Throwable;
throw p1
.line 133
:cond_4f
:goto_4f
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->request:Lokhttp3/Request;
.line 134
new-instance v6, Lokhttp3/internal/connection/ExchangeFinder;
.line 135
iget-object v2, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
invoke-virtual {p1}, Lokhttp3/Request;->url()Lokhttp3/HttpUrl;
move-result-object p1
invoke-direct {p0, p1}, Lokhttp3/internal/connection/Transmitter;->createAddress(Lokhttp3/HttpUrl;)Lokhttp3/Address;
move-result-object v3
iget-object v4, p0, Lokhttp3/internal/connection/Transmitter;->call:Lokhttp3/Call;
iget-object v5, p0, Lokhttp3/internal/connection/Transmitter;->eventListener:Lokhttp3/EventListener;
move-object v0, v6
move-object v1, p0
.line 134
invoke-direct/range {v0 .. v5}, Lokhttp3/internal/connection/ExchangeFinder;-><init>(Lokhttp3/internal/connection/Transmitter;Lokhttp3/internal/connection/RealConnectionPool;Lokhttp3/Address;Lokhttp3/Call;Lokhttp3/EventListener;)V
iput-object v6, p0, Lokhttp3/internal/connection/Transmitter;->exchangeFinder:Lokhttp3/internal/connection/ExchangeFinder;
return-void
.end method
.method public final releaseConnectionNoEvents()Ljava/net/Socket;
.registers 7
.line 187
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
.line 349
sget-boolean v1, Lokhttp3/internal/Util;->assertionsEnabled:Z
if-eqz v1, :cond_3b
invoke-static {v0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z
move-result v1
if-eqz v1, :cond_d
goto :goto_3b
.line 350
:cond_d
new-instance v1, Ljava/lang/AssertionError;
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
const-string v3, "Thread "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object v3
const-string v4, "Thread.currentThread()"
invoke-static {v3, v4}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
invoke-virtual {v3}, Ljava/lang/Thread;->getName()Ljava/lang/String;
move-result-object v3
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " MUST hold lock on "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
invoke-direct {v1, v0}, Ljava/lang/AssertionError;-><init>(Ljava/lang/Object;)V
check-cast v1, Ljava/lang/Throwable;
throw v1
.line 189
:cond_3b
:goto_3b
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
if-nez v0, :cond_42
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_42
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->getTransmitters()Ljava/util/List;
move-result-object v0
.line 354
invoke-interface {v0}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object v0
const/4 v1, 0x0
const/4 v2, 0x0
:goto_4c
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v3
const/4 v4, -0x1
if-eqz v3, :cond_6c
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v3
.line 355
check-cast v3, Ljava/lang/ref/Reference;
.line 189
invoke-virtual {v3}, Ljava/lang/ref/Reference;->get()Ljava/lang/Object;
move-result-object v3
check-cast v3, Lokhttp3/internal/connection/Transmitter;
move-object v5, p0
check-cast v5, Lokhttp3/internal/connection/Transmitter;
invoke-static {v3, v5}, Lkotlin/jvm/internal/Intrinsics;->areEqual(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v3
if-eqz v3, :cond_69
goto :goto_6d
:cond_69
add-int/lit8 v2, v2, 0x1
goto :goto_4c
:cond_6c
const/4 v2, -0x1
:goto_6d
if-eq v2, v4, :cond_70
const/4 v1, 0x1
:cond_70
if-eqz v1, :cond_a5
.line 192
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
if-nez v0, :cond_79
.line 193
invoke-static {}, Lkotlin/jvm/internal/Intrinsics;->throwNpe()V
:cond_79
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->getTransmitters()Ljava/util/List;
move-result-object v1
invoke-interface {v1, v2}, Ljava/util/List;->remove(I)Ljava/lang/Object;
const/4 v1, 0x0
.line 194
move-object v2, v1
check-cast v2, Lokhttp3/internal/connection/RealConnection;
iput-object v2, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
.line 196
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->getTransmitters()Ljava/util/List;
move-result-object v2
invoke-interface {v2}, Ljava/util/List;->isEmpty()Z
move-result v2
if-eqz v2, :cond_a4
.line 197
invoke-static {}, Ljava/lang/System;->nanoTime()J
move-result-wide v2
invoke-virtual {v0, v2, v3}, Lokhttp3/internal/connection/RealConnection;->setIdleAtNanos$okhttp(J)V
.line 198
iget-object v2, p0, Lokhttp3/internal/connection/Transmitter;->connectionPool:Lokhttp3/internal/connection/RealConnectionPool;
invoke-virtual {v2, v0}, Lokhttp3/internal/connection/RealConnectionPool;->connectionBecameIdle(Lokhttp3/internal/connection/RealConnection;)Z
move-result v2
if-eqz v2, :cond_a4
.line 199
invoke-virtual {v0}, Lokhttp3/internal/connection/RealConnection;->socket()Ljava/net/Socket;
move-result-object v0
return-object v0
:cond_a4
return-object v1
.line 190
:cond_a5
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Check failed."
invoke-virtual {v1}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object v1
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast v0, Ljava/lang/Throwable;
throw v0
.end method
.method public final setConnection(Lokhttp3/internal/connection/RealConnection;)V
.registers 2
.line 70
iput-object p1, p0, Lokhttp3/internal/connection/Transmitter;->connection:Lokhttp3/internal/connection/RealConnection;
return-void
.end method
.method public final timeout()Lokio/Timeout;
.registers 2
.line 85
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->timeout:Lokhttp3/internal/connection/Transmitter$timeout$1;
check-cast v0, Lokio/Timeout;
return-object v0
.end method
.method public final timeoutEarlyExit()V
.registers 3
.line 96
iget-boolean v0, p0, Lokhttp3/internal/connection/Transmitter;->timeoutEarlyExit:Z
const/4 v1, 0x1
xor-int/2addr v0, v1
if-eqz v0, :cond_e
.line 97
iput-boolean v1, p0, Lokhttp3/internal/connection/Transmitter;->timeoutEarlyExit:Z
.line 98
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->timeout:Lokhttp3/internal/connection/Transmitter$timeout$1;
invoke-virtual {v0}, Lokhttp3/internal/connection/Transmitter$timeout$1;->exit()Z
return-void
.line 96
:cond_e
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "Check failed."
invoke-virtual {v1}, Ljava/lang/Object;->toString()Ljava/lang/String;
move-result-object v1
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
check-cast v0, Ljava/lang/Throwable;
throw v0
.end method
.method public final timeoutEnter()V
.registers 2
.line 88
iget-object v0, p0, Lokhttp3/internal/connection/Transmitter;->timeout:Lokhttp3/internal/connection/Transmitter$timeout$1;
invoke-virtual {v0}, Lokhttp3/internal/connection/Transmitter$timeout$1;->enter()V
return-void
.end method