From ee0025c6a33c0deec790802b71e8e796ae365620 Mon Sep 17 00:00:00 2001 From: voidlizard Date: Mon, 26 May 2025 18:10:11 +0300 Subject: [PATCH] maybe fixed TCP loop on error -- additional probe --- hbs2-core/lib/HBS2/Net/Messaging/TCP.hs | 1 + 1 file changed, 1 insertion(+) diff --git a/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs b/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs index 70608b4a..801815da 100644 --- a/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs +++ b/hbs2-core/lib/HBS2/Net/Messaging/TCP.hs @@ -238,6 +238,7 @@ runMessagingTCP env@MessagingTCP{..} = liftIO do S.yield =<< ( readTVarIO _tcpClientThreads <&> ("tcpClientThreads",) . fromIntegral . HM.size ) S.yield =<< ( readTVarIO _tcpServerThreadsCount <&> ("tcpServerThreadsCount",) . fromIntegral ) S.yield =<< ( readTVarIO _tcpPeerConn <&> ("tcpPeerConn",) . fromIntegral . HM.size) + S.yield =<< ( readTVarIO _tcpConnDemand <&> ("tcpPeerConnDemand",) . fromIntegral . HPSQ.size) coo <- readTVarIO _tcpPeerCookie -- <&> ("tcpPeerCookie",) let cooNn = sum [ 1 | (_,v) <- HM.toList coo, v >= 1 ]