Synnefo » snf-ganeti

  @_RpcTimeout(_TMO_NORMAL)

  def call_finalize_export(self, node, instance, snap_disks):

    """Request the completion of an export operation.

    This writes the export config file, etc.

    This is a single-node call.

    """

    flat_disks = []

    for disk in snap_disks:

      if isinstance(disk, bool):

        flat_disks.append(disk)

      else:

        flat_disks.append(disk.ToDict())

    return self._SingleNodeCall(node, "finalize_export",

                                [self._InstDict(instance), flat_disks])

  @_RpcTimeout(_TMO_FAST)

  def call_export_info(self, node, path):

    """Queries the export information in a given path.

    This is a single-node call.

    """

    return self._SingleNodeCall(node, "export_info", [path])

  @_RpcTimeout(_TMO_FAST)

  def call_export_list(self, node_list):

    """Gets the stored exports list.

    This is a multi-node call.

    """

    return self._MultiNodeCall(node_list, "export_list", [])

  @_RpcTimeout(_TMO_FAST)

  def call_export_remove(self, node, export):

    """Requests removal of a given export.

    This is a single-node call.

    """

    return self._SingleNodeCall(node, "export_remove", [export])

  @_RpcTimeout(_TMO_FAST)

  def call_impexp_status(self, node, names):

    """Gets the status of an import or export.

    This is a single-node call.

    @type node: string

    @param node: Node name

    @type names: List of strings

    @param names: Import/export names

    @rtype: List of L{objects.ImportExportStatus} instances

    @return: Returns a list of the state of each named import/export or None if

             a status couldn't be retrieved

    """

    result = self._SingleNodeCall(node, "impexp_status", [names])

    if not result.fail_msg:

      decoded = []

      for i in result.payload:

        if i is None:

          decoded.append(None)

          continue

        decoded.append(objects.ImportExportStatus.FromDict(i))

      result.payload = decoded

    return result

  @_RpcTimeout(_TMO_NORMAL)

  def call_impexp_abort(self, node, name):

    """Aborts an import or export.

    This is a single-node call.

    @type node: string

    @param node: Node name

    @type name: string

    @param name: Import/export name

    """

    return self._SingleNodeCall(node, "impexp_abort", [name])

  @_RpcTimeout(_TMO_NORMAL)

  def call_impexp_cleanup(self, node, name):

    """Cleans up after an import or export.

    This is a single-node call.

    @type node: string

    @param node: Node name

    @type name: string

    @param name: Import/export name

    """

    return self._SingleNodeCall(node, "impexp_cleanup", [name])