X-Git-Url: http://git.lukelau.me/?a=blobdiff_plain;f=src%2FLanguage%2FHaskell%2FLSP%2FTest%2FSession.hs;h=b8286a208c8f5e5369171b87ad62802d899b485d;hb=f91ebeacf72035e1fcb7cb6a5ed2ec270e2c0a1d;hp=bbfdf386ac167bd0f8ab5b9a277b754920aacf57;hpb=02c7c7c4e3783fef173f63b8f6421ced55285bff;p=lsp-test.git diff --git a/src/Language/Haskell/LSP/Test/Session.hs b/src/Language/Haskell/LSP/Test/Session.hs index bbfdf38..b8286a2 100644 --- a/src/Language/Haskell/LSP/Test/Session.hs +++ b/src/Language/Haskell/LSP/Test/Session.hs @@ -34,7 +34,7 @@ import Control.Lens hiding (List) import Control.Monad import Control.Monad.IO.Class import Control.Monad.Except -#if __GLASGOW_HASKELL__ >= 806 +#if __GLASGOW_HASKELL__ == 806 import Control.Monad.Fail #endif import Control.Monad.Trans.Reader (ReaderT, runReaderT) @@ -198,7 +198,6 @@ runSessionWithHandles :: Handle -- ^ Server in -> Session a -> IO a runSessionWithHandles serverIn serverOut serverProc serverHandler config caps rootDir exitServer session = do - absRootDir <- canonicalizePath rootDir hSetBuffering serverIn NoBuffering @@ -219,13 +218,16 @@ runSessionWithHandles serverIn serverOut serverProc serverHandler config caps ro runSession' = runSession context initState errorHandler = throwTo mainThreadId :: SessionException -> IO() - serverLauncher = forkIO $ catch (serverHandler serverOut context) errorHandler + serverListenerLauncher = + forkIO $ catch (serverHandler serverOut context) errorHandler server = (Just serverIn, Just serverOut, Nothing, serverProc) - serverFinalizer tid = finally (timeout (messageTimeout config * 1000000) + serverAndListenerFinalizer tid = + finally (timeout (messageTimeout config * 1000000) (runSession' exitServer)) - (cleanupRunningProcess server >> killThread tid) + (cleanupProcess server >> killThread tid) - (result, _) <- bracket serverLauncher serverFinalizer (const $ runSession' session) + (result, _) <- bracket serverListenerLauncher serverAndListenerFinalizer + (const $ runSession' session) return result updateStateC :: ConduitM FromServerMessage FromServerMessage (StateT SessionState (ReaderT SessionContext IO)) ()