@@ -258,6 +258,7 @@ impl Socket {
258
258
259
259
#[ cfg( test) ]
260
260
fn forget_all_incoming_packets ( & mut self ) {
261
+ std:: thread:: sleep ( std:: time:: Duration :: from_millis ( 100 ) ) ;
261
262
loop {
262
263
match self . socket . recv_from ( & mut self . recv_buffer ) {
263
264
Ok ( ( recv_len, _address) ) => {
@@ -489,28 +490,27 @@ mod tests {
489
490
. send ( Packet :: reliable_sequenced ( server_addr, vec ! [ id] , None ) )
490
491
. unwrap ( ) ;
491
492
client. manual_poll ( time) ;
492
- server. manual_poll ( time) ;
493
493
}
494
494
495
+ server. manual_poll ( time) ;
496
+
495
497
let mut seen = HashSet :: new ( ) ;
496
498
497
499
while let Ok ( message) = server_receiver. try_recv ( ) {
498
500
match message {
499
501
SocketEvent :: Connect ( connect_event) => { }
500
502
SocketEvent :: Packet ( packet) => {
501
- assert ! [ !seen. contains( & packet. payload( ) [ 0 ] ) ] ;
502
- seen. insert ( packet. payload ( ) [ 0 ] ) ;
503
+ let byte = packet. payload ( ) [ 0 ] ;
504
+ assert ! [ !seen. contains( & byte) ] ;
505
+ seen. insert ( byte) ;
503
506
}
504
507
SocketEvent :: Timeout ( timeout_event) => {
505
508
panic ! [ "This should not happen, as we've not advanced time" ] ;
506
509
}
507
510
}
508
511
}
509
512
510
- #[ cfg( not( target_os = "mac_os" ) ) ]
511
513
assert_eq ! [ 100 , seen. len( ) ] ;
512
- #[ cfg( target_os = "mac_os" ) ]
513
- assert_eq ! [ 99 , seen. len( ) ] ;
514
514
}
515
515
516
516
#[ test]
@@ -845,10 +845,10 @@ mod tests {
845
845
// The first chatting sequence sends packets 0..100 from the client to the server. After
846
846
// this we just chat with a value of 255 so we don't accidentally overlap those chatting
847
847
// packets with the packets we want to ack.
848
- assert_eq ! [ 42 , send_many_packets( None ) ] ;
849
- assert_eq ! [ 85 , send_many_packets( Some ( 255 ) ) ] ;
850
- assert_eq ! [ 98 , send_many_packets( Some ( 255 ) ) ] ;
851
- assert_eq ! [ 100 , send_many_packets( Some ( 255 ) ) ] ;
848
+ send_many_packets ( None ) ;
849
+ send_many_packets ( Some ( 255 ) ) ;
850
+ send_many_packets ( Some ( 255 ) ) ;
851
+ send_many_packets ( Some ( 255 ) ) ;
852
852
853
853
// 101 because we have 0..100 and 255 from the dummies
854
854
assert_eq ! [ 101 , send_many_packets( Some ( 255 ) ) ] ;
0 commit comments