| 1319 | } |
| 1320 | |
| 1321 | Status Shutdown() override { |
| 1322 | please_shutdown_.store(true); |
| 1323 | errno = 0; |
| 1324 | if (!DoSend(kEofPayload)) { |
| 1325 | if (errno) { |
| 1326 | return IOErrorFromErrno(errno, "Could not shutdown self-pipe"); |
| 1327 | } else if (!pipe_.wfd.closed()) { |
| 1328 | return Status::UnknownError("Could not shutdown self-pipe"); |
| 1329 | } |
| 1330 | } |
| 1331 | return pipe_.wfd.Close(); |
| 1332 | } |
| 1333 | |
| 1334 | ~SelfPipeImpl() { ARROW_WARN_NOT_OK(Shutdown(), "On self-pipe destruction"); } |
| 1335 |
nothing calls this directly
no test coverage detected