static
| 291 | Driver::~Driver() = default; |
| 292 | // static |
| 293 | void 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 | |
| 305 | void Driver::init( |
| 306 | std::unique_ptr<DriverCtx> ctx, |
no test coverage detected