diff options
Diffstat (limited to 'src/table/table_sync.rs')
| -rw-r--r-- | src/table/table_sync.rs | 32 |
1 files changed, 27 insertions, 5 deletions
diff --git a/src/table/table_sync.rs b/src/table/table_sync.rs index 2c984226..5fa6793b 100644 --- a/src/table/table_sync.rs +++ b/src/table/table_sync.rs @@ -319,7 +319,13 @@ where } counter += 1; - debug!("Offloading {} items from {:?}..{:?} ({})", items.len(), begin, end, counter); + debug!( + "Offloading {} items from {:?}..{:?} ({})", + items.len(), + begin, + end, + counter + ); self.offload_items(&items, &nodes[..]).await?; } else { break; @@ -408,7 +414,11 @@ where .iter() .all(|x| *x == 0u8) { - trace!("range_checksum {:?} returning {} items", range, children.len()); + trace!( + "range_checksum {:?} returning {} items", + range, + children.len() + ); return Ok(RangeChecksum { bounds: range.clone(), children, @@ -423,7 +433,11 @@ where }; children.push((item_range, blake2sum(&value[..]))); } - trace!("range_checksum {:?} returning {} items", range, children.len()); + trace!( + "range_checksum {:?} returning {} items", + range, + children.len() + ); Ok(RangeChecksum { bounds: range.clone(), children, @@ -449,7 +463,11 @@ where } if sub_ck.found_limit.is_none() || sub_ck.hash.is_none() { - trace!("range_checksum {:?} returning {} items", range, children.len()); + trace!( + "range_checksum {:?} returning {} items", + range, + children.len() + ); return Ok(RangeChecksum { bounds: range.clone(), children, @@ -464,7 +482,11 @@ where .iter() .all(|x| *x == 0u8) { - trace!("range_checksum {:?} returning {} items", range, children.len()); + trace!( + "range_checksum {:?} returning {} items", + range, + children.len() + ); return Ok(RangeChecksum { bounds: range.clone(), children, |