Merge branch 'fix_block_race_condition' into block_store

This commit is contained in:
aniketfuryrocks 2023-02-02 18:09:25 +05:30
commit eb7573e13b
No known key found for this signature in database
GPG Key ID: FA6BFCFAA7D4B764
1 changed files with 9 additions and 0 deletions

View File

@ -164,9 +164,18 @@ impl BlockListener {
let parent_slot = block.parent_slot;
<<<<<<< HEAD
self.block_store
.insert(blockhash, BlockInformation { slot, block_height });
*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.clone(), BlockInformation { slot, block_height });
*self.latest_block_hash.write().await = blockhash;
>>>>>>> fix_block_race_condition
if let Some(postgres) = &postgres {
let Some(rewards) = block.rewards else {