X-Git-Url: http://git.lukelau.me/?a=blobdiff_plain;f=src%2FLanguage%2FHaskell%2FLSP%2FTest%2FServer.hs;h=bd5bdb959f670652a5e910d5d0942b43fcb0c494;hb=5732d9891b7515251ba3fd66269c21d63ed12c79;hp=8159bef129784d07fcab9cd6e7b842ab4d9d47f5;hpb=1f39d55cc3fb2e840a115c12d7da3935b9529361;p=opengl.git diff --git a/src/Language/Haskell/LSP/Test/Server.hs b/src/Language/Haskell/LSP/Test/Server.hs index 8159bef..bd5bdb9 100644 --- a/src/Language/Haskell/LSP/Test/Server.hs +++ b/src/Language/Haskell/LSP/Test/Server.hs @@ -1,13 +1,16 @@ module Language.Haskell.LSP.Test.Server (withServer) where import Control.Concurrent +import Control.Exception import Control.Monad -import Data.Maybe +import Language.Haskell.LSP.Test.Compat import System.IO import System.Process -withServer :: String -> (Handle -> Handle -> Int -> IO a) -> IO a -withServer serverExe f = do +withServer :: String -> Bool -> (Handle -> Handle -> Int -> IO a) -> IO a +withServer serverExe logStdErr f = do + -- TODO Probably should just change runServer to accept + -- separate command and arguments let cmd:args = words serverExe createProc = (proc cmd args) { std_in = CreatePipe, std_out = CreatePipe, std_err = CreatePipe } (Just serverIn, Just serverOut, Just serverErr, serverProc) <- createProcess createProc @@ -15,12 +18,10 @@ withServer serverExe f = do -- Need to continuously consume to stderr else it gets blocked -- Can't pass NoStream either to std_err hSetBuffering serverErr NoBuffering - errSinkThread <- forkIO $ forever $ hGetLine serverErr + errSinkThread <- forkIO $ forever $ hGetLine serverErr >>= when logStdErr . putStrLn - pid <- fromIntegral . fromJust <$> getPid serverProc - - result <- f serverIn serverOut pid + pid <- getProcessID serverProc + finally (f serverIn serverOut pid) $ do killThread errSinkThread terminateProcess serverProc - return result \ No newline at end of file