Pipe$sink$1.smali
.class public final Lokio/Pipe$sink$1;
.super Ljava/lang/Object;
.source "Pipe.kt"
# interfaces
.implements Lokio/Sink;
# annotations
.annotation system Ldalvik/annotation/EnclosingMethod;
value = Lokio/Pipe;-><init>(J)V
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x19
name = null
.end annotation
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000%\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000*\u0001\u0000\u0008\n\u0018\u00002\u00020\u0001J\u0008\u0010\u0004\u001a\u00020\u0005H\u0016J\u0008\u0010\u0006\u001a\u00020\u0005H\u0016J\u0008\u0010\u0002\u001a\u00020\u0003H\u0016J\u0018\u0010\u0007\u001a\u00020\u00052\u0006\u0010\u0008\u001a\u00020\t2\u0006\u0010\n\u001a\u00020\u000bH\u0016R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004\u00a2\u0006\u0002\n\u0000\u00a8\u0006\u000c"
}
d2 = {
"okio/Pipe$sink$1",
"Lokio/Sink;",
"timeout",
"Lokio/Timeout;",
"close",
"",
"flush",
"write",
"source",
"Lokio/Buffer;",
"byteCount",
"",
"okio"
}
k = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# instance fields
.field public final synthetic this$0:Lokio/Pipe;
.field public final timeout:Lokio/Timeout;
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method public constructor <init>(Lokio/Pipe;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"()V"
}
.end annotation
iput-object p1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
new-instance p1, Lokio/Timeout;
invoke-direct {p1}, Lokio/Timeout;-><init>()V
iput-object p1, p0, Lokio/Pipe$sink$1;->timeout:Lokio/Timeout;
return-void
.end method
# virtual methods
.method public close()V
.registers 12
iget-object v0, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v0}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v0
monitor-enter v0
:try_start_7
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getSinkClosed$okio()Z
move-result v1
:try_end_d
.catchall {:try_start_7 .. :try_end_d} :catchall_f0
if-eqz v1, :cond_11
monitor-exit v0
return-void
:cond_11
:try_start_11
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getFoldedSink$okio()Lokio/Sink;
move-result-object v1
if-eqz v1, :cond_1a
goto :goto_4d
:cond_1a
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getSourceClosed$okio()Z
move-result v1
if-eqz v1, :cond_3b
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v1
invoke-virtual {v1}, Lokio/Buffer;->size()J
move-result-wide v1
const-wide/16 v3, 0x0
cmp-long v5, v1, v3
if-gtz v5, :cond_33
goto :goto_3b
:cond_33
new-instance v1, Ljava/io/IOException;
const-string v2, "source is closed"
invoke-direct {v1, v2}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw v1
:cond_3b
:goto_3b
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
const/4 v2, 0x1
invoke-virtual {v1, v2}, Lokio/Pipe;->setSinkClosed$okio(Z)V
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v1
if-eqz v1, :cond_e8
invoke-virtual {v1}, Ljava/lang/Object;->notifyAll()V
const/4 v1, 0x0
:goto_4d
sget-object v2, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_4f
.catchall {:try_start_11 .. :try_end_4f} :catchall_f0
monitor-exit v0
if-eqz v1, :cond_e7
iget-object v0, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-interface {v1}, Lokio/Sink;->timeout()Lokio/Timeout;
move-result-object v2
invoke-virtual {v0}, Lokio/Pipe;->sink()Lokio/Sink;
move-result-object v0
invoke-interface {v0}, Lokio/Sink;->timeout()Lokio/Timeout;
move-result-object v0
invoke-virtual {v2}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v3
sget-object v5, Lokio/Timeout;->Companion:Lokio/Timeout$Companion;
invoke-virtual {v0}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v6
invoke-virtual {v2}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v8
invoke-virtual {v5, v6, v7, v8, v9}, Lokio/Timeout$Companion;->minTimeout(JJ)J
move-result-wide v5
sget-object v7, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v5, v6, v7}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v2}, Lokio/Timeout;->hasDeadline()Z
move-result v5
if-eqz v5, :cond_b8
invoke-virtual {v2}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v5
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v7
if-eqz v7, :cond_96
invoke-virtual {v2}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v7
invoke-virtual {v0}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v9
invoke-static {v7, v8, v9, v10}, Ljava/lang/Math;->min(JJ)J
move-result-wide v7
invoke-virtual {v2, v7, v8}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_96
:try_start_96
invoke-interface {v1}, Lokio/Sink;->close()V
:try_end_99
.catchall {:try_start_96 .. :try_end_99} :catchall_a8
sget-object v1, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v1}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_e7
invoke-virtual {v2, v5, v6}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
goto :goto_e7
:catchall_a8
move-exception v1
sget-object v7, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v7}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_b7
invoke-virtual {v2, v5, v6}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_b7
throw v1
:cond_b8
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v5
if-eqz v5, :cond_c5
invoke-virtual {v0}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v5
invoke-virtual {v2, v5, v6}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_c5
:try_start_c5
invoke-interface {v1}, Lokio/Sink;->close()V
:try_end_c8
.catchall {:try_start_c5 .. :try_end_c8} :catchall_d7
sget-object v1, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v1}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_e7
invoke-virtual {v2}, Lokio/Timeout;->clearDeadline()Lokio/Timeout;
goto :goto_e7
:catchall_d7
move-exception v1
sget-object v5, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v5}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_e6
invoke-virtual {v2}, Lokio/Timeout;->clearDeadline()Lokio/Timeout;
:cond_e6
throw v1
:cond_e7
:goto_e7
return-void
:cond_e8
:try_start_e8
new-instance v1, Lkotlin/TypeCastException;
const-string v2, "null cannot be cast to non-null type java.lang.Object"
invoke-direct {v1, v2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw v1
:try_end_f0
.catchall {:try_start_e8 .. :try_end_f0} :catchall_f0
:catchall_f0
move-exception v1
monitor-exit v0
throw v1
.end method
.method public flush()V
.registers 12
iget-object v0, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v0}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v0
monitor-enter v0
:try_start_7
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getSinkClosed$okio()Z
move-result v1
xor-int/lit8 v1, v1, 0x1
if-eqz v1, :cond_d7
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getFoldedSink$okio()Lokio/Sink;
move-result-object v1
if-eqz v1, :cond_1a
goto :goto_3c
:cond_1a
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getSourceClosed$okio()Z
move-result v1
if-eqz v1, :cond_3b
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v1
invoke-virtual {v1}, Lokio/Buffer;->size()J
move-result-wide v1
const-wide/16 v3, 0x0
cmp-long v5, v1, v3
if-gtz v5, :cond_33
goto :goto_3b
:cond_33
new-instance v1, Ljava/io/IOException;
const-string v2, "source is closed"
invoke-direct {v1, v2}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw v1
:cond_3b
:goto_3b
const/4 v1, 0x0
:goto_3c
sget-object v2, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_3e
.catchall {:try_start_7 .. :try_end_3e} :catchall_e3
monitor-exit v0
if-eqz v1, :cond_d6
iget-object v0, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-interface {v1}, Lokio/Sink;->timeout()Lokio/Timeout;
move-result-object v2
invoke-virtual {v0}, Lokio/Pipe;->sink()Lokio/Sink;
move-result-object v0
invoke-interface {v0}, Lokio/Sink;->timeout()Lokio/Timeout;
move-result-object v0
invoke-virtual {v2}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v3
sget-object v5, Lokio/Timeout;->Companion:Lokio/Timeout$Companion;
invoke-virtual {v0}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v6
invoke-virtual {v2}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v8
invoke-virtual {v5, v6, v7, v8, v9}, Lokio/Timeout$Companion;->minTimeout(JJ)J
move-result-wide v5
sget-object v7, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v5, v6, v7}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v2}, Lokio/Timeout;->hasDeadline()Z
move-result v5
if-eqz v5, :cond_a7
invoke-virtual {v2}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v5
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v7
if-eqz v7, :cond_85
invoke-virtual {v2}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v7
invoke-virtual {v0}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v9
invoke-static {v7, v8, v9, v10}, Ljava/lang/Math;->min(JJ)J
move-result-wide v7
invoke-virtual {v2, v7, v8}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_85
:try_start_85
invoke-interface {v1}, Lokio/Sink;->flush()V
:try_end_88
.catchall {:try_start_85 .. :try_end_88} :catchall_97
sget-object v1, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v1}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_d6
invoke-virtual {v2, v5, v6}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
goto :goto_d6
:catchall_97
move-exception v1
sget-object v7, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v7}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_a6
invoke-virtual {v2, v5, v6}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_a6
throw v1
:cond_a7
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v5
if-eqz v5, :cond_b4
invoke-virtual {v0}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v5
invoke-virtual {v2, v5, v6}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_b4
:try_start_b4
invoke-interface {v1}, Lokio/Sink;->flush()V
:try_end_b7
.catchall {:try_start_b4 .. :try_end_b7} :catchall_c6
sget-object v1, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v1}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_d6
invoke-virtual {v2}, Lokio/Timeout;->clearDeadline()Lokio/Timeout;
goto :goto_d6
:catchall_c6
move-exception v1
sget-object v5, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v2, v3, v4, v5}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v0
if-eqz v0, :cond_d5
invoke-virtual {v2}, Lokio/Timeout;->clearDeadline()Lokio/Timeout;
:cond_d5
throw v1
:cond_d6
:goto_d6
return-void
:cond_d7
:try_start_d7
const-string v1, "closed"
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
throw v2
:try_end_e3
.catchall {:try_start_d7 .. :try_end_e3} :catchall_e3
:catchall_e3
move-exception v1
monitor-exit v0
throw v1
.end method
.method public timeout()Lokio/Timeout;
.registers 2
iget-object v0, p0, Lokio/Pipe$sink$1;->timeout:Lokio/Timeout;
return-object v0
.end method
.method public write(Lokio/Buffer;J)V
.registers 16
iget-object v0, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v0}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v0
monitor-enter v0
:try_start_7
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getSinkClosed$okio()Z
move-result v1
xor-int/lit8 v1, v1, 0x1
if-eqz v1, :cond_10f
:goto_11
const-wide/16 v1, 0x0
cmp-long v3, p2, v1
if-lez v3, :cond_73
iget-object v3, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v3}, Lokio/Pipe;->getFoldedSink$okio()Lokio/Sink;
move-result-object v3
if-eqz v3, :cond_20
goto :goto_74
:cond_20
iget-object v3, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v3}, Lokio/Pipe;->getSourceClosed$okio()Z
move-result v3
if-nez v3, :cond_6b
iget-object v3, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v3}, Lokio/Pipe;->getMaxBufferSize$okio()J
move-result-wide v3
iget-object v5, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v5}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v5
invoke-virtual {v5}, Lokio/Buffer;->size()J
move-result-wide v5
sub-long/2addr v3, v5
cmp-long v5, v3, v1
if-nez v5, :cond_49
iget-object v1, p0, Lokio/Pipe$sink$1;->timeout:Lokio/Timeout;
iget-object v2, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v2}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v2
invoke-virtual {v1, v2}, Lokio/Timeout;->waitUntilNotified(Ljava/lang/Object;)V
goto :goto_11
:cond_49
invoke-static {v3, v4, p2, p3}, Ljava/lang/Math;->min(JJ)J
move-result-wide v1
iget-object v3, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v3}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v3
invoke-virtual {v3, p1, v1, v2}, Lokio/Buffer;->write(Lokio/Buffer;J)V
sub-long/2addr p2, v1
iget-object v1, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-virtual {v1}, Lokio/Pipe;->getBuffer$okio()Lokio/Buffer;
move-result-object v1
if-eqz v1, :cond_63
invoke-virtual {v1}, Ljava/lang/Object;->notifyAll()V
goto :goto_11
:cond_63
new-instance p1, Lkotlin/TypeCastException;
const-string p2, "null cannot be cast to non-null type java.lang.Object"
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw p1
:cond_6b
new-instance p1, Ljava/io/IOException;
const-string p2, "source is closed"
invoke-direct {p1, p2}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw p1
:cond_73
const/4 v3, 0x0
:goto_74
sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
:try_end_76
.catchall {:try_start_7 .. :try_end_76} :catchall_11b
monitor-exit v0
if-eqz v3, :cond_10e
iget-object v0, p0, Lokio/Pipe$sink$1;->this$0:Lokio/Pipe;
invoke-interface {v3}, Lokio/Sink;->timeout()Lokio/Timeout;
move-result-object v1
invoke-virtual {v0}, Lokio/Pipe;->sink()Lokio/Sink;
move-result-object v0
invoke-interface {v0}, Lokio/Sink;->timeout()Lokio/Timeout;
move-result-object v0
invoke-virtual {v1}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v4
sget-object v2, Lokio/Timeout;->Companion:Lokio/Timeout$Companion;
invoke-virtual {v0}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v6
invoke-virtual {v1}, Lokio/Timeout;->timeoutNanos()J
move-result-wide v8
invoke-virtual {v2, v6, v7, v8, v9}, Lokio/Timeout$Companion;->minTimeout(JJ)J
move-result-wide v6
sget-object v2, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v1, v6, v7, v2}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v1}, Lokio/Timeout;->hasDeadline()Z
move-result v2
if-eqz v2, :cond_df
invoke-virtual {v1}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v6
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v2
if-eqz v2, :cond_bd
invoke-virtual {v1}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v8
invoke-virtual {v0}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v10
invoke-static {v8, v9, v10, v11}, Ljava/lang/Math;->min(JJ)J
move-result-wide v8
invoke-virtual {v1, v8, v9}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_bd
:try_start_bd
invoke-interface {v3, p1, p2, p3}, Lokio/Sink;->write(Lokio/Buffer;J)V
:try_end_c0
.catchall {:try_start_bd .. :try_end_c0} :catchall_cf
sget-object p1, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v1, v4, v5, p1}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result p1
if-eqz p1, :cond_10e
invoke-virtual {v1, v6, v7}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
goto :goto_10e
:catchall_cf
move-exception p1
sget-object p2, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v1, v4, v5, p2}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result p2
if-eqz p2, :cond_de
invoke-virtual {v1, v6, v7}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_de
throw p1
:cond_df
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result v2
if-eqz v2, :cond_ec
invoke-virtual {v0}, Lokio/Timeout;->deadlineNanoTime()J
move-result-wide v6
invoke-virtual {v1, v6, v7}, Lokio/Timeout;->deadlineNanoTime(J)Lokio/Timeout;
:cond_ec
:try_start_ec
invoke-interface {v3, p1, p2, p3}, Lokio/Sink;->write(Lokio/Buffer;J)V
:try_end_ef
.catchall {:try_start_ec .. :try_end_ef} :catchall_fe
sget-object p1, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v1, v4, v5, p1}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result p1
if-eqz p1, :cond_10e
invoke-virtual {v1}, Lokio/Timeout;->clearDeadline()Lokio/Timeout;
goto :goto_10e
:catchall_fe
move-exception p1
sget-object p2, Ljava/util/concurrent/TimeUnit;->NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invoke-virtual {v1, v4, v5, p2}, Lokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout;
invoke-virtual {v0}, Lokio/Timeout;->hasDeadline()Z
move-result p2
if-eqz p2, :cond_10d
invoke-virtual {v1}, Lokio/Timeout;->clearDeadline()Lokio/Timeout;
:cond_10d
throw p1
:cond_10e
:goto_10e
return-void
:cond_10f
:try_start_10f
const-string p1, "closed"
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
throw p2
:try_end_11b
.catchall {:try_start_10f .. :try_end_11b} :catchall_11b
:catchall_11b
move-exception p1
monitor-exit v0
goto :goto_11f
:goto_11e
throw p1
:goto_11f
goto :goto_11e
.end method