diff --git a/src/streamer.rs b/src/streamer.rs index 5ad180b84..53055c1ad 100644 --- a/src/streamer.rs +++ b/src/streamer.rs @@ -123,6 +123,8 @@ fn recv_window( let rsubs = subs.read().unwrap(); for b in &dq { let p = b.read().unwrap(); + //TODO this check isn't safe against adverserial packets + //we need to maintain a sequence window if p.meta.addr() == rsubs.leader.addr { //TODO //need to copy the retransmited blob