Synnefo » snf-ganeti » ganeti-local

      idx = -1,

      peers = PeerMap.empty,

      r_mem = 0,

      p_rem = 0,

      p_cpu = 0,

      offline = offline_init,

setMdsk t val = t { m_dsk = val,

                    lo_dsk = if val == noLimit

                             then noLimitInt

-- | Sets the max cpu usage ratio

setMcpu :: Node -> Double -> Node

-- | Computes the maximum reserved memory for peers from a peer map.

computeMaxRes :: PeerMap.PeerMap -> PeerMap.Elem

-- | Builds the peer map for a given node.

buildPeers :: Node -> Instance.List -> Node

                (slist t)

        pmap = PeerMap.accumArray (+) mdata

        new_rmem = computeMaxRes pmap

    in t {peers=pmap, failN1 = new_failN1, r_mem = new_rmem, p_rem = new_prem}

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

setPri :: Node -> T.Idx -> Node

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

setSec :: Node -> T.Idx -> Node

-- | Add primary cpus to a node

addCpus :: Node -> Int -> Node

addCpus t count =

-- * Update functions

-- | Sets the free memory.

setFmem :: Node -> Int -> Node

setFmem t new_mem =

    in

      t { f_mem = new_mem, failN1 = new_n1, p_mem = new_mp }

        new_plist = delete iname (plist t)

        new_mem = f_mem t + Instance.mem inst

        new_dsk = f_dsk t + Instance.dsk inst

    in t {plist = new_plist, f_mem = new_mem, f_dsk = new_dsk,

          failN1 = new_failn1, p_mem = new_mp, p_dsk = new_dp,

          u_cpu = new_ucpu, p_cpu = new_rcpu}

        new_dsk = f_dsk t + Instance.dsk inst

        old_peers = peers t

        old_peem = PeerMap.find pnode old_peers

        new_peers = PeerMap.add pnode new_peem old_peers

        old_rmem = r_mem t

        new_rmem = if old_peem < old_rmem then

                       old_rmem

                   else

                       computeMaxRes new_peers

    in t {slist = new_slist, f_dsk = new_dsk, peers = new_peers,

          failN1 = new_failn1, r_mem = new_rmem, p_dsk = new_dp,

          p_rem = new_prem}

    let iname = Instance.idx inst

        new_mem = f_mem t - Instance.mem inst

        new_dsk = f_dsk t - Instance.dsk inst

        l_cpu = m_cpu t

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

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

       else if l_cpu >= 0 && l_cpu < new_pcpu then T.OpFail T.FailCPU

       else

               r = t { plist = new_plist, f_mem = new_mem, f_dsk = new_dsk,

                       failN1 = new_failn1, p_mem = new_mp, p_dsk = new_dp,

                       u_cpu = new_ucpu, p_cpu = new_pcpu }

        new_peem = PeerMap.find pdx old_peers + Instance.mem inst

        new_peers = PeerMap.add pdx new_peem old_peers

        new_rmem = max (r_mem t) new_peem

        new_failn1 = old_mem <= new_rmem

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

                r = t { slist = new_slist, f_dsk = new_dsk,

                        peers = new_peers, failN1 = new_failn1,

                        r_mem = new_rmem, p_dsk = new_dp,

        nmem = n_mem t

        xmem = x_mem t

        fmem = f_mem t

    in

      if off

         then printf " - %-*s %57s %3d %3d"

                    \ %4.0f %4d %3d %3d %6.4f %6.4f %5.2f"

                 (if off then '-' else if fn then '*' else ' ')

                 mname (name t) tmem nmem imem xmem fmem (r_mem t)

                 (t_cpu t) (u_cpu t)

                 pl sl mp dp cp