daqbuf/daqbuf-items-2
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Reduce log

Browse Source
This commit is contained in:
Dominik Werder
2024-12-09 23:01:45 +01:00
parent ca787cee78
commit 08b1afeb72
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/binning/timeweight/timeweight_bins.rs
View File

@@ -13,7 +13,7 @@ use std::any;
macro_rules! trace_init { ($($arg:tt)*) => ( if true { trace!($($arg)*); }) }
macro_rules! trace_ingest_bin { ($($arg:tt)*) => ( if true { trace!($($arg)*); }) }
macro_rules! trace_ingest_bin { ($($arg:tt)*) => ( if false { trace!($($arg)*); }) }
#[derive(Debug, thiserror::Error)]
#[cstm(name = "BinBinsTimeweight")]
@@ -103,7 +103,7 @@ where
fn ingest_bins(&mut self, bins: &ContainerBins<EVT, BVT>) -> Result<(), BinningggError> {
for (((((((&ts1, &ts2), &cnt), min), max), agg), lst), &fnl) in bins.zip_iter() {
let grid = self.range.bin_len_dt_ns();
trace_ingest_bin!("grid {:?} ts1 {:?} agg {:?}", grid, ts1, agg);
trace_ingest_bin!("ingest_bins grid {:?} ts1 {:?} agg {:?}", grid, ts1, agg);
if ts1 < self.active_beg {
self.lst = Some(lst.into());
} else {