summaryrefslogtreecommitdiff
path: root/Remote/Bup.hs
diff options
context:
space:
mode:
authorGravatar Joey Hess <joey@kitenet.net>2011-04-19 15:26:50 -0400
committerGravatar Joey Hess <joey@kitenet.net>2011-04-19 15:27:03 -0400
commit5985acdfad8a6791f0b2fc54a1e116cee9c12479 (patch)
tree79bb1aa8ff55e4c53dc5ca08ea511aa6f9bd4232 /Remote/Bup.hs
parentb1274b637863ebb4e14d39ca2cf00a27c9d1f142 (diff)
bup: Avoid memory leak when transferring encrypted data.
This was a most surprising leak. It occurred in the process that is forked off to feed data to gpg. That process was passed a lazy ByteString of input, and ghc seemed to not GC the ByteString as it was lazily read and consumed, so memory slowly leaked as the file was read and passed through gpg to bup. To fix it, I simply changed the feeder to take an IO action that returns the lazy bytestring, and fed the result directly to hPut. AFAICS, this should change nothing WRT buffering. But somehow it makes ghc's GC do the right thing. Probably I triggered some weakness in ghc's GC (version 6.12.1). (Note that S3 still has this leak, and others too. Fixing it will involve another dance with the type system.) Update: One theory I have is that this has something to do with the forking of the feeder process. Perhaps, when the ByteString is produced before the fork, ghc decides it need to hold a pointer to the start of it, for some reason -- maybe it doesn't realize that it is only used in the forked process.
Diffstat (limited to 'Remote/Bup.hs')
-rw-r--r--Remote/Bup.hs6
1 files changed, 2 insertions, 4 deletions
diff --git a/Remote/Bup.hs b/Remote/Bup.hs
index 16e1bbdcb..6ae002c3b 100644
--- a/Remote/Bup.hs
+++ b/Remote/Bup.hs
@@ -126,8 +126,7 @@ storeEncrypted r buprepo (cipher, enck) k = do
let src = gitAnnexLocation g k
params <- bupSplitParams r buprepo enck (Param "-")
liftIO $ catchBool $ do
- content <- L.readFile src
- withEncryptedHandle cipher content $ \h -> do
+ withEncryptedHandle cipher (L.readFile src) $ \h -> do
pipeBup params (Just h) Nothing
retrieve :: BupRepo -> Key -> FilePath -> Annex Bool
@@ -142,8 +141,7 @@ retrieveEncrypted buprepo (cipher, enck) f = do
let params = bupParams "join" buprepo [Param $ show enck]
liftIO $ catchBool $ do
(pid, h) <- hPipeFrom "bup" $ toCommand params
- content <- L.hGetContents h
- withDecryptedContent cipher content $ L.writeFile f
+ withDecryptedContent cipher (L.hGetContents h) $ L.writeFile f
forceSuccess pid
return True