SyntheticBird/cuprate-hinto-janai
1
0
Fork 0
mirror of https://github.com/hinto-janai/cuprate.git synced 2024-12-31 16:09:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix rx seed initialization from previous commit

Browse source
This commit is contained in:
Boog900 2024-01-10 23:55:17 +00:00
parent 2c4ab3cc85
commit d6495cdb01
No known key found for this signature in database
GPG key ID: 5401367FB7302004
1 changed files with 18 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
consensus/src/bin/scan_chain.rs
View file

@ -221,13 +221,29 @@ where
panic!("ctx svc sent wrong response!"); panic!("ctx svc sent wrong response!");
}; };
let mut rx_seed_cache = ctx.unchecked_blockchain_context().rx_seed_cache.clone(); let mut rx_seed_cache = ctx.unchecked_blockchain_context().rx_seed_cache.clone();
let mut rx_seed_cache_initiated = false;
let mut randomx_vms: Option<HashMap<u64, RandomXVM>> = Some(HashMap::new()); let mut randomx_vms: Option<HashMap<u64, RandomXVM>> = Some(HashMap::new());
let mut cloned_ctx_svc = ctx_svc.clone();
tokio::spawn(async move { tokio::spawn(async move {
while let Some(blocks) = incoming_blocks.next().await { while let Some(blocks) = incoming_blocks.next().await {
// RX technically starts at hf 12 but we do 11 so the seed hash is in the cache. if blocks.last().unwrap().header.major_version >= 12 {
if blocks.last().unwrap().header.major_version >= 11 { if !rx_seed_cache_initiated {
let BlockChainContextResponse::Context(ctx) = cloned_ctx_svc
.ready()
.await
.unwrap()
.call(BlockChainContextRequest::Get)
.await
.unwrap()
else {
panic!("ctx svc sent wrong response!");
};
rx_seed_cache = ctx.unchecked_blockchain_context().rx_seed_cache.clone();
rx_seed_cache_initiated = true;
}
let unwrapped_rx_vms = randomx_vms.as_mut().unwrap(); let unwrapped_rx_vms = randomx_vms.as_mut().unwrap();
let blocks = rayon_spawn_async(move || { let blocks = rayon_spawn_async(move || {