MCPcopy Create free account
hub / github.com/apache/arrow / AssertStopRequested

Method AssertStopRequested

cpp/src/arrow/util/cancel_test.cc:198–205  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

196 }
197
198 void AssertStopRequested() {
199 BusyWait(1.0, [&]() { return stop_token_->IsStopRequested(); });
200 ASSERT_TRUE(stop_token_->IsStopRequested());
201 auto st = stop_token_->Poll();
202 ASSERT_RAISES(Cancelled, st);
203 ASSERT_EQ(st.message(), "Operation cancelled");
204 ASSERT_EQ(internal::SignalFromStatus(st), expected_signal_);
205 }
206
207#ifndef _WIN32
208 void RunInChild(std::function<void()> func) {

Callers

nothing calls this directly

Calls 4

BusyWaitFunction · 0.85
SignalFromStatusFunction · 0.85
IsStopRequestedMethod · 0.80
PollMethod · 0.80

Tested by

no test coverage detected