use the RequestBlocksResponse message as separate

MystenLabs · Jan 2, 2024 · d87ed37 · d87ed37
1 parent e616638
commit d87ed37
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/mysticeti-core/src/synchronizer.rs b/mysticeti-core/src/synchronizer.rs
@@ -90,7 +90,10 @@ where
             }
 
             if to_send.len() >= CHUNK_SIZE {
-                self.send(peer, NetworkMessage::Blocks(std::mem::take(&mut to_send)))?;
+                self.send(
+                    peer,
+                    NetworkMessage::RequestBlocksResponse(std::mem::take(&mut to_send)),
+                )?;
             }
 
             self.metrics
@@ -101,7 +104,10 @@ where
 
         // send any leftovers
         if !to_send.is_empty() {
-            self.send(peer, NetworkMessage::Blocks(std::mem::take(&mut to_send)))?;
+            self.send(
+                peer,
+                NetworkMessage::RequestBlocksResponse(std::mem::take(&mut to_send)),
+            )?;
         }
 
         self.send(peer, NetworkMessage::BlockNotFound(missing))