smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2025-11-03 08:07:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fill all middle seqs

Browse Source
This commit is contained in:
Peter Zhang 2025-07-08 16:53:49 +08:00
parent 1381428aee
commit ba67443325
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
node/storage/src/log_store/log_manager.rs
View File

@ -319,11 +319,11 @@ impl LogStoreWrite for LogManager {
// If this is the first tx with this data root, copy and finalize all same-root txs. // If this is the first tx with this data root, copy and finalize all same-root txs.
self.copy_tx_and_finalize(tx_seq, same_root_seq_list[1..].to_vec())?; self.copy_tx_and_finalize(tx_seq, same_root_seq_list[1..].to_vec())?;
} else { } else {
// If this is not the first tx with this data root, copy and finalize the first one. // If this is not the first tx with this data root, and the first one is not finalized.
let maybe_first_seq = same_root_seq_list.first().cloned(); let maybe_first_seq = same_root_seq_list.first().cloned();
if let Some(first_seq) = maybe_first_seq { if let Some(first_seq) = maybe_first_seq {
if !self.check_tx_completed(first_seq)? { if !self.check_tx_completed(first_seq)? {
self.copy_tx_and_finalize(tx_seq, vec![first_seq])?; self.copy_tx_and_finalize(tx_seq, same_root_seq_list)?;
} }
} }
} }
@ -370,7 +370,7 @@ impl LogStoreWrite for LogManager {
let maybe_first_seq = same_root_seq_list.first().cloned(); let maybe_first_seq = same_root_seq_list.first().cloned();
if let Some(first_seq) = maybe_first_seq { if let Some(first_seq) = maybe_first_seq {
if !self.check_tx_completed(first_seq)? { if !self.check_tx_completed(first_seq)? {
self.copy_tx_and_finalize(tx_seq, vec![first_seq])?; self.copy_tx_and_finalize(tx_seq, same_root_seq_list)?;
} }
} }
} }