diff options
author | Joey Hess <joey@kitenet.net> | 2013-10-08 11:48:28 -0400 |
---|---|---|
committer | Joey Hess <joey@kitenet.net> | 2013-10-08 11:48:28 -0400 |
commit | 7ea377dadf61a4acf8ecdfec39954e7b4344c65f (patch) | |
tree | f37feed88774b13c8d503484d5e1417441d84ffb /Assistant/Threads | |
parent | 6abf023cb98a5d3b2f9fb251055270e576570983 (diff) |
half way complete cronner thread to run scheduled activities
Diffstat (limited to 'Assistant/Threads')
-rw-r--r-- | Assistant/Threads/ConfigMonitor.hs | 18 | ||||
-rw-r--r-- | Assistant/Threads/Cronner.hs | 80 |
2 files changed, 89 insertions, 9 deletions
diff --git a/Assistant/Threads/ConfigMonitor.hs b/Assistant/Threads/ConfigMonitor.hs index 3d8be476e..3c1f56bb0 100644 --- a/Assistant/Threads/ConfigMonitor.hs +++ b/Assistant/Threads/ConfigMonitor.hs @@ -12,9 +12,9 @@ import Assistant.BranchChange import Assistant.DaemonStatus import Assistant.Commits import Utility.ThreadScheduler +import Logs import Logs.UUID import Logs.Trust -import Logs.Remote import Logs.PreferredContent import Logs.Group import Remote.List (remoteListRefresh) @@ -52,12 +52,13 @@ configMonitorThread = namedThread "ConfigMonitor" $ loop =<< getConfigs type Configs = S.Set (FilePath, String) {- All git-annex's config files, and actions to run when they change. -} -configFilesActions :: [(FilePath, Annex ())] +configFilesActions :: [(FilePath, Assistant ())] configFilesActions = - [ (uuidLog, void uuidMapLoad) - , (remoteLog, void remoteListRefresh) - , (trustLog, void trustMapLoad) - , (groupLog, void groupMapLoad) + [ (uuidLog, void $ liftAnnex uuidMapLoad) + , (remoteLog, void $ liftAnnex remoteListRefresh) + , (trustLog, void $ liftAnnex trustMapLoad) + , (groupLog, void $ liftAnnex groupMapLoad) + , (scheduleLog, void updateScheduleLog) -- Preferred content settings depend on most of the other configs, -- so will be reloaded whenever any configs change. , (preferredContentLog, noop) @@ -65,9 +66,8 @@ configFilesActions = reloadConfigs :: Configs -> Assistant () reloadConfigs changedconfigs = do - liftAnnex $ do - sequence_ as - void preferredContentMapLoad + sequence_ as + void $ liftAnnex preferredContentMapLoad {- Changes to the remote log, or the trust log, can affect the - syncRemotes list. Changes to the uuid log may affect its - display so are also included. -} diff --git a/Assistant/Threads/Cronner.hs b/Assistant/Threads/Cronner.hs new file mode 100644 index 000000000..d1d7945e3 --- /dev/null +++ b/Assistant/Threads/Cronner.hs @@ -0,0 +1,80 @@ +{- git-annex assistant sceduled jobs runner + - + - Copyright 2013 Joey Hess <joey@kitenet.net> + - + - Licensed under the GNU GPL version 3 or higher. + -} + +{-# LANGUAGE DeriveDataTypeable #-} + +module Assistant.Threads.Cronner ( + cronnerThread +) where + +import Assistant.Common +import Assistant.DaemonStatus +import Utility.NotificationBroadcaster +import Logs.Schedule +import Annex.UUID +import Types.ScheduledActivity + +import Control.Concurrent.Async +import Data.Time.LocalTime +import qualified Data.Map as M +import qualified Data.Set as S +import qualified Control.Exception as E +import Data.Typeable + +data ActivityException = PleaseTerminate + deriving (Typeable, Show) + +instance E.Exception ActivityException + +{- Loads schedules for this repository, and fires off one thread for each + - scheduled event. These threads sleep until the next time the event + - should run. + - + - In the meantime the main thread waits for any changes to the + - schedules. When there's a change, compare the old and new list of + - schedules to find deleted and added ones. Start new threads for added + - ones, and send the threads a PleaseTerminate exception for the deleted + - ones. -} +cronnerThread :: NamedThread +cronnerThread = namedThreadUnchecked "Cronner" $ do + dstatus <- getDaemonStatus + h <- liftIO $ newNotificationHandle False (scheduleLogNotifier dstatus) + go h M.empty + where + go h m = do + activities <- liftAnnex $ scheduleGet =<< getUUID + + let addedactivities = activities `S.difference` M.keysSet m + let removedactivities = M.keysSet m `S.difference` activities + + liftIO $ forM_ (mapMaybe (`M.lookup` m) $ S.toList removedactivities) $ + flip cancelWith PleaseTerminate + + lastruntimes <- liftAnnex getLastRunTimes + addedm <- M.fromList <$> startactivities (S.toList addedactivities) lastruntimes + + liftIO $ waitNotification h + + let m' = M.difference (M.union addedm m) + (M.filterWithKey (\k _ -> S.member k removedactivities) m) + go h m' + startactivities as lastruntimes = forM as $ \activity -> do + runner <- asIO2 activityThread + a <- liftIO $ async $ + runner activity (M.lookup activity lastruntimes) + return (activity, a) + +{- Calculate the next time the activity is scheduled to run, then + - sleep until that time, and run it. Then call setLastRunTime, and + - loop. + - + - At any point, a PleaseTerminate could be received. This should result in + - the thread and any processes it has run shutting down. + -} +activityThread :: ScheduledActivity -> Maybe LocalTime -> Assistant () +activityThread activity lastrun = do + noop |