| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | FailingClientStream.java | 32 private final RpcProgress rpcProgress; field in FailingClientStream
44 public FailingClientStream(Status error, RpcProgress rpcProgress) { in FailingClientStream() argument
47 this.rpcProgress = rpcProgress; in FailingClientStream()
54 listener.closed(error, rpcProgress, new Metadata()); in start()
|
| D | FailingClientTransport.java | 38 private final RpcProgress rpcProgress; field in FailingClientTransport
40 FailingClientTransport(Status error, RpcProgress rpcProgress) { in FailingClientTransport() argument
43 this.rpcProgress = rpcProgress; in FailingClientTransport()
49 return new FailingClientStream(error, rpcProgress); in newStream()
|
| D | ForwardingClientStreamListener.java | 38 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed() argument
39 delegate().closed(status, rpcProgress, trailers); in closed()
|
| D | AbstractClientStream.java | 416 final Status status, final RpcProgress rpcProgress, boolean stopDelivery, in transportReportStatus() argument
429 closeListener(status, rpcProgress, trailers); in transportReportStatus()
435 closeListener(status, rpcProgress, trailers); in transportReportStatus()
448 Status status, RpcProgress rpcProgress, Metadata trailers) { in closeListener() argument
452 listener().closed(status, rpcProgress, trailers); in closeListener()
|
| D | ClientStreamListener.java | 64 void closed(Status status, RpcProgress rpcProgress, Metadata trailers); in closed() argument
|
| D | DelayedStream.java | 436 final Status status, final RpcProgress rpcProgress, in closed() argument
441 realListener.closed(status, rpcProgress, trailers); in closed()
|
| D | RetriableStream.java | 552 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed() argument
568 if (rpcProgress == RpcProgress.REFUSED && !noMoreTransparentRetry) { in closed()
581 } else if (rpcProgress == RpcProgress.DROPPED) { in closed()
|
| D | InternalSubchannel.java | 714 Status status, RpcProgress rpcProgress, Metadata trailers) { in newStream()
716 super.closed(status, rpcProgress, trailers); in newStream()
|
| D | ClientCallImpl.java | 559 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed() argument
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | FailingClientTransportTest.java | 42 RpcProgress rpcProgress = RpcProgress.DROPPED; in newStreamStart() local
43 FailingClientTransport transport = new FailingClientTransport(error, rpcProgress); in newStreamStart()
49 verify(listener).closed(eq(error), eq(rpcProgress), any(Metadata.class)); in newStreamStart()
|
| D | NoopClientStreamListener.java | 39 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) {} in closed() argument
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 1734 assertNull(listener1.rpcProgress); in goAway_streamListenerRpcProgress()
1735 assertEquals(REFUSED, listener2.rpcProgress); in goAway_streamListenerRpcProgress()
1736 assertEquals(REFUSED, listener3.rpcProgress); in goAway_streamListenerRpcProgress()
1743 assertEquals(PROCESSED, listener1.rpcProgress); in goAway_streamListenerRpcProgress()
1772 assertNull(listener1.rpcProgress); in reset_streamListenerRpcProgress()
1773 assertEquals(REFUSED, listener2.rpcProgress); in reset_streamListenerRpcProgress()
1774 assertNull(listener3.rpcProgress); in reset_streamListenerRpcProgress()
1778 assertEquals(PROCESSED, listener1.rpcProgress); in reset_streamListenerRpcProgress()
1779 assertNull(listener3.rpcProgress); in reset_streamListenerRpcProgress()
1784 assertEquals(PROCESSED, listener3.rpcProgress); in reset_streamListenerRpcProgress()
[all …]
|
| D | OkHttpClientStreamTest.java | 107 Status status, RpcProgress rpcProgress, Metadata trailers) { in cancel_notStarted()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 799 RpcProgress rpcProgress, in finishStream() argument
814 rpcProgress, in finishStream()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 1012 Status status, RpcProgress rpcProgress, Metadata trailers) { in earlyServerClose_serverFailure_withClientCancelOnListenerClosed()
1013 super.closed(status, rpcProgress, trailers); in earlyServerClose_serverFailure_withClientCancelOnListenerClosed()
1096 Status status, RpcProgress rpcProgress, Metadata trailers) { in clientCancelFromWithinMessageRead()
2010 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed() argument
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 705 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed() argument
|