fix(xo-server): detect interruption of full backups (#2686)
This commit is contained in:
parent
d90cb09b56
commit
11d4cb2f04
@ -939,8 +939,6 @@ export default class {
|
|||||||
$defer.onFailure.call(handler, 'unlink', file)
|
$defer.onFailure.call(handler, 'unlink', file)
|
||||||
$defer.onFailure.call(targetStream, 'close')
|
$defer.onFailure.call(targetStream, 'close')
|
||||||
|
|
||||||
const promise = eventToPromise(targetStream, 'finish')
|
|
||||||
|
|
||||||
const sourceStream = await this._xo.getXapi(vm).exportVm(vm._xapiId, {
|
const sourceStream = await this._xo.getXapi(vm).exportVm(vm._xapiId, {
|
||||||
compress,
|
compress,
|
||||||
})
|
})
|
||||||
@ -949,7 +947,10 @@ export default class {
|
|||||||
|
|
||||||
sourceStream.pipe(sizeStream).pipe(targetStream)
|
sourceStream.pipe(sizeStream).pipe(targetStream)
|
||||||
|
|
||||||
await promise
|
await Promise.all([
|
||||||
|
sourceStream.task,
|
||||||
|
eventToPromise(targetStream, 'finish'),
|
||||||
|
])
|
||||||
|
|
||||||
return {
|
return {
|
||||||
transferSize: sizeStream.size,
|
transferSize: sizeStream.size,
|
||||||
|
Loading…
Reference in New Issue
Block a user