helpy4/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich synced 2025-11-07 17:27:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: prevent isolate deadlock (#21692)

Browse source
This commit is contained in:
Alex 2025-09-08 14:18:13 -05:00 • committed by GitHub
parent 059a0e8aa8
commit 59accbf32a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 11 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

15
mobile/lib/domain/services/background_worker.service.dart
View file

@ -169,15 +169,20 @@ class BackgroundWorkerBgService extends BackgroundWorkerFlutterApi {
try { try {
_isCleanedUp = true; _isCleanedUp = true;
_logger.info("Cleaning up background worker"); _logger.info("Cleaning up background worker");
await _ref.read(backgroundSyncProvider).cancel(); final cleanupFutures = [
await _ref.read(backgroundSyncProvider).cancelLocal(); _drift.close(),
_driftLogger.close(),
_ref.read(backgroundSyncProvider).cancel(),
_ref.read(backgroundSyncProvider).cancelLocal(),
];
if (_isar.isOpen) { if (_isar.isOpen) {
await _isar.close(); cleanupFutures.add(_isar.close());
} }
await _drift.close();
await _driftLogger.close();
_ref.dispose(); _ref.dispose();
_lockManager.releaseLock(); _lockManager.releaseLock();
await Future.wait(cleanupFutures);
_logger.info("Background worker resources cleaned up"); _logger.info("Background worker resources cleaned up");
} catch (error, stack) { } catch (error, stack) {
debugPrint('Failed to cleanup background worker: $error with stack: $stack'); debugPrint('Failed to cleanup background worker: $error with stack: $stack');

2
mobile/lib/infrastructure/repositories/db.repository.dart
View file

@ -148,7 +148,7 @@ class Drift extends $Drift implements IDatabaseRepository {
await customStatement('PRAGMA foreign_keys = ON'); await customStatement('PRAGMA foreign_keys = ON');
await customStatement('PRAGMA synchronous = NORMAL'); await customStatement('PRAGMA synchronous = NORMAL');
await customStatement('PRAGMA journal_mode = WAL'); await customStatement('PRAGMA journal_mode = WAL');
await customStatement('PRAGMA busy_timeout = 500'); await customStatement('PRAGMA busy_timeout = 30000');
}, },
); );
} }