"git-annex find --in remote" by over 50%.
* Optimised git-annex branch log file timestamp parsing.
* Add "total-size" field to --json-progress output.
+ * Make --json-progress output be shown even when the size of a object
+ is not known.
-- Joey Hess <id@joeyh.name> Mon, 26 Sep 2016 16:46:19 -0400
-- Show JSON formatted progress, including the current state of the JSON
-- object for the action being performed.
-progress :: Maybe Object -> Integer -> BytesProcessed -> IO ()
-progress maction size bytesprocessed = emit $ case maction of
+progress :: Maybe Object -> Maybe Integer -> BytesProcessed -> IO ()
+progress maction msize bytesprocessed = emit $ case maction of
Just action -> HM.insert "action" (Object action) o
Nothing -> o
where
n = fromBytesProcessed bytesprocessed :: Integer
- Object o = object
- [ "byte-progress" .= n
- , "percent-progress" .= showPercentage 2 (percentage size n)
- , "total-size" .= size
- ]
+ Object o = case msize of
+ Just size -> object
+ [ "byte-progress" .= n
+ , "percent-progress" .= showPercentage 2 (percentage size n)
+ , "total-size" .= size
+ ]
+ Nothing -> object
+ [ "byte-progress" .= n ]
-- A value that can be displayed either normally, or as JSON.
data DualDisp = DualDisp
{- Shows a progress meter while performing a transfer of a key.
- The action is passed a callback to use to update the meter. -}
metered :: Maybe MeterUpdate -> Key -> (MeterUpdate -> Annex a) -> Annex a
-metered othermeter key a = case keySize key of
- Nothing -> nometer
- Just size -> withMessageState (go $ fromInteger size)
+metered othermeter key a = withMessageState $ go (keySize key)
where
go _ (MessageState { outputType = QuietOutput }) = nometer
- go size (MessageState { outputType = NormalOutput, concurrentOutputEnabled = False }) = do
+ go (Just size) (MessageState { outputType = NormalOutput, concurrentOutputEnabled = False }) = do
showOutput
(progress, meter) <- mkmeter size
m <- liftIO $ rateLimitMeterUpdate 0.1 (Just size) $ \n -> do
r <- a (combinemeter m)
liftIO $ clearMeter stdout meter
return r
- go size (MessageState { outputType = NormalOutput, concurrentOutputEnabled = True }) =
+ go (Just size) (MessageState { outputType = NormalOutput, concurrentOutputEnabled = True }) =
#if WITH_CONCURRENTOUTPUT
withProgressRegion $ \r -> do
(progress, meter) <- mkmeter size
nometer
#endif
go _ (MessageState { outputType = JSONOutput False }) = nometer
- go size (MessageState { outputType = JSONOutput True }) = do
+ go msize (MessageState { outputType = JSONOutput True }) = do
buf <- withMessageState $ return . jsonBuffer
- m <- liftIO $ rateLimitMeterUpdate 0.1 (Just size) $
- JSON.progress buf size
+ m <- liftIO $ rateLimitMeterUpdate 0.1 msize $
+ JSON.progress buf msize
a (combinemeter m)
mkmeter size = do