return out of push_mergeset, if we cannot push any more.

kaspanet · Nov 18, 2024 · e4fb910 · e4fb910
1 parent fa43c3a
commit e4fb910
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/consensus/src/processes/window.rs b/consensus/src/processes/window.rs
@@ -410,7 +410,9 @@ impl<T: GhostdagStoreReader, U: BlockWindowCacheReader, V: HeaderStoreReader, W:
         for block in self.sampled_mergeset_iterator(sample_rate, ghostdag_data, selected_parent_blue_work) {
             match block {
                 SampledBlock::Sampled(block) => {
-                    heap.deref_mut().try_push(block.hash, block.blue_work);
+                    if !heap.deref_mut().try_push(block.hash, block.blue_work) {
+                        return;
+                    }
                 }
                 SampledBlock::NonDaa(hash) => mergeset_non_daa_inserter(hash),
             }