| /external/protobuf/src/google/protobuf/stubs/ |
| D | statusor_test.cc | 78 StatusOr<int> thing(Status::CANCELLED); in TEST()
80 EXPECT_EQ(Status::CANCELLED, thing.status()); in TEST()
99 StatusOr<int> original(Status::CANCELLED); in TEST()
113 StatusOr<int> original(Status::CANCELLED); in TEST()
128 StatusOr<int> source(Status::CANCELLED); in TEST()
144 StatusOr<int> source(Status::CANCELLED); in TEST()
153 StatusOr<int> bad(Status::CANCELLED); in TEST()
155 EXPECT_EQ(Status::CANCELLED, bad.status()); in TEST()
177 StatusOr<int*> thing(Status::CANCELLED); in TEST()
179 EXPECT_EQ(Status::CANCELLED, thing.status()); in TEST()
[all …]
|
| D | status_test.cc | 48 EXPECT_EQ(util::error::CANCELLED, util::Status::CANCELLED.error_code()); in TEST()
107 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
108 const util::Status b = util::Status(util::error::CANCELLED, "message"); in TEST()
113 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
119 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
125 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
126 const util::Status b = util::Status(util::error::CANCELLED, "another"); in TEST()
|
| D | status.cc | 45 case CANCELLED: in CodeEnumToString()
86 const Status Status::CANCELLED = Status(error::CANCELLED, ""); member in google::protobuf::util::Status
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | StatusTest.java | 37 Status.CANCELLED.withDescription("This is a test").asRuntimeException().getMessage()); in verifyExceptionMessage()
40 Status.CANCELLED.withDescription("This is a test").asException().getMessage()); in verifyExceptionMessage()
50 assertSame(Status.CANCELLED, Status.CANCELLED.withCause(null)); in sameCauseReturnsSelf()
55 assertSame(Status.CANCELLED, Status.CANCELLED.withDescription(null)); in sameDescriptionReturnsSelf()
56 assertSame(Status.CANCELLED, Status.CANCELLED.augmentDescription(null)); in sameDescriptionReturnsSelf()
61 assertEquals(Status.CANCELLED.hashCode(), System.identityHashCode(Status.CANCELLED)); in useObjectHashCode()
|
| D | StatusExceptionTest.java | 34 new StatusException(Status.CANCELLED, null, false) {}.getStackTrace(); in internalCtorRemovesStack()
42 new StatusException(Status.CANCELLED, null) {}.getStackTrace(); in normalCtorKeepsStack()
49 StackTraceElement[] trace = new StatusException(Status.CANCELLED) {}.getStackTrace(); in extendPreservesStack()
57 StatusException exception = new StatusException(Status.CANCELLED, new Metadata()) { in extendAndOverridePreservesStack()
|
| D | StatusRuntimeExceptionTest.java | 34 new StatusRuntimeException(Status.CANCELLED, null, false) {}.getStackTrace(); in internalCtorRemovesStack()
42 new StatusRuntimeException(Status.CANCELLED, null) {}.getStackTrace(); in normalCtorKeepsStack()
49 StackTraceElement[] trace = new StatusRuntimeException(Status.CANCELLED) {}.getStackTrace(); in extendPreservesStack()
58 new StatusRuntimeException(Status.CANCELLED, new Metadata()) { in extendAndOverridePreservesStack()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | test_service_impl.cc | 101 return Status::CANCELLED; in Echo()
120 return Status::CANCELLED; in Echo()
127 return Status::CANCELLED; in Echo()
148 return Status::CANCELLED; in Echo()
189 return Status::CANCELLED; in RequestStream()
207 return Status::CANCELLED; in RequestStream()
212 return Status::CANCELLED; in RequestStream()
243 return Status::CANCELLED; in ResponseStream()
265 return Status::CANCELLED; in ResponseStream()
270 return Status::CANCELLED; in ResponseStream()
[all …]
|
| /external/tensorflow/tensorflow/stream_executor/lib/ |
| D | statusor_test.cc | 90 EXPECT_EQ(statusor.status().code(), tensorflow::error::CANCELLED); in TEST()
232 StatusOr<int> thing(Status(tensorflow::error::CANCELLED, "")); in TEST()
234 EXPECT_EQ(thing.status().code(), tensorflow::error::CANCELLED); in TEST()
253 StatusOr<int> original(Status(tensorflow::error::CANCELLED, "")); in TEST()
276 StatusOr<int> original(Status(tensorflow::error::CANCELLED, "")); in TEST()
291 StatusOr<int> source(Status(tensorflow::error::CANCELLED, "")); in TEST()
300 StatusOr<int> bad(Status(tensorflow::error::CANCELLED, "")); in TEST()
302 EXPECT_EQ(bad.status(), Status(tensorflow::error::CANCELLED, "")); in TEST()
318 StatusOr<int> thing(Status(tensorflow::error::CANCELLED, "cancelled")); in TEST()
339 StatusOr<int*> thing(Status(tensorflow::error::CANCELLED, "")); in TEST()
[all …]
|
| /external/opencensus-java/api/src/test/java/io/opencensus/trace/ |
| D | EndSpanOptionsTest.java | 45 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError")) in setStatus_Error()
48 .isEqualTo(Status.CANCELLED.withDescription("ThisIsAnError")); in setStatus_Error()
63 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError")) in endSpanOptions_EqualsAndHashCode()
66 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError")) in endSpanOptions_EqualsAndHashCode()
76 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError")) in endSpanOptions_ToString()
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | _base.py | 20 CANCELLED = 'CANCELLED' variable
28 CANCELLED,
36 CANCELLED: "cancelled",
358 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
361 self._state = CANCELLED
370 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]
380 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]
400 if self._state not in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]:
422 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
429 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedStreamTest.java | 204 stream.cancel(Status.CANCELLED); in startThenCancelled()
205 verify(listener).closed(eq(Status.CANCELLED), any(Metadata.class)); in startThenCancelled()
212 stream.cancel(Status.CANCELLED); in startThenSetStreamThenCancelled()
214 verify(realStream).cancel(same(Status.CANCELLED)); in startThenSetStreamThenCancelled()
221 stream.cancel(Status.CANCELLED); in setStreamThenStartThenCancelled()
223 verify(realStream).cancel(same(Status.CANCELLED)); in setStreamThenStartThenCancelled()
229 stream.cancel(Status.CANCELLED); in setStreamThenCancelled()
230 verify(realStream).cancel(same(Status.CANCELLED)); in setStreamThenCancelled()
245 stream.cancel(Status.CANCELLED); in cancelThenSetStream()
254 Status status = Status.CANCELLED.withDescription("that was quick"); in cancel_beforeStart()
[all …]
|
| /external/python/futures/concurrent/futures/ |
| D | _base.py | 22 CANCELLED = 'CANCELLED' variable
30 CANCELLED,
38 CANCELLED: "cancelled",
381 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
384 self._state = CANCELLED
393 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]
403 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]
430 if self._state not in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]:
452 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
459 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 232 static final int CANCELLED = 4; field in AbstractFuture.Sync
304 case CANCELLED: in getValue()
320 return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0; in isDone()
327 return (getState() & (CANCELLED | INTERRUPTED)) != 0; in isCancelled()
355 return complete(null, null, interrupt ? INTERRUPTED : CANCELLED); in cancel()
378 this.exception = ((finalState & (CANCELLED | INTERRUPTED)) != 0) in complete()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_close_test.py | 116 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
127 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
138 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
156 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
181 self.assertIs(response_iterator.code(), grpc.StatusCode.CANCELLED)
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 113 stream.cancel(Status.CANCELLED); in cancel_notStarted()
115 assertEquals(Status.Code.CANCELLED, statusRef.get().getCode()); in cancel_notStarted()
129 1234, Status.CANCELLED, PROCESSED, true, ErrorCode.CANCEL, null); in cancel_started()
131 stream.cancel(Status.CANCELLED); in cancel_started()
133 verify(transport).finishStream(1234, Status.CANCELLED, PROCESSED,true, ErrorCode.CANCEL, null); in cancel_started()
139 stream.cancel(Status.CANCELLED); in start_alreadyCancelled()
|
| D | OkHttpClientTransportTest.java | 476 getStream(3).cancel(Status.CANCELLED); in cancelStream()
499 getStream(3).cancel(Status.CANCELLED); in addDefaultUserAgent()
518 getStream(3).cancel(Status.CANCELLED); in overrideDefaultUserAgent()
552 stream.cancel(Status.CANCELLED); in writeMessage()
633 stream1.cancel(Status.CANCELLED); in windowUpdate()
639 stream2.cancel(Status.CANCELLED); in windowUpdate()
672 getStream(3).cancel(Status.CANCELLED); in windowUpdateWithInboundFlowControl()
712 stream.cancel(Status.CANCELLED); in outboundFlowControl()
758 stream.cancel(Status.CANCELLED); in outboundFlowControlWithInitialWindowSizeChange()
792 stream.cancel(Status.CANCELLED); in outboundFlowControlWithInitialWindowSizeChangeInMiddleOfStream()
[all …]
|
| /external/protobuf/src/google/protobuf/util/internal/ |
| D | json_stream_parser.cc | 245 if (!finishing_ && result == util::Status::CANCELLED) { in RunParser()
285 return util::Status::CANCELLED; in ParseValue()
324 return util::Status::CANCELLED; in ParseStringHelper()
393 return util::Status::CANCELLED; in ParseStringHelper()
410 return util::Status::CANCELLED; in ParseUnicodeEscape()
427 return util::Status::CANCELLED; in ParseUnicodeEscape()
521 return util::Status::CANCELLED; in ParseNumberHelper()
671 if (result == util::Status::CANCELLED) { in ParseArrayValue()
738 return util::Status::CANCELLED; in ReportUnknown()
768 return util::Status::CANCELLED; in ParseKey()
|
| /external/opencensus-java/contrib/grpc_util/src/main/java/io/opencensus/contrib/grpc/util/ |
| D | StatusConverter.java | 87 case CANCELLED: in opencensusStatusFromGrpcCode()
88 return io.opencensus.trace.Status.CANCELLED; in opencensusStatusFromGrpcCode()
128 case CANCELLED: in grpcStatusFromOpencensusCanonicalCode()
129 return io.grpc.Status.CANCELLED; in grpcStatusFromOpencensusCanonicalCode()
|
| /external/grpc-grpc/src/cpp/util/ |
| D | status.cc | 24 const Status& Status::CANCELLED = Status(StatusCode::CANCELLED, ""); member in grpc::Status
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientHandlerTest.java | 199 cancelStream(Status.CANCELLED); in cancelBufferedStreamShouldChangeClientStreamStatus()
202 verify(streamListener).closed(eq(Status.CANCELLED), same(PROCESSED), any(Metadata.class)); in cancelBufferedStreamShouldChangeClientStreamStatus()
215 cancelStream(Status.CANCELLED); in cancelShouldSucceed()
241 ChannelFuture cancelFuture = cancelStream(Status.CANCELLED); in cancelWhileBufferedShouldSucceed()
256 cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed()
261 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed()
274 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceDifferentReasons()
383 assertEquals(Status.CANCELLED.getCode(), captor.getValue().getCode()); in receivedGoAwayShouldFailUnknownStreams()
399 assertEquals(Status.CANCELLED.getCode(), status.getCode()); in receivedGoAwayShouldFailUnknownBufferedStreams()
414 assertEquals(Status.CANCELLED.getCode(), status.getCode()); in receivedGoAwayShouldFailNewStreams()
[all …]
|
| /external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/ |
| D | MojoResult.java | 12 public static final int CANCELLED = 1; field in MojoResult
43 case CANCELLED: in describe()
|
| /external/grpc-grpc/src/cpp/ext/ |
| D | proto_server_reflection.cc | 116 return Status::CANCELLED; in GetFileByName()
133 return Status::CANCELLED; in GetFileContainingSymbol()
150 return Status::CANCELLED; in GetFileContainingExtension()
174 return Status::CANCELLED; in GetAllExtensionNumbers()
|
| /external/opencensus-java/impl_core/src/test/java/io/opencensus/implcore/trace/export/ |
| D | InProcessSampledSpanStoreImplTest.java | 216 span.end(EndSpanOptions.builder().setStatus(Status.CANCELLED).build()); in getErrorSampledSpans()
219 ErrorFilter.create(REGISTERED_SPAN_NAME, CanonicalCode.CANCELLED, 0)); in getErrorSampledSpans()
228 span1.end(EndSpanOptions.builder().setStatus(Status.CANCELLED).build()); in getErrorSampledSpans_MaxSpansToReturn()
233 span2.end(EndSpanOptions.builder().setStatus(Status.CANCELLED).build()); in getErrorSampledSpans_MaxSpansToReturn()
236 ErrorFilter.create(REGISTERED_SPAN_NAME, CanonicalCode.CANCELLED, 1)); in getErrorSampledSpans_MaxSpansToReturn()
246 span1.end(EndSpanOptions.builder().setStatus(Status.CANCELLED).build()); in getErrorSampledSpans_NullCode()
260 span1.end(EndSpanOptions.builder().setStatus(Status.CANCELLED).build()); in getErrorSampledSpans_NullCode_MaxSpansToReturn()
|
| /external/opencensus-java/api/src/main/java/io/opencensus/trace/ |
| D | Status.java | 62 CANCELLED(1), enumConstant
267 public static final Status CANCELLED = CanonicalCode.CANCELLED.toStatus(); field in Status
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ClientCallImpl.java | 386 Status status = Status.CANCELLED; in cancel()
425 stream.cancel(Status.CANCELLED.withCause(e).withDescription("Failed to stream message")); in sendMessage()
428 stream.cancel(Status.CANCELLED.withDescription("Client sendMessage() failed with Error")); in sendMessage()
491 Status.CANCELLED.withCause(t).withDescription("Failed to read headers"); in headersRead()
529 Status.CANCELLED.withCause(t).withDescription("Failed to read message."); in messagesAvailable()
561 if (status.getCode() == Status.Code.CANCELLED && deadline != null) { in closed()
604 Status.CANCELLED.withCause(t).withDescription("Failed to call onReady."); in onReady()
|