TerribleDev/ente
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use lock for full sync

Browse Source
This commit is contained in:
Neeraj Gupta
2025-03-25 05:47:47 +05:30
parent b18298dc62
commit 4369317a4d
1 changed files with 19 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
mobile/lib/services/local/local_import.dart
View File

@@ -113,23 +113,25 @@ class LocalImportService {
bool hasChanges = false;
_fullSync = Completer<bool>();
try {
final TimeLogger tL = TimeLogger(context: "fullSync");
final inAppAssetIds = await localDB.getAssetsIDs();
final inAppPathToAssetIds = await localDB.pathToAssetIDs();
_log.info("loaded inApp State $tL");
final fullDiff = await _deviceAssetsService.fullDiffWithOnDevice(
inAppAssetIds,
inAppPathToAssetIds,
tL,
);
if (fullDiff.isInOutOfSync) {
_log.info("fullSyncDiff: ${fullDiff.countLog()} ${tL.elapsed}");
await _storeDiff(fullDiff: fullDiff);
}
_log.fine(
"${fullDiff.isInOutOfSync ? 'changed saved ${fullDiff.countLog()} $tL)' : 'no change'}, completeTime ${tL.elapsed}",
);
hasChanges = fullDiff.isInOutOfSync;
await _lock.synchronized(() async {
final TimeLogger tL = TimeLogger(context: "fullSync");
final inAppAssetIds = await localDB.getAssetsIDs();
final inAppPathToAssetIds = await localDB.pathToAssetIDs();
_log.info("loaded inApp State $tL");
final fullDiff = await _deviceAssetsService.fullDiffWithOnDevice(
inAppAssetIds,
inAppPathToAssetIds,
tL,
);
if (fullDiff.isInOutOfSync) {
_log.info("fullSyncDiff: ${fullDiff.countLog()} ${tL.elapsed}");
await _storeDiff(fullDiff: fullDiff);
}
_log.fine(
"${fullDiff.isInOutOfSync ? 'changed saved ${fullDiff.countLog()} $tL)' : 'no change'}, completeTime ${tL.elapsed}",
);
hasChanges = fullDiff.isInOutOfSync;
});
} catch (e, s) {
_log.severe("fullSync failed", e, s);
rethrow;