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

Method enqueue

bolt/exec/Driver.cpp:293–303  ·  view source on GitHub ↗

static

Source from the content-addressed store, hash-verified

291Driver::~Driver() = default;
292// static
293void Driver::enqueue(std::shared_ptr<Driver> driver) {
294 process::ScopedThreadDebugInfo scopedInfo(
295 driver->driverCtx()->threadDebugInfo);
296 // This is expected to be called inside the Driver's Tasks's mutex.
297 driver->enqueueInternal();
298 if (driver->closed_) {
299 return;
300 }
301 driver->task()->queryCtx()->executor()->add(
302 [driver]() { Driver::run(driver); });
303}
304
305void Driver::init(
306 std::unique_ptr<DriverCtx> ctx,

Callers 4

flushMethod · 0.45
finishSourceMethod · 0.45
makeOperatorSupplierFunction · 0.45

Calls 7

enqueueInternalMethod · 0.80
queryCtxMethod · 0.80
taskMethod · 0.80
runFunction · 0.50
driverCtxMethod · 0.45
addMethod · 0.45
executorMethod · 0.45

Tested by

no test coverage detected