loooooooooooooooooooooooooooooooooooooooooooooooogs taiboku

src/new_index/fetch.rs

@@ -197,8 +197,10 @@ fn parse_blocks(blob: Vec<u8>, magic: u32) -> Result<Vec<SizedBlock>> {
 
     while cursor.position() < max_pos {
         let offset = cursor.position();
+        warn!("offset: {offset}");
         match u32::consensus_decode(&mut cursor) {
             Ok(value) => {
+                warn!("Magic: {magic}, Actual: {value}");
                 if magic != value {
                     cursor.set_position(offset + 1);
                     continue;
@@ -207,15 +209,18 @@ fn parse_blocks(blob: Vec<u8>, magic: u32) -> Result<Vec<SizedBlock>> {
             Err(_) => break, // EOF
         };
         let block_size = u32::consensus_decode(&mut cursor).chain_err(|| "no block size")?;
+        warn!("Block size {block_size}");
         let start = cursor.position();
         let end = start + block_size as u64;
+        warn!("start {start}, end {end}");
 
         // If Core's WriteBlockToDisk ftell fails, only the magic bytes and size will be written
         // and the block body won't be written to the blk*.dat file.
         // Since the first 4 bytes should contain the block's version, we can skip such blocks
         // by peeking the cursor (and skipping previous `magic` and `block_size`).
         match u32::consensus_decode(&mut cursor) {
             Ok(value) => {
+                warn!("(edge case magic check) Magic: {magic}, Actual: {value}");
                 if magic == value {
                     cursor.set_position(start);
                     continue;
@@ -224,6 +229,7 @@ fn parse_blocks(blob: Vec<u8>, magic: u32) -> Result<Vec<SizedBlock>> {
             Err(_) => break, // EOF
         }
         slices.push((&blob[start as usize..end as usize], block_size));
+        warn!("slices size: {}", slices.len());
         cursor.set_position(end);
     }