From b9125dab0726c05597d9dd372e12f779906c5b5b Mon Sep 17 00:00:00 2001 From: jneira Date: Wed, 17 Jul 2019 14:57:26 +0200 Subject: [PATCH] Add cleanupRunningProcess to Compat module --- src/Language/Haskell/LSP/Test/Compat.hs | 26 ++++++++++++++++++++++-- src/Language/Haskell/LSP/Test/Session.hs | 7 +++---- 2 files changed, 27 insertions(+), 6 deletions(-) diff --git a/src/Language/Haskell/LSP/Test/Compat.hs b/src/Language/Haskell/LSP/Test/Compat.hs index 9467a32..ddf4a78 100644 --- a/src/Language/Haskell/LSP/Test/Compat.hs +++ b/src/Language/Haskell/LSP/Test/Compat.hs @@ -6,10 +6,11 @@ module Language.Haskell.LSP.Test.Compat where import Data.Maybe +import System.IO #if MIN_VERSION_process(1,6,3) -import System.Process hiding (getPid) -import qualified System.Process (getPid) +import System.Process hiding (getPid, cleanupProcess) +import qualified System.Process (getPid, cleanupProcess) #else import System.Process import System.Process.Internals @@ -52,3 +53,24 @@ getProcessID p = fromIntegral . fromJust <$> getProcessID' p #endif _ -> return Nothing #endif + +cleanupRunningProcess :: (Maybe Handle, Maybe Handle, Maybe Handle, ProcessHandle) -> IO () +cleanupRunningProcess p@(_, _, _, ph) = + getProcessExitCode ph >>= maybe (cleanupProcess p) (const $ return ()) + +cleanupProcess :: (Maybe Handle, Maybe Handle, Maybe Handle, ProcessHandle) -> IO () +#if MIN_VERSION_process(1,6,3) +cleanupProcess = System.Process.cleanupProcess +#else +cleanupProcess (mb_stdin, mb_stdout, mb_stderr, ph) = do + + terminateProcess ph + -- Note, it's important that other threads that might be reading/writing + -- these handles also get killed off, since otherwise they might be holding + -- the handle lock and prevent us from closing, leading to deadlock. + maybe (return ()) hClose mb_stdin + maybe (return ()) hClose mb_stdout + maybe (return ()) hClose mb_stderr + + return () +#endif diff --git a/src/Language/Haskell/LSP/Test/Session.hs b/src/Language/Haskell/LSP/Test/Session.hs index f85eed9..bbfdf38 100644 --- a/src/Language/Haskell/LSP/Test/Session.hs +++ b/src/Language/Haskell/LSP/Test/Session.hs @@ -60,12 +60,13 @@ import Language.Haskell.LSP.Types.Capabilities import Language.Haskell.LSP.Types import Language.Haskell.LSP.Types.Lens hiding (error) import Language.Haskell.LSP.VFS +import Language.Haskell.LSP.Test.Compat import Language.Haskell.LSP.Test.Decoding import Language.Haskell.LSP.Test.Exceptions import System.Console.ANSI import System.Directory import System.IO -import System.Process +import System.Process (ProcessHandle()) import System.Timeout -- | A session representing one instance of launching and connecting to a server. @@ -222,9 +223,7 @@ runSessionWithHandles serverIn serverOut serverProc serverHandler config caps ro server = (Just serverIn, Just serverOut, Nothing, serverProc) serverFinalizer tid = finally (timeout (messageTimeout config * 1000000) (runSession' exitServer)) - (terminateProcess serverProc - >> hClose serverOut - >> killThread tid) + (cleanupRunningProcess server >> killThread tid) (result, _) <- bracket serverLauncher serverFinalizer (const $ runSession' session) return result -- 2.30.2