Toggle parameters
This commit is contained in:
@ -45,7 +45,7 @@ fn broadcast(
|
|||||||
if log_enabled!(Level::Trace) {
|
if log_enabled!(Level::Trace) {
|
||||||
trace!(
|
trace!(
|
||||||
"{}",
|
"{}",
|
||||||
window::print_window(&id, &window.read().unwrap(), *receive_index)
|
window::print_window(&window.read().unwrap(), &id, *receive_index)
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -465,7 +465,7 @@ fn recv_window(
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
if log_enabled!(Level::Trace) {
|
if log_enabled!(Level::Trace) {
|
||||||
trace!("{}", print_window(id, &window.read().unwrap(), *consumed));
|
trace!("{}", print_window(&window.read().unwrap(), id, *consumed));
|
||||||
trace!(
|
trace!(
|
||||||
"{}: consumed: {} received: {} sending consume.len: {} pixs: {:?} took {} ms",
|
"{}: consumed: {} received: {} sending consume.len: {} pixs: {:?} took {} ms",
|
||||||
id,
|
id,
|
||||||
@ -483,7 +483,7 @@ fn recv_window(
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn print_window(id: &Pubkey, window: &Window, consumed: u64) -> String {
|
pub fn print_window(window: &Window, id: &Pubkey, consumed: u64) -> String {
|
||||||
let pointer: Vec<_> = window
|
let pointer: Vec<_> = window
|
||||||
.iter()
|
.iter()
|
||||||
.enumerate()
|
.enumerate()
|
||||||
|
Reference in New Issue
Block a user