Synnefo » snf-ganeti » ganeti-local

    idict["beparams"] = cluster.FillBE(instance)

    return idict

  def call_volume_list(self, node_list, vg_name):

    """Gets the logical volumes present in a given volume group.

    """

    c = Client("volume_list", [vg_name])

    c.Run()

    return c.GetResults()

    """

    c = Client("vg_list", [])

    c.Run()

    return c.GetResults()

    """

    c = Client("bridges_exist", [bridges_list])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("instance_start", [self._InstDict(instance), extra_args])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("instance_shutdown", [self._InstDict(instance)])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("instance_migrate", [self._InstDict(instance), target, live])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("instance_reboot", [self._InstDict(instance),

                                   reboot_type, extra_args])

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [self._InstDict(inst)]

    c = Client("instance_os_add", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [self._InstDict(inst), old_name]

    c = Client("instance_run_rename", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("instance_info", [instance, hname])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("all_instances_info", [hypervisor_list])

    c.Run()

    return c.GetResults()

    """

    c = Client("instance_list", [hypervisor_list])

    c.Run()

    return c.GetResults()

    """

    c = Client("node_tcp_ping", [source, target, port, timeout,

                                 live_port_needed])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("node_has_ip_address", [address])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("node_info", [vg_name, hypervisor_type])

    c.Run()

    retux = c.GetResults()

    """

    params = [dsa, dsapub, rsa, rsapub, ssh, sshpub]

    c = Client("node_add", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("node_verify", [checkdict, cluster_name])

    c.Run()

    return c.GetResults()

    """

    c = Client("version", [])

    c.Run()

    return c.GetResults()

    """

    params = [bdev.ToDict(), size, owner, on_primary, info]

    c = Client("blockdev_create", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("blockdev_remove", [bdev.ToDict()])

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [(d.ToDict(), uid) for d, uid in devlist]

    c = Client("blockdev_rename", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [disk.ToDict(), owner, on_primary]

    c = Client("blockdev_assemble", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("blockdev_shutdown", [disk.ToDict()])

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [bdev.ToDict(), [disk.ToDict() for disk in ndevs]]

    c = Client("blockdev_addchildren", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [bdev.ToDict(), [disk.ToDict() for disk in ndevs]]

    c = Client("blockdev_removechildren", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [dsk.ToDict() for dsk in disks]

    c = Client("blockdev_getmirrorstatus", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("blockdev_find", [disk.ToDict()])

    c.Run()

    return c.GetResults().get(node, False)

    """

    params = [cf.ToDict() for cf in disks]

    c = Client("blockdev_close", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("os_diagnose", [])

    c.Run()

    result = c.GetResults()

    new_result = {}

    """

    c = Client("os_get", [name])

    c.Run()

    result = c.GetResults().get(node, False)

    if isinstance(result, dict):

    """

    params = [hpath, phase, env]

    c = Client("hooks_runner", params)

    c.Run()

    result = c.GetResults()

    return result

    """

    params = [name, idata]

    c = Client("iallocator_runner", params)

    c.Run()

    result = c.GetResults().get(node, False)

    return result

    """

    c = Client("blockdev_grow", [cf_bdev.ToDict(), amount])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("blockdev_snapshot", [cf_bdev.ToDict()])

    c.Run()

    return c.GetResults().get(node, False)

    params = [snap_bdev.ToDict(), dest_node,

              self._InstDict(instance), cluster_name]

    c = Client("snapshot_export", params)

    c.Run()

    return c.GetResults().get(node, False)

      flat_disks.append(disk.ToDict())

    params = [self._InstDict(instance), flat_disks]

    c = Client("finalize_export", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("export_info", [path])

    c.Run()

    result = c.GetResults().get(node, False)

    if not result:

    params = [self._InstDict(inst), osdev, swapdev,

              src_node, src_image, cluster_name]

    c = Client("instance_os_import", params)

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("export_list", [])

    c.Run()

    result = c.GetResults()

    return result

    """

    c = Client("export_remove", [export])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("node_volumes", [])

    c.Run()

    return c.GetResults()

    """

    c = Client("test_delay", [duration])

    c.Run()

    return c.GetResults()

    """

    c = Client("file_storage_dir_create", [file_storage_dir])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("file_storage_dir_remove", [file_storage_dir])

    c.Run()

    return c.GetResults().get(node, False)

    """

    c = Client("file_storage_dir_rename",

               [old_file_storage_dir, new_file_storage_dir])

    c.Run()

    return c.GetResults().get(node, False)

    cluster = self._cfg.GetClusterInfo()

    hv_full = cluster.FillDict(cluster.hvparams.get(hvname, {}), hvparams)

    c = Client("hypervisor_validate_params", [hvname, hv_full])

    c.Run()

    result = c.GetResults()

    return result