MCPcopy Create free account
hub / github.com/bytedance/bolt / moveNext

Method moveNext

bolt/exec/tests/utils/Cursor.cpp:325–340  ·  view source on GitHub ↗

Fetches another batch from the task queue. Starts the task if not started yet.

Source from the content-addressed store, hash-verified

323 /// Fetches another batch from the task queue.
324 /// Starts the task if not started yet.
325 bool moveNext() override {
326 start();
327 if (error_) {
328 std::rethrow_exception(error_);
329 }
330
331 // Task might be aborted before start.
332 checkTaskError();
333 current_ = queue_->dequeue();
334
335 checkTaskError();
336 if (!current_) {
337 atEnd_ = true;
338 }
339 return current_ != nullptr;
340 }
341
342 void setNoMoreSplits() override {
343 BOLT_CHECK(!noMoreSplits_);

Callers 15

TEST_FFunction · 0.45
runShuffleMethod · 0.45
TEST_FFunction · 0.45
DEBUG_ONLY_TEST_FFunction · 0.45
runOneMethod · 0.45
TEST_FFunction · 0.45
TEST_FFunction · 0.45
DEBUG_ONLY_TEST_FFunction · 0.45
TEST_FFunction · 0.45
TEST_FFunction · 0.45
TEST_FFunction · 0.45

Calls 1

dequeueMethod · 0.80

Tested by

no test coverage detected