gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix recvmmsg test for timeout

Browse Source
This commit is contained in:
Pankaj Garg
2019-01-31 10:47:31 -08:00
committed by Grimes
parent e104941569
commit aa1bd603e6
1 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/recvmmsg.rs
View File

@ -145,7 +145,7 @@ mod tests {
reader.set_nonblocking(false).unwrap(); reader.set_nonblocking(false).unwrap();
let sender = UdpSocket::bind("127.0.0.1:0").expect("bind"); let sender = UdpSocket::bind("127.0.0.1:0").expect("bind");
let saddr = sender.local_addr().unwrap(); let saddr = sender.local_addr().unwrap();
let sent = NUM_RCVMMSGS + 10; let sent = NUM_RCVMMSGS;
for _ in 0..sent { for _ in 0..sent {
let data = [0; PACKET_DATA_SIZE]; let data = [0; PACKET_DATA_SIZE];
sender.send_to(&data[..], &addr).unwrap(); sender.send_to(&data[..], &addr).unwrap();
@ -160,12 +160,7 @@ mod tests {
assert_eq!(packets[i].meta.addr(), saddr); assert_eq!(packets[i].meta.addr(), saddr);
} }
let recv = recv_mmsg(&reader, &mut packets[..]).unwrap(); let _recv = recv_mmsg(&reader, &mut packets[..]);
assert_eq!(sent - NUM_RCVMMSGS, recv);
for i in 0..recv {
assert_eq!(packets[i].meta.size, PACKET_DATA_SIZE);
assert_eq!(packets[i].meta.addr(), saddr);
}
assert!(start.elapsed().as_secs() < 5); assert!(start.elapsed().as_secs() < 5);
} }