Skip to content

Commit 6855711

Browse files
committed
fix
1 parent 2965b69 commit 6855711

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/Simplex/Messaging/Server.hs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -579,13 +579,12 @@ smpServer started cfg@ServerConfig {transports, transportConfig = tCfg} attachHT
579579
rtm <- getRealTimeMetrics env
580580
T.writeFile metricsFile $ prometheusMetrics sm rtm ts
581581

582-
getServerMetrics :: STMQueueStore s => s -> ServerStats -> IO ServerMetrics
582+
getServerMetrics :: MsgStoreClass s => s -> ServerStats -> IO ServerMetrics
583583
getServerMetrics st ss = do
584584
d <- getServerStatsData ss
585585
let ps = periodStatDataCounts $ _activeQueues d
586586
psNtf = periodStatDataCounts $ _activeQueuesNtf d
587-
queueCount <- M.size <$> readTVarIO (activeMsgQueues st)
588-
notifierCount <- M.size <$> readTVarIO (notifiers' st)
587+
QueueCounts {queueCount, notifierCount} <- queueCounts st
589588
pure ServerMetrics {statsData = d, activeQueueCounts = ps, activeNtfCounts = psNtf, queueCount, notifierCount}
590589

591590
getRealTimeMetrics :: Env -> IO RealTimeMetrics

0 commit comments

Comments
 (0)