Synnefo » snf-ganeti

import Data.Maybe

-- | Watcher task for a job, to update it on file changes. It also

-- reinstantiates itself upon receiving an Ignored event.

jobWatcher :: JQStatus -> JobWithStat -> Event -> IO ()

jobWatcher state jWS e = do

  let jid = qjId $ jJob jWS

      jids = show $ fromJobId jid

  logInfo $ "Scheduler notified of change of job " ++ jids

  logDebug $ "Scheulder notify event for " ++ jids ++ ": " ++ show e

  let inotify = jINotify jWS

  when (e == Ignored  && isJust inotify) $ do

    qdir <- queueDir

    let fpath = liveJobFile qdir jid

    _ <- addWatch (fromJust inotify) [Modify, Delete] fpath

           (jobWatcher state jWS)

    return ()

  updateJob state jWS

-- | Attach the job watcher to a running job.

attachWatcher :: JQStatus -> JobWithStat -> IO ()

attachWatcher state jWS = when (isNothing $ jINotify jWS) $ do

  inotify <- initINotify

  qdir <- queueDir

  let fpath = liveJobFile qdir . qjId $ jJob jWS

      jWS' = jWS { jINotify=Just inotify }

  logDebug $ "Attaching queue watcher for " ++ fpath

  _ <- addWatch inotify [Modify, Delete] fpath $ jobWatcher state jWS'

  modifyJobs state . onRunningJobs $ updateJobStatus jWS'

  mapM_ (attachWatcher qstate) chosen