Synnefo » snf-ganeti

import Ganeti.HTools.Types

import Ganeti.HTools.CLI

-- | Parse the environment and return the node\/instance names.

--

wrapIO :: IO (Result a) -> IO (Result a)

wrapIO = flip catch (return . Bad . show)

-- | External tool data loader from a variety of sources.

loadExternalData :: Options

                 -> IO (Node.List, Instance.List, String)

                           " files options should be given.")

         exitWith $ ExitFailure 1

  input_data <-

      case () of

        _ | setRapi ->

          | setSim -> Simu.loadData $ fromJust simdata

          | otherwise -> wrapIO $ Text.loadData nodef instf

  (loaded_nl, il, csf) <-

      (case ldresult of

         Ok x -> return x

  let idata = fromJSObject ilist

  iobj <- mapM (\(x,y) -> asJSObject y >>= parseInstance ktn x) idata

  let (kti, il) = assignIndices iobj

  req_nodes <- fromObj "required_nodes" request

  optype <- fromObj "type" request

  rqtype <-

    , Request(..)

    ) where

import Data.Function (on)

import Data.List

import Data.Maybe (fromJust)

-- | For each instance, add its index to its primary and secondary nodes.

fixNodes :: [(Ndx, Node.Node)]

         -> [(Ndx, Node.Node)]

    let

        pdx = Instance.pNode inst

        sdx = Instance.sNode inst

-- | Initializer function that loads the data from a node and instance

-- list and massages it into the correct format.

              Instance.AssocList) -- ^ Data from either Text.loadData

                                  -- or Rapi.loadData

          -> Result (Node.List, Instance.List, String)

            (map (\ (k, v) -> (k, Node.buildPeers v il3)) nl2)

      node_names = map Node.name $ Container.elems nl3

      inst_names = map Instance.name $ Container.elems il3

-}

module Ganeti.HTools.Node

    , List

    -- * Constructor

    , create

    in t {peers=pmap, failN1 = new_failN1, rMem = new_rmem, pRem = new_prem}

-- | Assigns an instance to a node as primary and update the used VCPU

setPri :: Node -> Instance.Instance -> Node

                  , uCpu = new_count

    where new_count = uCpu t + Instance.vcpus inst

-- | Assigns an instance to a node as secondary without other updates.

setSec :: Node -> Instance.Instance -> Node

-- * Update functions

        new_failn1 = new_mem <= rMem t

        new_ucpu = uCpu t - Instance.vcpus inst

        new_rcpu = fromIntegral new_ucpu / tCpu t

    in t {pList = new_plist, fMem = new_mem, fDsk = new_dsk,

          failN1 = new_failn1, pMem = new_mp, pDsk = new_dp,

-- | Removes a secondary instance.

removeSec :: Node -> Instance.Instance -> Node

        new_prem = fromIntegral new_rmem / tMem t

        new_failn1 = fMem t <= new_rmem

        new_dp = fromIntegral new_dsk / tDsk t

    in t {sList = new_slist, fDsk = new_dsk, peers = new_peers,

          failN1 = new_failn1, rMem = new_rmem, pDsk = new_dp,

-- | Adds a primary instance.

addPri :: Node -> Instance.Instance -> T.OpResult Node

        new_pcpu = fromIntegral new_ucpu / tCpu t

        new_dp = fromIntegral new_dsk / tDsk t

        l_cpu = mCpu t

    in if new_mem <= 0 then T.OpFail T.FailMem

       else if new_dsk <= 0 || mDsk t > new_dp then T.OpFail T.FailDisk

       else if new_failn1 && not (failN1 t) then T.OpFail T.FailMem

               new_mp = fromIntegral new_mem / tMem t

               r = t { pList = new_plist, fMem = new_mem, fDsk = new_dsk,

                       failN1 = new_failn1, pMem = new_mp, pDsk = new_dp,

           in T.OpGood r

-- | Adds a secondary instance.

        new_prem = fromIntegral new_rmem / tMem t

        new_failn1 = old_mem <= new_rmem

        new_dp = fromIntegral new_dsk / tDsk t

    in if new_dsk <= 0 || mDsk t > new_dp then T.OpFail T.FailDisk

       else if new_failn1 && not (failN1 t) then T.OpFail T.FailMem

       else let new_slist = iname:sList t

                r = t { sList = new_slist, fDsk = new_dsk,

                        peers = new_peers, failN1 = new_failn1,

                        rMem = new_rmem, pDsk = new_dp,

           in T.OpGood r

-- * Stats functions

    , oMaxCpu

    , oMinDisk

    , oDiskMoves

    , oShowVer

    , oShowHelp

    ]

              printf "%-*s " nlen name

              hFlush stdout

              input_data <- Rapi.loadData name

              (case ldresult of

                 Bad err -> printf "\nError: failed to load data. \

                                   \Details:\n%s\n" err