dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-05-25 18:34:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

log stalled subQ

Browse Source
This commit is contained in:
Alexander Bondarenko
2024-05-30 17:26:14 +03:00
parent 2ce3c712e1
commit c76d16758e
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Simplex/Messaging/Agent/Client.hs
+2 -1
View File
@@ -1351,12 +1351,13 @@ subscribeQueues c qs = do
then do
when (any isNothing subResults) resubscribe
let up = catMaybes $ L.toList subResults
unless (null up) $ notifySub c "" $ UP srv up
unless (null up) $ notifyUP up
pure rs
else do
logWarn "subcription batch result for replaced SMP client, resubscribing"
resubscribe $> L.map (second $ \_ -> Left PCENetworkError) rs
where
notifyUP up = maybe (logError "sndQ full" >> notifyUP up) pure =<< timeout 30000000 (notifySub c "" $ UP srv up)
tSess@(_, srv, _) = transportSession' smp
sessId = sessionId $ thParams smp
processSubResults :: NonEmpty (RcvQueue, Either SMPClientError ()) -> STM (NonEmpty (Maybe ConnId))