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

Method enqueue

bolt/exec/OutputBuffer.cpp:46–50  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

44}
45
46void ArbitraryBuffer::enqueue(std::unique_ptr<SerializedPage> page) {
47 BOLT_CHECK_NOT_NULL(page, "Unexpected null page");
48 BOLT_CHECK(!hasNoMoreData(), "Arbitrary buffer has set no more data marker");
49 pages_.push_back(std::shared_ptr<SerializedPage>(page.release()));
50}
51
52std::vector<std::shared_ptr<SerializedPage>> ArbitraryBuffer::getPages(
53 uint64_t maxBytes) {

Calls 10

backMethod · 0.80
recordEnqueueMethod · 0.80
push_backMethod · 0.45
releaseMethod · 0.45
emptyMethod · 0.45
isRunningMethod · 0.45
sizeMethod · 0.45
valueMethod · 0.45
numRowsMethod · 0.45
notifyMethod · 0.45

Tested by

no test coverage detected