Fix streaming logic

This commit is contained in:
Igor Katson 2024-04-26 09:30:26 +01:00
parent 0a895c5b9c
commit 5ffe2d59b7

View file

@ -984,7 +984,7 @@ impl PeerHandler {
.iter_next_pieces(&self.state.lengths) .iter_next_pieces(&self.state.lengths)
.filter(|pid| { .filter(|pid| {
!chunk_tracker.is_piece_have(*pid) !chunk_tracker.is_piece_have(*pid)
&& chunk_tracker.is_piece_queued(*pid) && !g.inflight_pieces.contains_key(pid)
}); });
let natural_order_pieces = let natural_order_pieces =
chunk_tracker.iter_queued_pieces(&g.file_priorities, &self.state.files); chunk_tracker.iter_queued_pieces(&g.file_priorities, &self.state.files);