github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-29 17:18:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

perf: only lookup in db in cache layer (#3773)

Browse Source
This commit is contained in:
Matthias Seitz
2023-07-14 11:06:23 +02:00
committed by GitHub
parent ad4c590b65
commit e3ac77a231
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
crates/rpc/rpc/src/eth/cache/mod.rs vendored
View File

@@ -3,7 +3,9 @@
use futures::{future::Either, Stream, StreamExt};
use reth_interfaces::{provider::ProviderError, Result};
use reth_primitives::{Block, Receipt, SealedBlock, TransactionSigned, H256};
use reth_provider::{BlockReader, CanonStateNotification, EvmEnvProvider, StateProviderFactory};
use reth_provider::{
BlockReader, BlockSource, CanonStateNotification, EvmEnvProvider, StateProviderFactory,
};
use reth_tasks::{TaskSpawner, TokioTaskExecutor};
use revm::primitives::{BlockEnv, CfgEnv};
use schnellru::{ByLength, Limiter};
@@ -307,7 +309,10 @@ where
let provider = this.provider.clone();
let action_tx = this.action_tx.clone();
this.action_task_spawner.spawn_blocking(Box::pin(async move {
let res = provider.block_by_hash(block_hash);
// Only look in the database to prevent situations where we
// looking up the tree is blocking
let res = provider
.find_block_by_hash(block_hash, BlockSource::Database);
let _ = action_tx
.send(CacheAction::BlockResult { block_hash, res });
}));
@@ -325,7 +330,10 @@ where
let provider = this.provider.clone();
let action_tx = this.action_tx.clone();
this.action_task_spawner.spawn_blocking(Box::pin(async move {
let res = provider.block_by_hash(block_hash);
// Only look in the database to prevent situations where we
// looking up the tree is blocking
let res = provider
.find_block_by_hash(block_hash, BlockSource::Database);
let _ = action_tx
.send(CacheAction::BlockResult { block_hash, res });
}));