dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-09-01 20:18:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "log using events"

Browse Source 
This reverts commit c71f0d7beb.
This commit is contained in:
spaced4ndy
2024-09-30 15:08:39 +04:00
parent c71f0d7beb
commit 6c1e1f18d4
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Simplex/Messaging/Agent/NtfSubSupervisor.hs
-3
View File
@@ -60,7 +60,6 @@ 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
@@ -199,7 +198,6 @@ 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
@@ -369,7 +367,6 @@ 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