| /third_party/grpc/test/cpp/end2end/ |
| D | test_service_impl.cc | 108 EXPECT_FALSE(context->IsCancelled()); in ServerTryCancel()
112 while (!context->IsCancelled()) { in ServerTryCancel()
119 EXPECT_FALSE(context->IsCancelled()); in ServerTryCancelNonblocking()
140 async_cancel_check_ = std::thread([this] { (void)ctx_->IsCancelled(); }); in Echo()
177 EXPECT_TRUE(ctx_->IsCancelled()); in Echo()
186 EXPECT_EQ(ctx_->IsCancelled(), on_cancel_invoked_); in Echo()
204 EXPECT_TRUE(ctx_->IsCancelled()); in Echo()
225 EXPECT_FALSE(ctx_->IsCancelled()); in Echo()
252 EXPECT_FALSE(ctx_->IsCancelled()); in Echo()
302 cancel_cv_.wait(l, [this] { return ctx_->IsCancelled(); }); in Echo()
[all …]
|
| D | async_end2end_test.cc | 397 EXPECT_FALSE(srv_ctx.IsCancelled()); in TEST_P()
1264 EXPECT_TRUE(srv_ctx.IsCancelled()); in TEST_P()
1298 EXPECT_FALSE(srv_ctx.IsCancelled()); in TEST_P()
1388 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestClientStreamingServerCancel()
1450 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestClientStreamingServerCancel()
1472 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestClientStreamingServerCancel()
1549 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestServerStreamingServerCancel()
1600 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestServerStreamingServerCancel()
1620 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestServerStreamingServerCancel()
1715 EXPECT_TRUE(srv_ctx.IsCancelled()); in TestBidiStreamingServerCancel()
[all …]
|
| D | test_health_check_service_impl.cc | 45 while (!context->IsCancelled()) { in Watch()
|
| D | shutdown_test.cc | 52 while (!context->IsCancelled()) { in Echo()
|
| D | test_service_impl.h | 171 while (!context->IsCancelled()) { in Echo()
187 EXPECT_FALSE(context->IsCancelled()); in Echo()
|
| /third_party/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 | 357 Assert.IsTrue(fakeCall.IsCancelled); in ClientStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
577 Assert.IsTrue(fakeCall.IsCancelled); in DuplexStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException()
596 Assert.IsTrue(fakeCall.IsCancelled); in DuplexStreaming_ReadAfterCancellationRequestCanSucceed()
618 Assert.IsTrue(fakeCall.IsCancelled); in DuplexStreaming_ReadStartedBeforeCancellationRequestCanSucceed()
|
| /third_party/grpc/test/cpp/interop/ |
| D | server_helper.cc | 76 bool InteropServerContextInspector::IsCancelled() const { in IsCancelled() function in grpc::testing::InteropServerContextInspector
77 return context_.IsCancelled(); in IsCancelled()
|
| D | server_helper.h | 44 bool IsCancelled() const;
|
| /third_party/cef/libcef_dll/base/ |
| D | cef_callback_internal.cc | 71 bool CallbackBase::IsCancelled() const { in IsCancelled() function in base::internal::CallbackBase
73 return bind_state_->IsCancelled(); in IsCancelled()
|
| /third_party/cef/include/base/internal/ |
| D | cef_callback_internal.h | 114 bool IsCancelled() const { in IsCancelled() function
157 bool IsCancelled() const;
|
| D | cef_bind_internal.h | 802 return CallbackCancellationTraits<Functor, BoundArgsTuple>::IsCancelled(
1355 static bool IsCancelled(const Functor&,
1376 static bool IsCancelled(const Functor& functor, const BoundArgs&...) {
1377 return functor.IsCancelled();
1392 static bool IsCancelled(const Functor& functor, const BoundArgs&...) {
1393 return functor.IsCancelled();
|
| /third_party/libusb/libusb/os/ |
| D | haiku_usb.h | 96 bool IsCancelled();
|
| D | haiku_usb_raw.cpp | 162 if (transfer->IsCancelled()) { in haiku_handle_transfer_completion()
|
| D | haiku_usb_backend.cpp | 59 USBTransfer::IsCancelled() in IsCancelled() function in USBTransfer
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | server_context_impl.h | 188 bool IsCancelled() const;
534 using ServerContextBase::IsCancelled;
576 using ServerContextBase::IsCancelled;
|
| D | server_context.h | 196 bool IsCancelled() const;
560 using ServerContextBase::IsCancelled;
603 using ServerContextBase::IsCancelled;
|
| /third_party/cef/include/base/ |
| D | cef_cancelable_callback.h | 116 bool IsCancelled() const { return callback_.is_null(); } in IsCancelled() function
|
| /third_party/grpc/src/cpp/server/ |
| D | server_context.cc | 322 bool ServerContextBase::IsCancelled() const { in IsCancelled() function in grpc::ServerContextBase
|
| /third_party/abseil-cpp/absl/status/ |
| D | status.h | 629 ABSL_MUST_USE_RESULT bool IsCancelled(const Status& status);
|
| D | status.cc | 388 bool IsCancelled(const Status& status) { in IsCancelled() function
|
| /third_party/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.cc | 324 if (ctx_.IsCancelled()) { in OnDoneNotified()
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/status/ |
| D | status.h | 691 ABSL_MUST_USE_RESULT bool IsCancelled(const Status& status);
|
| D | status.cc | 387 bool IsCancelled(const Status& status) { in IsCancelled() function
|
| /third_party/grpc/src/cpp/server/health/ |
| D | default_health_check_service.cc | 500 service_, this, static_cast<int>(ctx_.IsCancelled())); in OnDoneNotified()
|