RealCall$AsyncCall.smali
.class public final Lokhttp3/RealCall$AsyncCall;
.super Ljava/lang/Object;
.source "RealCall.kt"
# interfaces
.implements Ljava/lang/Runnable;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lokhttp3/RealCall;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x11
name = "AsyncCall"
.end annotation
.annotation system Ldalvik/annotation/SourceDebugExtension;
value = "SMAP\nRealCall.kt\nKotlin\n*S Kotlin\n*F\n+ 1 RealCall.kt\nokhttp3/RealCall$AsyncCall\n+ 2 Util.kt\nokhttp3/internal/Util\n*L\n1#1,223:1\n544#2,4:224\n376#2,9:228\n*E\n*S KotlinDebug\n*F\n+ 1 RealCall.kt\nokhttp3/RealCall$AsyncCall\n*L\n115#1,4:224\n134#1,9:228\n*E\n"
.end annotation
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u00008\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0004\u0008\u0080\u0004\u0018\u00002\u00020\u0001B\r\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u00a2\u0006\u0002\u0010\u0004J\u0006\u0010\u0005\u001a\u00020\u0006J\u000e\u0010\u0007\u001a\u00020\u00082\u0006\u0010\t\u001a\u00020\nJ\u0006\u0010\u000b\u001a\u00020\u000cJ\u0006\u0010\r\u001a\u00020\u000eJ\u0006\u0010\u000f\u001a\u00020\u0010J\u0012\u0010\u0011\u001a\u00020\u00082\n\u0010\u0012\u001a\u00060\u0000R\u00020\u000cJ\u0008\u0010\u0013\u001a\u00020\u0008H\u0016R\u000e\u0010\u0005\u001a\u00020\u0006X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004\u00a2\u0006\u0002\n\u0000\u00a8\u0006\u0014"
}
d2 = {
"Lokhttp3/RealCall$AsyncCall;",
"Ljava/lang/Runnable;",
"responseCallback",
"Lokhttp3/Callback;",
"(Lokhttp3/RealCall;Lokhttp3/Callback;)V",
"callsPerHost",
"Ljava/util/concurrent/atomic/AtomicInteger;",
"executeOn",
"",
"executorService",
"Ljava/util/concurrent/ExecutorService;",
"get",
"Lokhttp3/RealCall;",
"host",
"",
"request",
"Lokhttp3/Request;",
"reuseCallsPerHostFrom",
"other",
"run",
"okhttp"
}
k = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# instance fields
.field private volatile callsPerHost:Ljava/util/concurrent/atomic/AtomicInteger;
.field private final responseCallback:Lokhttp3/Callback;
.field final synthetic this$0:Lokhttp3/RealCall;
# direct methods
.method public constructor <init>(Lokhttp3/RealCall;Lokhttp3/Callback;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lokhttp3/Callback;",
")V"
}
.end annotation
const-string v0, "responseCallback"
invoke-static {p2, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 93
iput-object p1, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
iput-object p2, p0, Lokhttp3/RealCall$AsyncCall;->responseCallback:Lokhttp3/Callback;
.line 96
new-instance p1, Ljava/util/concurrent/atomic/AtomicInteger;
const/4 p2, 0x0
invoke-direct {p1, p2}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>(I)V
iput-object p1, p0, Lokhttp3/RealCall$AsyncCall;->callsPerHost:Ljava/util/concurrent/atomic/AtomicInteger;
return-void
.end method
# virtual methods
.method public final callsPerHost()Ljava/util/concurrent/atomic/AtomicInteger;
.registers 2
.line 98
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->callsPerHost:Ljava/util/concurrent/atomic/AtomicInteger;
return-object v0
.end method
.method public final executeOn(Ljava/util/concurrent/ExecutorService;)V
.registers 6
const-string v0, "executorService"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 115
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v0}, Lokhttp3/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/OkHttpClient;->dispatcher()Lokhttp3/Dispatcher;
move-result-object v0
.line 224
sget-boolean v1, Lokhttp3/internal/Util;->assertionsEnabled:Z
if-eqz v1, :cond_48
invoke-static {v0}, Ljava/lang/Thread;->holdsLock(Ljava/lang/Object;)Z
move-result v1
if-nez v1, :cond_1a
goto :goto_48
.line 225
:cond_1a
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 NOT 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 119
:cond_48
:goto_48
:try_start_48
move-object v0, p0
check-cast v0, Ljava/lang/Runnable;
invoke-interface {p1, v0}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V
:try_end_4e
.catch Ljava/util/concurrent/RejectedExecutionException; {:try_start_48 .. :try_end_4e} :catch_51
.catchall {:try_start_48 .. :try_end_4e} :catchall_4f
goto :goto_82
:catchall_4f
move-exception p1
goto :goto_83
:catch_51
move-exception p1
.line 122
:try_start_52
new-instance v0, Ljava/io/InterruptedIOException;
const-string v1, "executor rejected"
invoke-direct {v0, v1}, Ljava/io/InterruptedIOException;-><init>(Ljava/lang/String;)V
.line 123
check-cast p1, Ljava/lang/Throwable;
invoke-virtual {v0, p1}, Ljava/io/InterruptedIOException;->initCause(Ljava/lang/Throwable;)Ljava/lang/Throwable;
.line 124
iget-object p1, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-static {p1}, Lokhttp3/RealCall;->access$getTransmitter$p(Lokhttp3/RealCall;)Lokhttp3/internal/connection/Transmitter;
move-result-object p1
move-object v1, v0
check-cast v1, Ljava/io/IOException;
invoke-virtual {p1, v1}, Lokhttp3/internal/connection/Transmitter;->noMoreExchanges(Ljava/io/IOException;)Ljava/io/IOException;
.line 125
iget-object p1, p0, Lokhttp3/RealCall$AsyncCall;->responseCallback:Lokhttp3/Callback;
iget-object v1, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
check-cast v1, Lokhttp3/Call;
check-cast v0, Ljava/io/IOException;
invoke-interface {p1, v1, v0}, Lokhttp3/Callback;->onFailure(Lokhttp3/Call;Ljava/io/IOException;)V
:try_end_75
.catchall {:try_start_52 .. :try_end_75} :catchall_4f
.line 128
iget-object p1, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {p1}, Lokhttp3/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object p1
invoke-virtual {p1}, Lokhttp3/OkHttpClient;->dispatcher()Lokhttp3/Dispatcher;
move-result-object p1
invoke-virtual {p1, p0}, Lokhttp3/Dispatcher;->finished$okhttp(Lokhttp3/RealCall$AsyncCall;)V
:goto_82
return-void
:goto_83
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v0}, Lokhttp3/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/OkHttpClient;->dispatcher()Lokhttp3/Dispatcher;
move-result-object v0
invoke-virtual {v0, p0}, Lokhttp3/Dispatcher;->finished$okhttp(Lokhttp3/RealCall$AsyncCall;)V
throw p1
.end method
.method public final get()Lokhttp3/RealCall;
.registers 2
.line 108
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
return-object v0
.end method
.method public final host()Ljava/lang/String;
.registers 2
.line 104
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v0}, Lokhttp3/RealCall;->getOriginalRequest()Lokhttp3/Request;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/Request;->url()Lokhttp3/HttpUrl;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/HttpUrl;->host()Ljava/lang/String;
move-result-object v0
return-object v0
.end method
.method public final request()Lokhttp3/Request;
.registers 2
.line 106
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v0}, Lokhttp3/RealCall;->getOriginalRequest()Lokhttp3/Request;
move-result-object v0
return-object v0
.end method
.method public final reuseCallsPerHostFrom(Lokhttp3/RealCall$AsyncCall;)V
.registers 3
const-string v0, "other"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkParameterIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
.line 101
iget-object p1, p1, Lokhttp3/RealCall$AsyncCall;->callsPerHost:Ljava/util/concurrent/atomic/AtomicInteger;
iput-object p1, p0, Lokhttp3/RealCall$AsyncCall;->callsPerHost:Ljava/util/concurrent/atomic/AtomicInteger;
return-void
.end method
.method public run()V
.registers 7
.line 134
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v1, "OkHttp "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v1, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v1}, Lokhttp3/RealCall;->redactedUrl()Ljava/lang/String;
move-result-object v1
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
.line 228
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object v1
const-string v2, "currentThread"
.line 229
invoke-static {v1, v2}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
invoke-virtual {v1}, Ljava/lang/Thread;->getName()Ljava/lang/String;
move-result-object v2
.line 230
invoke-virtual {v1, v0}, Ljava/lang/Thread;->setName(Ljava/lang/String;)V
const/4 v0, 0x0
.line 136
:try_start_28
iget-object v3, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-static {v3}, Lokhttp3/RealCall;->access$getTransmitter$p(Lokhttp3/RealCall;)Lokhttp3/internal/connection/Transmitter;
move-result-object v3
invoke-virtual {v3}, Lokhttp3/internal/connection/Transmitter;->timeoutEnter()V
:try_end_31
.catchall {:try_start_28 .. :try_end_31} :catchall_d2
.line 138
:try_start_31
iget-object v3, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v3}, Lokhttp3/RealCall;->getResponseWithInterceptorChain()Lokhttp3/Response;
move-result-object v0
:try_end_37
.catch Ljava/io/IOException; {:try_start_31 .. :try_end_37} :catch_83
.catchall {:try_start_31 .. :try_end_37} :catchall_54
const/4 v3, 0x1
.line 140
:try_start_38
iget-object v4, p0, Lokhttp3/RealCall$AsyncCall;->responseCallback:Lokhttp3/Callback;
iget-object v5, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
check-cast v5, Lokhttp3/Call;
invoke-interface {v4, v5, v0}, Lokhttp3/Callback;->onResponse(Lokhttp3/Call;Lokhttp3/Response;)V
:try_end_41
.catch Ljava/io/IOException; {:try_start_38 .. :try_end_41} :catch_52
.catchall {:try_start_38 .. :try_end_41} :catchall_50
.line 157
:try_start_41
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v0}, Lokhttp3/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/OkHttpClient;->dispatcher()Lokhttp3/Dispatcher;
move-result-object v0
:goto_4b
invoke-virtual {v0, p0}, Lokhttp3/Dispatcher;->finished$okhttp(Lokhttp3/RealCall$AsyncCall;)V
:try_end_4e
.catchall {:try_start_41 .. :try_end_4e} :catchall_d2
goto/16 :goto_c0
:catchall_50
move-exception v0
goto :goto_57
:catch_52
move-exception v0
goto :goto_86
:catchall_54
move-exception v3
move-object v0, v3
const/4 v3, 0x0
.line 149
:goto_57
:try_start_57
iget-object v4, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v4}, Lokhttp3/RealCall;->cancel()V
if-nez v3, :cond_80
.line 151
new-instance v3, Ljava/io/IOException;
new-instance v4, Ljava/lang/StringBuilder;
invoke-direct {v4}, Ljava/lang/StringBuilder;-><init>()V
const-string v5, "canceled due to "
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v4
invoke-direct {v3, v4}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
.line 152
invoke-virtual {v3, v0}, Ljava/io/IOException;->addSuppressed(Ljava/lang/Throwable;)V
.line 153
iget-object v4, p0, Lokhttp3/RealCall$AsyncCall;->responseCallback:Lokhttp3/Callback;
iget-object v5, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
check-cast v5, Lokhttp3/Call;
invoke-interface {v4, v5, v3}, Lokhttp3/Callback;->onFailure(Lokhttp3/Call;Ljava/io/IOException;)V
.line 155
:cond_80
throw v0
:catchall_81
move-exception v0
goto :goto_c4
:catch_83
move-exception v3
move-object v0, v3
const/4 v3, 0x0
:goto_86
if-eqz v3, :cond_ac
.line 144
sget-object v3, Lokhttp3/internal/platform/Platform;->Companion:Lokhttp3/internal/platform/Platform$Companion;
invoke-virtual {v3}, Lokhttp3/internal/platform/Platform$Companion;->get()Lokhttp3/internal/platform/Platform;
move-result-object v3
new-instance v4, Ljava/lang/StringBuilder;
invoke-direct {v4}, Ljava/lang/StringBuilder;-><init>()V
const-string v5, "Callback failure for "
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v5, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v5}, Lokhttp3/RealCall;->toLoggableString()Ljava/lang/String;
move-result-object v5
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v4
const/4 v5, 0x4
check-cast v0, Ljava/lang/Throwable;
invoke-virtual {v3, v4, v5, v0}, Lokhttp3/internal/platform/Platform;->log(Ljava/lang/String;ILjava/lang/Throwable;)V
goto :goto_b5
.line 146
:cond_ac
iget-object v3, p0, Lokhttp3/RealCall$AsyncCall;->responseCallback:Lokhttp3/Callback;
iget-object v4, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
check-cast v4, Lokhttp3/Call;
invoke-interface {v3, v4, v0}, Lokhttp3/Callback;->onFailure(Lokhttp3/Call;Ljava/io/IOException;)V
:try_end_b5
.catchall {:try_start_57 .. :try_end_b5} :catchall_81
.line 157
:goto_b5
:try_start_b5
iget-object v0, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v0}, Lokhttp3/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/OkHttpClient;->dispatcher()Lokhttp3/Dispatcher;
move-result-object v0
:try_end_bf
.catchall {:try_start_b5 .. :try_end_bf} :catchall_d2
goto :goto_4b
.line 234
:goto_c0
invoke-virtual {v1, v2}, Ljava/lang/Thread;->setName(Ljava/lang/String;)V
return-void
.line 157
:goto_c4
:try_start_c4
iget-object v3, p0, Lokhttp3/RealCall$AsyncCall;->this$0:Lokhttp3/RealCall;
invoke-virtual {v3}, Lokhttp3/RealCall;->getClient()Lokhttp3/OkHttpClient;
move-result-object v3
invoke-virtual {v3}, Lokhttp3/OkHttpClient;->dispatcher()Lokhttp3/Dispatcher;
move-result-object v3
invoke-virtual {v3, p0}, Lokhttp3/Dispatcher;->finished$okhttp(Lokhttp3/RealCall$AsyncCall;)V
throw v0
:try_end_d2
.catchall {:try_start_c4 .. :try_end_d2} :catchall_d2
:catchall_d2
move-exception v0
.line 234
invoke-virtual {v1, v2}, Ljava/lang/Thread;->setName(Ljava/lang/String;)V
throw v0
.end method