diff --git a/src/crdt.rs b/src/crdt.rs
index f77835e4aa818d..4d6f3bf289d05c 100644
--- a/src/crdt.rs
+++ b/src/crdt.rs
@@ -1025,7 +1025,7 @@ impl Crdt {
                 let out = entry.to_blob(
                     blob_recycler,
                     Some(ix),
-                    Some(from.id),
+                    Some(me.id), // causes retransmission if I'm the leader
                     Some(&from.contact_info.tvu_window),
                 );
 
diff --git a/src/streamer.rs b/src/streamer.rs
index 936edc25c3372d..37467a3c04de53 100644
--- a/src/streamer.rs
+++ b/src/streamer.rs
@@ -460,7 +460,7 @@ fn blob_idx_in_window(debug_id: u64, pix: u64, consumed: u64, received: &mut u64
         //  the window.  The worst case here is the server *starts* outside
         //  the window, none of the packets it receives fits in the window
         //  and repair requests (which are based on received) are never generated
-        *received = cmp::min(consumed + WINDOW_SIZE, cmp::max(pix, *received));
+        *received = cmp::max(pix, *received);
 
         if pix >= consumed + WINDOW_SIZE {
             trace!(