mirror/nlnetlabs-rtrtr
1
0
Fork 0
mirror of https://github.com/NLnetLabs/rtrtr.git synced 2024-05-11 05:55:07 +00:00
Code Issues Releases Activity

Only break if there is no active unit.

Browse Source
This commit is contained in:
Martin Hoffmann
2024-01-26 14:22:35 +01:00
parent 67fda0d910
commit 50cc62f2a9
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/units/combine.rs
View File

@ -41,7 +41,7 @@ impl Any {
None; self.sources.len()
];
// Outer loop picks a new source.
// Outer loop picks a new active source.
loop {
let new_idx = self.pick(curr_idx);
if new_idx != curr_idx {
@ -68,7 +68,7 @@ impl Any {
}
}
// Inner loop works the source until it stalls
// Inner loop collects updates until the active unit stalls
loop {
let (res, idx, _) = {
let res = select(
@ -95,7 +95,7 @@ impl Any {
if Some(idx) == curr_idx {
gate.update_data(update.clone()).await;
}
else {
else if curr_idx.is_none() {
// We currently don’t have an active source but
// there was an update. Break to pick a new active
// source.