blockworks-foundation
/
lite-rpc
mirror of https://github.com/blockworks-foundation/lite-rpc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix block_store race conditiom

This commit is contained in:
aniketfuryrocks 2023-02-02 18:02:44 +05:30
parent 2cc7d9709e
commit 0cd06f48c1
No known key found for this signature in database
GPG Key ID: FA6BFCFAA7D4B764
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/workers/block_listenser.rs
View File

@ -96,7 +96,7 @@ impl BlockListener {
blockhash.to_owned(),
self.block_store
.get(blockhash)
.expect("Latest Block Not in Map")
.expect("Internal Error: Block store race condition")
.value()
.to_owned(),
)
@ -171,9 +171,12 @@ impl BlockListener {
let parent_slot = block.parent_slot;
*self.latest_block_hash.write().await = blockhash.clone();
// Write to block store first in order to prevent
// any race condition i.e prevent some one to
// ask the map what it doesn't have rn
self.block_store
.insert(blockhash, BlockInformation { slot, block_height });
.insert(blockhash.clone(), BlockInformation { slot, block_height });
*self.latest_block_hash.write().await = blockhash;
if let Some(postgres) = &postgres {
postgres