| 2813 | } |
| 2814 | |
| 2815 | void enqueue(std::unique_ptr<rdbInsertJob> &spjob) { |
| 2816 | if (!fLaunched) { |
| 2817 | processJob(*spjob); |
| 2818 | spjob = nullptr; |
| 2819 | } else { |
| 2820 | vecbatch.push_back(spjob.release()); |
| 2821 | if (vecbatch.size() >= 64) { |
| 2822 | queueJobs.enqueue_bulk(vecbatch.data(), vecbatch.size()); |
| 2823 | vecbatch.clear(); |
| 2824 | throttle(); |
| 2825 | } |
| 2826 | } |
| 2827 | } |
| 2828 | |
| 2829 | void pauseExecution() { |
| 2830 | m_lockPause.lock(); |
no test coverage detected