Git-Mirrors/veilid
1
0
Fork 0
mirror of https://gitlab.com/veilid/veilid.git synced 2025-01-26 06:26:05 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix fanout regression

Browse Source
This commit is contained in:
Christien Rioux 2024-04-23 18:52:38 -04:00
parent 6373cc0e9d
commit d3b596a70e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
veilid-core/src/rpc_processor/fanout_queue.rs
View File

@ -1,3 +1,7 @@
/// Fanout Queue
/// Keep a deque of unique nodes
/// Internally the 'front' of the list is the next out, and new nodes are added to the 'back' of the list
/// When passing in a 'cleanup' function, if it sorts the queue, the 'first' items in the queue are the 'next' out.
use super::*;
#[derive(Debug)]
@ -44,7 +48,7 @@ impl FanoutQueue {
}
if !dup {
// Add the new node
self.current_nodes.push_front(nn.clone());
self.current_nodes.push_back(nn.clone());
}
}
@ -72,7 +76,7 @@ impl FanoutQueue {
// Return next fanout candidate
pub fn next(&mut self) -> Option<NodeRef> {
let cn = self.current_nodes.pop_back()?;
let cn = self.current_nodes.pop_front()?;
self.current_nodes.make_contiguous();
let key = cn.node_ids().get(self.crypto_kind).unwrap();