Remove epidemic propagation for fully replicated stuff: write directly to all nodes

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,