Synnefo » snf-ganeti

        connect_timeout = constants.RIE_CONNECT_TIMEOUT

        timeouts = masterd.instance.ImportExportTimeouts(connect_timeout)

        if not compat.all(disk_results):

          # TODO: Should the instance still be started, even if some disks

          # failed to import (valid for local imports, too)?

        self.LogWarning("Could not remove metadata for disk %d on node %s,"

                        " continuing anyway: %s", idx, pnode, msg)

  def Exec(self, feedback_fn):

    """Modifies an instance.

    try:

      for idx, (dev, (host, port, magic)) in enumerate(zip(instance.disks,

                                                           disk_info)):

        opts = objects.ImportExportOptions(key_name=key_name,

                                           ca_pem=dest_ca_pem,

        self._feedback_fn("Sending disk %s to %s:%s" % (idx, host, port))

        finished_fn = compat.partial(self._TransferFinished, idx)

    self._dresults[idx] = bool(ie.success)

  """Imports an instance from another cluster.

  @param lu: Logical unit instance

  @param feedback_fn: Feedback function

  @type instance: L{objects.Instance}

  @param instance: Instance object

  @type source_x509_ca: OpenSSL.crypto.X509

  @param source_x509_ca: Import source's X509 CA

  @type cds: string

  magic_base = utils.GenerateSecret(6)

  # Create crypto key

  result = lu.rpc.call_x509_cert_create(instance.primary_node,

                                        constants.RIE_CERT_VALIDITY)

      utils.SignX509Certificate(x509_cert, cds, utils.GenerateSecret(8))

    cbs = _RemoteImportCb(feedback_fn, cds, signed_x509_cert_pem,

    ieloop = ImportExportLoop(lu)

    try:

        # Import daemon options

        opts = objects.ImportExportOptions(key_name=x509_key_name,

                                           ca_pem=source_ca_pem,

        ieloop.Add(DiskImport(lu, instance.primary_node, opts, instance,

                              constants.IEIO_SCRIPT, (dev, idx),

  if not utils.VerifySha1Hmac(cds, msg, hmac_digest, salt=hmac_salt):

    raise errors.GenericError("HMAC is wrong")

          utils.ValidateServiceName(port),

          magic)