aljaz/breez-sdk-liquid
1
0
Fork 0
mirror of https://github.com/aljazceru/breez-sdk-liquid.git synced 2026-01-08 00:24:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: switch to single-threaded claiming (#63)

Browse Source
This commit is contained in:
yse
2024-03-28 09:18:41 +01:00
committed by GitHub
parent 21f6d7068a
commit f7703e103f
1 changed files with 14 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
lib/src/wallet.rs
View File

@@ -101,25 +101,21 @@ impl Wallet {
thread::sleep(Duration::from_secs(5));
let ongoing_swaps = cloned.swap_persister.list_ongoing_swaps().unwrap();
thread::scope(|scope| {
for swap in ongoing_swaps {
scope.spawn(|| {
if let OngoingSwap::Receive {
id,
preimage,
redeem_script,
blinding_key,
..
} = swap
{
match cloned.try_claim(&preimage, &redeem_script, &blinding_key, None) {
Ok(_) => cloned.swap_persister.resolve_ongoing_swap(&id).unwrap(),
Err(e) => warn!("Could not claim yet. Err: {e}"),
}
}
});
for swap in ongoing_swaps {
if let OngoingSwap::Receive {
id,
preimage,
redeem_script,
blinding_key,
..
} = swap
{
match cloned.try_claim(&preimage, &redeem_script, &blinding_key, None) {
Ok(_) => cloned.swap_persister.resolve_ongoing_swap(&id).unwrap(),
Err(e) => warn!("Could not claim yet. Err: {e}"),
}
}
});
}
});
Ok(())