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

Method Shutdown

cpp/src/arrow/util/io_util.cc:1321–1332  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 5

IOErrorFromErrnoFunction · 0.85
UnknownErrorFunction · 0.85
storeMethod · 0.80
closedMethod · 0.45
CloseMethod · 0.45

Tested by

no test coverage detected