0ct0pu5/ente
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Rename variable

Browse source
This commit is contained in:
vishnukvmd 2024-02-18 11:05:04 +05:30
parent d8541e6a46
commit 60204cd910
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
lib/services/machine_learning/semantic_search/semantic_search_service.dart
View file

@ -51,7 +51,7 @@ class SemanticSearchService {
Future<List<EnteFile>>? _ongoingRequest;
List<Embedding> _cachedEmbeddings = <Embedding>[];
PendingQuery? _nextQuery;
Completer<void> _healthCheckCompleter = Completer<void>();
Completer<void> _mlController = Completer<void>();
get hasInitialized => _hasInitialized;
@ -290,9 +290,9 @@ class SemanticSearchService {
if (!_frameworkInitialization.isCompleted) {
return;
}
if (!_healthCheckCompleter.isCompleted) {
_logger.info("Waiting for health check to give a green signal...");
await _healthCheckCompleter.future;
if (!_mlController.isCompleted) {
_logger.info("Waiting for a green signal from controller...");
await _mlController.future;
}
try {
final thumbnail = await getThumbnailForUploadedFile(file);
@ -368,15 +368,15 @@ class SemanticSearchService {
void _startIndexing() {
_logger.info("Start indexing");
if (!_healthCheckCompleter.isCompleted) {
_healthCheckCompleter.complete();
if (!_mlController.isCompleted) {
_mlController.complete();
}
}
void _pauseIndexing() {
if (_healthCheckCompleter.isCompleted) {
if (_mlController.isCompleted) {
_logger.info("Pausing indexing");
_healthCheckCompleter = Completer<void>();
_mlController = Completer<void>();
}
}
}