diff options
| author |  Joey Hess <joeyh@joeyh.name> | 2017-12-05 15:00:50 -0400 |
|---|---|---|
| committer | Joey Hess <joeyh@joeyh.name> | 2017-12-05 15:00:50 -0400 |
| commit | 236c467da19f34edb08f124e37fd26eb62c43fcf (patch) | |
| tree | f4e488f77fb954812e4d48f399fc2ecab072afea /Annex/Transfer.hs | |
| parent | f013f71cb5d3f7eee3afb3eb8f01a33206d717c4 (diff) | |
more lambda-case conversion
Diffstat (limited to 'Annex/Transfer.hs')
| -rw-r--r-- | Annex/Transfer.hs | 26 |
1 files changed, 11 insertions, 15 deletions
diff --git a/Annex/Transfer.hs b/Annex/Transfer.hs index ccb5409a7..ad617a7df 100644 --- a/Annex/Transfer.hs +++ b/Annex/Transfer.hs @@ -92,8 +92,7 @@ runTransfer' ignorelock t afile shouldretry transferaction = checkSecureHashes t prep tfile mode info = catchPermissionDenied (const prepfailed) $ do let lck = transferLockFile tfile createAnnexDirectory $ takeDirectory lck - r <- tryLockExclusive (Just mode) lck - case r of + tryLockExclusive (Just mode) lck >>= \case Nothing -> return (Nothing, True) Just lockhandle -> ifM (checkSaneLock lck lockhandle) ( do @@ -108,8 +107,7 @@ runTransfer' ignorelock t afile shouldretry transferaction = checkSecureHashes t prep tfile _mode info = catchPermissionDenied (const prepfailed) $ do let lck = transferLockFile tfile createAnnexDirectory $ takeDirectory lck - v <- catchMaybeIO $ liftIO $ lockExclusive lck - case v of + catchMaybeIO (liftIO $ lockExclusive lck) >>= \case Nothing -> return (Nothing, False) Just Nothing -> return (Nothing, True) Just (Just lockhandle) -> do @@ -135,17 +133,15 @@ runTransfer' ignorelock t afile shouldretry transferaction = checkSecureHashes t dropLock lockhandle void $ tryIO $ removeFile lck #endif - retry oldinfo metervar run = do - v <- tryNonAsync run - case v of - Right b -> return b - Left e -> do - warning (show e) - b <- getbytescomplete metervar - let newinfo = oldinfo { bytesComplete = Just b } - if shouldretry oldinfo newinfo - then retry newinfo metervar run - else return observeFailure + retry oldinfo metervar run = tryNonAsync run >>= \case + Right b -> return b + Left e -> do + warning (show e) + b <- getbytescomplete metervar + let newinfo = oldinfo { bytesComplete = Just b } + if shouldretry oldinfo newinfo + then retry newinfo metervar run + else return observeFailure getbytescomplete metervar | transferDirection t == Upload = liftIO $ readMVar metervar |