MCPcopy Create free account
hub / github.com/deepseek-ai/3FS / enqueue

Method enqueue

src/client/cli/admin/ScanTree.cc:90–93  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

88 using TaskPtr = std::unique_ptr<Task>;
89
90 void enqueue(Task task) {
91 pending_++;
92 queue_.enqueue(std::make_unique<Task>(std::move(task)));
93 }
94
95 CoTask<void> worker() {
96 while (true) {

Callers 15

stopMethod · 0.45
scanCloseTaskMethod · 0.45
pruneSessionMethod · 0.45
watchMethod · 0.45
periodicSyncScanMethod · 0.45
openMethod · 0.45
appendMethod · 0.45
flushMethod · 0.45
scanMethod · 0.45
runMethod · 0.45
scanTaskMethod · 0.45
allocateFromDBMethod · 0.45

Calls

no outgoing calls

Tested by 5

TESTFunction · 0.36
TESTFunction · 0.36
TESTFunction · 0.36
TESTFunction · 0.36
testCoroutinesPoolFunction · 0.36