jeff/nucleo
1
0
Fork 0
mirror of https://github.com/solaeus/nucleo.git synced 2024-11-10 01:27:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix incorrect unmatched count calculation

Browse Source 
This could lead to underflow (and crashed in debug builds)
This commit is contained in:
Pascal Kuthe 2023-08-04 08:55:54 +02:00
parent e499e2b601
commit 9670035cdc
No known key found for this signature in database
GPG Key ID: D715E8655AE166A6
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/worker.rs
View File

@ -36,7 +36,6 @@ pub(crate) struct Woker<T: Sync + Send + 'static> {
notify: Arc<(dyn Fn() + Sync + Send)>, notify: Arc<(dyn Fn() + Sync + Send)>,
pub(crate) items: Arc<boxcar::Vec<T>>, pub(crate) items: Arc<boxcar::Vec<T>>,
in_flight: Vec<u32>, in_flight: Vec<u32>,
unmatched: AtomicU32,
} }
impl<T: Sync + Send + 'static> Woker<T> { impl<T: Sync + Send + 'static> Woker<T> {
@ -78,7 +77,6 @@ impl<T: Sync + Send + 'static> Woker<T> {
notify, notify,
items: Arc::new(boxcar::Vec::with_capacity(2 * 1024, cols)), items: Arc::new(boxcar::Vec::with_capacity(2 * 1024, cols)),
in_flight: Vec::with_capacity(64), in_flight: Vec::with_capacity(64),
unmatched: AtomicU32::new(0),
}; };
(pool, worker) (pool, worker)
} }
@ -152,13 +150,11 @@ impl<T: Sync + Send + 'static> Woker<T> {
if cleared { if cleared {
self.last_snapshot = 0; self.last_snapshot = 0;
*self.unmatched.get_mut() = 0;
self.matches.clear(); self.matches.clear();
} }
// TODO: be smarter around reusing past results for rescoring // TODO: be smarter around reusing past results for rescoring
if self.pattern.cols.iter().all(|pat| pat.is_empty()) { if self.pattern.cols.iter().all(|pat| pat.is_empty()) {
*self.unmatched.get_mut() = 0;
self.matches.clear(); self.matches.clear();
self.matches self.matches
.extend((0..self.last_snapshot).map(|idx| Match { score: 0, idx })); .extend((0..self.last_snapshot).map(|idx| Match { score: 0, idx }));
@ -179,6 +175,7 @@ impl<T: Sync + Send + 'static> Woker<T> {
self.remove_in_flight_matches(); self.remove_in_flight_matches();
} }
let mut unmatched = AtomicU32::new(0);
let matchers = &self.matchers; let matchers = &self.matchers;
let pattern = &self.pattern; let pattern = &self.pattern;
if pattern_status != pattern::Status::Unchanged && !self.matches.is_empty() { if pattern_status != pattern::Status::Unchanged && !self.matches.is_empty() {
@ -187,6 +184,7 @@ impl<T: Sync + Send + 'static> Woker<T> {
.take_any_while(|_| !self.canceled.load(atomic::Ordering::Relaxed)) .take_any_while(|_| !self.canceled.load(atomic::Ordering::Relaxed))
.for_each(|match_| { .for_each(|match_| {
if match_.idx == u32::MAX { if match_.idx == u32::MAX {
unmatched.fetch_add(1, atomic::Ordering::Relaxed);
return; return;
} }
// safety: in-flight items are never added to the matches // safety: in-flight items are never added to the matches
@ -194,7 +192,7 @@ impl<T: Sync + Send + 'static> Woker<T> {
if let Some(score) = pattern.score(item.matcher_columns, matchers.get()) { if let Some(score) = pattern.score(item.matcher_columns, matchers.get()) {
match_.score = score; match_.score = score;
} else { } else {
self.unmatched.fetch_add(1, atomic::Ordering::Release); unmatched.fetch_add(1, atomic::Ordering::Relaxed);
match_.score = 0; match_.score = 0;
match_.idx = u32::MAX; match_.idx = u32::MAX;
} }
@ -241,7 +239,7 @@ impl<T: Sync + Send + 'static> Woker<T> {
self.was_canceled = true; self.was_canceled = true;
} else { } else {
self.matches self.matches
.truncate(self.matches.len() - take(self.unmatched.get_mut()) as usize); .truncate(self.matches.len() - take(unmatched.get_mut()) as usize);
if self.should_notify.load(atomic::Ordering::Acquire) { if self.should_notify.load(atomic::Ordering::Acquire) {
(self.notify)(); (self.notify)();
} }