Dispatcher.smali
.class public final Lokhttp3/Dispatcher;
.super Ljava/lang/Object;
# instance fields
.field private executorService:Ljava/util/concurrent/ExecutorService;
.field private idleCallback:Ljava/lang/Runnable;
.field private maxRequests:I
.field private maxRequestsPerHost:I
.field private final readyAsyncCalls:Ljava/util/Deque;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Deque",
"<",
"Lokhttp3/RealCall$AsyncCall;",
">;"
}
.end annotation
.end field
.field private final runningAsyncCalls:Ljava/util/Deque;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Deque",
"<",
"Lokhttp3/RealCall$AsyncCall;",
">;"
}
.end annotation
.end field
.field private final runningSyncCalls:Ljava/util/Deque;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Deque",
"<",
"Lokhttp3/RealCall;",
">;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>()V
.registers 2
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
const/16 v0, 0x40
iput v0, p0, Lokhttp3/Dispatcher;->maxRequests:I
const/4 v0, 0x5
iput v0, p0, Lokhttp3/Dispatcher;->maxRequestsPerHost:I
new-instance v0, Ljava/util/ArrayDeque;
invoke-direct {v0}, Ljava/util/ArrayDeque;-><init>()V
iput-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
new-instance v0, Ljava/util/ArrayDeque;
invoke-direct {v0}, Ljava/util/ArrayDeque;-><init>()V
iput-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
new-instance v0, Ljava/util/ArrayDeque;
invoke-direct {v0}, Ljava/util/ArrayDeque;-><init>()V
iput-object v0, p0, Lokhttp3/Dispatcher;->runningSyncCalls:Ljava/util/Deque;
return-void
.end method
.method public constructor <init>(Ljava/util/concurrent/ExecutorService;)V
.registers 3
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
const/16 v0, 0x40
iput v0, p0, Lokhttp3/Dispatcher;->maxRequests:I
const/4 v0, 0x5
iput v0, p0, Lokhttp3/Dispatcher;->maxRequestsPerHost:I
new-instance v0, Ljava/util/ArrayDeque;
invoke-direct {v0}, Ljava/util/ArrayDeque;-><init>()V
iput-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
new-instance v0, Ljava/util/ArrayDeque;
invoke-direct {v0}, Ljava/util/ArrayDeque;-><init>()V
iput-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
new-instance v0, Ljava/util/ArrayDeque;
invoke-direct {v0}, Ljava/util/ArrayDeque;-><init>()V
iput-object v0, p0, Lokhttp3/Dispatcher;->runningSyncCalls:Ljava/util/Deque;
iput-object p1, p0, Lokhttp3/Dispatcher;->executorService:Ljava/util/concurrent/ExecutorService;
return-void
.end method
.method private finished(Ljava/util/Deque;Ljava/lang/Object;Z)V
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Ljava/util/Deque",
"<TT;>;TT;Z)V"
}
.end annotation
monitor-enter p0
:try_start_1
invoke-interface {p1, p2}, Ljava/util/Deque;->remove(Ljava/lang/Object;)Z
move-result v0
if-nez v0, :cond_13
new-instance v0, Ljava/lang/AssertionError;
const-string/jumbo v1, "Call wasn\'t in-flight!"
invoke-direct {v0, v1}, Ljava/lang/AssertionError;-><init>(Ljava/lang/Object;)V
throw v0
:catchall_10
move-exception v0
monitor-exit p0
:try_end_12
.catchall {:try_start_1 .. :try_end_12} :catchall_10
throw v0
:cond_13
if-eqz p3, :cond_18
:try_start_15
invoke-direct {p0}, Lokhttp3/Dispatcher;->promoteCalls()V
:cond_18
invoke-virtual {p0}, Lokhttp3/Dispatcher;->runningCallsCount()I
move-result v0
iget-object v1, p0, Lokhttp3/Dispatcher;->idleCallback:Ljava/lang/Runnable;
monitor-exit p0
:try_end_1f
.catchall {:try_start_15 .. :try_end_1f} :catchall_10
if-nez v0, :cond_26
if-eqz v1, :cond_26
invoke-interface {v1}, Ljava/lang/Runnable;->run()V
:cond_26
return-void
.end method
.method private promoteCalls()V
.registers 5
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->size()I
move-result v0
iget v1, p0, Lokhttp3/Dispatcher;->maxRequests:I
if-lt v0, v1, :cond_b
:cond_a
:goto_a
return-void
:cond_b
iget-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->isEmpty()Z
move-result v0
if-nez v0, :cond_a
iget-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->iterator()Ljava/util/Iterator;
move-result-object v1
:cond_19
invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_a
invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/RealCall$AsyncCall;
invoke-direct {p0, v0}, Lokhttp3/Dispatcher;->runningCallsForHost(Lokhttp3/RealCall$AsyncCall;)I
move-result v2
iget v3, p0, Lokhttp3/Dispatcher;->maxRequestsPerHost:I
if-ge v2, v3, :cond_3c
invoke-interface {v1}, Ljava/util/Iterator;->remove()V
iget-object v2, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v2, v0}, Ljava/util/Deque;->add(Ljava/lang/Object;)Z
invoke-virtual {p0}, Lokhttp3/Dispatcher;->executorService()Ljava/util/concurrent/ExecutorService;
move-result-object v2
invoke-interface {v2, v0}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V
:cond_3c
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->size()I
move-result v0
iget v2, p0, Lokhttp3/Dispatcher;->maxRequests:I
if-lt v0, v2, :cond_19
goto :goto_a
.end method
.method private runningCallsForHost(Lokhttp3/RealCall$AsyncCall;)I
.registers 6
const/4 v0, 0x0
iget-object v1, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v1}, Ljava/util/Deque;->iterator()Ljava/util/Iterator;
move-result-object v2
move v1, v0
:goto_8
invoke-interface {v2}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_26
invoke-interface {v2}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/RealCall$AsyncCall;
invoke-virtual {v0}, Lokhttp3/RealCall$AsyncCall;->host()Ljava/lang/String;
move-result-object v0
invoke-virtual {p1}, Lokhttp3/RealCall$AsyncCall;->host()Ljava/lang/String;
move-result-object v3
invoke-virtual {v0, v3}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z
move-result v0
if-eqz v0, :cond_27
add-int/lit8 v0, v1, 0x1
:goto_24
move v1, v0
goto :goto_8
:cond_26
return v1
:cond_27
move v0, v1
goto :goto_24
.end method
# virtual methods
.method public declared-synchronized cancelAll()V
.registers 3
monitor-enter p0
:try_start_1
iget-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->iterator()Ljava/util/Iterator;
move-result-object v1
:goto_7
invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_1e
invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/RealCall$AsyncCall;
invoke-virtual {v0}, Lokhttp3/RealCall$AsyncCall;->get()Lokhttp3/RealCall;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/RealCall;->cancel()V
:try_end_1a
.catchall {:try_start_1 .. :try_end_1a} :catchall_1b
goto :goto_7
:catchall_1b
move-exception v0
monitor-exit p0
throw v0
:cond_1e
:try_start_1e
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->iterator()Ljava/util/Iterator;
move-result-object v1
:goto_24
invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_38
invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/RealCall$AsyncCall;
invoke-virtual {v0}, Lokhttp3/RealCall$AsyncCall;->get()Lokhttp3/RealCall;
move-result-object v0
invoke-virtual {v0}, Lokhttp3/RealCall;->cancel()V
goto :goto_24
:cond_38
iget-object v0, p0, Lokhttp3/Dispatcher;->runningSyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->iterator()Ljava/util/Iterator;
move-result-object v1
:goto_3e
invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_4e
invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/RealCall;
invoke-virtual {v0}, Lokhttp3/RealCall;->cancel()V
:try_end_4d
.catchall {:try_start_1e .. :try_end_4d} :catchall_1b
goto :goto_3e
:cond_4e
monitor-exit p0
return-void
.end method
.method declared-synchronized enqueue(Lokhttp3/RealCall$AsyncCall;)V
.registers 4
monitor-enter p0
:try_start_1
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->size()I
move-result v0
iget v1, p0, Lokhttp3/Dispatcher;->maxRequests:I
if-ge v0, v1, :cond_21
invoke-direct {p0, p1}, Lokhttp3/Dispatcher;->runningCallsForHost(Lokhttp3/RealCall$AsyncCall;)I
move-result v0
iget v1, p0, Lokhttp3/Dispatcher;->maxRequestsPerHost:I
if-ge v0, v1, :cond_21
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v0, p1}, Ljava/util/Deque;->add(Ljava/lang/Object;)Z
invoke-virtual {p0}, Lokhttp3/Dispatcher;->executorService()Ljava/util/concurrent/ExecutorService;
move-result-object v0
invoke-interface {v0, p1}, Ljava/util/concurrent/ExecutorService;->execute(Ljava/lang/Runnable;)V
:try_end_1f
.catchall {:try_start_1 .. :try_end_1f} :catchall_27
:goto_1f
monitor-exit p0
return-void
:cond_21
:try_start_21
iget-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
invoke-interface {v0, p1}, Ljava/util/Deque;->add(Ljava/lang/Object;)Z
:try_end_26
.catchall {:try_start_21 .. :try_end_26} :catchall_27
goto :goto_1f
:catchall_27
move-exception v0
monitor-exit p0
throw v0
.end method
.method declared-synchronized executed(Lokhttp3/RealCall;)V
.registers 3
monitor-enter p0
:try_start_1
iget-object v0, p0, Lokhttp3/Dispatcher;->runningSyncCalls:Ljava/util/Deque;
invoke-interface {v0, p1}, Ljava/util/Deque;->add(Ljava/lang/Object;)Z
:try_end_6
.catchall {:try_start_1 .. :try_end_6} :catchall_8
monitor-exit p0
return-void
:catchall_8
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized executorService()Ljava/util/concurrent/ExecutorService;
.registers 10
monitor-enter p0
:try_start_1
iget-object v0, p0, Lokhttp3/Dispatcher;->executorService:Ljava/util/concurrent/ExecutorService;
if-nez v0, :cond_21
new-instance v1, Ljava/util/concurrent/ThreadPoolExecutor;
const/4 v2, 0x0
const v3, 0x7fffffff
const-wide/16 v4, 0x3c
sget-object v6, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;
new-instance v7, Ljava/util/concurrent/SynchronousQueue;
invoke-direct {v7}, Ljava/util/concurrent/SynchronousQueue;-><init>()V
const-string/jumbo v0, "OkHttp Dispatcher"
const/4 v8, 0x0
invoke-static {v0, v8}, Lokhttp3/internal/Util;->threadFactory(Ljava/lang/String;Z)Ljava/util/concurrent/ThreadFactory;
move-result-object v8
invoke-direct/range {v1 .. v8}, Ljava/util/concurrent/ThreadPoolExecutor;-><init>(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V
iput-object v1, p0, Lokhttp3/Dispatcher;->executorService:Ljava/util/concurrent/ExecutorService;
:cond_21
iget-object v0, p0, Lokhttp3/Dispatcher;->executorService:Ljava/util/concurrent/ExecutorService;
:try_end_23
.catchall {:try_start_1 .. :try_end_23} :catchall_25
monitor-exit p0
return-object v0
:catchall_25
move-exception v0
monitor-exit p0
throw v0
.end method
.method finished(Lokhttp3/RealCall$AsyncCall;)V
.registers 4
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
const/4 v1, 0x1
invoke-direct {p0, v0, p1, v1}, Lokhttp3/Dispatcher;->finished(Ljava/util/Deque;Ljava/lang/Object;Z)V
return-void
.end method
.method finished(Lokhttp3/RealCall;)V
.registers 4
iget-object v0, p0, Lokhttp3/Dispatcher;->runningSyncCalls:Ljava/util/Deque;
const/4 v1, 0x0
invoke-direct {p0, v0, p1, v1}, Lokhttp3/Dispatcher;->finished(Ljava/util/Deque;Ljava/lang/Object;Z)V
return-void
.end method
.method public declared-synchronized getMaxRequests()I
.registers 2
monitor-enter p0
:try_start_1
iget v0, p0, Lokhttp3/Dispatcher;->maxRequests:I
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return v0
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized getMaxRequestsPerHost()I
.registers 2
monitor-enter p0
:try_start_1
iget v0, p0, Lokhttp3/Dispatcher;->maxRequestsPerHost:I
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return v0
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized queuedCalls()Ljava/util/List;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/List",
"<",
"Lokhttp3/Call;",
">;"
}
.end annotation
monitor-enter p0
:try_start_1
new-instance v1, Ljava/util/ArrayList;
invoke-direct {v1}, Ljava/util/ArrayList;-><init>()V
iget-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->iterator()Ljava/util/Iterator;
move-result-object v2
:goto_c
invoke-interface {v2}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_23
invoke-interface {v2}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/RealCall$AsyncCall;
invoke-virtual {v0}, Lokhttp3/RealCall$AsyncCall;->get()Lokhttp3/RealCall;
move-result-object v0
invoke-interface {v1, v0}, Ljava/util/List;->add(Ljava/lang/Object;)Z
:try_end_1f
.catchall {:try_start_1 .. :try_end_1f} :catchall_20
goto :goto_c
:catchall_20
move-exception v0
monitor-exit p0
throw v0
:cond_23
:try_start_23
invoke-static {v1}, Ljava/util/Collections;->unmodifiableList(Ljava/util/List;)Ljava/util/List;
:try_end_26
.catchall {:try_start_23 .. :try_end_26} :catchall_20
move-result-object v0
monitor-exit p0
return-object v0
.end method
.method public declared-synchronized queuedCallsCount()I
.registers 2
monitor-enter p0
:try_start_1
iget-object v0, p0, Lokhttp3/Dispatcher;->readyAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->size()I
:try_end_6
.catchall {:try_start_1 .. :try_end_6} :catchall_9
move-result v0
monitor-exit p0
return v0
:catchall_9
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized runningCalls()Ljava/util/List;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/List",
"<",
"Lokhttp3/Call;",
">;"
}
.end annotation
monitor-enter p0
:try_start_1
new-instance v1, Ljava/util/ArrayList;
invoke-direct {v1}, Ljava/util/ArrayList;-><init>()V
iget-object v0, p0, Lokhttp3/Dispatcher;->runningSyncCalls:Ljava/util/Deque;
invoke-interface {v1, v0}, Ljava/util/List;->addAll(Ljava/util/Collection;)Z
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->iterator()Ljava/util/Iterator;
move-result-object v2
:goto_11
invoke-interface {v2}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_28
invoke-interface {v2}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/RealCall$AsyncCall;
invoke-virtual {v0}, Lokhttp3/RealCall$AsyncCall;->get()Lokhttp3/RealCall;
move-result-object v0
invoke-interface {v1, v0}, Ljava/util/List;->add(Ljava/lang/Object;)Z
:try_end_24
.catchall {:try_start_1 .. :try_end_24} :catchall_25
goto :goto_11
:catchall_25
move-exception v0
monitor-exit p0
throw v0
:cond_28
:try_start_28
invoke-static {v1}, Ljava/util/Collections;->unmodifiableList(Ljava/util/List;)Ljava/util/List;
:try_end_2b
.catchall {:try_start_28 .. :try_end_2b} :catchall_25
move-result-object v0
monitor-exit p0
return-object v0
.end method
.method public declared-synchronized runningCallsCount()I
.registers 3
monitor-enter p0
:try_start_1
iget-object v0, p0, Lokhttp3/Dispatcher;->runningAsyncCalls:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->size()I
move-result v0
iget-object v1, p0, Lokhttp3/Dispatcher;->runningSyncCalls:Ljava/util/Deque;
invoke-interface {v1}, Ljava/util/Deque;->size()I
:try_end_c
.catchall {:try_start_1 .. :try_end_c} :catchall_10
move-result v1
add-int/2addr v0, v1
monitor-exit p0
return v0
:catchall_10
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized setIdleCallback(Ljava/lang/Runnable;)V
.registers 3
monitor-enter p0
:try_start_1
iput-object p1, p0, Lokhttp3/Dispatcher;->idleCallback:Ljava/lang/Runnable;
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return-void
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized setMaxRequests(I)V
.registers 5
monitor-enter p0
const/4 v0, 0x1
if-ge p1, v0, :cond_21
:try_start_4
new-instance v0, Ljava/lang/IllegalArgumentException;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
const-string/jumbo v2, "max < 1: "
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
move-result-object v1
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
move-result-object v1
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-direct {v0, v1}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V
throw v0
:try_end_1e
.catchall {:try_start_4 .. :try_end_1e} :catchall_1e
:catchall_1e
move-exception v0
monitor-exit p0
throw v0
:cond_21
:try_start_21
iput p1, p0, Lokhttp3/Dispatcher;->maxRequests:I
invoke-direct {p0}, Lokhttp3/Dispatcher;->promoteCalls()V
:try_end_26
.catchall {:try_start_21 .. :try_end_26} :catchall_1e
monitor-exit p0
return-void
.end method
.method public declared-synchronized setMaxRequestsPerHost(I)V
.registers 5
monitor-enter p0
const/4 v0, 0x1
if-ge p1, v0, :cond_21
:try_start_4
new-instance v0, Ljava/lang/IllegalArgumentException;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
const-string/jumbo v2, "max < 1: "
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
move-result-object v1
invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
move-result-object v1
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-direct {v0, v1}, Ljava/lang/IllegalArgumentException;-><init>(Ljava/lang/String;)V
throw v0
:try_end_1e
.catchall {:try_start_4 .. :try_end_1e} :catchall_1e
:catchall_1e
move-exception v0
monitor-exit p0
throw v0
:cond_21
:try_start_21
iput p1, p0, Lokhttp3/Dispatcher;->maxRequestsPerHost:I
invoke-direct {p0}, Lokhttp3/Dispatcher;->promoteCalls()V
:try_end_26
.catchall {:try_start_21 .. :try_end_26} :catchall_1e
monitor-exit p0
return-void
.end method