MCPcopy Create free account
hub / github.com/apache/arrow / ~SignalStopState

Method ~SignalStopState

cpp/src/arrow/util/cancel.cc:176–190  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

174 }
175
176 ~SignalStopState() {
177 atfork_handler_.reset();
178 UnregisterHandlers();
179 Disable();
180 if (signal_receiving_thread_) {
181 // Tell the receiving thread to stop
182 auto st = self_pipe_->Shutdown();
183 ARROW_WARN_NOT_OK(st, "Failed to shutdown self-pipe");
184 if (st.ok()) {
185 signal_receiving_thread_->join();
186 } else {
187 signal_receiving_thread_->detach();
188 }
189 }
190 }
191
192 StopSource* stop_source() {
193 std::lock_guard<std::mutex> lock(mutex_);

Callers

nothing calls this directly

Calls 4

resetMethod · 0.45
ShutdownMethod · 0.45
okMethod · 0.45
joinMethod · 0.45

Tested by

no test coverage detected