dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-03-30 16:26:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix race

Browse Source
This commit is contained in:
spaced4ndy
2024-09-12 11:35:57 +04:00
parent 6cc19b38bc
commit ed9b18e8a7
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/Simplex/Messaging/Agent/NtfSubSupervisor.hs
View File

@@ -102,12 +102,13 @@ processNtfSub c (connId, cmd) = do
withStore' c $ \db -> supervisorUpdateNtfSub db sub' (NSASMP NSASmpKey)
lift . void $ getNtfSMPWorker True c smpServer
NSCSmpDelete -> do
withStore' c (`getPrimaryRcvQueue` connId) >>= \case
Right rq@RcvQueue {server = smpServer} -> do
logInfo $ "processNtfSub, NSCSmpDelete - rq = " <> tshow rq
withStore' c $ \db -> supervisorUpdateNtfAction db connId (NSASMP NSASmpDelete)
lift . void $ getNtfSMPWorker True c smpServer
_ -> notifyInternalError c connId "NSCSmpDelete - no rcv queue"
sub_ <- withStore' c $ \db -> do
supervisorUpdateNtfAction db connId (NSASMP NSASmpDelete)
getNtfSubscription db connId
logInfo $ "processNtfSub, NSCSmpDelete - sub_ = " <> tshow sub_
case sub_ of
(Just (NtfSubscription {smpServer}, _)) -> lift . void $ getNtfSMPWorker True c smpServer
_ -> pure () -- err "NSCSmpDelete - no subscription"
NSCNtfWorker ntfServer -> lift . void $ getNtfNTFWorker True c ntfServer
NSCNtfSMPWorker smpServer -> lift . void $ getNtfSMPWorker True c smpServer