Http2Stream.smali
.class public final Lokhttp3/internal/http2/Http2Stream;
.super Ljava/lang/Object;
.source "SourceFile"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lokhttp3/internal/http2/Http2Stream$StreamTimeout;,
Lokhttp3/internal/http2/Http2Stream$FramingSource;,
Lokhttp3/internal/http2/Http2Stream$FramingSink;
}
.end annotation
# static fields
.field public static final synthetic $assertionsDisabled:Z
# instance fields
.field public bytesLeftInWriteWindow:J
.field public final connection:Lokhttp3/internal/http2/Http2Connection;
.field public errorCode:Lokhttp3/internal/http2/ErrorCode;
.field private hasResponseHeaders:Z
.field private headersListener:Lokhttp3/internal/http2/Header$Listener;
.field private final headersQueue:Ljava/util/Deque;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Deque<",
"Lokhttp3/Headers;",
">;"
}
.end annotation
.end field
.field public final id:I
.field public final readTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
.field public final sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
.field private final source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
.field public unacknowledgedBytesRead:J
.field public final writeTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
# direct methods
.method public constructor <init>(ILokhttp3/internal/http2/Http2Connection;ZZLokhttp3/Headers;)V
.registers 9
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
const-wide/16 v0, 0x0
.line 2
iput-wide v0, p0, Lokhttp3/internal/http2/Http2Stream;->unacknowledgedBytesRead:J
.line 3
new-instance v0, Ljava/util/ArrayDeque;
invoke-direct {v0}, Ljava/util/ArrayDeque;-><init>()V
iput-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->headersQueue:Ljava/util/Deque;
.line 4
new-instance v1, Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
invoke-direct {v1, p0}, Lokhttp3/internal/http2/Http2Stream$StreamTimeout;-><init>(Lokhttp3/internal/http2/Http2Stream;)V
iput-object v1, p0, Lokhttp3/internal/http2/Http2Stream;->readTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
.line 5
new-instance v1, Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
invoke-direct {v1, p0}, Lokhttp3/internal/http2/Http2Stream$StreamTimeout;-><init>(Lokhttp3/internal/http2/Http2Stream;)V
iput-object v1, p0, Lokhttp3/internal/http2/Http2Stream;->writeTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
const/4 v1, 0x0
.line 6
iput-object v1, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
const-string v1, "connection == null"
.line 7
invoke-static {p2, v1}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 8
iput p1, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
.line 9
iput-object p2, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
.line 10
iget-object p1, p2, Lokhttp3/internal/http2/Http2Connection;->peerSettings:Lokhttp3/internal/http2/Settings;
.line 11
invoke-virtual {p1}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I
move-result p1
int-to-long v1, p1
iput-wide v1, p0, Lokhttp3/internal/http2/Http2Stream;->bytesLeftInWriteWindow:J
.line 12
new-instance p1, Lokhttp3/internal/http2/Http2Stream$FramingSource;
iget-object p2, p2, Lokhttp3/internal/http2/Http2Connection;->okHttpSettings:Lokhttp3/internal/http2/Settings;
invoke-virtual {p2}, Lokhttp3/internal/http2/Settings;->getInitialWindowSize()I
move-result p2
int-to-long v1, p2
invoke-direct {p1, p0, v1, v2}, Lokhttp3/internal/http2/Http2Stream$FramingSource;-><init>(Lokhttp3/internal/http2/Http2Stream;J)V
iput-object p1, p0, Lokhttp3/internal/http2/Http2Stream;->source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
.line 13
new-instance p2, Lokhttp3/internal/http2/Http2Stream$FramingSink;
invoke-direct {p2, p0}, Lokhttp3/internal/http2/Http2Stream$FramingSink;-><init>(Lokhttp3/internal/http2/Http2Stream;)V
iput-object p2, p0, Lokhttp3/internal/http2/Http2Stream;->sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
.line 14
iput-boolean p4, p1, Lokhttp3/internal/http2/Http2Stream$FramingSource;->finished:Z
.line 15
iput-boolean p3, p2, Lokhttp3/internal/http2/Http2Stream$FramingSink;->finished:Z
if-eqz p5, :cond_4f
.line 16
invoke-interface {v0, p5}, Ljava/util/Deque;->add(Ljava/lang/Object;)Z
.line 17
:cond_4f
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Stream;->isLocallyInitiated()Z
move-result p1
if-eqz p1, :cond_60
if-nez p5, :cond_58
goto :goto_60
.line 18
:cond_58
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "locally-initiated streams shouldn\'t have headers yet"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
.line 19
:cond_60
:goto_60
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Stream;->isLocallyInitiated()Z
move-result p1
if-nez p1, :cond_71
if-eqz p5, :cond_69
goto :goto_71
.line 20
:cond_69
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "remotely-initiated streams should have headers"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_71
:goto_71
return-void
.end method
.method public static synthetic access$000(Lokhttp3/internal/http2/Http2Stream;)Ljava/util/Deque;
.registers 1
iget-object p0, p0, Lokhttp3/internal/http2/Http2Stream;->headersQueue:Ljava/util/Deque;
return-object p0
.end method
.method public static synthetic access$100(Lokhttp3/internal/http2/Http2Stream;)Lokhttp3/internal/http2/Header$Listener;
.registers 1
iget-object p0, p0, Lokhttp3/internal/http2/Http2Stream;->headersListener:Lokhttp3/internal/http2/Header$Listener;
return-object p0
.end method
.method private closeInternal(Lokhttp3/internal/http2/ErrorCode;)Z
.registers 4
.line 1
monitor-enter p0
.line 2
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
const/4 v1, 0x0
if-eqz v0, :cond_8
.line 3
monitor-exit p0
return v1
.line 4
:cond_8
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
iget-boolean v0, v0, Lokhttp3/internal/http2/Http2Stream$FramingSource;->finished:Z
if-eqz v0, :cond_16
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
iget-boolean v0, v0, Lokhttp3/internal/http2/Http2Stream$FramingSink;->finished:Z
if-eqz v0, :cond_16
.line 5
monitor-exit p0
return v1
.line 6
:cond_16
iput-object p1, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
.line 7
invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V
.line 8
monitor-exit p0
:try_end_1c
.catchall {:try_start_1 .. :try_end_1c} :catchall_25
.line 9
iget-object p1, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget v0, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
invoke-virtual {p1, v0}, Lokhttp3/internal/http2/Http2Connection;->removeStream(I)Lokhttp3/internal/http2/Http2Stream;
const/4 p1, 0x1
return p1
:catchall_25
move-exception p1
.line 10
:try_start_26
monitor-exit p0
:try_end_27
.catchall {:try_start_26 .. :try_end_27} :catchall_25
throw p1
.end method
# virtual methods
.method public addBytesToWriteWindow(J)V
.registers 6
.line 1
iget-wide v0, p0, Lokhttp3/internal/http2/Http2Stream;->bytesLeftInWriteWindow:J
add-long/2addr v0, p1
iput-wide v0, p0, Lokhttp3/internal/http2/Http2Stream;->bytesLeftInWriteWindow:J
const-wide/16 v0, 0x0
cmp-long v2, p1, v0
if-lez v2, :cond_e
.line 2
invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V
:cond_e
return-void
.end method
.method public cancelStreamIfNecessary()V
.registers 3
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
.line 1
monitor-enter p0
.line 2
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
iget-boolean v1, v0, Lokhttp3/internal/http2/Http2Stream$FramingSource;->finished:Z
if-nez v1, :cond_17
iget-boolean v0, v0, Lokhttp3/internal/http2/Http2Stream$FramingSource;->closed:Z
if-eqz v0, :cond_17
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
iget-boolean v1, v0, Lokhttp3/internal/http2/Http2Stream$FramingSink;->finished:Z
if-nez v1, :cond_15
iget-boolean v0, v0, Lokhttp3/internal/http2/Http2Stream$FramingSink;->closed:Z
if-eqz v0, :cond_17
:cond_15
const/4 v0, 0x1
goto :goto_18
:cond_17
const/4 v0, 0x0
.line 3
:goto_18
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Stream;->isOpen()Z
move-result v1
.line 4
monitor-exit p0
:try_end_1d
.catchall {:try_start_1 .. :try_end_1d} :catchall_2f
if-eqz v0, :cond_25
.line 5
sget-object v0, Lokhttp3/internal/http2/ErrorCode;->CANCEL:Lokhttp3/internal/http2/ErrorCode;
invoke-virtual {p0, v0}, Lokhttp3/internal/http2/Http2Stream;->close(Lokhttp3/internal/http2/ErrorCode;)V
goto :goto_2e
:cond_25
if-nez v1, :cond_2e
.line 6
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget v1, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
invoke-virtual {v0, v1}, Lokhttp3/internal/http2/Http2Connection;->removeStream(I)Lokhttp3/internal/http2/Http2Stream;
:cond_2e
:goto_2e
return-void
:catchall_2f
move-exception v0
.line 7
:try_start_30
monitor-exit p0
:try_end_31
.catchall {:try_start_30 .. :try_end_31} :catchall_2f
throw v0
.end method
.method public checkOutNotClosed()V
.registers 3
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
.line 1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
iget-boolean v1, v0, Lokhttp3/internal/http2/Http2Stream$FramingSink;->closed:Z
if-nez v1, :cond_1f
.line 2
iget-boolean v0, v0, Lokhttp3/internal/http2/Http2Stream$FramingSink;->finished:Z
if-nez v0, :cond_17
.line 3
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
if-nez v0, :cond_f
return-void
.line 4
:cond_f
new-instance v0, Lokhttp3/internal/http2/StreamResetException;
iget-object v1, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
invoke-direct {v0, v1}, Lokhttp3/internal/http2/StreamResetException;-><init>(Lokhttp3/internal/http2/ErrorCode;)V
throw v0
.line 5
:cond_17
new-instance v0, Ljava/io/IOException;
const-string v1, "stream finished"
invoke-direct {v0, v1}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw v0
.line 6
:cond_1f
new-instance v0, Ljava/io/IOException;
const-string v1, "stream closed"
invoke-direct {v0, v1}, Ljava/io/IOException;-><init>(Ljava/lang/String;)V
throw v0
.end method
.method public close(Lokhttp3/internal/http2/ErrorCode;)V
.registers 4
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
.line 1
invoke-direct {p0, p1}, Lokhttp3/internal/http2/Http2Stream;->closeInternal(Lokhttp3/internal/http2/ErrorCode;)Z
move-result v0
if-nez v0, :cond_7
return-void
.line 2
:cond_7
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget v1, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
invoke-virtual {v0, v1, p1}, Lokhttp3/internal/http2/Http2Connection;->writeSynReset(ILokhttp3/internal/http2/ErrorCode;)V
return-void
.end method
.method public closeLater(Lokhttp3/internal/http2/ErrorCode;)V
.registers 4
.line 1
invoke-direct {p0, p1}, Lokhttp3/internal/http2/Http2Stream;->closeInternal(Lokhttp3/internal/http2/ErrorCode;)Z
move-result v0
if-nez v0, :cond_7
return-void
.line 2
:cond_7
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget v1, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
invoke-virtual {v0, v1, p1}, Lokhttp3/internal/http2/Http2Connection;->writeSynResetLater(ILokhttp3/internal/http2/ErrorCode;)V
return-void
.end method
.method public getConnection()Lokhttp3/internal/http2/Http2Connection;
.registers 2
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
return-object v0
.end method
.method public declared-synchronized getErrorCode()Lokhttp3/internal/http2/ErrorCode;
.registers 2
monitor-enter p0
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return-object v0
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method public getId()I
.registers 2
iget v0, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
return v0
.end method
.method public getSink()Lokio/v;
.registers 3
.line 1
monitor-enter p0
.line 2
:try_start_1
iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Stream;->hasResponseHeaders:Z
if-nez v0, :cond_14
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Stream;->isLocallyInitiated()Z
move-result v0
if-eqz v0, :cond_c
goto :goto_14
.line 3
:cond_c
new-instance v0, Ljava/lang/IllegalStateException;
const-string v1, "reply before requesting the sink"
invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v0
.line 4
:cond_14
:goto_14
monitor-exit p0
:try_end_15
.catchall {:try_start_1 .. :try_end_15} :catchall_18
.line 5
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
return-object v0
:catchall_18
move-exception v0
.line 6
:try_start_19
monitor-exit p0
:try_end_1a
.catchall {:try_start_19 .. :try_end_1a} :catchall_18
throw v0
.end method
.method public getSource()Lokio/w;
.registers 2
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
return-object v0
.end method
.method public isLocallyInitiated()Z
.registers 5
.line 1
iget v0, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
const/4 v1, 0x1
and-int/2addr v0, v1
const/4 v2, 0x0
if-ne v0, v1, :cond_9
const/4 v0, 0x1
goto :goto_a
:cond_9
const/4 v0, 0x0
.line 2
:goto_a
iget-object v3, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget-boolean v3, v3, Lokhttp3/internal/http2/Http2Connection;->client:Z
if-ne v3, v0, :cond_11
goto :goto_12
:cond_11
const/4 v1, 0x0
:goto_12
return v1
.end method
.method public declared-synchronized isOpen()Z
.registers 4
monitor-enter p0
.line 1
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_25
const/4 v1, 0x0
if-eqz v0, :cond_8
.line 2
monitor-exit p0
return v1
.line 3
:cond_8
:try_start_8
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
iget-boolean v2, v0, Lokhttp3/internal/http2/Http2Stream$FramingSource;->finished:Z
if-nez v2, :cond_12
iget-boolean v0, v0, Lokhttp3/internal/http2/Http2Stream$FramingSource;->closed:Z
if-eqz v0, :cond_22
:cond_12
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
iget-boolean v2, v0, Lokhttp3/internal/http2/Http2Stream$FramingSink;->finished:Z
if-nez v2, :cond_1c
iget-boolean v0, v0, Lokhttp3/internal/http2/Http2Stream$FramingSink;->closed:Z
if-eqz v0, :cond_22
:cond_1c
iget-boolean v0, p0, Lokhttp3/internal/http2/Http2Stream;->hasResponseHeaders:Z
:try_end_1e
.catchall {:try_start_8 .. :try_end_1e} :catchall_25
if-eqz v0, :cond_22
.line 4
monitor-exit p0
return v1
:cond_22
const/4 v0, 0x1
.line 5
monitor-exit p0
return v0
:catchall_25
move-exception v0
monitor-exit p0
throw v0
.end method
.method public readTimeout()Lokio/x;
.registers 2
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->readTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
return-object v0
.end method
.method public receiveData(Lokio/d;I)V
.registers 6
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
int-to-long v1, p2
invoke-virtual {v0, p1, v1, v2}, Lokhttp3/internal/http2/Http2Stream$FramingSource;->receive(Lokio/d;J)V
return-void
.end method
.method public receiveFin()V
.registers 3
.line 1
monitor-enter p0
.line 2
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->source:Lokhttp3/internal/http2/Http2Stream$FramingSource;
const/4 v1, 0x1
iput-boolean v1, v0, Lokhttp3/internal/http2/Http2Stream$FramingSource;->finished:Z
.line 3
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Stream;->isOpen()Z
move-result v0
.line 4
invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V
.line 5
monitor-exit p0
:try_end_e
.catchall {:try_start_1 .. :try_end_e} :catchall_18
if-nez v0, :cond_17
.line 6
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget v1, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
invoke-virtual {v0, v1}, Lokhttp3/internal/http2/Http2Connection;->removeStream(I)Lokhttp3/internal/http2/Http2Stream;
:cond_17
return-void
:catchall_18
move-exception v0
.line 7
:try_start_19
monitor-exit p0
:try_end_1a
.catchall {:try_start_19 .. :try_end_1a} :catchall_18
throw v0
.end method
.method public receiveHeaders(Ljava/util/List;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;)V"
}
.end annotation
.line 1
monitor-enter p0
const/4 v0, 0x1
.line 2
:try_start_2
iput-boolean v0, p0, Lokhttp3/internal/http2/Http2Stream;->hasResponseHeaders:Z
.line 3
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->headersQueue:Ljava/util/Deque;
invoke-static {p1}, Lokhttp3/internal/Util;->toHeaders(Ljava/util/List;)Lokhttp3/Headers;
move-result-object p1
invoke-interface {v0, p1}, Ljava/util/Deque;->add(Ljava/lang/Object;)Z
.line 4
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Stream;->isOpen()Z
move-result p1
.line 5
invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V
.line 6
monitor-exit p0
:try_end_15
.catchall {:try_start_2 .. :try_end_15} :catchall_1f
if-nez p1, :cond_1e
.line 7
iget-object p1, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget v0, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
invoke-virtual {p1, v0}, Lokhttp3/internal/http2/Http2Connection;->removeStream(I)Lokhttp3/internal/http2/Http2Stream;
:cond_1e
return-void
:catchall_1f
move-exception p1
.line 8
:try_start_20
monitor-exit p0
:try_end_21
.catchall {:try_start_20 .. :try_end_21} :catchall_1f
throw p1
.end method
.method public declared-synchronized receiveRstStream(Lokhttp3/internal/http2/ErrorCode;)V
.registers 3
monitor-enter p0
.line 1
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
if-nez v0, :cond_a
.line 2
iput-object p1, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
.line 3
invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V
:try_end_a
.catchall {:try_start_1 .. :try_end_a} :catchall_c
.line 4
:cond_a
monitor-exit p0
return-void
:catchall_c
move-exception p1
monitor-exit p0
throw p1
.end method
.method public declared-synchronized setHeadersListener(Lokhttp3/internal/http2/Header$Listener;)V
.registers 3
monitor-enter p0
.line 1
:try_start_1
iput-object p1, p0, Lokhttp3/internal/http2/Http2Stream;->headersListener:Lokhttp3/internal/http2/Header$Listener;
.line 2
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->headersQueue:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Collection;->isEmpty()Z
move-result v0
if-nez v0, :cond_10
if-eqz p1, :cond_10
.line 3
invoke-virtual {p0}, Ljava/lang/Object;->notifyAll()V
:try_end_10
.catchall {:try_start_1 .. :try_end_10} :catchall_12
.line 4
:cond_10
monitor-exit p0
return-void
:catchall_12
move-exception p1
monitor-exit p0
throw p1
.end method
.method public declared-synchronized takeHeaders()Lokhttp3/Headers;
.registers 3
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
monitor-enter p0
.line 1
:try_start_1
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->readTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
invoke-virtual {v0}, Lokio/a;->enter()V
:try_end_6
.catchall {:try_start_1 .. :try_end_6} :catchall_3c
.line 2
:goto_6
:try_start_6
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->headersQueue:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Collection;->isEmpty()Z
move-result v0
if-eqz v0, :cond_16
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
if-nez v0, :cond_16
.line 3
invoke-virtual {p0}, Lokhttp3/internal/http2/Http2Stream;->waitForIo()V
:try_end_15
.catchall {:try_start_6 .. :try_end_15} :catchall_35
goto :goto_6
.line 4
:cond_16
:try_start_16
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->readTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
invoke-virtual {v0}, Lokhttp3/internal/http2/Http2Stream$StreamTimeout;->exitAndThrowIfTimedOut()V
.line 5
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->headersQueue:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Collection;->isEmpty()Z
move-result v0
if-nez v0, :cond_2d
.line 6
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->headersQueue:Ljava/util/Deque;
invoke-interface {v0}, Ljava/util/Deque;->removeFirst()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lokhttp3/Headers;
:try_end_2b
.catchall {:try_start_16 .. :try_end_2b} :catchall_3c
monitor-exit p0
return-object v0
.line 7
:cond_2d
:try_start_2d
new-instance v0, Lokhttp3/internal/http2/StreamResetException;
iget-object v1, p0, Lokhttp3/internal/http2/Http2Stream;->errorCode:Lokhttp3/internal/http2/ErrorCode;
invoke-direct {v0, v1}, Lokhttp3/internal/http2/StreamResetException;-><init>(Lokhttp3/internal/http2/ErrorCode;)V
throw v0
:catchall_35
move-exception v0
.line 8
iget-object v1, p0, Lokhttp3/internal/http2/Http2Stream;->readTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
invoke-virtual {v1}, Lokhttp3/internal/http2/Http2Stream$StreamTimeout;->exitAndThrowIfTimedOut()V
.line 9
throw v0
:try_end_3c
.catchall {:try_start_2d .. :try_end_3c} :catchall_3c
:catchall_3c
move-exception v0
monitor-exit p0
throw v0
.end method
.method public waitForIo()V
.registers 2
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/InterruptedIOException;
}
.end annotation
.line 1
:try_start_0
invoke-virtual {p0}, Ljava/lang/Object;->wait()V
:try_end_3
.catch Ljava/lang/InterruptedException; {:try_start_0 .. :try_end_3} :catch_4
return-void
.line 2
:catch_4
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object v0
invoke-virtual {v0}, Ljava/lang/Thread;->interrupt()V
.line 3
new-instance v0, Ljava/io/InterruptedIOException;
invoke-direct {v0}, Ljava/io/InterruptedIOException;-><init>()V
throw v0
.end method
.method public writeHeaders(Ljava/util/List;Z)V
.registers 11
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"Lokhttp3/internal/http2/Header;",
">;Z)V"
}
.end annotation
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/io/IOException;
}
.end annotation
const-string v0, "headers == null"
.line 1
invoke-static {p1, v0}, Ljava/util/Objects;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 2
monitor-enter p0
const/4 v0, 0x1
.line 3
:try_start_7
iput-boolean v0, p0, Lokhttp3/internal/http2/Http2Stream;->hasResponseHeaders:Z
const/4 v1, 0x0
if-nez p2, :cond_13
.line 4
iget-object p2, p0, Lokhttp3/internal/http2/Http2Stream;->sink:Lokhttp3/internal/http2/Http2Stream$FramingSink;
iput-boolean v0, p2, Lokhttp3/internal/http2/Http2Stream$FramingSink;->finished:Z
const/4 p2, 0x1
const/4 v2, 0x1
goto :goto_15
:cond_13
const/4 p2, 0x0
const/4 v2, 0x0
.line 5
:goto_15
monitor-exit p0
:try_end_16
.catchall {:try_start_7 .. :try_end_16} :catchall_3c
if-nez p2, :cond_2d
.line 6
iget-object v3, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
monitor-enter v3
.line 7
:try_start_1b
iget-object p2, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget-wide v4, p2, Lokhttp3/internal/http2/Http2Connection;->bytesLeftInWriteWindow:J
const-wide/16 v6, 0x0
cmp-long p2, v4, v6
if-nez p2, :cond_26
goto :goto_27
:cond_26
const/4 v0, 0x0
.line 8
:goto_27
monitor-exit v3
move p2, v0
goto :goto_2d
:catchall_2a
move-exception p1
monitor-exit v3
:try_end_2c
.catchall {:try_start_1b .. :try_end_2c} :catchall_2a
throw p1
.line 9
:cond_2d
:goto_2d
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
iget v1, p0, Lokhttp3/internal/http2/Http2Stream;->id:I
invoke-virtual {v0, v1, v2, p1}, Lokhttp3/internal/http2/Http2Connection;->writeSynReply(IZLjava/util/List;)V
if-eqz p2, :cond_3b
.line 10
iget-object p1, p0, Lokhttp3/internal/http2/Http2Stream;->connection:Lokhttp3/internal/http2/Http2Connection;
invoke-virtual {p1}, Lokhttp3/internal/http2/Http2Connection;->flush()V
:cond_3b
return-void
:catchall_3c
move-exception p1
.line 11
:try_start_3d
monitor-exit p0
:try_end_3e
.catchall {:try_start_3d .. :try_end_3e} :catchall_3c
throw p1
.end method
.method public writeTimeout()Lokio/x;
.registers 2
iget-object v0, p0, Lokhttp3/internal/http2/Http2Stream;->writeTimeout:Lokhttp3/internal/http2/Http2Stream$StreamTimeout;
return-object v0
.end method