git-annex/Assistant/Threads/Transferrer.hs

{- git-annex assistant data transferrer thread
 -
 - Copyright 2012 Joey Hess <id@joeyh.name>
 -
 - Licensed under the GNU AGPL version 3 or higher.
 -}

module Assistant.Threads.Transferrer where

import Assistant.Common
import Assistant.TransferQueue
import Assistant.TransferSlots
import Types.Transfer
import Annex.Path
import Utility.Batch

{- Dispatches transfers from the queue. -}
transfererThread :: NamedThread
transfererThread = namedThread "Transferrer" $ do
	program <- liftIO programPath
	batchmaker <- liftIO getBatchCommandMaker
	forever $ inTransferSlot program batchmaker $
		maybe (return Nothing) (uncurry genTransfer)
			=<< getNextTransfer notrunning
  where
	{- Skip transfers that are already running. -}
	notrunning = isNothing . startedTime
wrote transfer thread finally! 2012-07-05 14:34:20 -06:00			`{- git-annex assistant data transferrer thread`
			`-`
update my email address and homepage url 2015-01-21 12:50:09 -04:00			`- Copyright 2012 Joey Hess <id@joeyh.name>`
wrote transfer thread finally! 2012-07-05 14:34:20 -06:00			`-`
update licenses from GPL to AGPL This does not change the overall license of the git-annex program, which was already AGPL due to a number of sources files being AGPL already. Legally speaking, I'm adding a new license under which these files are now available; I already released their current contents under the GPL license. Now they're dual licensed GPL and AGPL. However, I intend for all my future changes to these files to only be released under the AGPL license, and I won't be tracking the dual licensing status, so I'm simply changing the license statement to say it's AGPL. (In some cases, others wrote parts of the code of a file and released it under the GPL; but in all cases I have contributed a significant portion of the code in each file and it's that code that is getting the AGPL license; the GPL license of other contributors allows combining with AGPL code.) 2019-03-13 15:48:14 -04:00			`- Licensed under the GNU AGPL version 3 or higher.`
wrote transfer thread finally! 2012-07-05 14:34:20 -06:00			`-}`

			`module Assistant.Threads.Transferrer where`

debugging improvements add timestamps to debug messages Add lots of debug output in the assistant's threads. 2012-07-20 19:29:59 -04:00			`import Assistant.Common`
wrote transfer thread finally! 2012-07-05 14:34:20 -06:00			`import Assistant.TransferQueue`
it builds again Currently nothing waits on transfer processes. (Second drive of the day fried. Not concentrating very well.) 2012-07-06 16:39:07 -04:00			`import Assistant.TransferSlots`
get, move, copy, mirror: Added --failed switch which retries failed copies/moves Note that get --from foo --failed will get things that a previous get --from bar tried and failed to get, etc. I considered making --failed only retry transfers from the same remote, but it was easier, and seems more useful, to not have the same remote requirement. Noisy due to some refactoring into Types/ 2016-08-03 12:37:12 -04:00			`import Types.Transfer`
When re-execing git-annex, use current program location, rather than ~/.config/git-annex/program, when possible. Most of the time, there will be no discreprancy between programPath and readProgramFile. But, the programFile might have been written by an old version of git-annex that is still installed, while a newer one is currently running. In this case, we want to run the same one that's currently running. This is especially important for things like the GIT_SSH=git-annex used for ssh connection caching. The only code that still uses readProgramFile directly is the upgrade code, which needs to know where the standalone git-annex was installed, in order to upgrade it. 2015-02-28 17:23:13 -04:00			`import Annex.Path`
avoid repeatedly searching path to make batch command when running transferkeys 2013-12-01 15:37:51 -04:00			`import Utility.Batch`
wrote transfer thread finally! 2012-07-05 14:34:20 -06:00
unfinished (and unbuildable) work toward separate transfer processes 2012-07-05 18:57:06 -06:00			`{- Dispatches transfers from the queue. -}`
Assistant monad, stage 3 All toplevel named threads are converted to the Assistant monad. Some utility functions still need to be converted. 2012-10-29 14:07:12 -04:00			`transfererThread :: NamedThread`
webapp: Now allows restarting any threads that crash. 2013-01-26 17:09:33 +11:00			`transfererThread = namedThread "Transferrer" $ do`
When re-execing git-annex, use current program location, rather than ~/.config/git-annex/program, when possible. Most of the time, there will be no discreprancy between programPath and readProgramFile. But, the programFile might have been written by an old version of git-annex that is still installed, while a newer one is currently running. In this case, we want to run the same one that's currently running. This is especially important for things like the GIT_SSH=git-annex used for ssh connection caching. The only code that still uses readProgramFile directly is the upgrade code, which needs to know where the standalone git-annex was installed, in order to upgrade it. 2015-02-28 17:23:13 -04:00			`program <- liftIO programPath`
avoid repeatedly searching path to make batch command when running transferkeys 2013-12-01 15:37:51 -04:00			`batchmaker <- liftIO getBatchCommandMaker`
			`forever $ inTransferSlot program batchmaker $`
hlint 2013-10-02 22:59:07 -04:00			`maybe (return Nothing) (uncurry genTransfer)`
finished pushing Assistant monad into all relevant files All temporary and old functions are removed. 2012-10-30 17:14:26 -04:00			`=<< getNextTransfer notrunning`
Assistant monad, stage 3 All toplevel named threads are converted to the Assistant monad. Some utility functions still need to be converted. 2012-10-29 14:07:12 -04:00			`where`
			`{- Skip transfers that are already running. -}`
			`notrunning = isNothing . startedTime`