composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-07-14 23:00:24 +03:00
Code Issues Packages Projects Releases Wiki Activity

Add stop reason and life-time duration to channel dump

Browse Source
This commit is contained in:
Harendra Kumar 2024-02-16 00:41:51 +05:30
parent 79e743667b
commit 13d165082b
1 changed files with 44 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
src/Streamly/Internal/Data/Channel/Dispatcher.hs
View File

@ -207,47 +207,55 @@ dumpSVarStats inspecting rateInfo ss = do
minLat <- readIORef $ minWorkerLatency ss
maxLat <- readIORef $ maxWorkerLatency ss
(avgCnt, avgTime) <- readIORef $ avgWorkerLatency ss
(svarCnt, svarGainLossCnt, svarLat) <- case rateInfo of
Nothing -> return (0, 0, 0)
stopTime <- readIORef (svarStopTime ss)
let stopReason =
case stopTime of
Nothing -> "on GC"
Just _ -> "normal"
(svarCnt, svarGainLossCnt, svarLat, interval) <- case rateInfo of
Nothing -> return (0, 0, 0, 0)
Just yinfo -> do
(cnt, startTime) <- readIORef $ svarAllTimeLatency yinfo
if cnt > 0
then do
t <- readIORef (svarStopTime ss)
gl <- readIORef (svarGainedLostYields yinfo)
case t of
interval <-
case stopTime of
Nothing -> do
now <- getTime Monotonic
let interval = diffAbsTime64 now startTime
return (cnt, gl, interval `div` fromIntegral cnt)
Just stopTime -> do
let interval = diffAbsTime64 stopTime startTime
return (cnt, gl, interval `div` fromIntegral cnt)
else return (0, 0, 0)
return (diffAbsTime64 now startTime)
Just t -> do
return (diffAbsTime64 t startTime)
if cnt > 0
then do
gl <- readIORef (svarGainedLostYields yinfo)
return (cnt, gl, interval `div` fromIntegral cnt, interval)
else return (0, 0, 0, interval)
return $ unlines
[ "total dispatches = " <> show dispatches
, "max workers = " <> show maxWrk
, "max outQSize = " <> show maxOq
<> (if minLat > 0
then "\nmin worker latency = " <> showNanoSecond64 minLat
else "")
<> (if maxLat > 0
then "\nmax worker latency = " <> showNanoSecond64 maxLat
else "")
<> (if avgCnt > 0
then let lat = avgTime `div` fromIntegral avgCnt
in "\navg worker latency = " <> showNanoSecond64 lat
else "")
<> (if svarLat > 0
then "\nSVar latency = " <> showRelTime64 svarLat
else "")
<> (if svarCnt > 0
then "\nSVar yield count = " <> show svarCnt
else "")
<> (if svarGainLossCnt > 0
then "\nSVar gain/loss yield count = " <> show svarGainLossCnt
else "")
return $ concat
[ "stop reason = " <> stopReason
, if interval > 0
then "\nlife time = " <> showRelTime64 interval
else ""
, "\ntotal dispatches = " <> show dispatches
, "\nmax workers = " <> show maxWrk
, "\nmax outQSize = " <> show maxOq
, if minLat > 0
then "\nmin worker latency = " <> showNanoSecond64 minLat
else ""
, if maxLat > 0
then "\nmax worker latency = " <> showNanoSecond64 maxLat
else ""
, if avgCnt > 0
then let lat = avgTime `div` fromIntegral avgCnt
in "\navg worker latency = " <> showNanoSecond64 lat
else ""
, if svarLat > 0
then "\nchannel latency = " <> showRelTime64 svarLat
else ""
, if svarCnt > 0
then "\nchannel yield count = " <> show svarCnt
else ""
, if svarGainLossCnt > 0
then "\nchannel gain/loss yield count = " <> show svarGainLossCnt
else ""
]
-------------------------------------------------------------------------------