| /external/libchrome/base/ |
| D | cancelable_callback_unittest.cc | 111 EXPECT_FALSE(cancelable.IsCancelled()); in TEST()
117 EXPECT_TRUE(cancelable.IsCancelled()); in TEST()
139 EXPECT_FALSE(cancelable.IsCancelled()); in TEST()
159 EXPECT_TRUE(cancelable.IsCancelled()); in TEST()
164 EXPECT_FALSE(cancelable.IsCancelled()); in TEST()
167 EXPECT_TRUE(cancelable.IsCancelled()); in TEST()
|
| D | callback_internal.cc | 59 bool CallbackBase::IsCancelled() const { in IsCancelled() function in base::internal::CallbackBase
61 return bind_state_->IsCancelled(); in IsCancelled()
|
| D | callback_internal.h | 75 bool IsCancelled() const { in IsCancelled() function
113 bool IsCancelled() const;
|
| D | callback_unittest.cc | 25 FakeBindState() : BindStateBase(&NopInvokeFunc, &Destroy, &IsCancelled) {} in FakeBindState()
32 static bool IsCancelled(const internal::BindStateBase*) { in IsCancelled() function
|
| D | bind_unittest.cc | 1314 EXPECT_FALSE(cb4.IsCancelled()); in TEST_F()
1318 EXPECT_FALSE(cb.IsCancelled()); in TEST_F()
1319 EXPECT_FALSE(cb2.IsCancelled()); in TEST_F()
1320 EXPECT_FALSE(cb3.IsCancelled()); in TEST_F()
1321 EXPECT_FALSE(cb5.IsCancelled()); in TEST_F()
1328 EXPECT_TRUE(cb.IsCancelled()); in TEST_F()
1329 EXPECT_TRUE(cb2.IsCancelled()); in TEST_F()
1330 EXPECT_TRUE(cb3.IsCancelled()); in TEST_F()
1331 EXPECT_TRUE(cb5.IsCancelled()); in TEST_F()
|
| D | bind_internal.h | 733 return CallbackCancellationTraits<Functor, BoundArgsTuple>::IsCancelled(
933 static bool IsCancelled(const Functor&,
947 static bool IsCancelled(const Functor& functor, const BoundArgs&...) {
948 return functor.IsCancelled();
958 static bool IsCancelled(const Functor& functor, const BoundArgs&...) {
959 return functor.IsCancelled();
|
| D | cancelable_callback.h | 81 bool IsCancelled() const { in IsCancelled() function
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | FakeNativeCall.cs | 77 public bool IsCancelled property in Grpc.Core.Internal.Tests.FakeNativeCall
91 IsCancelled = true; in Cancel()
96 IsCancelled = true; in CancelWithStatus()
|
| D | AsyncCallTest.cs | 353 Assert.IsTrue(fakeCall.IsCancelled); in ClientStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
573 Assert.IsTrue(fakeCall.IsCancelled); in DuplexStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
592 Assert.IsTrue(fakeCall.IsCancelled); in DuplexStreaming_ReadAfterCancellationRequestCanSucceed()
614 Assert.IsTrue(fakeCall.IsCancelled); in DuplexStreaming_ReadStartedBeforeCancellationRequestCanSucceed()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | server_helper.cc | 72 bool InteropServerContextInspector::IsCancelled() const { in IsCancelled() function in grpc::testing::InteropServerContextInspector
73 return context_.IsCancelled(); in IsCancelled()
|
| D | server_helper.h | 44 bool IsCancelled() const;
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner.cc | 306 if (!tasks_.top().task.IsCancelled()) { in TakePendingTasks()
318 while (!tasks_.empty() && tasks_.top().task.IsCancelled()) in HasPendingTask()
328 if (!tasks_.top().task.IsCancelled()) { in GetPendingTaskCount()
341 while (!tasks_.empty() && tasks_.top().task.IsCancelled()) in NextPendingTaskDelay()
403 if (task_info.task.IsCancelled()) in ProcessAllTasksNoLaterThan()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | test_service_impl.cc | 114 while (!context->IsCancelled()) { in Echo()
130 EXPECT_FALSE(context->IsCancelled()); in Echo()
349 EXPECT_FALSE(context->IsCancelled()); in ServerTryCancel()
353 while (!context->IsCancelled()) { in ServerTryCancel()
|
| D | async_end2end_test.cc | 1105 EXPECT_TRUE(srv_ctx.IsCancelled()); in TEST_P()
1139 EXPECT_FALSE(srv_ctx.IsCancelled()); in TEST_P()
1229 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestClientStreamingServerCancel()
1291 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestClientStreamingServerCancel()
1313 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestClientStreamingServerCancel()
1390 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestServerStreamingServerCancel()
1441 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestServerStreamingServerCancel()
1461 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestServerStreamingServerCancel()
1556 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestBidiStreamingServerCancel()
1586 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestBidiStreamingServerCancel()
[all …]
|
| D | shutdown_test.cc | 52 while (!context->IsCancelled()) { in Echo()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | cancellation_test.cc | 98 TEST(Cancellation, IsCancelled) { in TEST() argument
105 while (!cm->IsCancelled()) { in TEST()
|
| D | cancellation.h | 57 bool IsCancelled() { return is_cancelled_.load(std::memory_order_acquire); } in IsCancelled() function
|
| /external/tensorflow/tensorflow/core/profiler/rpc/ |
| D | profiler_service_impl.cc | 52 if (ctx->IsCancelled()) { in Profile()
|
| /external/libusb/libusb/os/ |
| D | haiku_usb.h | 95 bool IsCancelled();
|
| D | haiku_usb_raw.cpp | 168 if (transfer->IsCancelled()) { in haiku_handle_transfer_completion()
|
| /external/libchrome/base/message_loop/ |
| D | message_loop.cc | 434 if (!pending_task.task.IsCancelled()) { in ProcessNextDelayedNonNestableTask()
510 if (pending_task.task.IsCancelled()) in DoWork()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 170 if (ctx_.IsCancelled()) { in RequestCancelled()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_context.cc | 182 bool ServerContext::IsCancelled() const { in IsCancelled() function in grpc::ServerContext
|
| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue.cc | 152 (!tasks_.front().task || tasks_.front().task.IsCancelled())) { in RemoveAllCanceledTasksFromFront()
|
| D | task_queue_impl.cc | 429 if (!task.task || task.task.IsCancelled()) { in WakeUpForDelayedWork()
762 state->SetBoolean("is_cancelled", task.task.IsCancelled()); in TaskAsValueInto()
871 if (!main_thread_only().delayed_incoming_queue.top().task.IsCancelled()) { in SweepCanceledDelayedTasks()
|