asakul
/
libatrade
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

brokerclient: update sqnum based on incoming sqnum

master
Denis Tereshkin 2 years ago
parent
b7ba5bcf14
commit
c94e4b90d7
1 changed files with 1 additions and 1 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      src/ATrade/Broker/Client.hs

2
src/ATrade/Broker/Client.hs
Unescape View File

@ -188,7 +188,7 @@ notificationThread clientIdentity callbacks ctx ep idCounter cmdVar killMv secPa
when (getNotificationSqnum notification /= currentSqnum) $ do when (getNotificationSqnum notification /= currentSqnum) $ do
log Warning "Broker.Client" $ log Warning "Broker.Client" $
"Notification sqnum mismatch: " <> (T.pack . show) currentSqnum <> " -> " <> (T.pack . show) (getNotificationSqnum notification) "Notification sqnum mismatch: " <> (T.pack . show) currentSqnum <> " -> " <> (T.pack . show) (getNotificationSqnum notification)
atomicWriteIORef notifSqnumRef (nextSqnum currentSqnum) atomicWriteIORef notifSqnumRef (nextSqnum $ getNotificationSqnum notification)
forM_ callbacks $ \c -> c notification forM_ callbacks $ \c -> c notification
atomicWriteIORef lastKnownNotificationSqnum currentSqnum atomicWriteIORef lastKnownNotificationSqnum currentSqnum
_ -> return () _ -> return ()

Write Preview
Loading…
Cancel
Save