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

Method SetFinished

cpp/src/arrow/util/future_test.cc:118–127  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

116 std::vector<Future<T>>& futures() { return futures_; }
117
118 void SetFinished(const std::vector<std::pair<int, bool>>& pairs) {
119 for (const auto& pair : pairs) {
120 const int fut_index = pair.first;
121 if (pair.second) {
122 futures_[fut_index].MarkFinished(T(fut_index));
123 } else {
124 futures_[fut_index].MarkFinished(Status::UnknownError("xxx"));
125 }
126 }
127 }
128
129 void SetFinishedDeferred(std::vector<std::pair<int, bool>> pairs) {
130 std::this_thread::sleep_for(kYieldDuration);

Callers 1

MakeExecutorMethod · 0.80

Calls 2

UnknownErrorFunction · 0.85
MarkFinishedMethod · 0.45

Tested by

no test coverage detected