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

Function FileSystemDefer

cpp/src/arrow/filesystem/filesystem.cc:153–162  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

151
152template <typename DeferredFunc>
153auto FileSystemDefer(FileSystem* fs, bool synchronous, DeferredFunc&& func)
154 -> decltype(DeferNotOk(
155 fs->io_context().executor()->Submit(func, std::shared_ptr<FileSystem>{}))) {
156 auto self = fs->shared_from_this();
157 if (synchronous) {
158 return std::forward<DeferredFunc>(func)(std::move(self));
159 }
160 return DeferNotOk(io::internal::SubmitIO(
161 fs->io_context(), std::forward<DeferredFunc>(func), std::move(self)));
162}
163
164} // namespace
165

Callers 5

GetFileInfoAsyncMethod · 0.85
GetFileInfoGeneratorMethod · 0.85
OpenInputStreamAsyncMethod · 0.85
OpenInputFileAsyncMethod · 0.85

Calls 3

DeferNotOkFunction · 0.85
SubmitIOFunction · 0.85
executorMethod · 0.45

Tested by

no test coverage detected