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

debug log on the padding index

Browse Source
This commit is contained in:
Peter Zhang 2025-11-19 09:12:18 +08:00
parent b857728660
commit ba0ed29869
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1157,8 +1157,8 @@ impl LogManager {
let (segments_for_proof, last_segment_size_for_proof) = let (segments_for_proof, last_segment_size_for_proof) =
compute_segment_size(chunks, PORA_CHUNK_SIZE); compute_segment_size(chunks, PORA_CHUNK_SIZE);
debug!( debug!(
"segments_for_proof: {}, last_segment_size_for_proof: {}", "tx seq: {}, segments_for_proof: {}, last_segment_size_for_proof: {}",
segments_for_proof, last_segment_size_for_proof tx.seq, segments_for_proof, last_segment_size_for_proof
); );
let chunks_for_file = bytes_to_entries(tx.size) as usize; let chunks_for_file = bytes_to_entries(tx.size) as usize;
@ -1169,6 +1169,13 @@ impl LogManager {
segments_for_file, last_segment_size_for_file segments_for_file, last_segment_size_for_file
); );
// Padding should only start after real data ends
let real_data_end_index = (segments_for_file - 1) * PORA_CHUNK_SIZE + last_segment_size_for_file;
debug!(
"Padding: real_data_end_index={}, padding_start_segment={}, padding_start_offset={}",
real_data_end_index, segments_for_file - 1, last_segment_size_for_file
);
while segments_for_file <= segments_for_proof { while segments_for_file <= segments_for_proof {
let padding_size = if segments_for_file == segments_for_proof { let padding_size = if segments_for_file == segments_for_proof {
(last_segment_size_for_proof - last_segment_size_for_file) * ENTRY_SIZE (last_segment_size_for_proof - last_segment_size_for_file) * ENTRY_SIZE
@ -1176,7 +1183,14 @@ impl LogManager {
(PORA_CHUNK_SIZE - last_segment_size_for_file) * ENTRY_SIZE (PORA_CHUNK_SIZE - last_segment_size_for_file) * ENTRY_SIZE
}; };
debug!("Padding size: {}", padding_size); let padding_start_index = ((segments_for_file - 1) * PORA_CHUNK_SIZE
+ last_segment_size_for_file) as u64;
debug!(
"Padding iteration: segment={}, offset={}, padding_size={}, start_index={}",
segments_for_file - 1, last_segment_size_for_file, padding_size, padding_start_index
);
if padding_size > 0 { if padding_size > 0 {
// This tx hash is guaranteed to be consistent. // This tx hash is guaranteed to be consistent.
self.put_chunks_with_tx_hash( self.put_chunks_with_tx_hash(
@ -1184,9 +1198,7 @@ impl LogManager {
tx.hash(), tx.hash(),
ChunkArray { ChunkArray {
data: vec![0u8; padding_size], data: vec![0u8; padding_size],
start_index: ((segments_for_file - 1) * PORA_CHUNK_SIZE start_index: padding_start_index,
+ last_segment_size_for_file)
as u64,
}, },
None, None,
)?; )?;