diff --git a/daqbufp2/src/test/api4/binnedjson.rs b/daqbufp2/src/test/api4/binnedjson.rs index 21ace3d..582d88f 100644 --- a/daqbufp2/src/test/api4/binnedjson.rs +++ b/daqbufp2/src/test/api4/binnedjson.rs @@ -189,7 +189,8 @@ fn binned_d0_json_05() -> Result<(), Error> { let res: items_2::binsdim0::BinsDim0CollectedResult = serde_json::from_value(jsv)?; // inmem was meant just for functional test, ignores the requested time range assert_eq!(res.ts_anchor_sec(), 0); - assert_eq!(res.len(), 3); + // TODO make disk parse faster and avoid timeout + assert_eq!(res.len(), 11); assert_eq!(res.range_final(), false); assert_eq!(f32_cmp_near(res.avgs()[0], 42.0), true); Ok(()) diff --git a/disk/src/raw/conn.rs b/disk/src/raw/conn.rs index cb4b40a..09f4d6c 100644 --- a/disk/src/raw/conn.rs +++ b/disk/src/raw/conn.rs @@ -42,7 +42,7 @@ where .as_any_mut() .downcast_mut::>() { - warn!("ScalarEvents"); + trace!("ScalarEvents"); let tss: VecDeque = item.tss.iter().map(|x| *x).collect(); let pulses: VecDeque = item.pulses.iter().map(|x| *x).collect(); let values: VecDeque = item.values.iter().map(|x| x.clone()).collect(); @@ -50,7 +50,7 @@ where let item = ChannelEvents::Events(Box::new(item)); Ok(StreamItem::DataItem(RangeCompletableItem::Data(item))) } else if let Some(item) = item.as_any_mut().downcast_mut::>() { - warn!("WaveEvents"); + trace!("WaveEvents"); let _tss: VecDeque = item.tss.iter().map(|x| *x).collect(); let _pulses: VecDeque = item.pulses.iter().map(|x| *x).collect(); let _values: VecDeque> = item.vals.iter().map(|x| x.clone()).collect(); @@ -62,7 +62,7 @@ where .as_any_mut() .downcast_mut::>() { - warn!("XBinnedScalarEvents"); + trace!("XBinnedScalarEvents"); let tss: VecDeque = item.tss.iter().map(|x| *x).collect(); let pulses: VecDeque = (0..tss.len()).map(|_| 0).collect(); let _avgs: VecDeque = item.avgs.iter().map(|x| x.clone()).collect();