gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fixups

Browse Source
This commit is contained in:
Rob Walker
2018-07-24 12:56:39 -07:00
parent 75505bbd72
commit 2b528e2225
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/streamer.rs
View File

@ -4,6 +4,7 @@ use counter::Counter;
use crdt::{Crdt, CrdtError, NodeInfo};
#[cfg(feature = "erasure")]
use erasure;
use log::Level::Trace;
use packet::{
Blob, BlobRecycler, PacketRecycler, SharedBlob, SharedBlobs, SharedPackets, BLOB_SIZE,
};
@ -481,7 +482,9 @@ fn recv_window(
consumed,
);
}
trace!("{}", print_window(debug_id, window, *consumed));
if log_enabled!(Trace) {
trace!("{}", print_window(debug_id, window, *consumed));
}
trace!(
"{:x}: sending consume_queue.len: {}",
debug_id,
@ -688,7 +691,9 @@ fn broadcast(
// break them up into window-sized chunks to process
let blobs_chunked = blobs_vec.chunks(WINDOW_SIZE as usize).map(|x| x.to_vec());
trace!("{}", print_window(debug_id, window, *receive_index));
if log_enabled!(Trace) {
trace!("{}", print_window(debug_id, window, *receive_index));
}
for mut blobs in blobs_chunked {
let blobs_len = blobs.len();