Minor fix

aptos-labs · Jul 18, 2024 · ef47712 · ef47712
1 parent e4b1c07
commit ef47712
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/config/src/config/quorum_store_config.rs b/config/src/config/quorum_store_config.rs
@@ -109,7 +109,7 @@ impl Default for QuorumStoreConfig {
             // TODO: on next release, remove BATCH_PADDING_BYTES
             sender_max_batch_bytes: 1024 * 1024 - BATCH_PADDING_BYTES,
             sender_max_num_batches: DEFAULT_MAX_NUM_BATCHES,
-            sender_max_total_txns: 2000,
+            sender_max_total_txns: 2500,
             // TODO: on next release, remove DEFAULT_MAX_NUM_BATCHES * BATCH_PADDING_BYTES
             sender_max_total_bytes: 4 * 1024 * 1024 - DEFAULT_MAX_NUM_BATCHES * BATCH_PADDING_BYTES,
             receiver_max_batch_txns: 250,

diff --git a/consensus/src/quorum_store/batch_generator.rs b/consensus/src/quorum_store/batch_generator.rs
@@ -484,7 +484,7 @@ impl BatchGenerator {
                         if batches.len() as u64 >= self.config.minimum_batch_size
                             || (!batches.is_empty() && since_last_non_empty_pull_ms >= self.config.batch_generation_max_interval_ms) {
                             last_non_empty_pull = tick_start;
-
+                            pulled_txns_window.push_back((tick_start, batches.len() as u64));
                             let persist_start = Instant::now();
                             let mut persist_requests = vec![];
                             for batch in batches.clone().into_iter() {