| /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/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 | 50 EXPECT_EQ(util::error::CANCELLED, util::Status::CANCELLED.error_code()); in TEST()
51 EXPECT_EQ(util::error::CANCELLED, util::Status::CANCELLED.code()); in TEST()
114 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
115 const util::Status b = util::Status(util::error::CANCELLED, "message"); in TEST()
120 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
126 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
132 const util::Status a = util::Status(util::error::CANCELLED, "message"); in TEST()
133 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/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/python/cpython3/Lib/concurrent/futures/ |
| D | _base.py | 21 CANCELLED = 'CANCELLED' variable
29 CANCELLED,
37 CANCELLED: "cancelled",
363 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
366 self._state = CANCELLED
375 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]
385 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]
405 if self._state not in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]:
430 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
437 if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:
[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/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-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureBenchmarks.java | 269 static final int CANCELLED = 4; field in AbstractFutureBenchmarks.OldAbstractFuture.Sync
338 case CANCELLED: in getValue()
349 return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0; in isDone()
354 return (getState() & (CANCELLED | INTERRUPTED)) != 0; in isCancelled()
374 return complete(null, null, interrupt ? INTERRUPTED : CANCELLED); in cancel()
395 ((finalState & (CANCELLED | INTERRUPTED)) != 0) in complete()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractFutureBenchmarks.java | 269 static final int CANCELLED = 4; field in AbstractFutureBenchmarks.OldAbstractFuture.Sync
338 case CANCELLED: in getValue()
349 return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0; in isDone()
354 return (getState() & (CANCELLED | INTERRUPTED)) != 0; in isCancelled()
374 return complete(null, null, interrupt ? INTERRUPTED : CANCELLED); in cancel()
395 ((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/rust/crates/grpcio-sys/grpc/src/cpp/util/ |
| D | status.cc | 24 const Status& Status::CANCELLED = Status(StatusCode::CANCELLED, ""); member in grpc::Status
|
| /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/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/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/rust/crates/tokio/src/runtime/task/ |
| D | state.rs | 38 const CANCELLED: usize = 0b100_000; constant
41 const STATE_MASK: usize = LIFECYCLE_MASK | NOTIFIED | JOIN_INTEREST | JOIN_WAKER | CANCELLED;
372 self.0 & CANCELLED == CANCELLED in is_cancelled()
376 self.0 |= CANCELLED; in set_cancelled()
|
| /external/protobuf/src/google/protobuf/util/internal/ |
| D | json_stream_parser.cc | 57 using util::error::CANCELLED;
253 result == util::Status(util::error::CANCELLED, "")) { in RunParser()
297 return util::Status(util::error::CANCELLED, ""); in ParseValue()
335 return util::Status(util::error::CANCELLED, ""); in ParseStringHelper()
403 return util::Status(util::error::CANCELLED, ""); in ParseStringHelper()
420 return util::Status(util::error::CANCELLED, ""); in ParseUnicodeEscape()
437 return util::Status(util::error::CANCELLED, ""); in ParseUnicodeEscape()
544 return util::Status(util::error::CANCELLED, ""); in ParseNumberHelper()
712 if (result == util::Status(util::error::CANCELLED, "")) { in ParseArrayValue()
791 return util::Status(util::error::CANCELLED, ""); in ReportUnknown()
[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/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionSequencer.java | 19 import static com.google.common.util.concurrent.ExecutionSequencer.RunningState.CANCELLED;
260 CANCELLED,
324 if (get() == RunningState.CANCELLED) {
413 return compareAndSet(NOT_RUN, CANCELLED);
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionSequencer.java | 19 import static com.google.common.util.concurrent.ExecutionSequencer.RunningState.CANCELLED;
260 CANCELLED,
324 if (get() == RunningState.CANCELLED) {
413 return compareAndSet(NOT_RUN, CANCELLED);
|