From fcdb0403ba397291e91fae46c65273118b30db9b Mon Sep 17 00:00:00 2001 From: Rob Walker Date: Tue, 24 Jul 2018 08:22:21 -0700 Subject: [PATCH] eliminate unused parameter received, this branch fixes #636 --- src/streamer.rs | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/src/streamer.rs b/src/streamer.rs index 4ef44ac043..08c9d40718 100644 --- a/src/streamer.rs +++ b/src/streamer.rs @@ -315,7 +315,6 @@ fn process_blob( window: &Window, recycler: &BlobRecycler, consumed: &mut u64, - received: u64, ) { let mut window = window.write().unwrap(); let w = (pix % WINDOW_SIZE) as usize; @@ -395,13 +394,7 @@ fn process_blob( // push all contiguous blobs into consumed queue, increment consumed loop { let k = (*consumed % WINDOW_SIZE) as usize; - trace!( - "{:x}: k: {} consumed: {} received: {}", - debug_id, - k, - *consumed, - received - ); + trace!("{:x}: k: {} consumed: {}", debug_id, k, *consumed,); if let Some(blob) = &window[k].data { if blob.read().unwrap().get_index().unwrap() < *consumed { @@ -486,7 +479,6 @@ fn recv_window( window, recycler, consumed, - *received, ); } print_window(debug_id, window, *consumed);