Synnefo » snf-ganeti » ganeti-local

                 utils.CommaJoin(ial.result))

  def CheckArguments(self):

      # Normalize and convert deprecated list of disk indices

      self.op.disks = [(idx, {}) for idx in sorted(frozenset(self.op.disks))]

#

#

#

# This program is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License as published by

#: Maybe a dictionary (dict or None)

TMaybeDict = TOr(TDict, TNone)

TPositiveInt = \

#: a maybe positive integer (positive integer or None)

TMaybePositiveInt = TOr(TPositiveInt, TNone)

  TAnd(TInt, WithDesc("LessThanZero")(compat.partial(operator.gt, 0)))

#: a positive float

#: Job ID

                               TRegex(re.compile("^%s$" %

                                                 constants.JOB_ID_TEMPLATE))))

TNumber = TOr(TInt, TFloat)

#: Relative job ID

def TInstanceOf(my_inst):

    @return: a list of job identifiers.

    """

    # New number

    serial = self._last_serial + count

  MODE = constants.IALLOCATOR_MODE_ALLOC

  REQ_PARAMS = [

    _INST_NAME,

    ("disks", ht.TListOf(ht.TDict)),

    ("disk_template", ht.TString),

    ("os", ht.TString),

#: the shutdown timeout

_PShutdownTimeout = \

   "How long to wait for instance to shut down")

#: the force parameter

  WITH_LU = True

  OP_PARAMS = [

    ("dry_run", None, ht.TMaybeBool, "Run checks only, don't execute"),

    ("priority", constants.OP_PRIO_DEFAULT,

     ht.TElemOf(constants.OP_PRIO_SUBMIT_VALID), "Opcode priority"),

    (DEPEND_ATTR, None, _BuildJobDepCheck(True),

    ]

  OP_RESULT = ht.TListOf(ht.TAnd(ht.TIsLength(3),

                                 ht.TItems([ht.TNonEmptyString,

class OpClusterConfigQuery(OpCode):

                              ht.TNone),

     "Cluster-wide OS parameter defaults"),

    _PDiskParams,

     "Master candidate pool size"),

    ("uid_pool", None, ht.NoType,

     "Set UID pool, must be list of lists describing UID ranges (two items,"

     "Timeout before the OOB helper will be terminated"),

    ("ignore_status", False, ht.TBool,

     "Ignores the node offline status for power off"),

     "Time in seconds to wait between powering on nodes"),

    ]

  # Fixme: Make it more specific with all the special cases in LUOobCommand

    ("source_instance_name", None, ht.TMaybeString,

     "Source instance name (remote import only)"),

    ("source_shutdown_timeout", constants.DEFAULT_SHUTDOWN_TIMEOUT,

     "How long source instance was given to shut down (remote import only)"),

    ("source_x509_ca", None, ht.TMaybeString,

     "Source X509 CA in PEM format (remote import only)"),

  OP_PARAMS = [

    _PInstanceName,

    _PIgnoreOfflineNodes,

     "How long to wait for instance to shut down"),

    _PNoRemember,

    ]

    _PIgnoreIpolicy,

    ("mode", ht.NoDefault, ht.TElemOf(constants.REPLACE_MODES),

     "Replacement mode"),

     "Disk indexes"),

    ("remote_node", None, ht.TMaybeString, "New secondary node"),

    ("iallocator", None, ht.TMaybeString,

  """Recreate an instance's disks."""

  _TDiskChanges = \

    ht.TAnd(ht.TIsLength(2),

                       ht.Comment("Parameters")(_TDiskParams)]))

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

    ("disks", ht.EmptyList,

     "List of disk indexes (deprecated) or a list of tuples containing a disk"

     " index and a possibly empty dictionary with disk parameter changes"),

    ("nodes", ht.EmptyList, ht.TListOf(ht.TNonEmptyString),

  # TODO: Remove in version 2.8 including support in LUInstanceSetParams

  old_mod_item_fn = \

    ht.TAnd(ht.TIsLength(2), ht.TItems([

      fn,

      ]))

    ("disks", ht.EmptyList, TestDiskModifications,

     "List of disk changes; see ``nics``"),

    ("beparams", ht.EmptyDict, ht.TDict, "Per-instance backend parameters"),

    ("hvparams", ht.EmptyDict, ht.TDict,

     "Per-instance hypervisor parameters, hypervisor-dependent"),

    ("disk_template", None, ht.TOr(ht.TNone, _BuildDiskTemplateCheck(False)),

    _PInstanceName,

    _PWaitForSync,

    ("disk", ht.NoDefault, ht.TInt, "Disk index"),

     "Amount of disk space to add (megabytes)"),

    ("absolute", False, ht.TBool,

     "Whether the amount parameter is an absolute target or a relative one"),

    ("duration", ht.NoDefault, ht.TNumber, None),

    ("on_master", True, ht.TBool, None),

    ("on_nodes", ht.EmptyList, ht.TListOf(ht.TNonEmptyString), None),

    ]

    ("hypervisor", None, ht.TMaybeString, None),

    ("allocator", None, ht.TMaybeString, None),

    ("tags", ht.EmptyList, ht.TListOf(ht.TNonEmptyString), None),

    ("os", None, ht.TMaybeString, None),

    ("disk_template", None, ht.TMaybeString, None),

    ("instances", None, ht.TMaybeListOf(ht.TNonEmptyString), None),

    ("evac_mode", None,

     ht.TOr(ht.TNone, ht.TElemOf(constants.IALLOCATOR_NEVAC_MODES)), None),

    ("target_groups", None, ht.TMaybeListOf(ht.TNonEmptyString), None),

    ]

#!/usr/bin/python

#

#

# This program is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License as published by

      self.assertFalse(ht.TInt(val))

    for val in range(0, 100, 4):

      neg = -(val + 1)

      self.assertFalse(ht.TPositiveInt(neg))

      self.assertFalse(ht.TPositiveInt(0.1 + val))

    for val in [0, 0.1, 0.9, -0.3]:

    for val in range(1, 100, 4):

  def testFloat(self):

    for val in [-100.21, -3.0, 0.0, 16.12, 128.3433, 923874.928]: