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

Method StartReader

cpp/src/arrow/io/file_benchmark.cc:71–75  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

69
70 public:
71 static std::shared_ptr<BackgroundReader> StartReader(int fd) {
72 std::shared_ptr<BackgroundReader> reader(new BackgroundReader(fd));
73 reader->worker_.reset(new std::thread([=] { reader->LoopReading(); }));
74 return reader;
75 }
76 void Stop() { ARROW_CHECK(SetEvent(event_)); }
77 void Join() { worker_->join(); }
78

Callers

nothing calls this directly

Calls 2

LoopReadingMethod · 0.80
resetMethod · 0.45

Tested by

no test coverage detected