mirrors/git-annex
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

read stdout and stderr concurrently

Browse source 
Avoids any buffering-related blocking.
This commit is contained in:
Joey Hess 2014-03-12 13:54:29 -04:00
parent 3f23935a76
commit 475bf70af6
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
Git/Fsck.hs
View file

@ -24,6 +24,7 @@ import qualified Git.Version
import qualified Data.Set as S import qualified Data.Set as S
import System.Process (std_out, std_err) import System.Process (std_out, std_err)
import Control.Concurrent.Async
type MissingObjects = S.Set Sha type MissingObjects = S.Set Sha
@ -53,8 +54,9 @@ findBroken batchmode r = do
{ std_out = CreatePipe { std_out = CreatePipe
, std_err = CreatePipe , std_err = CreatePipe
} }
bad1 <- readMissingObjs r supportsNoDangling (stdoutHandle p) (bad1, bad2) <- concurrently
bad2 <- readMissingObjs r supportsNoDangling (stderrHandle p) (readMissingObjs r supportsNoDangling (stdoutHandle p))
(readMissingObjs r supportsNoDangling (stderrHandle p))
fsckok <- checkSuccessProcess pid fsckok <- checkSuccessProcess pid
let badobjs = S.union bad1 bad2 let badobjs = S.union bad1 bad2