rename GitQueue to Git.Queue

This commit is contained in:
Joey Hess 2011-06-30 13:25:37 -04:00
parent 0f2859454c
commit f0497312a7
3 changed files with 12 additions and 12 deletions

View file

@ -19,7 +19,7 @@ module Annex (
import Control.Monad.State import Control.Monad.State
import qualified Git import qualified Git
import GitQueue import Git.Queue
import Types.Backend import Types.Backend
import Types.Remote import Types.Remote
import Types.Crypto import Types.Crypto

View file

@ -16,7 +16,7 @@ import Control.Monad (when, unless)
import Annex import Annex
import Messages import Messages
import qualified GitQueue import qualified Git.Queue
import Utility import Utility
{- Adds a git command to the queue, possibly running previously queued {- Adds a git command to the queue, possibly running previously queued
@ -24,24 +24,24 @@ import Utility
add :: String -> [CommandParam] -> FilePath -> Annex () add :: String -> [CommandParam] -> FilePath -> Annex ()
add command params file = do add command params file = do
q <- getState repoqueue q <- getState repoqueue
store $ GitQueue.add q command params file store $ Git.Queue.add q command params file
{- Runs the queue if it is full. Should be called periodically. -} {- Runs the queue if it is full. Should be called periodically. -}
flushWhenFull :: Annex () flushWhenFull :: Annex ()
flushWhenFull = do flushWhenFull = do
q <- getState repoqueue q <- getState repoqueue
when (GitQueue.full q) $ flush False when (Git.Queue.full q) $ flush False
{- Runs (and empties) the queue. -} {- Runs (and empties) the queue. -}
flush :: Bool -> Annex () flush :: Bool -> Annex ()
flush silent = do flush silent = do
q <- getState repoqueue q <- getState repoqueue
unless (0 == GitQueue.size q) $ do unless (0 == Git.Queue.size q) $ do
unless silent $ unless silent $
showSideAction "Recording state in git..." showSideAction "Recording state in git..."
g <- gitRepo g <- gitRepo
q' <- liftIO $ GitQueue.flush g q q' <- liftIO $ Git.Queue.flush g q
store q' store q'
store :: GitQueue.Queue -> Annex () store :: Git.Queue.Queue -> Annex ()
store q = changeState $ \s -> s { repoqueue = q } store q = changeState $ \s -> s { repoqueue = q }

View file

@ -5,7 +5,7 @@
- Licensed under the GNU GPL version 3 or higher. - Licensed under the GNU GPL version 3 or higher.
-} -}
module GitQueue ( module Git.Queue (
Queue, Queue,
empty, empty,
add, add,
@ -21,7 +21,7 @@ import Data.String.Utils
import Control.Monad (unless, forM_) import Control.Monad (unless, forM_)
import Utility import Utility
import qualified Git import Git
{- An action to perform in a git repository. The file to act on {- An action to perform in a git repository. The file to act on
- is not included, and must be able to be appended after the params. -} - is not included, and must be able to be appended after the params. -}
@ -72,7 +72,7 @@ full :: Queue -> Bool
full (Queue n _) = n > maxSize full (Queue n _) = n > maxSize
{- Runs a queue on a git repository. -} {- Runs a queue on a git repository. -}
flush :: Git.Repo -> Queue -> IO Queue flush :: Repo -> Queue -> IO Queue
flush repo (Queue _ m) = do flush repo (Queue _ m) = do
forM_ (M.toList m) $ uncurry $ runAction repo forM_ (M.toList m) $ uncurry $ runAction repo
return empty return empty
@ -80,10 +80,10 @@ flush repo (Queue _ m) = do
{- Runs an Action on a list of files in a git repository. {- Runs an Action on a list of files in a git repository.
- -
- Complicated by commandline length limits. -} - Complicated by commandline length limits. -}
runAction :: Git.Repo -> Action -> [FilePath] -> IO () runAction :: Repo -> Action -> [FilePath] -> IO ()
runAction repo action files = unless (null files) runxargs runAction repo action files = unless (null files) runxargs
where where
runxargs = pOpen WriteToPipe "xargs" ("-0":"git":params) feedxargs runxargs = pOpen WriteToPipe "xargs" ("-0":"git":params) feedxargs
params = toCommand $ Git.gitCommandLine repo params = toCommand $ gitCommandLine repo
(Param (getSubcommand action):getParams action) (Param (getSubcommand action):getParams action)
feedxargs h = hPutStr h $ join "\0" files feedxargs h = hPutStr h $ join "\0" files