OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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