Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2024-11-17 17:57:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

untested extra bool mutex flag

Browse source
This commit is contained in:
julian 2023-09-08 10:54:31 -06:00
parent 8f0da21d2b
commit 25bc126cf9
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
lib/electrumx_rpc/electrumx.dart
View file

@ -91,6 +91,7 @@ class ElectrumX {
StreamSubscription<TorConnectionStatusChangedEvent>? _torStatusListener;
final Mutex _torConnectingLock = Mutex();
bool _requireMutex = false;
ElectrumX({
required String host,
@ -117,11 +118,13 @@ class ElectrumX {
switch (event.newStatus) {
case TorConnectionStatus.connecting:
await _torConnectingLock.acquire();
_requireMutex = true;
break;
case TorConnectionStatus.connected:
case TorConnectionStatus.disconnected:
_torConnectingLock.release();
_requireMutex = false;
break;
}
},
@ -260,7 +263,11 @@ class ElectrumX {
throw WifiOnlyException();
}
await _torConnectingLock.protect(() async => _checkRpcClient());
if (_requireMutex) {
await _torConnectingLock.protect(() async => _checkRpcClient());
} else {
_checkRpcClient();
}
try {
final requestId = requestID ?? const Uuid().v1();
@ -346,7 +353,11 @@ class ElectrumX {
throw WifiOnlyException();
}
await _torConnectingLock.protect(() async => _checkRpcClient());
if (_requireMutex) {
await _torConnectingLock.protect(() async => _checkRpcClient());
} else {
_checkRpcClient();
}
try {
final List<String> requestStrings = [];