| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | FailingClientStream.java | 23 import io.grpc.internal.ClientStreamListener.RpcProgress;
32 private final RpcProgress rpcProgress;
38 this(error, RpcProgress.PROCESSED); in FailingClientStream()
44 public FailingClientStream(Status error, RpcProgress rpcProgress) { in FailingClientStream()
|
| D | FailingClientTransport.java | 29 import io.grpc.internal.ClientStreamListener.RpcProgress;
38 private final RpcProgress rpcProgress;
40 FailingClientTransport(Status error, RpcProgress rpcProgress) { in FailingClientTransport()
|
| D | ClientStreamListener.java | 64 void closed(Status status, RpcProgress rpcProgress, Metadata trailers); in closed()
69 enum RpcProgress { enum
|
| D | AbstractClientStream.java | 35 import io.grpc.internal.ClientStreamListener.RpcProgress;
397 transportReportStatus(status, RpcProgress.PROCESSED, stopDelivery, trailers); in transportReportStatus()
416 final Status status, final RpcProgress rpcProgress, boolean stopDelivery, in transportReportStatus()
448 Status status, RpcProgress rpcProgress, Metadata trailers) { in closeListener()
|
| D | ForwardingClientStreamListener.java | 38 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed()
|
| D | RetriableStream.java | 548 closed(status, RpcProgress.PROCESSED, trailers); in closed()
552 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed()
568 if (rpcProgress == RpcProgress.REFUSED && !noMoreTransparentRetry) { in closed()
581 } else if (rpcProgress == RpcProgress.DROPPED) { in closed()
|
| D | GrpcUtil.java | 41 import io.grpc.internal.ClientStreamListener.RpcProgress;
704 return new FailingClientTransport(result.getStatus(), RpcProgress.DROPPED); in getTransportFromPickResult()
707 return new FailingClientTransport(result.getStatus(), RpcProgress.PROCESSED); in getTransportFromPickResult()
|
| D | ClientCallImpl.java | 555 closed(status, RpcProgress.PROCESSED, trailers); in closed()
559 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed()
|
| D | DelayedStream.java | 436 final Status status, final RpcProgress rpcProgress, in closed()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | FailingClientStreamTest.java | 26 import io.grpc.internal.ClientStreamListener.RpcProgress;
44 verify(listener).closed(eq(status), eq(RpcProgress.PROCESSED), any(Metadata.class)); in processedRpcProgressPopulatedToListener()
52 ClientStream stream = new FailingClientStream(status, RpcProgress.DROPPED); in droppedRpcProgressPopulatedToListener()
54 verify(listener).closed(eq(status), eq(RpcProgress.DROPPED), any(Metadata.class)); in droppedRpcProgressPopulatedToListener()
|
| D | FailingClientTransportTest.java | 27 import io.grpc.internal.ClientStreamListener.RpcProgress;
42 RpcProgress rpcProgress = RpcProgress.DROPPED; in newStreamStart()
|
| D | GrpcUtilTest.java | 34 import io.grpc.internal.ClientStreamListener.RpcProgress;
251 verify(listener).closed(eq(status), eq(RpcProgress.PROCESSED), any(Metadata.class)); in getTransportFromPickResult_errorPickResult_failFast()
267 verify(listener).closed(eq(status), eq(RpcProgress.DROPPED), any(Metadata.class)); in getTransportFromPickResult_dropPickResult_waitForReady()
283 verify(listener).closed(eq(status), eq(RpcProgress.DROPPED), any(Metadata.class)); in getTransportFromPickResult_dropPickResult_failFast()
|
| D | AbstractClientStreamTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
44 import io.grpc.internal.ClientStreamListener.RpcProgress;
335 .closed(statusCaptor.capture(), any(RpcProgress.class), any(Metadata.class)); in rstStreamClosesStream()
352 .closed(statusCaptor.capture(), any(RpcProgress.class), any(Metadata.class)); in trailerOkWithTruncatedMessage()
370 .closed(statusCaptor.capture(), any(RpcProgress.class), any(Metadata.class)); in trailerNotOkWithTruncatedMessage()
|
| D | NoopClientStreamListener.java | 39 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) {} in closed()
|
| D | DelayedClientTransportTest.java | 46 import io.grpc.internal.ClientStreamListener.RpcProgress;
234 statusCaptor.capture(), any(RpcProgress.class), any(Metadata.class)); in newStreamThenShutdownTransportThenAssignTransport()
262 statusCaptor.capture(), any(RpcProgress.class), any(Metadata.class)); in shutdownThenNewStream()
283 statusCaptor.capture(), any(RpcProgress.class), any(Metadata.class)); in shutdownNowThenNewStream()
|
| D | Http2ClientStreamTransportStateTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 38 import io.grpc.internal.ClientStreamListener.RpcProgress;
327 .closed(statusCaptor.capture(), isA(RpcProgress.class), trailerCaptor.capture()); in streamSucceeded()
371 .closed(statusCaptor.capture(), isA(RpcProgress.class), isA(Metadata.class)); in streamSucceededWithGrpcError()
397 .closed(statusCaptor.capture(), isA(RpcProgress.class), isA(Metadata.class)); in streamFailed()
425 .closed(statusCaptor.capture(), isA(RpcProgress.class), isA(Metadata.class)); in streamFailedAfterResponseHeaderReceived()
456 .closed(statusCaptor.capture(), isA(RpcProgress.class), isA(Metadata.class)); in streamFailedAfterTrailerReceived()
489 .closed(statusCaptor.capture(), isA(RpcProgress.class), isA(Metadata.class)); in streamFailedAfterTrailerAndEndOfStreamReceived()
533 .closed(isA(Status.class), isA(RpcProgress.class), isA(Metadata.class)); in reportTrailersWhenTrailersReceivedBeforeReadClosed()
539 .closed(statusCaptor.capture(), isA(RpcProgress.class), isA(Metadata.class)); in reportTrailersWhenTrailersReceivedBeforeReadClosed()
561 .closed(isA(Status.class), isA(RpcProgress.class), isA(Metadata.class)); in reportTrailersWhenTrailersReceivedAfterReadClosed()
[all …]
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 47 import io.grpc.internal.ClientStreamListener.RpcProgress;
357 goAwayStatus, RpcProgress.REFUSED, true, new Metadata()); in streamReadyToStart()
765 status, RpcProgress.REFUSED, false, new Metadata()); in startGoAway()
771 status, RpcProgress.REFUSED, true, new Metadata()); in startGoAway()
798 RpcProgress rpcProgress, in finishStream()
1067 errorCode == ErrorCode.REFUSED_STREAM ? RpcProgress.REFUSED : RpcProgress.PROCESSED, in rstStream()
1170 streamId, Status.INTERNAL.withDescription(errorMsg), RpcProgress.PROCESSED, false, in windowUpdate()
|
| D | OkHttpClientStream.java | 21 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 31 import io.grpc.internal.ClientStreamListener.RpcProgress;
373 ? RpcProgress.REFUSED : RpcProgress.PROCESSED, in onRstStreamRead()
491 lifecycleManager.getShutdownStatus(), RpcProgress.REFUSED, true, new Metadata()); in createStream()
682 goAwayStatus, RpcProgress.REFUSED, false, new Metadata()); in goingAway()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
107 Status status, RpcProgress rpcProgress, Metadata trailers) { in cancel_notStarted()
|
| D | OkHttpClientTransportTest.java | 21 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
22 import static io.grpc.internal.ClientStreamListener.RpcProgress.REFUSED;
1939 RpcProgress rpcProgress;
1969 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
21 import static io.grpc.internal.ClientStreamListener.RpcProgress.REFUSED;
60 import io.grpc.internal.ClientStreamListener.RpcProgress;
355 .closed(any(Status.class), any(RpcProgress.class), any(Metadata.class)); in receivedGoAwayShouldNotAffectEarlyStreamId()
|
| D | NettyClientTransportTest.java | 690 closed(status, RpcProgress.PROCESSED, trailers); in closed()
694 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 1011 Status status, RpcProgress rpcProgress, Metadata trailers) { in earlyServerClose_serverFailure_withClientCancelOnListenerClosed()
1090 closed(status, RpcProgress.PROCESSED, trailers); in clientCancelFromWithinMessageRead()
1095 Status status, RpcProgress rpcProgress, Metadata trailers) { in clientCancelFromWithinMessageRead()
2005 closed(status, RpcProgress.PROCESSED, trailers); in closed()
2009 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed()
|