| /external/grpc-grpc/src/cpp/util/ |
| status.cc | 24 const Status& Status::CANCELLED = Status(StatusCode::CANCELLED, "");
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| StatusExceptionTest.java | 34 new StatusException(Status.CANCELLED, null, false) {}.getStackTrace();
42 new StatusException(Status.CANCELLED, null) {}.getStackTrace();
49 StackTraceElement[] trace = new StatusException(Status.CANCELLED) {}.getStackTrace();
57 StatusException exception = new StatusException(Status.CANCELLED, new Metadata()) {
|
| StatusRuntimeExceptionTest.java | 34 new StatusRuntimeException(Status.CANCELLED, null, false) {}.getStackTrace();
42 new StatusRuntimeException(Status.CANCELLED, null) {}.getStackTrace();
49 StackTraceElement[] trace = new StatusRuntimeException(Status.CANCELLED) {}.getStackTrace();
58 new StatusRuntimeException(Status.CANCELLED, new Metadata()) {
|
| StatusTest.java | 36 assertEquals("CANCELLED: This is a test",
37 Status.CANCELLED.withDescription("This is a test").asRuntimeException().getMessage());
39 assertEquals("CANCELLED: This is a test",
40 Status.CANCELLED.withDescription("This is a test").asException().getMessage());
50 assertSame(Status.CANCELLED, Status.CANCELLED.withCause(null));
55 assertSame(Status.CANCELLED, Status.CANCELLED.withDescription(null));
56 assertSame(Status.CANCELLED, Status.CANCELLED.augmentDescription(null))
[all...] |
| /external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/ |
| MojoResult.java | 12 public static final int CANCELLED = 1;
43 case CANCELLED:
44 return "CANCELLED";
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| status_code_enum.h | 28 /// The operation was cancelled (typically by the caller).
29 CANCELLED = 1,
|
| /external/opencensus-java/api/src/test/java/io/opencensus/trace/ |
| EndSpanOptionsTest.java | 45 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError"))
48 .isEqualTo(Status.CANCELLED.withDescription("ThisIsAnError"));
63 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError"))
66 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError"))
76 .setStatus(Status.CANCELLED.withDescription("ThisIsAnError"))
|
| StatusTest.java | 49 Status.CANCELLED.withDescription("ThisIsAnError"),
50 Status.CANCELLED.withDescription("ThisIsAnError"));
|
| /external/protobuf/src/google/protobuf/stubs/ |
| status_test.cc | 48 EXPECT_EQ(util::error::CANCELLED, util::Status::CANCELLED.error_code());
107 const util::Status a = util::Status(util::error::CANCELLED, "message");
108 const util::Status b = util::Status(util::error::CANCELLED, "message");
113 const util::Status a = util::Status(util::error::CANCELLED, "message");
119 const util::Status a = util::Status(util::error::CANCELLED, "message");
125 const util::Status a = util::Status(util::error::CANCELLED, "message");
126 const util::Status b = util::Status(util::error::CANCELLED, "another");
|
| statusor_test.cc | 78 StatusOr<int> thing(Status::CANCELLED);
80 EXPECT_EQ(Status::CANCELLED, thing.status());
99 StatusOr<int> original(Status::CANCELLED);
113 StatusOr<int> original(Status::CANCELLED);
128 StatusOr<int> source(Status::CANCELLED);
144 StatusOr<int> source(Status::CANCELLED);
153 StatusOr<int> bad(Status::CANCELLED);
155 EXPECT_EQ(Status::CANCELLED, bad.status());
177 StatusOr<int*> thing(Status::CANCELLED);
179 EXPECT_EQ(Status::CANCELLED, thing.status())
[all...] |
| status.cc | 45 case CANCELLED:
46 return "CANCELLED";
86 const Status Status::CANCELLED = Status(error::CANCELLED, "");
|
| status.h | 46 CANCELLED = 1,
81 static const Status CANCELLED;
|
| /external/grpc-grpc/test/cpp/end2end/ |
| test_service_impl.cc | 101 return Status::CANCELLED;
120 return Status::CANCELLED;
127 return Status::CANCELLED;
148 return Status::CANCELLED;
173 // If 'server_try_cancel' is set in the metadata, the RPC is cancelled by
175 // CANCEL_BEFORE_PROCESSING: The RPC is cancelled before the server reads
177 // CANCEL_DURING_PROCESSING: The RPC is cancelled while the server is
179 // CANCEL_AFTER_PROCESSING: The RPC is cancelled after the server reads
189 return Status::CANCELLED;
207 return Status::CANCELLED;
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| AbstractFuture.java | 50 * completed, failed, or cancelled.
154 * Returns true if this future was cancelled with {@code
213 * {@link #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED}
218 * computation, and only then transition to COMPLETED, CANCELLED, or
232 static final int CANCELLED = 4;
278 * was cancelled, or a {@link ExecutionException} if the task completed with
304 case CANCELLED:
307 "Task was cancelled.", exception);
316 * Checks if the state is {@link #COMPLETED}, {@link #CANCELLED}, or {@link
320 return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0
[all...] |
| /external/tensorflow/tensorflow/stream_executor/lib/ |
| statusor_test.cc | 88 StatusOr<NoDefaultConstructor> statusor(tensorflow::errors::Cancelled(""));
90 EXPECT_EQ(statusor.status().code(), tensorflow::error::CANCELLED);
111 StatusOr<std::unique_ptr<int>> thing(tensorflow::errors::Cancelled(""));
232 StatusOr<int> thing(Status(tensorflow::error::CANCELLED, ""));
234 EXPECT_EQ(thing.status().code(), tensorflow::error::CANCELLED);
253 StatusOr<int> original(Status(tensorflow::error::CANCELLED, ""));
276 StatusOr<int> original(Status(tensorflow::error::CANCELLED, ""));
291 StatusOr<int> source(Status(tensorflow::error::CANCELLED, ""));
300 StatusOr<int> bad(Status(tensorflow::error::CANCELLED, ""));
302 EXPECT_EQ(bad.status(), Status(tensorflow::error::CANCELLED, ""));
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| DelayedStreamTest.java | 204 stream.cancel(Status.CANCELLED);
205 verify(listener).closed(eq(Status.CANCELLED), any(Metadata.class));
212 stream.cancel(Status.CANCELLED);
214 verify(realStream).cancel(same(Status.CANCELLED));
221 stream.cancel(Status.CANCELLED);
223 verify(realStream).cancel(same(Status.CANCELLED));
229 stream.cancel(Status.CANCELLED);
230 verify(realStream).cancel(same(Status.CANCELLED));
245 stream.cancel(Status.CANCELLED);
254 Status status = Status.CANCELLED.withDescription("that was quick")
[all...] |
| /external/grpc-grpc/examples/ruby/errors_and_cancellation/ |
| error_examples_server.rb | 44 raise GRPC::BadStatus.new_status_exception(CANCELLED)
|
| /external/grpc-grpc/test/core/transport/ |
| status_metadata_test.cc | 32 TEST(GetStatusCodeFromMetadata, CANCELLED) {
|
| /external/opencensus-java/contrib/grpc_util/src/main/java/io/opencensus/contrib/grpc/util/ |
| StatusConverter.java | 87 case CANCELLED:
88 return io.opencensus.trace.Status.CANCELLED;
128 case CANCELLED:
129 return io.grpc.Status.CANCELLED;
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| Contexts.java | 124 * Returns the {@link Status} of a cancelled context or {@code null} if the context
125 * is not cancelled.
136 return Status.CANCELLED.withDescription("io.grpc.Context was cancelled without error");
147 // just return CANCELLED.
148 return Status.CANCELLED.withDescription("Context cancelled").withCause(cancellationCause);
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| _base.py | 19 # The future was cancelled by the user...
20 CANCELLED = 'CANCELLED'
28 CANCELLED,
36 CANCELLED: "cancelled",
37 CANCELLED_AND_NOTIFIED: "cancelled",
49 """The Future was cancelled."""
207 cancelled). If any given Futures are duplicated, they will be returned
272 cancelled
367 def cancelled(self): member in class:Future
[all...] |
| /external/python/futures/concurrent/futures/ |
| _base.py | 21 # The future was cancelled by the user...
22 CANCELLED = 'CANCELLED'
30 CANCELLED,
38 CANCELLED: "cancelled",
39 CANCELLED_AND_NOTIFIED: "cancelled",
51 """The Future was cancelled."""
209 cancelled). If any given Futures are duplicated, they will be returned
278 cancelled
390 def cancelled(self): member in class:Future
[all...] |
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| _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/opencensus-java/api/src/main/java/io/opencensus/trace/ |
| Status.java | 58 * The operation was cancelled (typically by the caller).
62 CANCELLED(1),
263 * The operation was cancelled (typically by the caller).
267 public static final Status CANCELLED = CanonicalCode.CANCELLED.toStatus();
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| OkHttpClientStreamTest.java | 113 stream.cancel(Status.CANCELLED);
115 assertEquals(Status.Code.CANCELLED, statusRef.get().getCode());
129 1234, Status.CANCELLED, PROCESSED, true, ErrorCode.CANCEL, null);
131 stream.cancel(Status.CANCELLED);
133 verify(transport).finishStream(1234, Status.CANCELLED, PROCESSED,true, ErrorCode.CANCEL, null);
139 stream.cancel(Status.CANCELLED);
|
