From 24494b91bf949adea53e0227faaeb7d5d7126f65 Mon Sep 17 00:00:00 2001 From: Denis Tereshkin Date: Tue, 21 Jan 2025 21:29:58 +0700 Subject: [PATCH] BrokerClient: more debug --- src/ATrade/Broker/Client.hs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/ATrade/Broker/Client.hs b/src/ATrade/Broker/Client.hs index e868b38..1a7c81e 100644 --- a/src/ATrade/Broker/Client.hs +++ b/src/ATrade/Broker/Client.hs @@ -117,6 +117,7 @@ brokerClientThread socketIdentity ep cmd comp killMv notificationCallbacks logge Just rawData -> do if B.length rawData > 0 then do + log Debug "Broker.Client" $ TL.toStrict $ [t|Got data: %?|] rawData atomicMapIORef pipeRef (push rawData) messages <- atomicModifyIORef' pipeRef getMessages let parsed = mapMaybe decodeEvent messages @@ -154,6 +155,7 @@ brokerClientThread socketIdentity ep cmd comp killMv notificationCallbacks logge handleMessage :: MVar (BrokerServerRequest, MVar BrokerServerResponse, UTCTime) -> BrokerClientEvent -> IO () handleMessage respVar (IncomingResponse resp) = do + log Debug "Broker.Client" $ TL.toStrict $ [t|Incoming message: %?|] resp (req, respVar, _) <- takeMVar respVar if getRequestId req == getResponseRequestId resp then putMVar respVar resp