MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / enqueue

Method enqueue

src/rdb.cpp:2815–2827  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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();

Callers 1

rdbLoadRioFunction · 0.45

Calls 5

dataMethod · 0.80
releaseMethod · 0.45
sizeMethod · 0.45
enqueue_bulkMethod · 0.45
clearMethod · 0.45

Tested by

no test coverage detected