Ecosystem/cake_wallet
1
0
Fork 0
mirror of https://github.com/cake-tech/cake_wallet.git synced 2025-01-18 16:55:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

improvements

Browse source
This commit is contained in:
Matthew Fosse 2024-12-19 10:39:23 -05:00
parent d4346e480c
commit f312072bdf
1 changed files with 21 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
lib/entities/background_tasks.dart
View file

@ -355,6 +355,11 @@ Future<void> onStart(ServiceInstance service) async {
return; return;
} }
// don't refresh the queue until we've finished syncing all wallets:
if (syncingWallets.isNotEmpty) {
return;
}
for (int i = 0; i < standbyWallets.length; i++) { for (int i = 0; i < standbyWallets.length; i++) {
final wallet = standbyWallets[i]; final wallet = standbyWallets[i];
final syncStatus = wallet.syncStatus; final syncStatus = wallet.syncStatus;
@ -376,14 +381,13 @@ Future<void> onStart(ServiceInstance service) async {
// setup a watch dog to restart the wallet sync process if it appears to get stuck: // setup a watch dog to restart the wallet sync process if it appears to get stuck:
List<double> lastFewProgresses = []; List<double> lastFewProgresses = [];
List<String> stuckWallets = [];
_stuckSyncTimer?.cancel(); _stuckSyncTimer?.cancel();
_stuckSyncTimer = Timer.periodic(const Duration(seconds: 10), (timer) async { _stuckSyncTimer = Timer.periodic(const Duration(seconds: 10), (timer) async {
if (syncingWallets.isEmpty) return; if (syncingWallets.isEmpty) return;
final wallet = syncingWallets.first; final wallet = syncingWallets.first;
final syncStatus = wallet.syncStatus; final syncStatus = wallet.syncStatus;
if (syncStatus is! SyncingSyncStatus) return; if (syncStatus is! SyncingSyncStatus) return;
if (syncStatus.progress() > SYNC_THRESHOLD)
return; // don't bother checking if we're close to synced
lastFewProgresses.add(syncStatus.progress()); lastFewProgresses.add(syncStatus.progress());
if (lastFewProgresses.length < 10) return; if (lastFewProgresses.length < 10) return;
// limit list size to 10: // limit list size to 10:
@ -393,8 +397,21 @@ Future<void> onStart(ServiceInstance service) async {
// if the progress is the same over the last 100 seconds, restart the sync: // if the progress is the same over the last 100 seconds, restart the sync:
if (lastFewProgresses.every((p) => p == lastFewProgresses.first)) { if (lastFewProgresses.every((p) => p == lastFewProgresses.first)) {
printV("syncing appears to be stuck, restarting..."); printV("syncing appears to be stuck, restarting...");
try {
stuckWallets.add(wallet.name);
await wallet.stopSync(); await wallet.stopSync();
await wallet.startSync(); } catch (e) {
printV("error restarting sync: $e");
}
// if this wallet has been stuck more than twice, don't restart it, instead, add it to the standby list and try again on next queue refresh:
// check if stuckWallets contains wallet.name more than 2 times:
if (stuckWallets.where((name) => name == wallet.name).length > 2) {
printV("wallet ${wallet.name} has been stuck more than 2 times, adding to standby list");
standbyWallets.add(syncingWallets.removeAt(0));
stuckWallets = [];
return;
}
wallet.startSync();
} }
}); });
}); });