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

Minor compilation changes

This commit is contained in:
Godmode Galactus 2023-09-08 13:57:55 +02:00
parent 3e4ec00f0a
commit 797ed8d556
No known key found for this signature in database
GPG Key ID: A04142C71ABB0DEA
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cluster-endpoints/src/rpc_polling/poll_blocks.rs
View File

@ -172,13 +172,18 @@ pub fn poll_block(
let task_spawner: AnyhowJoinHandle = tokio::spawn(async move { let task_spawner: AnyhowJoinHandle = tokio::spawn(async move {
let counting_semaphore = Arc::new(tokio::sync::Semaphore::new(1024)); let counting_semaphore = Arc::new(tokio::sync::Semaphore::new(1024));
let mut slot_notification = slot_notification; let mut slot_notification = slot_notification;
let current_slot = Arc::new(AtomicU64::new(rpc_client.get_slot())); let current_slot = Arc::new(AtomicU64::new(0));
loop { loop {
let SlotNotification { processed_slot, .. } = slot_notification let SlotNotification { processed_slot, .. } = slot_notification
.recv() .recv()
.await .await
.context("Slot notification channel close")?; .context("Slot notification channel close")?;
let last_processed_slot = current_slot.load(std::sync::atomic::Ordering::Relaxed); let last_processed_slot = current_slot.load(std::sync::atomic::Ordering::Relaxed);
let last_processed_slot = if last_processed_slot == 0 {
last_processed_slot.saturating_sub(1)
} else {
last_processed_slot
};
if processed_slot > last_processed_slot { if processed_slot > last_processed_slot {
current_slot.store(processed_slot, std::sync::atomic::Ordering::Relaxed); current_slot.store(processed_slot, std::sync::atomic::Ordering::Relaxed);