fix(XoBackups#deltaCopyVm): wait for the VDI exports to finish (#603)
It should prevent the creation of orphan snapshots on the source side.
This commit is contained in:
parent
d5e783e7e6
commit
d9ab8e83dc
@ -433,12 +433,15 @@ export default class {
|
|||||||
delta.vm.other_config[TAG_SOURCE_VM] = uuid
|
delta.vm.other_config[TAG_SOURCE_VM] = uuid
|
||||||
delta.vm.other_config[TAG_EXPORT_TIME] = safeDateFormat(now)
|
delta.vm.other_config[TAG_EXPORT_TIME] = safeDateFormat(now)
|
||||||
|
|
||||||
|
const { streams } = delta
|
||||||
forEach(delta.vdis, (vdi, key) => {
|
forEach(delta.vdis, (vdi, key) => {
|
||||||
const id = `${key}.vhd`
|
const id = `${key}.vhd`
|
||||||
|
const stream = streams[id]
|
||||||
const sizeStream = createSizeStream().once('finish', () => {
|
const sizeStream = createSizeStream().once('finish', () => {
|
||||||
size += sizeStream.size
|
size += sizeStream.size
|
||||||
})
|
})
|
||||||
delta.streams[id] = delta.streams[id].pipe(sizeStream)
|
sizeStream.task = stream.task
|
||||||
|
streams[id] = stream.pipe(sizeStream)
|
||||||
})
|
})
|
||||||
|
|
||||||
let toRemove = filter(targetXapi.objects.all, obj =>
|
let toRemove = filter(targetXapi.objects.all, obj =>
|
||||||
|
Loading…
Reference in New Issue
Block a user