git-annex/Assistant/Threads/Transferrer.hs

{- git-annex assistant data transferrer thread
 -
 - Copyright 2012 Joey Hess <joey@kitenet.net>
 -
 - Licensed under the GNU GPL version 3 or higher.
 -}

module Assistant.Threads.Transferrer where

import Assistant.Common
import Assistant.TransferQueue
import Assistant.TransferSlots
import Logs.Transfer
import Config.Files

{- Dispatches transfers from the queue. -}
transfererThread :: NamedThread
transfererThread = namedThread "Transferrer" $ do
	program <- liftIO readProgramFile
	forever $ inTransferSlot program $
		maybe (return Nothing) (uncurry genTransfer)
			=<< getNextTransfer notrunning
  where
	{- Skip transfers that are already running. -}
	notrunning = isNothing . startedTime
wrote transfer thread finally! 2012-07-05 20:34:20 +00:00			`{- git-annex assistant data transferrer thread`
			`-`
			`- Copyright 2012 Joey Hess <joey@kitenet.net>`
			`-`
			`- Licensed under the GNU GPL version 3 or higher.`
			`-}`

			`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 23:29:59 +00:00			`import Assistant.Common`
wrote transfer thread finally! 2012-07-05 20:34:20 +00: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 20:39:07 +00:00			`import Assistant.TransferSlots`
wrote transfer thread finally! 2012-07-05 20:34:20 +00:00			`import Logs.Transfer`
rename module 2013-04-23 15:38:52 +00:00			`import Config.Files`
wrote transfer thread finally! 2012-07-05 20:34:20 +00:00
unfinished (and unbuildable) work toward separate transfer processes 2012-07-06 00:57:06 +00: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 18:07:12 +00:00			`transfererThread :: NamedThread`
webapp: Now allows restarting any threads that crash. 2013-01-26 06:09:33 +00:00			`transfererThread = namedThread "Transferrer" $ do`
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 18:07:12 +00:00			`program <- liftIO readProgramFile`
maintain pools of running transferkeys processes (untested) 2013-03-19 22:46:29 +00:00			`forever $ inTransferSlot program $`
hlint 2013-10-03 02:59:07 +00:00			`maybe (return Nothing) (uncurry genTransfer)`
finished pushing Assistant monad into all relevant files All temporary and old functions are removed. 2012-10-30 21:14:26 +00: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 18:07:12 +00:00			`where`
			`{- Skip transfers that are already running. -}`
			`notrunning = isNothing . startedTime`