From 0115a1f834b03cd3e071d004ae9e5194652e27a4 Mon Sep 17 00:00:00 2001 From: Michael Vines Date: Fri, 8 Feb 2019 10:12:43 -0800 Subject: [PATCH] Remove unused SocketAddr --- src/banking_stage.rs | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) diff --git a/src/banking_stage.rs b/src/banking_stage.rs index 23ae1972d5..d2a34cbd3c 100644 --- a/src/banking_stage.rs +++ b/src/banking_stage.rs @@ -19,7 +19,6 @@ use solana_sdk::hash::Hash; use solana_sdk::pubkey::Pubkey; use solana_sdk::timing; use solana_sdk::transaction::Transaction; -use std::net::SocketAddr; use std::sync::atomic::{AtomicUsize, Ordering}; use std::sync::mpsc::{channel, Receiver, RecvTimeoutError}; use std::sync::{Arc, Mutex}; @@ -148,16 +147,11 @@ impl BankingStage { sys_info::cpu_num().unwrap_or(NUM_THREADS) } - /// Convert the transactions from a blob of binary data to a vector of transactions and - /// an unused `SocketAddr` that could be used to send a response. - fn deserialize_transactions(p: &Packets) -> Vec> { + /// Convert the transactions from a blob of binary data to a vector of transactions + fn deserialize_transactions(p: &Packets) -> Vec> { p.packets .iter() - .map(|x| { - deserialize(&x.data[0..x.meta.size]) - .map(|req| (req, x.meta.addr())) - .ok() - }) + .map(|x| deserialize(&x.data[0..x.meta.size]).ok()) .collect() } @@ -213,7 +207,7 @@ impl BankingStage { .zip(vers) .filter_map(|(tx, ver)| match tx { None => None, - Some((tx, _addr)) => { + Some(tx) => { if tx.verify_refs() && ver != 0 { Some(tx) } else {