aljaz/sphinx-key
1
1
Fork 0
mirror of https://github.com/stakwork/sphinx-key.git synced 2026-01-10 02:54:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Ordering::SeqCst

Browse Source
This commit is contained in:
Evan Feenstra
2023-09-06 09:29:39 -07:00
parent f5fa7fbe71
commit 2578792872
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
broker/src/looper.rs
View File

@@ -15,16 +15,16 @@ static COUNTER: AtomicU16 = AtomicU16::new(0u16);
static CURRENT: AtomicU16 = AtomicU16::new(0u16);
pub fn take_a_ticket() -> u16 {
COUNTER.fetch_add(1u16, Ordering::Relaxed)
COUNTER.fetch_add(1u16, Ordering::SeqCst)
}
pub fn is_my_turn(ticket: u16) -> bool {
let curr = CURRENT.load(Ordering::Relaxed);
let curr = CURRENT.load(Ordering::SeqCst);
curr == ticket
}
pub fn my_turn_is_done() {
CURRENT.fetch_add(1u16, Ordering::Relaxed);
CURRENT.fetch_add(1u16, Ordering::SeqCst);
}
#[derive(Clone, Debug)]