Synnefo » snf-ganeti

                 PlainQuery str -> return str

                 _ -> fail $ "Invalid query type " ++ show (confdRqQuery req)

  node <- gntErrorToResult $ getNode cfg node_name

               M.elems . fromContainer . configInstances $ cfg

      encoded = [J.JSArray [J.showJSON a, J.showJSON b, J.showJSON c,

                             J.showJSON d, J.showJSON e, J.showJSON f] |

    , getInstPrimaryNode

    , getInstMinorsForNode

    , getInstAllNodes

    , getFilledInstHvParams

    , getFilledInstBeParams

    , getFilledInstOsParams

-- | Computes all disk-related nodes of an instance. For non-DRBD,

-- this will be empty, for DRBD it will contain both the primary and

-- the secondaries.

-- | Computes all nodes of an instance.

-- | Computes the secondary nodes of an instance. Since this is valid

-- only for DRBD, we call directly 'instDiskNodes', skipping over the

-- extra primary insert.

-- | Get instances of a given node.

-- The node is specified through its UUID.

getNodeInstances cfg nname =

    let all_inst = M.elems . fromContainer . configInstances $ cfg

        pri_inst = filter ((== nname) . instPrimaryNode) all_inst

    in (pri_inst, sec_inst)

-- | Computes the role of a node.

-- the primary node has to be appended to the results.

getInstAllNodes :: ConfigData -> String -> ErrorResult [Node]

getInstAllNodes cfg name = do

  pNode <- getInstPrimaryNode cfg name

  return . nub $ pNode:diskNodes

-- | Get disks for a given instance.

-- The instance is specified by name or uuid.

-- | Filters DRBD minors for a given node.

getDrbdMinorsForNode :: String -> Disk -> [(Int, String)]

-- | Gets the list of DRBD minors for an instance that are related to

-- a given node.

                     -> [(String, Int, String, String, String, String)]

  let role = if node == instPrimaryNode inst

               then rolePrimary

               else roleSecondary

      iname = instName inst

  -- FIXME: the disk/ build there is hack-ish; unify this in a

  -- separate place, or reuse the iv_name (but that is deprecated on

  -- the Python side)

  in concatMap (\(idx, dsk) ->

            [(node, minor, iname, "disk/" ++ show idx, role, peer)

               | (minor, peer) <- getDrbdMinorsForNode node dsk]) .

-- | Builds link -> ip -> instname map.

--

import qualified Control.Exception as E

import Control.Monad

import Data.Attoparsec.Text.Lazy as A

import Data.Text.Lazy (pack, unpack)

import Network.BSD (getHostName)

import System.Process

  exitIfBad "Unable to obtain the list of instances" instances

-- | Adds the name of the instance to the information about one logical volume.

-- | Adds the name of the instance to the information about logical volumes.

addInstNameToLv :: [Instance] -> [LVInfo] -> [LVInfo]

-- | This function computes the JSON representation of the LV status.

buildJsonReport :: Options -> IO J.JSValue

  , allBeParamFields

  , Instance(..)

  , toDictInstance

  , PartialNDParams(..)

  , FilledNDParams(..)

  , fillNDParams

  , simpleField "osparams_private" [t| OsParamsPrivate    |]

  , simpleField "admin_state"      [t| AdminState         |]

  , simpleField "nics"             [t| [PartialNic]       |]

  , simpleField "disk_template"    [t| DiskTemplate       |]

  , simpleField "disks_active"     [t| Bool               |]

  , optionalField $ simpleField "network_port" [t| Int  |]

instance TagsObject Instance where

  tagsOf = instTags

-- * IPolicy definitions

$(buildParam "ISpec" "ispec"

  [ (FieldDefinition "disk_usage" "DiskUsage" QFTUnit

     "Total disk space used by instance on each of its nodes; this is not the\

     \ disk size visible to the instance, but the usage on the node",

  , (FieldDefinition "disk.count" "Disks" QFTNumber

     "Number of disks",

     FieldSimple (rsNormal . length . instDisks), QffNormal)

  , (FieldDefinition "disk.sizes" "Disk_sizes" QFTOther

     "List of disk sizes",

  , (FieldDefinition "disk.spindles" "Disk_spindles" QFTOther

     "List of disk spindles",

  , (FieldDefinition "disk.names" "Disk_names" QFTOther

     "List of disk names",

  , (FieldDefinition "disk.uuids" "Disk_UUIDs" QFTOther

     "List of disk UUIDs",

  ] ++

  -- Per-disk parameter fields

  -- Aggregate nic parameter fields

  [ (FieldDefinition "nic.count" "NICs" QFTNumber

getDefaultNicParams cfg =

  (Map.!) (fromContainer . clusterNicparams . configCluster $ cfg) C.ppDefault

-- | Returns a field that retrieves a given NIC's network name.

getIndexedNicNetworkNameField :: Int -> FieldGetter Instance Runtime

getIndexedNicNetworkNameField index =