Synnefo » snf-ganeti

      self._feedback_fn("Removing snapshot of disk/%s on node %s" %

                        (disk_index, src_node))

      if result.fail_msg:

        self._lu.LogWarning("Could not remove snapshot for disk/%d from node"

                            " %s: %s", disk_index, src_node, result.fail_msg)

      # FIXME: pass debug option from opcode to backend

      dt = DiskTransfer("snapshot/%s" % idx,

                        constants.IEIO_FILE, (path, ),

                        finished_fn)

      transfers.append(dt)

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

        ieloop.Add(DiskExport(self._lu, instance.primary_node,

                              opts, host, port, instance, "disk%d" % idx,

                              timeouts, cbs, private=(idx, finished_fn)))

      ieloop.Run()

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

                              "disk%d" % idx,

                              timeouts, cbs, private=(idx, )))

      ieloop.Run()