Synnefo » snf-ganeti

   OptComplFile)

oLuxiSocket :: IO OptType

oMachineReadable :: OptType

oMachineReadable =

  unless (null args) $

    exitErr "this program doesn't take any arguments."

  let master = fromMaybe luxiDef $ optLuxi opts

      opts' = opts { optLuxi = Just master }

                "t_disk" "f_disk" "Score"

  when (null clusters) $ do

         let lsock = fromMaybe def_socket (optLuxi opts)

         let name = local

         input_data <- Luxi.loadData lsock

  , runDir

  , logDir

  , socketDir

  , defaultQuerySocket

  , confdHmacKey

  , clusterConfFile

socketDir :: IO FilePath

socketDir = runDir `pjoin` "socket"

-- | The default LUXI socket for queries.

defaultQuerySocket :: IO FilePath

import Ganeti.Luxi

import qualified Ganeti.Query.Language as Qlang

import qualified Ganeti.Query.Cluster as QCluster

import Ganeti.Query.Query

import Ganeti.Query.Filter (makeSimpleFilter)

import Ganeti.Types

        case write_result of

          Bad s -> return . Bad . GenericError $ s

          Ok () -> do

            client <- getClient socketpath

            pickupResult <- callMethod (PickupJob jid) client

            closeClient client

                succeeded = map snd $ filter (isOk . fst) annotated_results

            when (any isBad write_results) . logWarning

              $ "Writing some jobs failed " ++ show annotated_results

            client <- getClient socketpath

            pickupResults <- mapM (flip callMethod client . PickupJob)

                               succeeded