HomeSort by relevance Sort by last modified time
    Searched refs:shutdownStatus (Results 1 - 9 of 9) sorted by null

  /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
ClientTransportLifecycleManager.java 29 private Status shutdownStatus;
51 shutdownStatus = s;
74 return shutdownStatus;
NettyClientTransport.java 385 Status shutdownStatus = lifecycleManager.getShutdownStatus();
386 if (shutdownStatus == null) {
390 return shutdownStatus;
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DelayedClientTransport.java 68 * When {@code shutdownStatus != null && !hasPendingStreams()}, then the transport is considered
72 private Status shutdownStatus;
138 if (shutdownStatus == null) {
145 return new FailingClientStream(shutdownStatus);
159 if (shutdownStatus != null) {
160 return new FailingClientStream(shutdownStatus);
208 if (shutdownStatus != null) {
211 shutdownStatus = status;
331 if (shutdownStatus != null && reportTransportTerminated != null) {
374 if (shutdownStatus != null)
    [all...]
ManagedChannelImpl.java     [all...]
RetriableStream.java 262 Status shutdownStatus = prestart();
264 if (shutdownStatus != null) {
265 cancel(shutdownStatus);
  /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
InProcessTransport.java 88 private Status shutdownStatus;
116 shutdownStatus = Status.UNAVAILABLE.withDescription("Could not find server: " + name);
117 final Status localShutdownStatus = shutdownStatus;
146 if (shutdownStatus != null) {
147 final Status capturedStatus = shutdownStatus;
166 final Status shutdownStatus = this.shutdownStatus;
170 callback.onFailure(shutdownStatus.asRuntimeException());
189 shutdownStatus = reason;
  /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
AbstractTransportTest.java 467 Status shutdownStatus = Status.UNKNOWN.withDescription("test shutdownNow");
468 serverTransport.shutdownNow(shutdownStatus);
483 assertStatusEquals(shutdownStatus, serverStreamTracer1.getStatus());
    [all...]
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 
  /external/grpc-grpc-java/netty/shaded/
grpc-netty-shaded-1.14.0.jar 

Completed in 323 milliseconds