64 lines
2.2 KiB
Rust
64 lines
2.2 KiB
Rust
use criterion::{criterion_group, criterion_main, Criterion};
|
|
use ethers::prelude::*;
|
|
use helios::types::BlockTag;
|
|
use std::str::FromStr;
|
|
|
|
mod harness;
|
|
|
|
criterion_main!(get_code);
|
|
criterion_group! {
|
|
name = get_code;
|
|
config = Criterion::default().sample_size(10);
|
|
targets = bench_mainnet_get_code, bench_goerli_get_code
|
|
}
|
|
|
|
/// Benchmark mainnet get code call.
|
|
/// Address: 0x00000000219ab540356cbb839cbe05303d7705fa (beacon chain deposit address)
|
|
pub fn bench_mainnet_get_code(c: &mut Criterion) {
|
|
c.bench_function("get_code", |b| {
|
|
// Create a new multi-threaded tokio runtime.
|
|
let rt = tokio::runtime::Builder::new_multi_thread()
|
|
.enable_all()
|
|
.build()
|
|
.unwrap();
|
|
|
|
// Construct a mainnet client using our harness and tokio runtime.
|
|
let client = std::sync::Arc::new(harness::construct_mainnet_client(&rt).unwrap());
|
|
|
|
// Get the beacon chain deposit contract address.
|
|
let addr = Address::from_str("0x00000000219ab540356cbb839cbe05303d7705fa").unwrap();
|
|
let block = BlockTag::Latest;
|
|
|
|
// Execute the benchmark asynchronously.
|
|
b.to_async(rt).iter(|| async {
|
|
let inner = std::sync::Arc::clone(&client);
|
|
inner.get_code(&addr, block).await.unwrap()
|
|
})
|
|
});
|
|
}
|
|
|
|
/// Benchmark goerli get code call.
|
|
/// Address: 0xB4FBF271143F4FBf7B91A5ded31805e42b2208d6 (goerli weth)
|
|
pub fn bench_goerli_get_code(c: &mut Criterion) {
|
|
c.bench_function("get_code", |b| {
|
|
// Create a new multi-threaded tokio runtime.
|
|
let rt = tokio::runtime::Builder::new_multi_thread()
|
|
.enable_all()
|
|
.build()
|
|
.unwrap();
|
|
|
|
// Construct a goerli client using our harness and tokio runtime.
|
|
let client = std::sync::Arc::new(harness::construct_goerli_client(&rt).unwrap());
|
|
|
|
// Get the beacon chain deposit contract address.
|
|
let addr = Address::from_str("0xB4FBF271143F4FBf7B91A5ded31805e42b2208d6").unwrap();
|
|
let block = BlockTag::Latest;
|
|
|
|
// Execute the benchmark asynchronously.
|
|
b.to_async(rt).iter(|| async {
|
|
let inner = std::sync::Arc::clone(&client);
|
|
inner.get_code(&addr, block).await.unwrap()
|
|
})
|
|
});
|
|
}
|