absolutebi/serai
1
0
Fork 0
mirror of https://github.com/serai-dex/serai.git synced 2025-12-08 20:29:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add/correct msrv labels

Browse Source
This commit is contained in:
Luke Parker
2024-12-08 18:27:01 -05:00
parent 834c16930b
commit 8013c56195
74 changed files with 326 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
message-queue/src/main.rs
View File

@@ -73,7 +73,8 @@ pub(crate) fn queue_message(
assert!(matches!(meta.from, Service::Coordinator) ^ matches!(meta.to, Service::Coordinator));
// Lock the queue
let queue_lock = QUEUES.read().unwrap()[&(meta.from, meta.to)].write().unwrap();
let queue_lock = QUEUES.read().unwrap();
let mut queue_lock = queue_lock[&(meta.from, meta.to)].write().unwrap();
// Verify (from, to, intent) hasn't been prior seen
fn key(domain: &'static [u8], key: impl AsRef<[u8]>) -> Vec<u8> {