Synnefo » snf-ganeti

import qualified Ganeti.Luxi as L

import Ganeti.Jobs

options :: [OptType]

options =

    [ oPrintNodes

                           mg_limit min_gain evac_mode

        Nothing -> return (ini_tbl, cmd_strs)

formatOneline :: Double -> Int -> Double -> String

formatOneline ini_cv plc_len fin_cv =

    printf "%.8f %d %.8f %8.3f" ini_cv plc_len fin_cv

               (if fin_cv == 0 then 1 else ini_cv / fin_cv)

-- | Polls a set of jobs at a fixed interval until all are finished

waitForJobs :: L.Client -> [String] -> IO (Result [JobStatus])

waitForJobs client jids = do

  sts <- L.queryJobsStatus client jids

              waitForJobs client jids

            else return $ Ok s

checkJobsStatus :: [JobStatus] -> Bool

checkJobsStatus = all (== JOB_STATUS_SUCCESS)

execWrapper :: String -> Node.List

           -> Instance.List -> IORef Int -> [JobSet] -> IO Bool

execWrapper _      _  _  _    [] = return True

     return False

   else execJobSet master nl il cref alljss)

execJobSet :: String -> Node.List

           -> Instance.List -> IORef Int -> [JobSet] -> IO Bool

execJobSet _      _  _  _    [] = return True

               hPutStrLn stderr "Aborting."

               return False)

hangleSigInt :: IORef Int -> IO ()

hangleSigInt cref = do

  writeIORef cref 1

  putStrLn ("Cancel request registered, will exit at" ++

            " the end of the current job set...")

hangleSigTerm :: IORef Int -> IO ()

hangleSigTerm cref = do

  -- update the cref to 2, just for consistency

  putStrLn "Double cancel request, exiting now..."

  exitImmediately $ ExitFailure 2

runJobSet :: String -> Node.List -> Instance.List -> [JobSet] -> IO Bool

runJobSet master fin_nl il cmd_jobs = do

  cref <- newIORef 0