|
|
|
@ -209,6 +209,7 @@ workThread = do |
|
|
|
liftIO $ bind sock $ T.unpack ep |
|
|
|
liftIO $ bind sock $ T.unpack ep |
|
|
|
whileM $ do |
|
|
|
whileM $ do |
|
|
|
incomingData <- liftIO . receiveMulti $ sock |
|
|
|
incomingData <- liftIO . receiveMulti $ sock |
|
|
|
|
|
|
|
log Debug "HistoryProviderServer.WorkThread" $ "Incoming data: " <> (T.pack . show) incomingData |
|
|
|
case incomingData of |
|
|
|
case incomingData of |
|
|
|
(sender:_:rawRq:_) -> |
|
|
|
(sender:_:rawRq:_) -> |
|
|
|
case eitherDecode $ BL.fromStrict rawRq of |
|
|
|
case eitherDecode $ BL.fromStrict rawRq of |
|
|
|
|