~cannam/bsq-samplestreams commit

1 files changed, 6 insertions(+), 0 deletions(-)

M blockstream-fn.sml

M blockstream-fn.sml +6 -0

@@ 492,12 492,18 @@ functor BlockStreamRateHelperFn (S : BLO
         let open SignalTypes SampleStreamLog
             val t0 = S.time s
             val upstreamRate = S.rate s
+            val () = SizeLog.report "BlockStreamRateHelperFn.deduceBlockRate"
+                                    NONE "stream passed in, before read" s
         in
             case S.read s of
                 NONE => (info (fn () => ["BlockStreamRateHelper: end-of-stream at start of stream means we can't deduce a rate, using upstream rate of %1 directly", R (rateOf upstreamRate)]);
                          upstreamRate)
               | SOME (s', _) =>
                 let val t1 = S.time s'
+                    val () = SizeLog.report "BlockStreamRateHelperFn.deduceBlockRate"
+                                            NONE "stream passed in, after read" s
+                    val () = SizeLog.report "BlockStreamRateHelperFn.deduceBlockRate"
+                                            NONE "stream returned by read" s'
                 in
                     if RealTime.== (t0, t1)
                     then (warn (fn () => ["BlockStreamRateHelper: no time increment reported by stream means we can't deduce a rate, using upstream rate of %1 directly", R (rateOf upstreamRate)]);