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

Method GetStopToken

r/src/safe-call-into-r.h:65–71  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

63 bool IsMainThread() { return initialized_ && std::this_thread::get_id() == thread_id_; }
64
65 arrow::StopToken GetStopToken() {
66 if (SignalStopSourceEnabled()) {
67 return stop_source_->token();
68 } else {
69 return arrow::StopToken::Unstoppable();
70 }
71 }
72
73 bool SignalStopSourceEnabled() { return stop_source_ != nullptr; }
74

Callers 2

ExecPlanReaderMethod · 0.80
CancellableIOContextMethod · 0.80

Calls 2

UnstoppableFunction · 0.85
tokenMethod · 0.80

Tested by

no test coverage detected