| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractClientStream.java | 267 transportReportStatus(trailerStatus, false, trailers); in deframerClosed()
395 public final void transportReportStatus(final Status status, boolean stopDelivery, in transportReportStatus() method in AbstractClientStream.TransportState
397 transportReportStatus(status, RpcProgress.PROCESSED, stopDelivery, trailers); in transportReportStatus()
415 public final void transportReportStatus( in transportReportStatus() method in AbstractClientStream.TransportState
|
| D | Http2ClientStreamTransportState.java | 153 transportReportStatus(transportError, false, transportErrorMetadata); in transportDataReceived()
|
| D | AbstractServerStream.java | 283 public final void transportReportStatus(final Status status) { in transportReportStatus() method in AbstractServerStream.TransportState
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientStreamTest.java | 208 stream().transportState().transportReportStatus(Status.OK, true, new Metadata()); in setStatusWithOkShouldCloseStream()
215 stream().transportState().transportReportStatus(errorStatus, true, new Metadata()); in setStatusWithErrorShouldCloseStream()
222 stream().transportState().transportReportStatus(errorStatus, true, new Metadata()); in setStatusWithOkShouldNotOverrideError()
223 stream().transportState().transportReportStatus(Status.OK, true, new Metadata()); in setStatusWithOkShouldNotOverrideError()
230 stream().transportState().transportReportStatus(errorStatus, true, new Metadata()); in setStatusWithErrorShouldNotOverridePreviousError()
231 stream().transportState().transportReportStatus( in setStatusWithErrorShouldNotOverridePreviousError()
378 stream().transportState().transportReportStatus(Status.CANCELLED, true, trailers); in deframedDataAfterCancelShouldBeIgnored()
|
| D | NettyServerStreamTest.java | 235 stream().transportState().transportReportStatus(status); in abortStreamAndNotSendStatus()
250 stream().transportState().transportReportStatus(status); in abortStreamAfterClientHalfCloseShouldCallClose()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 370 stream.transportReportStatus( in onRstStreamRead()
409 clientStream.transportReportStatus( in channelInactive()
465 stream.transportReportStatus(Utils.statusFromThrowable(cause), false, new Metadata()); in onStreamError()
490 command.stream().transportReportStatus( in createStream()
566 stream.transportReportStatus(reason, true, new Metadata()); in cancelStream()
656 clientStream.transportReportStatus(msg.getStatus(), true, new Metadata()); in forcefulClose()
681 clientStream.transportReportStatus( in goingAway()
|
| D | NettyClientStream.java | 149 transportState().transportReportStatus(s, true, new Metadata()); in writeHeaders()
269 transportReportStatus(status, stopDelivery, trailers); in http2ProcessingFailed()
|
| D | NettyServerHandler.java | 476 stream.transportReportStatus( in onRstStreamRead()
501 serverStream.transportReportStatus(Utils.statusFromThrowable(cause)); in onStreamError()
552 serverStream.transportReportStatus(status); in channelInactive()
644 cmd.stream().transportReportStatus(cmd.reason()); in cancelStream()
657 serverStream.transportReportStatus(msg.getStatus()); in forcefulClose()
|
| D | NettyServerStream.java | 193 transportReportStatus(status); in deframeFailed()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 130 clientStream.transportState().transportReportStatus(goAwayStatus, true, new Metadata()); in newStream()
257 stream.transportState().transportReportStatus(status, isCancelled, new Metadata());
|
| D | CronetClientStream.java | 251 transportReportStatus(status, stopDelivery, trailers); in http2ProcessingFailed()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 356 clientStream.transportState().transportReportStatus( in streamReadyToStart()
690 entry.getValue().transportState().transportReportStatus(reason, false, new Metadata()); in shutdownNow()
694 stream.transportState().transportReportStatus(reason, true, new Metadata()); in shutdownNow()
764 entry.getValue().transportState().transportReportStatus( in startGoAway()
770 stream.transportState().transportReportStatus( in startGoAway()
811 .transportReportStatus( in finishStream()
|
| D | OkHttpClientStream.java | 352 transportReportStatus(reason, true, trailers != null ? trailers : new Metadata()); in cancel()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractServerStreamTest.java | 144 stream.transportState().transportReportStatus(Status.CANCELLED); in queuedBytesInDeframerShouldNotBlockTransportReportStatus()
385 transportReportStatus(status); in deframeFailed()
|
| D | AbstractClientStreamTest.java | 137 state.transportReportStatus(errorStatus, true/*stop delivery*/, new Metadata()); in cancel_notifiesOnlyOnce()
197 stream.transportState().transportReportStatus(Status.CANCELLED, false, new Metadata()); in inboundHeadersReceived_failsIfStatusReported()
331 stream.transportState().transportReportStatus(status, false /*stop delivery*/, new Metadata()); in rstStreamClosesStream()
|
| D | Http2ClientStreamTransportStateTest.java | 353 transportReportStatus(status, stopDelivery, trailers); in http2ProcessingFailed()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 393 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailed()
421 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailedAfterResponseHeaderReceived()
452 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailedAfterTrailerReceived()
485 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailedAfterTrailerAndEndOfStreamReceived()
|