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

Method AppendReal

cpp/src/arrow/util/task_group.cc:43–52  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

41 explicit SerialTaskGroup(StopToken stop_token) : stop_token_(std::move(stop_token)) {}
42
43 void AppendReal(FnOnce<Status()> task) override {
44 DCHECK(!finished_);
45 if (stop_token_.IsStopRequested()) {
46 status_ &= stop_token_.Poll();
47 return;
48 }
49 if (status_.ok()) {
50 status_ &= std::move(task)();
51 }
52 }
53
54 Status current_status() override { return status_; }
55

Callers

nothing calls this directly

Calls 3

IsStopRequestedMethod · 0.80
PollMethod · 0.80
okMethod · 0.45

Tested by

no test coverage detected