File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change 11[package ]
22name = " rperf"
3- version = " 0.1.7 "
3+ version = " 0.1.8 "
44description = " validates network throughput capacity and reliability"
55authors = [" Neil Tallim <neiltallim@3d-p.com>" ]
66edition = " 2021"
Original file line number Diff line number Diff line change @@ -303,8 +303,8 @@ pub mod receiver {
303303 self . process_jitter ( & source_timestamp, & mut history) ;
304304
305305 if history. unbroken_sequence > history. longest_unbroken_sequence {
306- history. longest_unbroken_sequence = history. unbroken_sequence
307- history. longest_jitter_seconds = history. jitter_seconds
306+ history. longest_unbroken_sequence = history. unbroken_sequence ;
307+ history. longest_jitter_seconds = history. jitter_seconds ;
308308 }
309309 } else {
310310 history. unbroken_sequence = 0 ;
@@ -561,6 +561,8 @@ pub mod sender {
561561 Err ( e) if e. kind ( ) == std:: io:: ErrorKind :: WouldBlock => { //send-buffer is full
562562 //nothing to do, but avoid burning CPU cycles
563563 sleep ( BUFFER_FULL_TIMEOUT ) ;
564+ //roll back the packet-ID because nothing was actually emitted
565+ self . next_packet_id -= 1 ;
564566 } ,
565567 Err ( e) => {
566568 return Some ( Err ( Box :: new ( e) ) ) ;
You can’t perform that action at this time.
0 commit comments