Home
last modified time | relevance | path

Searched refs:shutdownStatus (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DDelayedClientTransport.java72 private Status shutdownStatus; field in DelayedClientTransport
138 if (shutdownStatus == null) { in newStream()
145 return new FailingClientStream(shutdownStatus); in newStream()
159 if (shutdownStatus != null) { in newStream()
160 return new FailingClientStream(shutdownStatus); in newStream()
208 if (shutdownStatus != null) { in shutdown()
211 shutdownStatus = status; in shutdown()
331 if (shutdownStatus != null && reportTransportTerminated != null) { in reprocess()
374 if (shutdownStatus != null) { in cancel()
DManagedChannelImpl.java928 Status shutdownStatus; field in ManagedChannelImpl.UncommittedRetriableStreamsRegistry
933 if (shutdownStatus != null) { in onShutdown()
936 shutdownStatus = reason; in onShutdown()
971 if (shutdownStatus != null) { in add()
972 return shutdownStatus; in add()
985 shutdownStatusCopy = shutdownStatus; in remove()
DRetriableStream.java262 Status shutdownStatus = prestart(); in start() local
264 if (shutdownStatus != null) { in start()
265 cancel(shutdownStatus); in start()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DClientTransportLifecycleManager.java29 private Status shutdownStatus; field in ClientTransportLifecycleManager
51 shutdownStatus = s; in notifyShutdown()
74 return shutdownStatus; in getShutdownStatus()
DNettyClientTransport.java395 Status shutdownStatus = lifecycleManager.getShutdownStatus();
396 if (shutdownStatus == null) {
400 return shutdownStatus;
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java88 private Status shutdownStatus; field in InProcessTransport
116 shutdownStatus = Status.UNAVAILABLE.withDescription("Could not find server: " + name); in start()
117 final Status localShutdownStatus = shutdownStatus; in start()
147 if (shutdownStatus != null) {
148 final Status capturedStatus = shutdownStatus;
167 final Status shutdownStatus = this.shutdownStatus;
171 callback.onFailure(shutdownStatus.asRuntimeException());
190 shutdownStatus = reason;
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java467 Status shutdownStatus = Status.UNKNOWN.withDescription("test shutdownNow"); in shutdownNowKillsServerStream() local
468 serverTransport.shutdownNow(shutdownStatus); in shutdownNowKillsServerStream()
483 assertStatusEquals(shutdownStatus, serverStreamTracer1.getStatus()); in shutdownNowKillsServerStream()