cerc-io/lighthouse
10
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Process transfers in parallel.

Browse Source
This commit is contained in:
Paul Hauner 2019-03-10 08:36:49 +11:00
parent 1ca99b8c4c
commit e7fba3a473
No known key found for this signature in database
GPG Key ID: D362883A9218FCC6
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
eth2/state_processing/src/per_block_processing.rs
View File

@ -442,8 +442,15 @@ pub fn process_transfers(
transfers.len() as u64 <= spec.max_transfers, transfers.len() as u64 <= spec.max_transfers,
Invalid::MaxTransfersExceed Invalid::MaxTransfersExceed
); );
transfers
.par_iter()
.enumerate()
.try_for_each(|(i, transfer)| {
verify_transfer(&state, transfer, spec).map_err(|e| e.into_with_index(i))
})?;
for (i, transfer) in transfers.iter().enumerate() { for (i, transfer) in transfers.iter().enumerate() {
verify_transfer(&state, transfer, spec).map_err(|e| e.into_with_index(i))?;
execute_transfer(state, transfer, spec).map_err(|e| e.into_with_index(i))?; execute_transfer(state, transfer, spec).map_err(|e| e.into_with_index(i))?;
} }

2
eth2/types/src/test_utils/testing_transfer_builder.rs
View File

@ -9,7 +9,7 @@ impl TestingTransferBuilder {
pub fn new(from: u64, to: u64, amount: u64, slot: Slot) -> Self { pub fn new(from: u64, to: u64, amount: u64, slot: Slot) -> Self {
let keypair = Keypair::random(); let keypair = Keypair::random();
let mut transfer = Transfer { let transfer = Transfer {
from, from,
to, to,
amount, amount,