summaryrefslogtreecommitdiff
path: root/Assistant/Threads/SanityChecker.hs
diff options
context:
space:
mode:
authorGravatar Joey Hess <joey@kitenet.net>2014-01-23 16:51:16 -0400
committerGravatar Joey Hess <joey@kitenet.net>2014-01-23 16:51:16 -0400
commit8d1787a73ddfb189005d80998503fae06b49c0f1 (patch)
tree15218a6dc0d15f4acca9e489301a055fe6c9ed8b /Assistant/Threads/SanityChecker.hs
parent5112650348f6bf04cebe1fb97ed900b24e4aaac1 (diff)
try to drop unused object if it does not need to be transferred anywhere
Diffstat (limited to 'Assistant/Threads/SanityChecker.hs')
-rw-r--r--Assistant/Threads/SanityChecker.hs12
1 files changed, 7 insertions, 5 deletions
diff --git a/Assistant/Threads/SanityChecker.hs b/Assistant/Threads/SanityChecker.hs
index 8a513a43b..aa7d4ff19 100644
--- a/Assistant/Threads/SanityChecker.hs
+++ b/Assistant/Threads/SanityChecker.hs
@@ -17,6 +17,7 @@ import Assistant.Common
import Assistant.DaemonStatus
import Assistant.Alert
import Assistant.Repair
+import Assistant.Drop
import Assistant.Ssh
import Assistant.TransferQueue
import Assistant.Types.UrlRenderer
@@ -94,11 +95,11 @@ sanityCheckerHourlyThread = namedThread "SanityCheckerHourly" $ forever $ do
{- This thread wakes up daily to make sure the tree is in good shape. -}
sanityCheckerDailyThread :: UrlRenderer -> NamedThread
sanityCheckerDailyThread urlrenderer = namedThread "SanityCheckerDaily" $ forever $ do
- waitForNextCheck
-
debug ["starting sanity check"]
void $ alertWhile sanityCheckAlert go
debug ["sanity check complete"]
+ waitForNextCheck
+
where
go = do
modifyDaemonStatus_ $ \s -> s { sanityCheckRunning = True }
@@ -172,11 +173,12 @@ dailyCheck urlrenderer = do
let (program', params') = batchmaker (program, [Param "unused"])
void $ liftIO $ boolSystem program' params'
{- Invalidate unused keys cache, and queue transfers of all unused
- - keys. -}
+ - keys, or if no transfers are called for, drop them. -}
unused <- liftAnnex unusedKeys'
void $ liftAnnex $ setUnusedKeys unused
- forM_ unused $ \k ->
- queueTransfers "unused" Later k Nothing Upload
+ forM_ unused $ \k -> do
+ unlessM (queueTransfers "unused" Later k Nothing Upload) $
+ handleDrops "unused" True k Nothing Nothing
return True
where