jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 19:09:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf: execute db read tasks on blocking pool (#2896)

Browse Source
This commit is contained in:
Matthias Seitz
2023-05-29 16:24:03 +02:00
committed by GitHub
parent e848dcd675
commit b1760e7332
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
crates/rpc/rpc/src/eth/cache.rs
View File

@ -312,7 +312,7 @@ where
if this.full_block_cache.queue(block_hash, Either::Left(response_tx)) { if this.full_block_cache.queue(block_hash, Either::Left(response_tx)) {
let client = this.client.clone(); let client = this.client.clone();
let action_tx = this.action_tx.clone(); let action_tx = this.action_tx.clone();
this.action_task_spawner.spawn(Box::pin(async move { this.action_task_spawner.spawn_blocking(Box::pin(async move {
let res = client.block_by_hash(block_hash); let res = client.block_by_hash(block_hash);
let _ = action_tx let _ = action_tx
.send(CacheAction::BlockResult { block_hash, res }); .send(CacheAction::BlockResult { block_hash, res });
@ -330,7 +330,7 @@ where
if this.full_block_cache.queue(block_hash, Either::Right(response_tx)) { if this.full_block_cache.queue(block_hash, Either::Right(response_tx)) {
let client = this.client.clone(); let client = this.client.clone();
let action_tx = this.action_tx.clone(); let action_tx = this.action_tx.clone();
this.action_task_spawner.spawn(Box::pin(async move { this.action_task_spawner.spawn_blocking(Box::pin(async move {
let res = client.block_by_hash(block_hash); let res = client.block_by_hash(block_hash);
let _ = action_tx let _ = action_tx
.send(CacheAction::BlockResult { block_hash, res }); .send(CacheAction::BlockResult { block_hash, res });
@ -350,7 +350,7 @@ where
if this.receipts_cache.queue(block_hash, response_tx) { if this.receipts_cache.queue(block_hash, response_tx) {
let client = this.client.clone(); let client = this.client.clone();
let action_tx = this.action_tx.clone(); let action_tx = this.action_tx.clone();
this.action_task_spawner.spawn(Box::pin(async move { this.action_task_spawner.spawn_blocking(Box::pin(async move {
let res = client.receipts_by_block(block_hash.into()); let res = client.receipts_by_block(block_hash.into());
let _ = action_tx let _ = action_tx
.send(CacheAction::ReceiptsResult { block_hash, res }); .send(CacheAction::ReceiptsResult { block_hash, res });
@ -369,7 +369,7 @@ where
if this.evm_env_cache.queue(block_hash, response_tx) { if this.evm_env_cache.queue(block_hash, response_tx) {
let client = this.client.clone(); let client = this.client.clone();
let action_tx = this.action_tx.clone(); let action_tx = this.action_tx.clone();
this.action_task_spawner.spawn(Box::pin(async move { this.action_task_spawner.spawn_blocking(Box::pin(async move {
let mut cfg = CfgEnv::default(); let mut cfg = CfgEnv::default();
let mut block_env = BlockEnv::default(); let mut block_env = BlockEnv::default();
let res = client let res = client