ASCEE/lasprs
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Even smarter. No stream meta stored but just the ranges for each channel.

Browse Source
This commit is contained in:
Anne de Jong 2024-11-02 00:38:33 +01:00
parent 79fca548b1
commit 26515b9ee0
1 changed files with 8 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/rt/simpleclip.rs
View File

@ -43,21 +43,18 @@ impl SimpleClipDetector {
smgr.addInQueue(tx);
rayon::spawn(
move || {
let mut streammeta: Option<Arc<StreamMetaData>> = None;
let mut mins = vec![];
let mut maxs = vec![];
let mut ranges = vec![];
loop {
if let Ok(msg) = rx.recv_timeout(Duration::from_millis(1500)) {
match msg {
InStreamMsg::StreamStarted(meta) => {
mins.resize(meta.nchannels(), 0.);
maxs.resize(meta.nchannels(), 0.);
streammeta = Some(meta);
ranges = meta.channelInfo.iter().map(|ch| ch.range).collect();
}
InStreamMsg::InStreamData(dat) => {
let meta = streammeta
.as_ref()
.expect("If we are here, stream metadata should be available");
let flt = dat.getFloatData();
// Update channel maximum values
flt.columns()
@ -71,12 +68,10 @@ impl SimpleClipDetector {
.for_each(|(coli, mini)| *mini = min(coli));
// Compare minima and maxima against clip limits
maxs.iter()
.zip(mins.iter())
.zip(&meta.channelInfo)
.for_each(|((max, min), ch)| {
let min_for_clip = CLIP_REL_LIMIT * ch.range.0;
let max_for_clip = CLIP_REL_LIMIT * ch.range.1;
maxs.iter().zip(mins.iter()).zip(ranges.iter()).for_each(
|((max, min), range)| {
let min_for_clip = CLIP_REL_LIMIT * range.0;
let max_for_clip = CLIP_REL_LIMIT * range.1;
if *max >= max_for_clip {
clipstate.store(true, Relaxed);
// We do not have to do anything anymore. The signal
@ -91,7 +86,8 @@ impl SimpleClipDetector {
// blocks anymore.
return;
}
});
},
);
}
// Ignore other stream messages
_ => {}