| 370 | } |
| 371 | |
| 372 | void ScanNode::ScannerThreadState::Shutdown() { |
| 373 | if (batch_queue_ != nullptr) batch_queue_->Shutdown(); |
| 374 | } |
| 375 | |
| 376 | void ScanNode::ScannerThreadState::Close(ScanNode* parent) { |
| 377 | scanner_threads_.JoinAll(); |
no outgoing calls
no test coverage detected