Synnefo » snf-ganeti » ganeti-local

    , oTieredSpec

import Ganeti.HTools.Utils

    { optShowNodes   :: Bool           -- ^ Whether to show node status

    , optShowInsts   :: Bool           -- ^ Whether to show the instance map

    , optShowCmds    :: Maybe FilePath -- ^ Whether to show the command list

    , optOneline     :: Bool           -- ^ Switch output to a single line

    , optOutPath     :: FilePath       -- ^ Path to the output directory

    , optNoHeaders   :: Bool           -- ^ Do not show a header line

    , optNodeFile    :: FilePath       -- ^ Path to the nodes file

    , optNodeSet     :: Bool           -- ^ The nodes have been set by options

    , optInstFile    :: FilePath       -- ^ Path to the instances file

    , optInstSet     :: Bool           -- ^ The insts have been set by options

    , optNodeSim     :: Maybe String   -- ^ Cluster simulation mode

    , optMaxLength   :: Int            -- ^ Stop after this many steps

    , optMaster      :: String         -- ^ Collect data from RAPI

    , optLuxi        :: Maybe FilePath -- ^ Collect data from Luxi

    , optExecJobs    :: Bool           -- ^ Execute the commands via Luxi

    , optOffline     :: [String]       -- ^ Names of offline nodes

    , optINodes      :: Int            -- ^ Nodes required for an instance

    , optISpec       :: RSpec          -- ^ Requested instance specs

    , optTieredSpec  :: Maybe RSpec    -- ^ Requested specs for tiered mode

    , optMinScore    :: Score          -- ^ The minimum score we aim for

    , optMcpu        :: Double         -- ^ Max cpu ratio for nodes

    , optMdsk        :: Double         -- ^ Max disk usage ratio for nodes

    , optDiskMoves   :: Bool           -- ^ Allow disk moves

    , optDynuFile    :: Maybe FilePath -- ^ Optional file with dynamic use data

    , optVerbose     :: Int            -- ^ Verbosity level

    , optShowVer     :: Bool           -- ^ Just show the program version

    , optShowHelp    :: Bool           -- ^ Just show the help

 { optShowNodes   = False

 , optShowInsts   = False

 , optShowCmds    = Nothing

 , optOneline     = False

 , optNoHeaders   = False

 , optOutPath     = "."

 , optNodeFile    = "nodes"

 , optNodeSet     = False

 , optInstFile    = "instances"

 , optInstSet     = False

 , optNodeSim     = Nothing

 , optMaxLength   = -1

 , optMaster      = ""

 , optLuxi        = Nothing

 , optExecJobs    = False

 , optOffline     = []

 , optINodes      = 2

 , optISpec       = RSpec 1 4096 102400

 , optTieredSpec  = Nothing

 , optMinScore    = 1e-9

 , optMcpu        = -1

 , optMdsk        = -1

 , optDiskMoves   = True

 , optDynuFile    = Nothing

 , optVerbose     = 1

 , optShowVer     = False

 , optShowHelp    = False

        (ReqArg (\ m opts ->

                     let ospec = optISpec opts

                         nspec = ospec { rspecMem = read m }

                     in Ok opts { optISpec = nspec }) "MEMORY")

         (ReqArg (\ d opts ->

                     let ospec = optISpec opts

                         nspec = ospec { rspecDsk = read d }

                     in Ok opts { optISpec = nspec }) "DISK")

          (ReqArg (\ p opts ->

                       let ospec = optISpec opts

                           nspec = ospec { rspecCpu = read p }

                       in Ok opts { optISpec = nspec }) "NUM")

oTieredSpec :: OptType

oTieredSpec = Option "" ["tiered-alloc"]

             (ReqArg (\ inp opts -> do

                          let sp = sepSplit ',' inp

                          prs <- mapM (tryRead "tiered specs") sp

                          tspec <-

                              case prs of

                                [cpu, ram, dsk] -> return $ RSpec cpu ram dsk

                                _ -> Bad $ "Invalid specification: " ++ inp

                          return $ opts { optTieredSpec = Just tspec } )

              "TSPEC")

             "enable tiered specs allocation, where we decrease the instance\

             \ spec on failure to allocate and restart the allocation process"

    , RSpec(..)

-- | The resource spec type.

data RSpec = RSpec

    { rspecCpu  :: Int  -- ^ Requested VCPUs

    , rspecMem  :: Int  -- ^ Requested memory

    , rspecDsk  :: Int  -- ^ Requested disk

    } deriving (Show)

    , oTieredSpec

specData :: [(String, RSpec -> String)]

specData = [ ("MEM", printf "%d" . rspecMem)

           , ("DSK", printf "%d" . rspecDsk)

           , ("CPU", printf "%d" . rspecCpu)

      ispec = optISpec opts

  printKeys $ map (\(a, fn) -> ("SPEC_" ++ a, fn ispec)) specData

  printKeys [ ("SPEC_RQN", printf "%d" (optINodes opts)) ]

      reqinst = Instance.create "new" (rspecMem ispec) (rspecDsk ispec)

                (rspecCpu ispec) "ADMIN_down" (-1) (-1)

  let result = iterateDepth nl il reqinst req_nodes []