Skip to content

Commit

Permalink
Cap repair requests timeout
Browse files Browse the repository at this point in the history
  • Loading branch information
sakridge committed Aug 13, 2018
1 parent bf15cad commit 52ff5a5
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/streamer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -236,6 +236,9 @@ fn repair_window(
}
*last = consumed;
*times += 1;
if *times > 128 {
*times = 65;
}
//if times flips from all 1s 7 -> 8, 15 -> 16, we retry otherwise return Ok
if *times & (*times - 1) != 0 {
trace!("repair_window counter {} {} {}", *times, consumed, received);
Expand Down

0 comments on commit 52ff5a5

Please sign in to comment.