receive: really close and forget on synchronization lost (possibly fi…

…x issue ANSSI-FR#4 also)
github-af · Jan 22, 2025 · 943b80b · 943b80b
1 parent a3a3368
commit 943b80b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/receive/dispatch.rs b/src/receive/dispatch.rs
@@ -56,7 +56,6 @@ pub(crate) fn start<F>(receiver: &receive::Receiver<F>) -> Result<(), receive::E
                     }
 
                     failed_transfers.insert(client_id);
-                    ended_transfers.insert(client_id, client_sendq);
                 }
                 active_transfers = BTreeMap::new();
                 continue;

diff --git a/src/receive/reordering.rs b/src/receive/reordering.rs
@@ -20,7 +20,8 @@ pub(crate) fn start<F>(receiver: &receive::Receiver<F>) -> Result<(), receive::E
         let (resync_needed, resync_block_id) = receiver.resync_needed_block_id.take();
 
         if resync_needed {
-            log::debug!("forced resynchronization");
+            log::debug!("forced resynchronization, propagating it");
+            receiver.to_dispatch.send(None)?;
             if pending_messages.iter().any(Option::is_some) {
                 log::warn!("forced resynchronization with pending messages, dropping everything");
                 pending_messages.fill_with(|| None);