Ecosystem/cake_wallet
1
0
Fork 0
mirror of https://github.com/cake-tech/cake_wallet.git synced 2025-01-03 09:29:48 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

[skip ci] sync stuck watch dog

Browse source
This commit is contained in:
Matthew Fosse 2024-12-18 17:00:23 -05:00
parent ac847d8b93
commit c2e764f77b
1 changed files with 19 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
lib/entities/background_tasks.dart
View file

@ -253,7 +253,7 @@ Future<void> onStart(ServiceInstance service) async {
if (progress > 0.999 && shouldSync) {
syncedTicks++;
if (syncedTicks > 10) {
if (syncedTicks > 5) {
syncedTicks = 0;
printV("WALLET $i SYNCED");
wallet.stopSync();
@ -374,25 +374,27 @@ Future<void> onStart(ServiceInstance service) async {
}
});
// setup a watch dog to restart the sync process if it gets stuck:
// setup a watch dog to restart the wallet sync process if it appears to get stuck:
List<double> lastFewProgresses = [];
_stuckSyncTimer?.cancel();
_stuckSyncTimer = Timer.periodic(const Duration(seconds: 10), (timer) async {
// TODO: finish this
// if (syncStatus is! SyncingSyncStatus) return;
// if (syncStatus.progress() > 0.98) return; // don't check if we're close to synced
// lastFewProgresses.add(syncStatus.progress());
// if (lastFewProgresses.length < 10) return;
// // limit list size to 10:
// while (lastFewProgresses.length > 10) {
// lastFewProgresses.removeAt(0);
// }
// // if the progress is the same over the last 100 seconds, restart the sync:
// if (lastFewProgresses.every((p) => p == lastFewProgresses.first)) {
// printV("mweb syncing is stuck, restarting...");
// syncStatus = LostConnectionSyncStatus();
// await stopSync();
// }
if (syncingWallets.isEmpty) return;
final wallet = syncingWallets.first;
final syncStatus = wallet.syncStatus;
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());
if (lastFewProgresses.length < 10) return;
// limit list size to 10:
while (lastFewProgresses.length > 10) {
lastFewProgresses.removeAt(0);
}
// if the progress is the same over the last 100 seconds, restart the sync:
if (lastFewProgresses.every((p) => p == lastFewProgresses.first)) {
printV("syncing appears to be stuck, restarting...");
await wallet.stopSync();
await wallet.startSync();
}
});
});
}