Skip to content

Commit 73023e8

Browse files
committed
monad-raptorcast: switch to round robin ordering
1 parent f863ffb commit 73023e8

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

monad-raptorcast/src/packet/assembler.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,15 +36,15 @@ use crate::{util::Redundancy, SIGNATURE_SIZE};
3636
pub enum AssembleMode {
3737
// Compatible with existing build_messages logic, does not support
3838
// streaming per merkle batch
39-
#[default]
39+
#[expect(unused)]
4040
GsoFull,
4141

4242
// Gso concatenated chunks only within a merkle batch.
4343
#[expect(unused)]
4444
GsoBestEffort,
4545

4646
// Each recipient gets its own packet in round-robin order.
47-
#[expect(unused)]
47+
#[default]
4848
RoundRobin,
4949
}
5050

monad-raptorcast/src/udp.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -933,7 +933,6 @@ mod tests {
933933

934934
let mut used_ids: HashMap<SocketAddr, HashSet<_>> = HashMap::new();
935935

936-
let messages_len = messages.len();
937936
for (to, mut aggregate_message) in messages {
938937
while !aggregate_message.is_empty() {
939938
let message = aggregate_message.split_to(DEFAULT_SEGMENT_SIZE.into());
@@ -948,7 +947,6 @@ mod tests {
948947
}
949948
}
950949

951-
assert_eq!(used_ids.len(), messages_len);
952950
let ids = used_ids.values().next().unwrap().clone();
953951
assert!(used_ids.values().all(|x| x == &ids)); // check that all recipients are sent same ids
954952
assert!(ids.contains(&0)); // check that starts from idx 0

0 commit comments

Comments
 (0)