@@ -65,7 +65,7 @@ pingNode :: MonadIO m
6565 => TestnetMagic -- ^ testnet magic
6666 -> IO. Sprocket -- ^ node sprocket
6767 -> m (Either PingClientError () ) -- ^ '()' means success
68- pingNode networkMagic sprocket = liftIO $ bracket
68+ pingNode networkMagic sprocket = liftIOAnnotated $ bracket
6969 (Socket. socket (Socket. addrFamily peer) Socket. Stream Socket. defaultProtocol)
7070 Socket. close
7171 (\ sd -> handle (pure . Left . PceException ) $ withTimeoutSerial $ \ timeoutfn -> do
@@ -143,7 +143,7 @@ waitForSprocket :: MonadIO m
143143 -> MT. DiffTime -- ^ interval
144144 -> IO. Sprocket
145145 -> m (Either IOException () )
146- waitForSprocket timeout interval sprocket = liftIO $ do
146+ waitForSprocket timeout interval sprocket = liftIOAnnotated $ do
147147 lastResult <- newIORef (Right () )
148148 _ <- MT. timeout timeout $ loop lastResult
149149 readIORef lastResult
@@ -158,7 +158,7 @@ waitForSprocket timeout interval sprocket = liftIO $ do
158158
159159-- | Check if the sprocket can be connected to. Returns an exception thrown during the connection attempt.
160160checkSprocket :: MonadIO m => IO. Sprocket -> m (Either IOException () )
161- checkSprocket sprocket = liftIO $ do
161+ checkSprocket sprocket = liftIOAnnotated $ do
162162 let AddrInfo {addrFamily, addrSocketType, addrProtocol, addrAddress} = sprocketToAddrInfo sprocket
163163 bracket (Socket. socket addrFamily addrSocketType addrProtocol) Socket. close $ \ sock -> do
164164 -- Capture only synchronous exceptions from the connection attempt.
@@ -179,10 +179,10 @@ waitForPortClosed
179179 -> MT. DiffTime -- ^ check interval
180180 -> PortNumber
181181 -> m Bool -- ^ 'True' if port is closed, 'False' if timeout was reached before that
182- waitForPortClosed timeout interval portNumber = liftIO $ do
182+ waitForPortClosed timeout interval portNumber = liftIOAnnotated $ do
183183 let retryPolicy = R. constantDelay (round @ Double $ realToFrac interval) <> R. limitRetries (ceiling $ toRational timeout / toRational interval)
184184 fmap not . R. retrying retryPolicy (const pure ) $ \ _ ->
185- liftIO (IO. isPortOpen (fromIntegral portNumber))
185+ liftIOAnnotated (IO. isPortOpen (fromIntegral portNumber))
186186
187187data PingClientError
188188 = PceDecodingError
0 commit comments