diff --git a/src/crdt.rs b/src/crdt.rs index 764b01b55..8c15b693d 100644 --- a/src/crdt.rs +++ b/src/crdt.rs @@ -236,7 +236,7 @@ impl Crdt { ) -> Result<()> { let me: ReplicatedData = { let robj = obj.read().expect("'obj' read lock in crdt::index_blobs"); - info!("broadcast table {}", robj.table.len()); + debug!("broadcast table {}", robj.table.len()); robj.table[&robj.me].clone() }; @@ -248,7 +248,6 @@ impl Crdt { blob.set_index(*transmit_index + i as u64) .expect("set_index in pub fn broadcast"); } - info!("set blobs index"); Ok(()) } @@ -289,7 +288,7 @@ impl Crdt { warn!("crdt too small"); return Err(Error::CrdtTooSmall); } - info!("nodes table {}", nodes.len()); + trace!("nodes table {}", nodes.len()); // enumerate all the blobs in the window, those are the indices // transmit them to nodes, starting from a different node @@ -305,7 +304,7 @@ impl Crdt { i %= window_l.len(); } - info!("orders table {}", orders.len()); + trace!("orders table {}", orders.len()); let errs: Vec<_> = orders .into_iter() .map(|(b, v)| { @@ -321,7 +320,7 @@ impl Crdt { e }) .collect(); - info!("broadcast results {}", errs.len()); + trace!("broadcast results {}", errs.len()); for e in errs { match e { Err(e) => { diff --git a/src/request_stage.rs b/src/request_stage.rs index d2c197850..520a095d6 100644 --- a/src/request_stage.rs +++ b/src/request_stage.rs @@ -43,7 +43,7 @@ impl RequestStage { ) -> Result<()> { let (batch, batch_len) = streamer::recv_batch(packet_receiver)?; - info!( + debug!( "@{:?} request_stage: processing: {}", timing::timestamp(), batch_len @@ -70,7 +70,7 @@ impl RequestStage { } let total_time_s = timing::duration_as_s(&proc_start.elapsed()); let total_time_ms = timing::duration_as_ms(&proc_start.elapsed()); - info!( + debug!( "@{:?} done process batches: {} time: {:?}ms reqs: {} reqs/s: {}", timing::timestamp(), batch_len, diff --git a/src/streamer.rs b/src/streamer.rs index 2f899194f..86ad3264c 100644 --- a/src/streamer.rs +++ b/src/streamer.rs @@ -179,7 +179,7 @@ fn repair_window( #[cfg(feature = "erasure")] { if erasure::recover(_recycler, &mut locked_window.write().unwrap(), *consumed).is_err() { - info!("erasure::recover failed"); + trace!("erasure::recover failed"); } } let reqs = find_next_missing(locked_window, crdt, consumed, received)?;