[sweep][ranker] always notify if sync is issued

Author: aslpavel

Cargo.lock

@@ -3,7 +3,7 @@ authors = ["Pavel Aslanov <[email protected]>"]
 build = "build.rs"
 edition = "2021"
 name = "sweep"
-version = "0.16.10"
+version = "0.16.11"
 include = ["**/*.rs", "src/icons.json", "Cargo.toml", "Cargo.lock", "README.md"]
 
 [lib]

sweep/Cargo.toml

@@ -203,12 +203,12 @@ fn ranker_worker<H, N>(
 
         // rank
         let rank_instant = Instant::now();
-        let matches = match action {
+        matches_prev = match action {
             DoNothing => {
-                for sync in synced.drain(..) {
-                    sync.store(true, Ordering::Release);
+                if synced.is_empty() {
+                    continue;
                 }
-                continue;
+                matches_prev
             }
             Offset(offset) => {
                 let mut matches = pool.alloc();
@@ -223,30 +223,29 @@ fn ranker_worker<H, N>(
                 if !keep_order {
                     matches.par_sort_unstable_by(|a, b| b.score.cmp(&a.score));
                 }
-                matches
+                pool.promote(matches)
             }
             CurrentMatch => {
                 let mut matches = pool.alloc();
                 matches.clear();
                 // score previous matches
                 matches.extend(matches_prev.iter().cloned());
                 rank(&ctx, scorer.clone(), &haystack, &mut matches, !keep_order);
-                matches
+                pool.promote(matches)
             }
             All => {
                 let mut matches = pool.alloc();
                 matches.clear();
                 // score all haystack elements
                 matches.extend((0..haystack.with(|hs| hs.len())).map(Match::new));
                 rank(&ctx, scorer.clone(), &haystack, &mut matches, !keep_order);
-                matches
+                pool.promote(matches)
             }
         };
         let rank_elapsed = rank_instant.elapsed();
 
         // update result
         rank_gen += 1;
-        matches_prev = pool.promote(matches);
         result.with_mut(|result| {
             *result = Arc::new(RankedItems {
                 haystack: haystack.clone(),

sweep/src/rank.rs

@@ -1463,6 +1463,7 @@ where
                     .as_ref()
                     .map_or_else(|| true, |s| s.load(Ordering::Acquire))
             {
+                tracing::debug!("[sweep_ui_worker][draw] suppressed");
                 return Ok(TerminalAction::WaitNoFrame);
             }
             render_supress_sync.take();