Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 2 additions & 18 deletions .github/workflows/bench.yml
Original file line number Diff line number Diff line change
Expand Up @@ -59,26 +59,10 @@ jobs:
run: |
./pr/.github/scripts/compare_iai.sh

# Checks that benchmarks not run in CI compile
bench-check:
name: check
runs-on:
group: Reth
steps:
- uses: actions/checkout@v3
- name: Install toolchain
uses: dtolnay/rust-toolchain@stable
- uses: Swatinem/rust-cache@v2
- name: Check if benchmarks build
run: cargo check --workspace --benches --all-features

bench-success:
if: always()
name: bench success
needs: bench-check
runs-on: ubuntu-20.04
steps:
- name: Decide whether the needed jobs succeeded or failed
uses: re-actors/alls-green@release/v1
with:
jobs: ${{ toJSON(needs) }}
# Note: This check is a dummy because we don't have any bench checks enabled.
- run: echo OK.
4 changes: 2 additions & 2 deletions .github/workflows/ci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ jobs:
uses: actions-rs/cargo@v1
with:
command: check
args: --all --all-features
args: --all --all-features --benches --tests

- name: cargo fmt
uses: actions-rs/cargo@v1
Expand All @@ -44,7 +44,7 @@ jobs:
uses: actions-rs/cargo@v1
with:
command: clippy
args: --all --all-features
args: --all --all-features --benches --tests

doc-lint:
name: doc lint
Expand Down
28 changes: 15 additions & 13 deletions crates/prune/src/pruner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1282,10 +1282,11 @@ mod tests {
.iter()
.enumerate()
.flat_map(|(block_number, changeset)| {
changeset.into_iter().map(move |change| (block_number, change))
changeset.iter().map(move |change| (block_number, change))
})
.collect::<Vec<_>>();

#[allow(clippy::skip_while_next)]
let pruned = changesets
.iter()
.enumerate()
Expand All @@ -1308,11 +1309,13 @@ mod tests {
.map(|(block_number, _)| if done { *block_number } else { block_number.saturating_sub(1) } as BlockNumber)
.unwrap_or(to_block);

let pruned_changesets =
pruned_changesets.fold(BTreeMap::new(), |mut acc, (block_number, change)| {
acc.entry(block_number).or_insert_with(Vec::new).push(change);
let pruned_changesets = pruned_changesets.fold(
BTreeMap::<_, Vec<_>>::new(),
|mut acc, (block_number, change)| {
acc.entry(block_number).or_default().push(change);
acc
});
},
);

assert_eq!(
tx.table::<tables::AccountChangeSet>().unwrap().len(),
Expand Down Expand Up @@ -1409,12 +1412,13 @@ mod tests {
.iter()
.enumerate()
.flat_map(|(block_number, changeset)| {
changeset.into_iter().flat_map(move |(address, _, entries)| {
entries.into_iter().map(move |entry| (block_number, address, entry))
changeset.iter().flat_map(move |(address, _, entries)| {
entries.iter().map(move |entry| (block_number, address, entry))
})
})
.collect::<Vec<_>>();

#[allow(clippy::skip_while_next)]
let pruned = changesets
.iter()
.enumerate()
Expand All @@ -1438,9 +1442,9 @@ mod tests {
.unwrap_or(to_block);

let pruned_changesets = pruned_changesets.fold(
BTreeMap::new(),
BTreeMap::<_, Vec<_>>::new(),
|mut acc, (block_number, address, entry)| {
acc.entry((block_number, address)).or_insert_with(Vec::new).push(entry);
acc.entry((block_number, address)).or_default().push(entry);
acc
},
);
Expand Down Expand Up @@ -1544,9 +1548,7 @@ mod tests {
.inner()
.get_prune_checkpoint(PrunePart::ContractLogs)
.unwrap()
.and_then(|checkpoint| {
Some((checkpoint.block_number.unwrap(), checkpoint.tx_number.unwrap()))
})
.map(|checkpoint| (checkpoint.block_number.unwrap(), checkpoint.tx_number.unwrap()))
.unwrap_or_default();

// All receipts are in the end of the block
Expand All @@ -1558,7 +1560,7 @@ mod tests {
((pruned_tx + 1) - unprunable) as usize
);

return done
done
};

while !run_prune() {}
Expand Down
2 changes: 1 addition & 1 deletion crates/rpc/rpc-engine-api/src/engine_api.rs
Original file line number Diff line number Diff line change
Expand Up @@ -772,10 +772,10 @@ mod tests {

let expected = blocks
.iter()
.cloned()
// filter anything after the second missing range to ensure we don't expect trailing
// `None`s
.filter(|b| !second_missing_range.contains(&b.number))
.cloned()
.map(|b| {
if first_missing_range.contains(&b.number) {
None
Expand Down
1 change: 1 addition & 0 deletions crates/trie/src/trie.rs
Original file line number Diff line number Diff line change
Expand Up @@ -533,6 +533,7 @@ where
}

#[cfg(test)]
#[allow(clippy::mutable_key_type)]
mod tests {
use super::*;
use crate::test_utils::{
Expand Down