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.java939 Status shutdownStatus; field in ManagedChannelImpl.UncommittedRetriableStreamsRegistry
944 if (shutdownStatus != null) { in onShutdown()
947 shutdownStatus = reason; in onShutdown()
982 if (shutdownStatus != null) { in add()
983 return shutdownStatus; in add()
996 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.java385 Status shutdownStatus = lifecycleManager.getShutdownStatus();
386 if (shutdownStatus == null) {
390 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()
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/
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()