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

Adapt to LogItem api

Browse Source
This commit is contained in:
Dominik Werder
2025-06-18 13:08:01 +02:00
parent caf0b83f5b
commit 3508c463a2
3 changed files with 8 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/binning/timeweight/timeweight_bins_stream.rs
View File

@@ -121,8 +121,7 @@ impl BinnedBinsTimeweightStream {
Ready(Some(Ok(DataItem(Data(x)))))
}
None => {
let item =
LogItem::from_node(888, log::Level::INFO, format!("no bins ready on eos"));
let item = LogItem::from_node(log::Level::INFO, format!("no bins ready on eos"));
Ready(Some(Ok(Log(item))))
}
}

3
src/binning/timeweight/timeweight_events_dyn.rs
View File

@@ -396,8 +396,7 @@ impl BinnedEventsTimeweightStream {
None => {
debug!("no bins ready on eos");
self.state = StreamState::Done;
let item =
LogItem::from_node(888, log::Level::INFO, format!("no bins ready on eos"));
let item = LogItem::from_node(log::Level::INFO, format!("no bins ready on eos"));
Ready(Some(Ok(Log(item))))
}
}

16
src/merger.rs
View File

@@ -198,16 +198,12 @@ where
if let Some((i1, t1)) = tslows[0].as_ref() {
if *t1 <= self.dim0ix_max {
self.dim0ix_max = *t1;
let item = LogItem {
node_ix: *i1 as _,
level: log::Level::INFO,
msg: format!(
"dim0ix_max {} vs {} diff {}",
self.dim0ix_max,
t1,
self.dim0ix_max.ns() - t1.ns()
),
};
let item = LogItem::info(format!(
"dim0ix_max {} vs {} diff {} i1 {i1}",
self.dim0ix_max,
t1,
self.dim0ix_max.ns() - t1.ns()
));
log_items.push(item);
}
}