Synnefo » snf-ganeti

import Control.Monad

import Data.List

import Data.IORef

import Ganeti.BasicTypes

import Ganeti.Constants as C

import Ganeti.Types

import Ganeti.Utils

data Queue = Queue { qEnqueued :: [JobWithStat], qRunning :: [JobWithStat] }

{-| Representation of the job queue

-- | Obtain a JobWithStat from a QueuedJob.

unreadJob :: QueuedJob -> JobWithStat

-- | Reload interval for polling the running jobs for updates in microseconds.

watchInterval :: Int

-- | Reread a job from disk, if the file has changed.

readJobStatus :: JobWithStat -> IO (Maybe JobWithStat)

  let jid = qjId job

  qdir <- queueDir

  let fpath = liveJobFile qdir jid

        Ok (job', _) -> do

          logDebug

            $ "Read job " ++ jids ++ ", staus is " ++ show (calcJobStatus job')

-- | Update a job in the job queue, if it is still there. This is the

-- pure function for inserting a previously read change into the queue.

  tryFstat <- try $ getFStat fpath :: IO (Either IOError FStat)

  let fstat = either (const nullFStat) id tryFstat

  loadResult <- JQ.loadJobFromDisk qdir False jid

-- | Read all non-finalized jobs from disk.

readJobsFromDisk :: IO [JobWithStat]