InProcessTransport.smali
.class Lio/grpc/inprocess/InProcessTransport;
.super Ljava/lang/Object;
.source "InProcessTransport.java"
# interfaces
.implements Lio/grpc/internal/ServerTransport;
.implements Lio/grpc/internal/ConnectionClientTransport;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/grpc/inprocess/InProcessTransport$InProcessStream;
}
.end annotation
# static fields
.field private static final log:Ljava/util/logging/Logger;
# instance fields
.field private clientTransportListener:Lio/grpc/internal/ManagedClientTransport$Listener;
.field private final name:Ljava/lang/String;
.field private final serverStreamAttributes:Lio/grpc/Attributes;
.field private serverTransportListener:Lio/grpc/internal/ServerTransportListener;
.field private shutdown:Z
.field private shutdownStatus:Lio/grpc/Status;
.field private streams:Ljava/util/Set;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Set<",
"Lio/grpc/inprocess/InProcessTransport$InProcessStream;",
">;"
}
.end annotation
.end field
.field private terminated:Z
# direct methods
.method static constructor <clinit>()V
.registers 1
.line 1
const-class v0, Lio/grpc/inprocess/InProcessTransport;
invoke-virtual {v0}, Ljava/lang/Class;->getName()Ljava/lang/String;
move-result-object v0
invoke-static {v0}, Ljava/util/logging/Logger;->getLogger(Ljava/lang/String;)Ljava/util/logging/Logger;
move-result-object v0
sput-object v0, Lio/grpc/inprocess/InProcessTransport;->log:Ljava/util/logging/Logger;
return-void
.end method
.method public constructor <init>(Ljava/lang/String;)V
.registers 5
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
new-instance v0, Ljava/util/HashSet;
invoke-direct {v0}, Ljava/util/HashSet;-><init>()V
iput-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->streams:Ljava/util/Set;
.line 3
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->name:Ljava/lang/String;
.line 4
invoke-static {}, Lio/grpc/Attributes;->newBuilder()Lio/grpc/Attributes$Builder;
move-result-object v0
sget-object v1, Lio/grpc/ServerCall;->REMOTE_ADDR_KEY:Lio/grpc/Attributes$Key;
new-instance v2, Lio/grpc/inprocess/InProcessSocketAddress;
invoke-direct {v2, p1}, Lio/grpc/inprocess/InProcessSocketAddress;-><init>(Ljava/lang/String;)V
.line 5
invoke-virtual {v0, v1, v2}, Lio/grpc/Attributes$Builder;->set(Lio/grpc/Attributes$Key;Ljava/lang/Object;)Lio/grpc/Attributes$Builder;
move-result-object p1
.line 6
invoke-virtual {p1}, Lio/grpc/Attributes$Builder;->build()Lio/grpc/Attributes;
move-result-object p1
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->serverStreamAttributes:Lio/grpc/Attributes;
return-void
.end method
.method static synthetic access$000(Lio/grpc/inprocess/InProcessTransport;Lio/grpc/Status;)V
.registers 2
.line 1
invoke-direct {p0, p1}, Lio/grpc/inprocess/InProcessTransport;->notifyShutdown(Lio/grpc/Status;)V
return-void
.end method
.method static synthetic access$100(Lio/grpc/inprocess/InProcessTransport;)V
.registers 1
.line 1
invoke-direct {p0}, Lio/grpc/inprocess/InProcessTransport;->notifyTerminated()V
return-void
.end method
.method static synthetic access$1000(Lio/grpc/Status;)Lio/grpc/Status;
.registers 1
.line 1
invoke-static {p0}, Lio/grpc/inprocess/InProcessTransport;->stripCause(Lio/grpc/Status;)Lio/grpc/Status;
move-result-object p0
return-object p0
.end method
.method static synthetic access$1300()Ljava/util/logging/Logger;
.registers 1
.line 1
sget-object v0, Lio/grpc/inprocess/InProcessTransport;->log:Ljava/util/logging/Logger;
return-object v0
.end method
.method static synthetic access$1400(Lio/grpc/inprocess/InProcessTransport;)Lio/grpc/Attributes;
.registers 1
.line 1
iget-object p0, p0, Lio/grpc/inprocess/InProcessTransport;->serverStreamAttributes:Lio/grpc/Attributes;
return-object p0
.end method
.method static synthetic access$200(Lio/grpc/inprocess/InProcessTransport;)Lio/grpc/internal/ManagedClientTransport$Listener;
.registers 1
.line 1
iget-object p0, p0, Lio/grpc/inprocess/InProcessTransport;->clientTransportListener:Lio/grpc/internal/ManagedClientTransport$Listener;
return-object p0
.end method
.method static synthetic access$2100(Lio/grpc/inprocess/InProcessTransport;)Lio/grpc/internal/ServerTransportListener;
.registers 1
.line 1
iget-object p0, p0, Lio/grpc/inprocess/InProcessTransport;->serverTransportListener:Lio/grpc/internal/ServerTransportListener;
return-object p0
.end method
.method static synthetic access$700(Lio/grpc/inprocess/InProcessTransport;)Ljava/util/Set;
.registers 1
.line 1
iget-object p0, p0, Lio/grpc/inprocess/InProcessTransport;->streams:Ljava/util/Set;
return-object p0
.end method
.method static synthetic access$800(Lio/grpc/inprocess/InProcessTransport;)Z
.registers 1
.line 1
iget-boolean p0, p0, Lio/grpc/inprocess/InProcessTransport;->shutdown:Z
return p0
.end method
.method private declared-synchronized notifyShutdown(Lio/grpc/Status;)V
.registers 3
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport;->shutdown:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_11
if-eqz v0, :cond_7
.line 2
monitor-exit p0
return-void
:cond_7
const/4 v0, 0x1
.line 3
:try_start_8
iput-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport;->shutdown:Z
.line 4
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->clientTransportListener:Lio/grpc/internal/ManagedClientTransport$Listener;
invoke-interface {v0, p1}, Lio/grpc/internal/ManagedClientTransport$Listener;->transportShutdown(Lio/grpc/Status;)V
:try_end_f
.catchall {:try_start_8 .. :try_end_f} :catchall_11
.line 5
monitor-exit p0
return-void
:catchall_11
move-exception p1
monitor-exit p0
throw p1
.end method
.method private declared-synchronized notifyTerminated()V
.registers 2
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport;->terminated: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
:cond_7
const/4 v0, 0x1
.line 3
:try_start_8
iput-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport;->terminated:Z
.line 4
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->clientTransportListener:Lio/grpc/internal/ManagedClientTransport$Listener;
invoke-interface {v0}, Lio/grpc/internal/ManagedClientTransport$Listener;->transportTerminated()V
.line 5
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->serverTransportListener:Lio/grpc/internal/ServerTransportListener;
if-eqz v0, :cond_18
.line 6
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->serverTransportListener:Lio/grpc/internal/ServerTransportListener;
invoke-interface {v0}, Lio/grpc/internal/ServerTransportListener;->transportTerminated()V
:try_end_18
.catchall {:try_start_8 .. :try_end_18} :catchall_1a
.line 7
:cond_18
monitor-exit p0
return-void
:catchall_1a
move-exception v0
monitor-exit p0
throw v0
.end method
.method private static stripCause(Lio/grpc/Status;)Lio/grpc/Status;
.registers 2
if-nez p0, :cond_4
const/4 p0, 0x0
return-object p0
.line 1
:cond_4
invoke-virtual {p0}, Lio/grpc/Status;->getCode()Lio/grpc/Status$Code;
move-result-object v0
invoke-virtual {v0}, Lio/grpc/Status$Code;->value()I
move-result v0
invoke-static {v0}, Lio/grpc/Status;->fromCodeValue(I)Lio/grpc/Status;
move-result-object v0
.line 2
invoke-virtual {p0}, Lio/grpc/Status;->getDescription()Ljava/lang/String;
move-result-object p0
invoke-virtual {v0, p0}, Lio/grpc/Status;->withDescription(Ljava/lang/String;)Lio/grpc/Status;
move-result-object p0
return-object p0
.end method
# virtual methods
.method public getAttrs()Lio/grpc/Attributes;
.registers 2
.line 1
sget-object v0, Lio/grpc/Attributes;->EMPTY:Lio/grpc/Attributes;
return-object v0
.end method
.method public getLogId()Ljava/lang/String;
.registers 2
.line 1
invoke-static {p0}, Lio/grpc/internal/GrpcUtil;->getLogId(Lio/grpc/internal/WithLogId;)Ljava/lang/String;
move-result-object v0
return-object v0
.end method
.method public declared-synchronized newStream(Lio/grpc/MethodDescriptor;Lio/grpc/Metadata;)Lio/grpc/internal/ClientStream;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/grpc/MethodDescriptor<",
"**>;",
"Lio/grpc/Metadata;",
")",
"Lio/grpc/internal/ClientStream;"
}
.end annotation
monitor-enter p0
.line 5
:try_start_1
sget-object v0, Lio/grpc/CallOptions;->DEFAULT:Lio/grpc/CallOptions;
invoke-virtual {p0, p1, p2, v0}, Lio/grpc/inprocess/InProcessTransport;->newStream(Lio/grpc/MethodDescriptor;Lio/grpc/Metadata;Lio/grpc/CallOptions;)Lio/grpc/internal/ClientStream;
move-result-object p1
:try_end_7
.catchall {:try_start_1 .. :try_end_7} :catchall_9
monitor-exit p0
return-object p1
:catchall_9
move-exception p1
monitor-exit p0
throw p1
.end method
.method public declared-synchronized newStream(Lio/grpc/MethodDescriptor;Lio/grpc/Metadata;Lio/grpc/CallOptions;)Lio/grpc/internal/ClientStream;
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/grpc/MethodDescriptor<",
"**>;",
"Lio/grpc/Metadata;",
"Lio/grpc/CallOptions;",
")",
"Lio/grpc/internal/ClientStream;"
}
.end annotation
monitor-enter p0
.line 1
:try_start_1
iget-object p3, p0, Lio/grpc/inprocess/InProcessTransport;->shutdownStatus:Lio/grpc/Status;
if-eqz p3, :cond_e
.line 2
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->shutdownStatus:Lio/grpc/Status;
.line 3
new-instance p2, Lio/grpc/inprocess/InProcessTransport$3;
invoke-direct {p2, p0, p1}, Lio/grpc/inprocess/InProcessTransport$3;-><init>(Lio/grpc/inprocess/InProcessTransport;Lio/grpc/Status;)V
:try_end_c
.catchall {:try_start_1 .. :try_end_c} :catchall_1a
monitor-exit p0
return-object p2
.line 4
:cond_e
:try_start_e
new-instance p3, Lio/grpc/inprocess/InProcessTransport$InProcessStream;
const/4 v0, 0x0
invoke-direct {p3, p0, p1, p2, v0}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;-><init>(Lio/grpc/inprocess/InProcessTransport;Lio/grpc/MethodDescriptor;Lio/grpc/Metadata;Lio/grpc/inprocess/InProcessTransport$1;)V
# getter for: Lio/grpc/inprocess/InProcessTransport$InProcessStream;->clientStream:Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;
invoke-static {p3}, Lio/grpc/inprocess/InProcessTransport$InProcessStream;->access$400(Lio/grpc/inprocess/InProcessTransport$InProcessStream;)Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;
move-result-object p1
:try_end_18
.catchall {:try_start_e .. :try_end_18} :catchall_1a
monitor-exit p0
return-object p1
:catchall_1a
move-exception p1
monitor-exit p0
throw p1
.end method
.method public declared-synchronized ping(Lio/grpc/internal/ClientTransport$PingCallback;Ljava/util/concurrent/Executor;)V
.registers 5
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport;->terminated:Z
if-eqz v0, :cond_10
.line 2
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->shutdownStatus:Lio/grpc/Status;
.line 3
new-instance v1, Lio/grpc/inprocess/InProcessTransport$4;
invoke-direct {v1, p0, p1, v0}, Lio/grpc/inprocess/InProcessTransport$4;-><init>(Lio/grpc/inprocess/InProcessTransport;Lio/grpc/internal/ClientTransport$PingCallback;Lio/grpc/Status;)V
invoke-interface {p2, v1}, Ljava/util/concurrent/Executor;->execute(Ljava/lang/Runnable;)V
goto :goto_18
.line 4
:cond_10
new-instance v0, Lio/grpc/inprocess/InProcessTransport$5;
invoke-direct {v0, p0, p1}, Lio/grpc/inprocess/InProcessTransport$5;-><init>(Lio/grpc/inprocess/InProcessTransport;Lio/grpc/internal/ClientTransport$PingCallback;)V
invoke-interface {p2, v0}, Ljava/util/concurrent/Executor;->execute(Ljava/lang/Runnable;)V
:try_end_18
.catchall {:try_start_1 .. :try_end_18} :catchall_1a
.line 5
:goto_18
monitor-exit p0
return-void
:catchall_1a
move-exception p1
monitor-exit p0
throw p1
.end method
.method public declared-synchronized shutdown()V
.registers 3
monitor-enter p0
.line 1
:try_start_1
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport;->shutdown:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_23
if-eqz v0, :cond_7
.line 2
monitor-exit p0
return-void
.line 3
:cond_7
:try_start_7
sget-object v0, Lio/grpc/Status;->UNAVAILABLE:Lio/grpc/Status;
const-string v1, "transport was requested to shut down"
invoke-virtual {v0, v1}, Lio/grpc/Status;->withDescription(Ljava/lang/String;)Lio/grpc/Status;
move-result-object v0
iput-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->shutdownStatus:Lio/grpc/Status;
.line 4
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->shutdownStatus:Lio/grpc/Status;
invoke-direct {p0, v0}, Lio/grpc/inprocess/InProcessTransport;->notifyShutdown(Lio/grpc/Status;)V
.line 5
iget-object v0, p0, Lio/grpc/inprocess/InProcessTransport;->streams:Ljava/util/Set;
invoke-interface {v0}, Ljava/util/Set;->isEmpty()Z
move-result v0
if-eqz v0, :cond_21
.line 6
invoke-direct {p0}, Lio/grpc/inprocess/InProcessTransport;->notifyTerminated()V
:try_end_21
.catchall {:try_start_7 .. :try_end_21} :catchall_23
.line 7
:cond_21
monitor-exit p0
return-void
:catchall_23
move-exception v0
monitor-exit p0
throw v0
.end method
.method public shutdownNow(Lio/grpc/Status;)V
.registers 4
const-string v0, "reason"
.line 1
invoke-static {p1, v0}, Lcom/google/common/base/r;->a(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
.line 2
monitor-enter p0
.line 3
:try_start_6
invoke-virtual {p0}, Lio/grpc/inprocess/InProcessTransport;->shutdown()V
.line 4
iget-boolean v0, p0, Lio/grpc/inprocess/InProcessTransport;->terminated:Z
if-eqz v0, :cond_f
.line 5
monitor-exit p0
return-void
.line 6
:cond_f
new-instance v0, Ljava/util/ArrayList;
iget-object v1, p0, Lio/grpc/inprocess/InProcessTransport;->streams:Ljava/util/Set;
invoke-direct {v0, v1}, Ljava/util/ArrayList;-><init>(Ljava/util/Collection;)V
.line 7
monitor-exit p0
:try_end_17
.catchall {:try_start_6 .. :try_end_17} :catchall_30
.line 8
invoke-interface {v0}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object v0
:goto_1b
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_2f
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lio/grpc/inprocess/InProcessTransport$InProcessStream;
.line 9
# 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-virtual {v1, p1}, Lio/grpc/inprocess/InProcessTransport$InProcessStream$InProcessClientStream;->cancel(Lio/grpc/Status;)V
goto :goto_1b
:cond_2f
return-void
:catchall_30
move-exception p1
.line 10
:try_start_31
monitor-exit p0
:try_end_32
.catchall {:try_start_31 .. :try_end_32} :catchall_30
goto :goto_34
:goto_33
throw p1
:goto_34
goto :goto_33
.end method
.method public declared-synchronized start(Lio/grpc/internal/ManagedClientTransport$Listener;)V
.registers 5
monitor-enter p0
.line 1
:try_start_1
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->clientTransportListener:Lio/grpc/internal/ManagedClientTransport$Listener;
.line 2
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->name:Ljava/lang/String;
invoke-static {p1}, Lio/grpc/inprocess/InProcessServer;->findServer(Ljava/lang/String;)Lio/grpc/inprocess/InProcessServer;
move-result-object p1
if-eqz p1, :cond_11
.line 3
invoke-virtual {p1, p0}, Lio/grpc/inprocess/InProcessServer;->register(Lio/grpc/inprocess/InProcessTransport;)Lio/grpc/internal/ServerTransportListener;
move-result-object p1
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->serverTransportListener:Lio/grpc/internal/ServerTransportListener;
.line 4
:cond_11
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->serverTransportListener:Lio/grpc/internal/ServerTransportListener;
const/4 v0, 0x1
if-nez p1, :cond_4a
.line 5
sget-object p1, Lio/grpc/Status;->UNAVAILABLE:Lio/grpc/Status;
new-instance v1, Ljava/lang/StringBuilder;
invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V
const-string v2, "Could not find server: "
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v2, p0, Lio/grpc/inprocess/InProcessTransport;->name:Ljava/lang/String;
invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
invoke-virtual {p1, v1}, Lio/grpc/Status;->withDescription(Ljava/lang/String;)Lio/grpc/Status;
move-result-object p1
iput-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->shutdownStatus:Lio/grpc/Status;
.line 6
iget-object p1, p0, Lio/grpc/inprocess/InProcessTransport;->shutdownStatus:Lio/grpc/Status;
.line 7
new-instance v1, Ljava/lang/Thread;
new-instance v2, Lio/grpc/inprocess/InProcessTransport$1;
invoke-direct {v2, p0, p1}, Lio/grpc/inprocess/InProcessTransport$1;-><init>(Lio/grpc/inprocess/InProcessTransport;Lio/grpc/Status;)V
invoke-direct {v1, v2}, Ljava/lang/Thread;-><init>(Ljava/lang/Runnable;)V
.line 8
invoke-virtual {v1, v0}, Ljava/lang/Thread;->setDaemon(Z)V
const-string p1, "grpc-inprocess-shutdown"
.line 9
invoke-virtual {v1, p1}, Ljava/lang/Thread;->setName(Ljava/lang/String;)V
.line 10
invoke-virtual {v1}, Ljava/lang/Thread;->start()V
:try_end_48
.catchall {:try_start_1 .. :try_end_48} :catchall_61
.line 11
monitor-exit p0
return-void
.line 12
:cond_4a
:try_start_4a
new-instance p1, Ljava/lang/Thread;
new-instance v1, Lio/grpc/inprocess/InProcessTransport$2;
invoke-direct {v1, p0}, Lio/grpc/inprocess/InProcessTransport$2;-><init>(Lio/grpc/inprocess/InProcessTransport;)V
invoke-direct {p1, v1}, Ljava/lang/Thread;-><init>(Ljava/lang/Runnable;)V
.line 13
invoke-virtual {p1, v0}, Ljava/lang/Thread;->setDaemon(Z)V
const-string v0, "grpc-inprocess-ready"
.line 14
invoke-virtual {p1, v0}, Ljava/lang/Thread;->setName(Ljava/lang/String;)V
.line 15
invoke-virtual {p1}, Ljava/lang/Thread;->start()V
:try_end_5f
.catchall {:try_start_4a .. :try_end_5f} :catchall_61
.line 16
monitor-exit p0
return-void
:catchall_61
move-exception p1
monitor-exit p0
throw p1
.end method
.method public toString()Ljava/lang/String;
.registers 3
.line 1
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
invoke-virtual {p0}, Lio/grpc/inprocess/InProcessTransport;->getLogId()Ljava/lang/String;
move-result-object v1
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v1, "("
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
iget-object v1, p0, Lio/grpc/inprocess/InProcessTransport;->name:Ljava/lang/String;
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string 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
return-object v0
.end method