| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | MessageDeframer.java | 107 private volatile boolean stopDelivery = false; field in MessageDeframer
203 void stopDelivery() { in stopDelivery() method in MessageDeframer
204 stopDelivery = true; in stopDelivery()
264 while (!stopDelivery && pendingDeliveries > 0 && readRequiredBytes()) { in deliver()
282 if (stopDelivery) { in deliver()
|
| D | AbstractClientStream.java | 395 public final void transportReportStatus(final Status status, boolean stopDelivery, in transportReportStatus() argument
397 transportReportStatus(status, RpcProgress.PROCESSED, stopDelivery, trailers); in transportReportStatus()
416 final Status status, final RpcProgress rpcProgress, boolean stopDelivery, in transportReportStatus() argument
421 if (statusReported && !stopDelivery) { in transportReportStatus()
438 closeDeframer(stopDelivery); in transportReportStatus()
|
| D | AbstractStream.java | 179 protected final void closeDeframer(boolean stopDelivery) { in closeDeframer() argument
180 if (stopDelivery) { in closeDeframer()
|
| D | ApplicationThreadDeframer.java | 122 deframer.stopDelivery(); in close()
|
| D | Http2ClientStreamTransportState.java | 79 Status status, boolean stopDelivery, Metadata trailers); in http2ProcessingFailed() argument
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 256 protected void http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers) { in http2ProcessingFailed() argument
257 cancel(status, stopDelivery, trailers); in http2ProcessingFailed()
338 private void cancel(Status reason, boolean stopDelivery, Metadata trailers) { in cancel() argument
357 id(), reason, PROCESSED, stopDelivery, ErrorCode.CANCEL, trailers); in cancel() local
|
| D | OkHttpClientTransport.java | 799 boolean stopDelivery, in finishStream() argument
814 stopDelivery, in finishStream()
1063 boolean stopDelivery = in rstStream()
1068 stopDelivery, null, null); in rstStream()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientStream.java | 268 protected void http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers) { in http2ProcessingFailed() argument
269 transportReportStatus(status, stopDelivery, trailers); in http2ProcessingFailed()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ApplicationThreadDeframerTest.java | 85 verify(mockDeframer).stopDelivery(); in closeInvokesMessagesAvailableOnListener()
|
| D | Http2ClientStreamTransportStateTest.java | 352 protected void http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers) { in http2ProcessingFailed() argument
353 transportReportStatus(status, stopDelivery, trailers); in http2ProcessingFailed()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 249 protected void http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers) { in http2ProcessingFailed() argument
251 transportReportStatus(status, stopDelivery, trailers); in http2ProcessingFailed()
|