From e56b4b2b406bad945afa2702ac755ba103f693d3 Mon Sep 17 00:00:00 2001 From: Alexander Bondarenko <486682+dpwiz@users.noreply.github.com> Date: Tue, 9 Apr 2024 20:26:32 +0300 Subject: [PATCH] mark waitForWork --- src/Simplex/Messaging/Agent/Client.hs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Simplex/Messaging/Agent/Client.hs b/src/Simplex/Messaging/Agent/Client.hs index 239f50031..47aa60761 100644 --- a/src/Simplex/Messaging/Agent/Client.hs +++ b/src/Simplex/Messaging/Agent/Client.hs @@ -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 ()