| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | CallCancellationTest.cs | 83 Assert.AreEqual(StatusCode.Cancelled, ex.Status.StatusCode); in ClientStreamingCall_CancelAfterBegin()
120 Assert.AreEqual(StatusCode.Cancelled, ex.Status.StatusCode); in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
146 Assert.AreEqual(StatusCode.Cancelled, ex.Status.StatusCode); in ClientStreamingCall_CancelServerSideRead()
178 Assert.AreEqual(StatusCode.Cancelled, ex.Status.StatusCode); in ServerStreamingCall_CancelClientSideRead()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | fifo_queue.cc | 65 errors::Cancelled("FIFOQueue '", name_, "' is closed.")); in TryEnqueue()
82 ctx->SetStatus(errors::Cancelled("Enqueue operation was cancelled")); in TryEnqueue()
123 errors::Cancelled("FIFOQueue '", name_, "' is closed.")); in TryEnqueueMany()
150 ctx->SetStatus(errors::Cancelled("Enqueue operation was cancelled")); in TryEnqueueMany()
190 ctx->SetStatus(errors::Cancelled("Dequeue operation was cancelled")); in TryDequeue()
353 ctx->SetStatus(errors::Cancelled("Dequeue operation was cancelled")); in TryDequeueMany()
|
| D | priority_queue.cc | 86 errors::Cancelled("PriorityQueue '", name_, "' is closed.")); in TryEnqueue()
111 ctx->SetStatus(errors::Cancelled("Enqueue operation was cancelled")); in TryEnqueue()
151 errors::Cancelled("PriorityQueue '", name_, "' is closed.")); in TryEnqueueMany()
192 ctx->SetStatus(errors::Cancelled("Enqueue operation was cancelled")); in TryEnqueueMany()
233 ctx->SetStatus(errors::Cancelled("Dequeue operation was cancelled")); in TryDequeue()
383 ctx->SetStatus(errors::Cancelled("Dequeue operation was cancelled")); in TryDequeueMany()
|
| D | random_shuffle_queue_op.cc | 141 attempt->context->SetStatus(errors::Cancelled( in TryEnqueue()
159 ctx->SetStatus(errors::Cancelled("Enqueue operation was cancelled")); in TryEnqueue()
199 attempt->context->SetStatus(errors::Cancelled( in TryEnqueueMany()
227 ctx->SetStatus(errors::Cancelled("Enqueue operation was cancelled")); in TryEnqueueMany()
269 ctx->SetStatus(errors::Cancelled("Dequeue operation was cancelled")); in TryDequeue()
431 ctx->SetStatus(errors::Cancelled("Dequeue operation was cancelled")); in TryDequeueMany()
|
| D | queue_base.cc | 203 errors::Cancelled("Enqueue operation was cancelled")); in Cancel()
206 errors::Cancelled("Dequeue operation was cancelled")); in Cancel()
229 errors::Cancelled("Enqueue operation was cancelled")); in CloseAndCancel()
253 errors::Cancelled("Queue '", name_, "' is already closed.")); in Close()
|
| D | conditional_accumulator_base.cc | 101 ctx->SetStatus(errors::Cancelled("TakeGrad operation was cancelled")); in TryTakeGrad()
122 errors::Cancelled("TakeGrad operation was cancelled")); in Cancel()
|
| D | mutex_ops.cc | 126 fn(errors::Cancelled("Lock acquisition cancelled."), in AcquireAsync()
151 fn_(errors::Cancelled("Lock acquisition cancelled."), in AcquireAsync()
|
| D | barrier_ops.cc | 117 errors::Cancelled( in TryInsertMany()
260 errors::Cancelled("Barrier '", name_, "' is already closed.")); in Close()
318 return errors::Cancelled( in InsertOneLocked()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallTest.cs | 359 CreateClientSideStatus(StatusCode.Cancelled), in ClientStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
363 AssertUnaryResponseError(asyncCall, fakeCall, resultTask, StatusCode.Cancelled); in ClientStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
580 …tatusOnClientCallback.OnReceivedStatusOnClient(true, CreateClientSideStatus(StatusCode.Cancelled)); in DuplexStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
582 AssertStreamingResponseError(asyncCall, fakeCall, readTask, StatusCode.Cancelled); in DuplexStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
601 …tatusOnClientCallback.OnReceivedStatusOnClient(true, CreateClientSideStatus(StatusCode.Cancelled)); in DuplexStreaming_ReadAfterCancellationRequestCanSucceed()
603 AssertStreamingResponseError(asyncCall, fakeCall, readTask2, StatusCode.Cancelled); in DuplexStreaming_ReadAfterCancellationRequestCanSucceed()
622 …tatusOnClientCallback.OnReceivedStatusOnClient(true, CreateClientSideStatus(StatusCode.Cancelled)); in DuplexStreaming_ReadStartedBeforeCancellationRequestCanSucceed()
624 AssertStreamingResponseError(asyncCall, fakeCall, readTask2, StatusCode.Cancelled); in DuplexStreaming_ReadStartedBeforeCancellationRequestCanSucceed()
|
| /external/grpc-grpc/src/ruby/lib/grpc/ |
| D | errors.rb | 57 codes[CANCELLED] = Cancelled
91 class Cancelled < BadStatus class
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | StatusCode.cs | 31 Cancelled = 1, enumerator
|
| D | Status.cs | 34 public static readonly Status DefaultCancelled = new Status(StatusCode.Cancelled, "");
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | cancellable_call.h | 51 done(errors::Cancelled("RPC Request was cancelled")); in Start()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | reader_op_kernel.h | 63 context->SetStatus(errors::Cancelled("read operation was cancelled")); in Compute()
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | errors.h | 103 DECLARE_ERROR(Cancelled, CANCELLED) in DECLARE_ERROR() argument
|
| D | status_test.cc | 115 const Status cancelled(errors::Cancelled("Cancelled after 10 steps.")); in TEST()
|
| /external/tensorflow/tensorflow/core/util/rpc/ |
| D | call_container.h | 152 ctx_->SetStatus(errors::Cancelled("Operation has been cancelled.")); in CallContainer()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| D | MathClientServerTests.cs | 127 Assert.AreEqual(StatusCode.Cancelled, e.Status.StatusCode); in FibWithCancel()
|
| /external/python/cpython2/Demo/tkinter/guido/ |
| D | sortvisu.py | 85 Cancelled = "Array.Cancelled" # Exception variable in Array
104 raise Array.Cancelled
600 except Array.Cancelled:
|
| /external/python/cpython3/Tools/demo/ |
| D | sortvisu.py | 31 class Cancelled(BaseException): class in Array
102 raise Array.Cancelled
601 except Array.Cancelled:
|
| /external/tensorflow/tensorflow/compiler/xla/ |
| D | util.h | 242 Status Cancelled(const absl::FormatSpec<Args...>& format, const Args&... args) { in Cancelled() function
244 tensorflow::errors::Cancelled(absl::StrFormat(format, args...))); in Cancelled()
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | InteropClient.cs | 412 Assert.AreEqual(StatusCode.Cancelled, ex.Status.StatusCode); in RunCancelAfterBeginAsync()
443 Assert.AreEqual(StatusCode.Cancelled, ex.Status.StatusCode); in RunCancelAfterFirstResponseAsync()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | multi_device_iterator_ops.cc | 186 elem.status = errors::Cancelled("Cancelled Multidevice iterator"); in GetNextFromShard()
246 errors::Cancelled("Cancelled and buffer not filled."); in RunPendingCallbacks()
|
| /external/tensorflow/tensorflow/stream_executor/lib/ |
| D | statusor_test.cc | 88 StatusOr<NoDefaultConstructor> statusor(tensorflow::errors::Cancelled("")); in TEST()
111 StatusOr<std::unique_ptr<int>> thing(tensorflow::errors::Cancelled("")); in TEST()
|
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
| D | cpu_transfer_manager.cc | 117 b->Done(Cancelled("Failed to infeed buffer to device.")); in TransferLiteralToInfeed()
|