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

log using events

Browse Source
This commit is contained in:
spaced4ndy
2024-09-30 13:54:32 +04:00
parent 52aa164f9a
commit c71f0d7beb
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -60,6 +60,7 @@ runNtfSupervisor c = do
ns <- asks ntfSupervisor
forever $ do
logInfo "#################### runNtfSupervisor - in forever loop"
notifyInternalError' c "#################### runNtfSupervisor - in forever loop"
cmd <- atomically . readTBQueue $ ntfSubQ ns
handleErr . agentOperationBracket c AONtfNetwork waitUntilActive $
runExceptT (processNtfCmd c cmd) >>= \case
@@ -198,6 +199,7 @@ runNtfWorker :: AgentClient -> NtfServer -> Worker -> AM ()
runNtfWorker c srv Worker {doWork} =
forever $ do
logInfo "#################### runNtfWorker - in forever loop"
notifyInternalError' c "#################### runNtfWorker - in forever loop"
waitForWork doWork
ExceptT $ agentOperationBracket c AONtfNetwork throwWhenInactive $ runExceptT runNtfOperation
where
@@ -367,6 +369,7 @@ runNtfWorker c srv Worker {doWork} =
runNtfSMPWorker :: AgentClient -> SMPServer -> Worker -> AM ()
runNtfSMPWorker c srv Worker {doWork} = forever $ do
logInfo "#################### runNtfSMPWorker - in forever loop"
notifyInternalError' c "#################### runNtfSMPWorker - in forever loop"
waitForWork doWork
ExceptT $ agentOperationBracket c AONtfNetwork throwWhenInactive $ runExceptT runNtfSMPOperation
where