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

Method NotifyAll

cpp/src/arrow/acero/test_nodes.cc:237–243  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

235
236 private:
237 void NotifyAll() {
238 if (current_waiter_.is_valid()) {
239 Future<> to_unlock = current_waiter_;
240 current_waiter_ = {};
241 to_unlock.MarkFinished();
242 }
243 }
244
245 Future<> current_waiter_;
246 int num_released_batches_ = 0;

Callers

nothing calls this directly

Calls 2

is_validMethod · 0.45
MarkFinishedMethod · 0.45

Tested by

no test coverage detected