MCPcopy Create free account
hub / github.com/NodeDB-Lab/nodedb / push

Method push

nodedb/src/data/executor/core_loop/priority_queues.rs:75–82  ·  view source on GitHub ↗

Enqueue a task at the appropriate tier.

(&mut self, task: ExecutionTask)

Source from the content-addressed store, hash-verified

73
74 /// Enqueue a task at the appropriate tier.
75 pub fn push(&mut self, task: ExecutionTask) {
76 let queued = QueuedTask::new(task);
77 match queued.task.request.priority {
78 Priority::Critical => self.critical.push_back(queued),
79 Priority::High => self.high.push_back(queued),
80 Priority::Normal | Priority::Background => self.low.push_back(queued),
81 }
82 }
83
84 /// Total tasks across all tiers.
85 pub fn len(&self) -> usize {

Callers 15

openMethod · 0.45
drain_completionsMethod · 0.45
read_syncMethod · 0.45
prefetch_batchMethod · 0.45
decode_f32_leFunction · 0.45
with_configMethod · 0.45
read_filesMethod · 0.45
scan_kvMethod · 0.45
scan_columnarMethod · 0.45
scan_sparseMethod · 0.45
write_strFunction · 0.45
plain_columnar_purgeMethod · 0.45

Calls

no outgoing calls

Tested by 5

test_spill_dirFunction · 0.36
drain_respects_ratioFunction · 0.36
no_permanent_starvationFunction · 0.36
empty_tier_slot_donationFunction · 0.36