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

mark waitForWork

Browse Source
This commit is contained in:
Alexander Bondarenko
2024-04-09 20:26:32 +03:00
parent aca371e547
commit e56b4b2b40
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Simplex/Messaging/Agent/Client.hs
+2 -2
View File
@@ -162,7 +162,7 @@ import Data.Text.Encoding
import Data.Time (UTCTime, defaultTimeLocale, formatTime, getCurrentTime)
import Data.Time.Clock.System (getSystemTime)
import Data.Word (Word16)
import GHC.Stack (HasCallStack)
import GHC.Stack (HasCallStack, withFrozenCallStack)
import Network.Socket (HostName)
import Simplex.FileTransfer.Client (XFTPChunkSpec (..), XFTPClient, XFTPClientConfig (..), XFTPClientError)
import qualified Simplex.FileTransfer.Client as X
@@ -1418,7 +1418,7 @@ cryptoError = \case
c = AGENT . A_CRYPTO
waitForWork :: (MonadIO m, HasCallStack) => TMVar () -> m ()
waitForWork = void . atomically' . readTMVar
waitForWork v = withFrozenCallStack $ void . atomically' $ readTMVar v
{-# INLINE waitForWork #-}
withWork :: AgentClient -> TMVar () -> (DB.Connection -> IO (Either StoreError (Maybe a))) -> (a -> AM ()) -> AM ()