| /external/crosvm/devices/src/usb/host_backend/ |
| D | utils.rs | 25 if status == TransferStatus::Cancelled { in update_transfer_state()
26 *state = XhciTransferState::Cancelled; in update_transfer_state()
32 *state = XhciTransferState::Cancelled; in update_transfer_state()
59 match mem::replace(&mut *state, XhciTransferState::Cancelled) { in submit_transfer()
82 XhciTransferState::Cancelled => { in submit_transfer()
84 TransferStatus::Cancelled in submit_transfer()
|
| D | usb_endpoint.rs | 149 XhciTransferState::Cancelled => { in do_handle_transfer()
153 .on_transfer_complete(&TransferStatus::Cancelled, 0) in do_handle_transfer()
204 XhciTransferState::Cancelled => { in do_handle_transfer()
208 .on_transfer_complete(&TransferStatus::Cancelled, 0) in do_handle_transfer()
|
| D | host_device.rs | 199 XhciTransferState::Cancelled => { in execute_control_transfer()
203 .on_transfer_complete(&TransferStatus::Cancelled, 0) in execute_control_transfer()
|
| /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 | 94 fn(errors::Cancelled("Lock acquisition cancelled."), in AcquireAsync()
119 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/tensorflow/tensorflow/core/framework/ |
| D | local_rendezvous.cc | 100 StartAbort(errors::Cancelled("LocalRendezvous deleted")); in ~LocalRendezvous()
218 errors::Cancelled("RecvAsync is cancelled.")), in RecvAsync()
227 errors::Cancelled("RecvAsync is cancelled.")), in RecvAsync()
|
| D | reader_op_kernel.h | 63 context->SetStatus(errors::Cancelled("read operation was cancelled")); in Compute()
|
| /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/crosvm/devices/src/usb/xhci/ |
| D | xhci_transfer.rs | 73 Cancelled, enumerator
91 *self = XhciTransferState::Cancelled; in try_cancel()
296 TransferStatus::Cancelled => { in on_transfer_complete()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | cancellable_call.h | 51 done(errors::Cancelled("RPC Request was cancelled")); in Start()
|
| D | base_rendezvous_mgr.cc | 439 call->StartAbort(errors::Cancelled("RecvFromRemoteAsync is cancelled.")); in RegisterCall()
445 call->StartAbort(errors::Cancelled("RecvFromRemoteAsync is cancelled.")); in RegisterCall()
|
| /external/crosvm/usb_util/src/ |
| D | usb_transfer.rs | 25 Cancelled, enumerator
37 LIBUSB_TRANSFER_CANCELLED => TransferStatus::Cancelled, in from()
|
| /external/tensorflow/tensorflow/core/platform/ |
| D | errors.h | 104 DECLARE_ERROR(Cancelled, CANCELLED) in DECLARE_ERROR() argument
|
| /external/tensorflow/tensorflow/core/util/rpc/ |
| D | call_container.h | 152 ctx_->SetStatus(errors::Cancelled("Operation has been cancelled.")); in CallContainer()
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | sleep_dataset_op.cc | 132 return errors::Cancelled("Operation was cancelled"); in GetNextInternal()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| D | MathClientServerTests.cs | 127 Assert.AreEqual(StatusCode.Cancelled, e.Status.StatusCode); in FibWithCancel()
|