| 69 | /// \return the fd of the write side of the pipe. |
| 70 | template <typename Fn> |
| 71 | arrow::Result<std::shared_ptr<SelfPipe>> Init(Fn handler) { |
| 72 | ARROW_ASSIGN_OR_RAISE(self_pipe_, SelfPipe::Make(/*signal_safe=*/true)); |
| 73 | handle_signals_ = std::thread(handler, self_pipe_); |
| 74 | return self_pipe_; |
| 75 | } |
| 76 | |
| 77 | Status Shutdown() { |
| 78 | RETURN_NOT_OK(self_pipe_->Shutdown()); |
nothing calls this directly
no test coverage detected