InProcessTransport$InProcessStream$InProcessClientStream.smali
.class Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;
.super Ljava/lang/Object;
.source "InProcessTransport.java"
# interfaces
.implements Lio/grpc/internal/ClientStream;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/grpc/inprocess/InProcessTransport$InProcessStream;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x2
name = "InProcessClientStream"
.end annotation
# instance fields
.field private closed:Z
.field private serverNotifyHalfClose:Z
.field private serverReceiveQueue:Ljava/util/ArrayDeque;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/ArrayDeque<",
"Ljava/io/InputStream;",
">;"
}
.end annotation
.end field
.field private serverRequested:I
.field private serverStreamListener:Lio/grpc/internal/ServerStreamListener;
.field final synthetic this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# direct methods
.method private constructor <init>(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)V
.registers 2
.line 1
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
new-instance p1, Ljava/util/ArrayDeque;
invoke-direct {p1}, Ljava/util/ArrayDeque;-><init>()V
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverReceiveQueue:Ljava/util/ArrayDeque;
return-void
.end method
.method synthetic constructor <init>(Lio/grpc/inprocess/InProcessTransport$InProcessStream;Lio/grpc/inprocess/InProcessTransport$1;)V
.registers 3
.line 3
invoke-direct {p0, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;-><init>(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)V
return-void
.end method
.method static synthetic access$1100(Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;Lio/grpc/Status;)V
.registers 2
.line 1
invoke-direct {p0, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverClosed(Lio/grpc/Status;)V
return-void
.end method
.method static synthetic access$900(Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;I)Z
.registers 2
.line 1
invoke-direct {p0, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested(I)Z
move-result p0
return p0
.end method
.method private declared-synchronized internalCancel(Lio/grpc/Status;)Z
.registers 7
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->closed:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_2d
if-eqz v0, :cond_8
const/4 p1, 0x0
.line 2
monitor-exit p0
return p1
:cond_8
const/4 v0, 0x1
.line 3
:try_start_9
iput-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->closed:Z
.line 4
:goto_b
iget-object v1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverReceiveQueue:Ljava/util/ArrayDeque;
invoke-virtual {v1}, Ljava/util/ArrayDeque;->poll()Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/io/InputStream;
:try_end_13
.catchall {:try_start_9 .. :try_end_13} :catchall_2d
if-eqz v1, :cond_26
.line 5
:try_start_15
invoke-virtual {v1}, Ljava/io/InputStream;->close()V
:try_end_18
.catch Ljava/lang/Throwable; {:try_start_15 .. :try_end_18} :catch_19
.catchall {:try_start_15 .. :try_end_18} :catchall_2d
goto :goto_b
:catch_19
move-exception v1
.line 6
:try_start_1a
# getter for: Lio/grpc/inprocess/InProcessTransport;->log:Ljava/util/logging/Logger;
invoke-static {}, Lio/grpc/inprocess/InProcessTransport;->access$1300()Ljava/util/logging/Logger;
move-result-object v2
sget-object v3, Ljava/util/logging/Level;->WARNING:Ljava/util/logging/Level;
const-string v4, "Exception closing stream"
invoke-virtual {v2, v3, v4, v1}, Ljava/util/logging/Logger;->log(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
goto :goto_b
.line 7
:cond_26
iget-object v1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverStreamListener:Lio/grpc/internal/ServerStreamListener;
invoke-interface {v1, p1}, Lio/grpc/internal/ServerStreamListener;->closed(Lio/grpc/Status;)V
:try_end_2b
.catchall {:try_start_1a .. :try_end_2b} :catchall_2d
.line 8
monitor-exit p0
return v0
:catchall_2d
move-exception p1
monitor-exit p0
goto :goto_31
:goto_30
throw p1
:goto_31
goto :goto_30
.end method
.method private serverClosed(Lio/grpc/Status;)V
.registers 2
.line 1
invoke-direct {p0, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->internalCancel(Lio/grpc/Status;)Z
return-void
.end method
.method private declared-synchronized serverRequested(I)Z
.registers 6
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->closed:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_55
const/4 v1, 0x0
if-eqz v0, :cond_8
.line 2
monitor-exit p0
return v1
.line 3
:cond_8
:try_start_8
iget v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
const/4 v2, 0x1
if-lez v0, :cond_f
const/4 v0, 0x1
goto :goto_10
:cond_f
const/4 v0, 0x0
.line 4
:goto_10
iget v3, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
add-int/2addr v3, p1
iput v3, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
.line 5
:goto_15
iget p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
if-lez p1, :cond_34
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverReceiveQueue:Ljava/util/ArrayDeque;
invoke-virtual {p1}, Ljava/util/ArrayDeque;->isEmpty()Z
move-result p1
if-nez p1, :cond_34
.line 6
iget p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
sub-int/2addr p1, v2
iput p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
.line 7
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverStreamListener:Lio/grpc/internal/ServerStreamListener;
iget-object v3, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverReceiveQueue:Ljava/util/ArrayDeque;
invoke-virtual {v3}, Ljava/util/ArrayDeque;->poll()Ljava/lang/Object;
move-result-object v3
check-cast v3, Ljava/io/InputStream;
invoke-interface {p1, v3}, Lio/grpc/internal/StreamListener;->messageRead(Ljava/io/InputStream;)V
goto :goto_15
.line 8
:cond_34
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverReceiveQueue:Ljava/util/ArrayDeque;
invoke-virtual {p1}, Ljava/util/ArrayDeque;->isEmpty()Z
move-result p1
if-eqz p1, :cond_47
iget-boolean p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverNotifyHalfClose:Z
if-eqz p1, :cond_47
.line 9
iput-boolean v1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverNotifyHalfClose:Z
.line 10
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverStreamListener:Lio/grpc/internal/ServerStreamListener;
invoke-interface {p1}, Lio/grpc/internal/ServerStreamListener;->halfClosed()V
.line 11
:cond_47
iget p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
:try_end_49
.catchall {:try_start_8 .. :try_end_49} :catchall_55
if-lez p1, :cond_4d
const/4 p1, 0x1
goto :goto_4e
:cond_4d
const/4 p1, 0x0
:goto_4e
if-nez v0, :cond_53
if-eqz p1, :cond_53
const/4 v1, 0x1
.line 12
:cond_53
monitor-exit p0
return v1
:catchall_55
move-exception p1
monitor-exit p0
goto :goto_59
:goto_58
throw p1
:goto_59
goto :goto_58
.end method
.method private declared-synchronized setListener(Lio/grpc/internal/ServerStreamListener;)V
.registers 2
monitor-enter p0
.line 1
:try_start_1
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverStreamListener:Lio/grpc/internal/ServerStreamListener;
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
.line 2
monitor-exit p0
return-void
:catchall_5
move-exception p1
monitor-exit p0
throw p1
.end method
# virtual methods
.method public cancel(Lio/grpc/Status;)V
.registers 3
.line 1
# invokes: Lio/grpc/inprocess/InProcessTransport;->stripCause(Lio/grpc/Status;)Lio/grpc/Status;
invoke-static {p1}, Lio/grpc/inprocess/InProcessTransport;->access$1000(Lio/grpc/Status;)Lio/grpc/Status;
move-result-object v0
invoke-direct {p0, v0}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->internalCancel(Lio/grpc/Status;)Z
move-result v0
if-nez v0, :cond_b
return-void
.line 2
:cond_b
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->serverStream:Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
invoke-static {v0}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$1500(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
move-result-object v0
# invokes: Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;->clientCancelled(Lio/grpc/Status;)V
invoke-static {v0, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;->access$1700(Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;Lio/grpc/Status;)V
.line 3
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# invokes: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->streamClosed()V
invoke-static {p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$1200(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)V
return-void
.end method
.method public flush()V
.registers 1
return-void
.end method
.method public declared-synchronized halfClose()V
.registers 2
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->closed:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_1a
if-eqz v0, :cond_7
.line 2
monitor-exit p0
return-void
.line 3
:cond_7
:try_start_7
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverReceiveQueue:Ljava/util/ArrayDeque;
invoke-virtual {v0}, Ljava/util/ArrayDeque;->isEmpty()Z
move-result v0
if-eqz v0, :cond_15
.line 4
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverStreamListener:Lio/grpc/internal/ServerStreamListener;
invoke-interface {v0}, Lio/grpc/internal/ServerStreamListener;->halfClosed()V
goto :goto_18
:cond_15
const/4 v0, 0x1
.line 5
iput-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverNotifyHalfClose:Z
:try_end_18
.catchall {:try_start_7 .. :try_end_18} :catchall_1a
.line 6
:goto_18
monitor-exit p0
return-void
:catchall_1a
move-exception v0
monitor-exit p0
throw v0
.end method
.method public declared-synchronized isReady()Z
.registers 3
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->closed:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_f
const/4 v1, 0x0
if-eqz v0, :cond_8
.line 2
monitor-exit p0
return v1
.line 3
:cond_8
:try_start_8
iget v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
:try_end_a
.catchall {:try_start_8 .. :try_end_a} :catchall_f
if-lez v0, :cond_d
const/4 v1, 0x1
:cond_d
monitor-exit p0
return v1
:catchall_f
move-exception v0
monitor-exit p0
throw v0
.end method
.method public request(I)V
.registers 3
.line 1
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->serverStream:Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
invoke-static {v0}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$1500(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
move-result-object v0
# invokes: Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;->clientRequested(I)Z
invoke-static {v0, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;->access$1600(Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;I)Z
move-result p1
if-eqz p1, :cond_1b
.line 2
monitor-enter p0
.line 3
:try_start_d
iget-boolean p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->closed:Z
if-nez p1, :cond_16
.line 4
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverStreamListener:Lio/grpc/internal/ServerStreamListener;
invoke-interface {p1}, Lio/grpc/internal/StreamListener;->onReady()V
.line 5
:cond_16
monitor-exit p0
goto :goto_1b
:catchall_18
move-exception p1
monitor-exit p0
:try_end_1a
.catchall {:try_start_d .. :try_end_1a} :catchall_18
throw p1
:cond_1b
:goto_1b
return-void
.end method
.method public setAuthority(Ljava/lang/String;)V
.registers 2
return-void
.end method
.method public setCompressor(Lio/grpc/Compressor;)V
.registers 2
return-void
.end method
.method public setDecompressor(Lio/grpc/Decompressor;)V
.registers 2
return-void
.end method
.method public setMessageCompression(Z)V
.registers 2
return-void
.end method
.method public start(Lio/grpc/internal/ClientStreamListener;)V
.registers 6
.line 1
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->serverStream:Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
invoke-static {v0}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$1500(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
move-result-object v0
# invokes: Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;->setListener(Lio/grpc/internal/ClientStreamListener;)V
invoke-static {v0, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;->access$1800(Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;Lio/grpc/internal/ClientStreamListener;)V
.line 2
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
iget-object p1, p1, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->this$0:Lio/grpc/inprocess/InProcessTransport;
monitor-enter p1
.line 3
:try_start_e
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
iget-object v0, v0, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->this$0:Lio/grpc/inprocess/InProcessTransport;
# getter for: Lio/grpc/inprocess/InProcessTransport;->serverTransportListener:Lio/grpc/internal/ServerTransportListener;
invoke-static {v0}, Lio/grpc/inprocess/InProcessTransport;->access$2100(Lio/grpc/inprocess/InProcessTransport;)Lio/grpc/internal/ServerTransportListener;
move-result-object v0
iget-object v1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
.line 4
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->serverStream:Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
invoke-static {v1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$1500(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessServerStream;
move-result-object v1
iget-object v2, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->method:Lio/grpc/MethodDescriptor;
invoke-static {v2}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$1900(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/MethodDescriptor;
move-result-object v2
invoke-virtual {v2}, Lio/grpc/MethodDescriptor;->getFullMethodName()Ljava/lang/String;
move-result-object v2
iget-object v3, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->headers:Lio/grpc/Metadata;
invoke-static {v3}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$2000(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/Metadata;
move-result-object v3
.line 5
invoke-interface {v0, v1, v2, v3}, Lio/grpc/internal/ServerTransportListener;->streamCreated(Lio/grpc/internal/ServerStream;Ljava/lang/String;Lio/grpc/Metadata;)Lio/grpc/internal/ServerStreamListener;
move-result-object v0
.line 6
iget-object v1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->clientStream:Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;
invoke-static {v1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$400(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;
move-result-object v1
invoke-direct {v1, v0}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->setListener(Lio/grpc/internal/ServerStreamListener;)V
.line 7
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
iget-object v0, v0, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->this$0:Lio/grpc/inprocess/InProcessTransport;
# getter for: Lio/grpc/inprocess/InProcessTransport;->streams:Ljava/util/Set;
invoke-static {v0}, Lio/grpc/inprocess/InProcessTransport;->access$700(Lio/grpc/inprocess/InProcessTransport;)Ljava/util/Set;
move-result-object v0
iget-object v1, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
invoke-interface {v0, v1}, Ljava/util/Set;->add(Ljava/lang/Object;)Z
.line 8
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
iget-object v0, v0, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->this$0:Lio/grpc/inprocess/InProcessTransport;
# getter for: Lio/grpc/inprocess/InProcessTransport;->streams:Ljava/util/Set;
invoke-static {v0}, Lio/grpc/inprocess/InProcessTransport;->access$700(Lio/grpc/inprocess/InProcessTransport;)Ljava/util/Set;
move-result-object v0
invoke-interface {v0}, Ljava/util/Set;->size()I
move-result v0
const/4 v1, 0x1
if-ne v0, v1, :cond_60
.line 9
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->this$1:Lio/grpc/inprocess/InProcessTransport$InProcessStream;
iget-object v0, v0, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->this$0:Lio/grpc/inprocess/InProcessTransport;
# getter for: Lio/grpc/inprocess/InProcessTransport;->clientTransportListener:Lio/grpc/internal/ManagedClientTransport$Listener;
invoke-static {v0}, Lio/grpc/inprocess/InProcessTransport;->access$200(Lio/grpc/inprocess/InProcessTransport;)Lio/grpc/internal/ManagedClientTransport$Listener;
move-result-object v0
invoke-interface {v0, v1}, Lio/grpc/internal/ManagedClientTransport$Listener;->transportInUse(Z)V
.line 10
:cond_60
monitor-exit p1
return-void
:catchall_62
move-exception v0
monitor-exit p1
:try_end_64
.catchall {:try_start_e .. :try_end_64} :catchall_62
throw v0
.end method
.method public declared-synchronized writeMessage(Ljava/io/InputStream;)V
.registers 3
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->closed:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_1e
if-eqz v0, :cond_7
.line 2
monitor-exit p0
return-void
.line 3
:cond_7
:try_start_7
iget v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
if-lez v0, :cond_17
.line 4
iget v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
add-int/lit8 v0, v0, -0x1
iput v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverRequested:I
.line 5
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverStreamListener:Lio/grpc/internal/ServerStreamListener;
invoke-interface {v0, p1}, Lio/grpc/internal/StreamListener;->messageRead(Ljava/io/InputStream;)V
goto :goto_1c
.line 6
:cond_17
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->serverReceiveQueue:Ljava/util/ArrayDeque;
invoke-virtual {v0, p1}, Ljava/util/ArrayDeque;->add(Ljava/lang/Object;)Z
:try_end_1c
.catchall {:try_start_7 .. :try_end_1c} :catchall_1e
.line 7
:goto_1c
monitor-exit p0
return-void
:catchall_1e
move-exception p1
monitor-exit p0
throw p1
.end method