grassrootseconomics/openethereum
7
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

do not clone pending transaction hashes

Browse Source
This commit is contained in:
debris 2016-05-26 12:44:17 +02:00
parent f811fdc2cd
commit 6fd9780e60
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
rpc/src/v1/impls/eth.rs
View File

@ -674,14 +674,18 @@ impl<C, M> EthFilter for EthFilterClient<C, M> where
PollFilter::PendingTransaction(ref mut previous_hashes) => { PollFilter::PendingTransaction(ref mut previous_hashes) => {
// get hashes of pending transactions // get hashes of pending transactions
let current_hashes = take_weak!(self.miner).pending_transactions_hashes(); let current_hashes = take_weak!(self.miner).pending_transactions_hashes();
let previous_hashes_set = previous_hashes.into_iter().map(|h| h.clone()).collect::<HashSet<H256>>();
let new_hashes =
{
let previous_hashes_set = previous_hashes.iter().collect::<HashSet<_>>();
// find all new hashes // find all new hashes
let new_hashes = current_hashes current_hashes
.iter() .iter()
.filter(|hash| !previous_hashes_set.contains(&hash)) .filter(|hash| !previous_hashes_set.contains(hash))
.cloned() .cloned()
.collect::<Vec<H256>>(); .collect::<Vec<H256>>()
};
// save all hashes of pending transactions // save all hashes of pending transactions
*previous_hashes = current_hashes; *previous_hashes = current_hashes;