|
|
|
|
@ -225,7 +225,7 @@ bcSubmitOrder clientIdentity idCounter cmdVar logger order = do
@@ -225,7 +225,7 @@ bcSubmitOrder clientIdentity idCounter cmdVar logger order = do
|
|
|
|
|
respVar <- newEmptyMVar |
|
|
|
|
sqnum <- nextId idCounter |
|
|
|
|
now <- getCurrentTime |
|
|
|
|
result <- timeout 3000000 $ do |
|
|
|
|
result <- timeout 10000000 $ do |
|
|
|
|
putMVar cmdVar (RequestSubmitOrder (RequestId sqnum) clientIdentity order, respVar, now) |
|
|
|
|
resp <- takeMVar respVar |
|
|
|
|
case resp of |
|
|
|
|
@ -252,7 +252,7 @@ bcCancelOrder clientIdentity idCounter cmdVar logger orderId = do
@@ -252,7 +252,7 @@ bcCancelOrder clientIdentity idCounter cmdVar logger orderId = do
|
|
|
|
|
respVar <- newEmptyMVar |
|
|
|
|
sqnum <- nextId idCounter |
|
|
|
|
now <- getCurrentTime |
|
|
|
|
result <- timeout 3000000 $ do |
|
|
|
|
result <- timeout 10000000 $ do |
|
|
|
|
putMVar cmdVar (RequestCancelOrder (RequestId sqnum) clientIdentity orderId, respVar, now) |
|
|
|
|
resp <- takeMVar respVar |
|
|
|
|
case resp of |
|
|
|
|
@ -280,7 +280,7 @@ bcGetNotifications clientIdentity idCounter notifSqnumRef cmdVar lastKnownNotifi
@@ -280,7 +280,7 @@ bcGetNotifications clientIdentity idCounter notifSqnumRef cmdVar lastKnownNotifi
|
|
|
|
|
sqnum <- nextId idCounter |
|
|
|
|
notifSqnum <- nextSqnum <$> readIORef notifSqnumRef |
|
|
|
|
now <- getCurrentTime |
|
|
|
|
result <- timeout 3000000 $ do |
|
|
|
|
result <- timeout 10000000 $ do |
|
|
|
|
putMVar cmdVar (RequestNotifications (RequestId sqnum) clientIdentity notifSqnum, respVar, now) |
|
|
|
|
resp <- takeMVar respVar |
|
|
|
|
case resp of |
|
|
|
|
|