| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | Http2ClientStreamTransportStateTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
83 verify(mockListener, never()).closed(any(Status.class), same(PROCESSED), any(Metadata.class)); in transportHeadersReceived_notifiesListener()
97 verify(mockListener, never()).closed(any(Status.class), same(PROCESSED), any(Metadata.class)); in transportHeadersReceived_doesntRequire200()
112 verify(mockListener).closed(statusCaptor.capture(), same(PROCESSED), same(headers)); in transportHeadersReceived_noHttpStatus()
127 verify(mockListener).closed(statusCaptor.capture(), same(PROCESSED), same(headers)); in transportHeadersReceived_wrongContentType_200()
143 verify(mockListener).closed(statusCaptor.capture(), same(PROCESSED), same(headers)); in transportHeadersReceived_wrongContentType_401()
167 verify(mockListener, never()).closed(any(Status.class), same(PROCESSED), any(Metadata.class)); in transportHeadersReceived_handles_1xx()
185 verify(mockListener).closed(statusCaptor.capture(), same(PROCESSED), same(headersAgain)); in transportHeadersReceived_twice()
205 verify(mockListener).closed(statusCaptor.capture(), same(PROCESSED), same(headers)); in transportHeadersReceived_unknownAndTwiceLogsSecondHeaders()
217 verify(mockListener).closed(statusCaptor.capture(), same(PROCESSED), any(Metadata.class)); in transportDataReceived_noHeaderReceived()
[all …]
|
| D | FailingClientStreamTest.java | 44 verify(listener).closed(eq(status), eq(RpcProgress.PROCESSED), any(Metadata.class)); in processedRpcProgressPopulatedToListener()
|
| D | AbstractClientStreamTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
145 verify(mockListener).closed(any(Status.class), same(PROCESSED), any(Metadata.class)); in cancel_notifiesOnlyOnce()
|
| D | GrpcUtilTest.java | 251 verify(listener).closed(eq(status), eq(RpcProgress.PROCESSED), any(Metadata.class)); in getTransportFromPickResult_errorPickResult_failFast()
|
| D | RetriableStreamTest.java | 21 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
1458 .closed(Status.fromCode(RETRIABLE_STATUS_CODE_1), PROCESSED, new Metadata()); in normalRetry_thenNoTransparentRetry_butNormalRetry() local
1508 .closed(Status.fromCode(RETRIABLE_STATUS_CODE_1), PROCESSED, new Metadata()); in normalRetry_thenNoTransparentRetry_andNoMoreRetry() local
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientStreamTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
209 verify(listener).closed(same(Status.OK), same(PROCESSED), any(Metadata.class)); in setStatusWithOkShouldCloseStream()
216 verify(listener).closed(eq(errorStatus), same(PROCESSED), any(Metadata.class)); in setStatusWithErrorShouldCloseStream()
224 verify(listener).closed(any(Status.class), same(PROCESSED), any(Metadata.class)); in setStatusWithOkShouldNotOverrideError()
233 verify(listener).closed(any(Status.class), same(PROCESSED), any(Metadata.class)); in setStatusWithErrorShouldNotOverridePreviousError()
292 verify(listener).closed(captor.capture(), same(PROCESSED), any(Metadata.class)); in inboundStatusShouldSetStatus()
318 verify(listener).closed(captor.capture(), same(PROCESSED), metadataCaptor.capture()); in invalidInboundHeadersCancelStream()
337 verify(listener).closed(captor.capture(), same(PROCESSED), metadataCaptor.capture()); in invalidInboundContentTypeShouldCancelStream()
349 verify(listener).closed(captor.capture(), same(PROCESSED), any(Metadata.class)); in nonGrpcResponseShouldSetStatus()
385 verify(listener).closed(eq(Status.CANCELLED), same(PROCESSED), eq(trailers)); in deframedDataAfterCancelShouldBeIgnored()
[all …]
|
| D | NettyClientHandlerTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
202 verify(streamListener).closed(eq(Status.CANCELLED), same(PROCESSED), any(Metadata.class)); in cancelBufferedStreamShouldChangeClientStreamStatus()
371 verify(streamListener).closed(any(Status.class), eq(PROCESSED), any(Metadata.class)); in receivedResetWithCanceCode()
467 verify(streamListener).closed(eq(Status.CANCELLED), same(PROCESSED), any(Metadata.class)); in cancelStreamShouldCreateAndThenFailBufferedStream()
489 verify(streamListener).closed(captor.capture(), same(PROCESSED), notNull(Metadata.class)); in channelShutdownShouldFailInFlightStreams()
|
| D | NettyClientTransportTest.java | 701 closed(status, RpcProgress.PROCESSED, trailers); in closed()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 21 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
320 PROCESSED, false, null, null); in transportDataReceived()
331 transport.finishStream(id(),null, PROCESSED, false, ErrorCode.CANCEL, null); in onEndOfStream() local
333 transport.finishStream(id(), null, PROCESSED, false, null, null); in onEndOfStream() local
357 id(), reason, PROCESSED, stopDelivery, ErrorCode.CANCEL, trailers); in cancel() local
|
| D | OkHttpClientTransport.java | 1068 errorCode == ErrorCode.REFUSED_STREAM ? RpcProgress.REFUSED : RpcProgress.PROCESSED, in rstStream()
1171 streamId, Status.INTERNAL.withDescription(errorMsg), RpcProgress.PROCESSED, false, in windowUpdate()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 20 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
129 1234, Status.CANCELLED, PROCESSED, true, ErrorCode.CANCEL, null); in cancel_started()
133 verify(transport).finishStream(1234, Status.CANCELLED, PROCESSED,true, ErrorCode.CANCEL, null); in cancel_started()
|
| D | OkHttpClientTransportTest.java | 21 import static io.grpc.internal.ClientStreamListener.RpcProgress.PROCESSED;
1743 assertEquals(PROCESSED, listener1.rpcProgress); in goAway_streamListenerRpcProgress()
1778 assertEquals(PROCESSED, listener1.rpcProgress); in reset_streamListenerRpcProgress()
1784 assertEquals(PROCESSED, listener3.rpcProgress); in reset_streamListenerRpcProgress()
1965 closed(status, PROCESSED, trailers); in closed()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ClientStreamListener.java | 73 PROCESSED, enumConstant
|
| D | FailingClientStream.java | 38 this(error, RpcProgress.PROCESSED); in FailingClientStream()
|
| D | AbstractClientStream.java | 397 transportReportStatus(status, RpcProgress.PROCESSED, stopDelivery, trailers); in transportReportStatus()
|
| D | GrpcUtil.java | 707 return new FailingClientTransport(result.getStatus(), RpcProgress.PROCESSED); in getTransportFromPickResult()
|
| D | ClientCallImpl.java | 555 closed(status, RpcProgress.PROCESSED, trailers); in closed()
|
| D | RetriableStream.java | 548 closed(status, RpcProgress.PROCESSED, trailers); in closed()
|
| /external/tensorflow/tensorflow/core/grappler/utils/ |
| D | graph_view.cc | 1399 enum TraversalState : uint8_t { PENDING, PROCESSING, PROCESSED }; enumerator
1525 if (curr_traversal_state == PROCESSED) { in SortTopologically()
1535 curr_traversal_state = PROCESSED; in SortTopologically()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 373 ? RpcProgress.REFUSED : RpcProgress.PROCESSED, in onRstStreamRead()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 1091 closed(status, RpcProgress.PROCESSED, trailers); in clientCancelFromWithinMessageRead()
2006 closed(status, RpcProgress.PROCESSED, trailers); in closed()
|
| /external/libffi/ |
| D | texinfo.tex | 2860 % @inlinefmt{FMTNAME,PROCESSED-TEXT} and @inlineraw{FMTNAME,RAW-TEXT}.
|
| /external/python/cpython2/Modules/_ctypes/libffi/ |
| D | texinfo.tex | 2860 % @inlinefmt{FMTNAME,PROCESSED-TEXT} and @inlineraw{FMTNAME,RAW-TEXT}.
|
| /external/mtools/ |
| D | texinfo.tex | 3386 % @inlinefmt{FMTNAME,PROCESSED-TEXT} and @inlineraw{FMTNAME,RAW-TEXT}.
|