c85323baa4
* full and delta backup jobs are renamed to full and incremental * inside an incremental job, the full and delta transfers are renamed to base and delta transver * the baseVm used for computing the snapshot is renamed to comparisasonBasisVm * split a lot of files to extract reusable methods * use a factory to instantiates BackubJob, the Backup* classes are now private by convention * the VmBackups class are instatiated by a XapiBackupJob => move them to the _backup folder * the writers need a VmBackup in their constructor: move them to the vmBackup folder
64 lines
1.7 KiB
JavaScript
64 lines
1.7 KiB
JavaScript
'use strict'
|
|
|
|
const { createLogger } = require('@xen-orchestra/log')
|
|
|
|
const { forkStreamUnpipe } = require('../forkStreamUnpipe.js')
|
|
const { watchStreamSize } = require('../../_watchStreamSize.js')
|
|
const { FullRemoteWriter } = require('./writers/FullRemoteWriter.js')
|
|
const { FullXapiWriter } = require('./writers/FullXapiWriter.js')
|
|
const { AbstractXapiVmBackup } = require('./AbstractXapiVMBackup.js')
|
|
|
|
const { debug } = createLogger('xo:backups:FullVmBackup')
|
|
|
|
class FullXapiVmBackup extends AbstractXapiVmBackup {
|
|
_getWriters() {
|
|
return [FullRemoteWriter, FullXapiWriter]
|
|
}
|
|
|
|
_mustDoSnapshot() {
|
|
const { vm } = this
|
|
|
|
const settings = this._settings
|
|
return (
|
|
settings.unconditionalSnapshot ||
|
|
(!settings.offlineBackup && vm.power_state === 'Running') ||
|
|
settings.snapshotRetention !== 0
|
|
)
|
|
}
|
|
_selectBaseVm() {}
|
|
|
|
async _copy() {
|
|
const { compression } = this.job
|
|
const stream = this._throttleStream(
|
|
await this._xapi.VM_export(this.exportedVm.$ref, {
|
|
compress: Boolean(compression) && (compression === 'native' ? 'gzip' : 'zstd'),
|
|
useSnapshot: false,
|
|
})
|
|
)
|
|
const sizeContainer = watchStreamSize(stream)
|
|
|
|
const timestamp = Date.now()
|
|
|
|
await this._callWriters(
|
|
writer =>
|
|
writer.run({
|
|
sizeContainer,
|
|
stream: forkStreamUnpipe(stream),
|
|
timestamp,
|
|
}),
|
|
'writer.run()'
|
|
)
|
|
|
|
const { size } = sizeContainer
|
|
const end = Date.now()
|
|
const duration = end - timestamp
|
|
debug('transfer complete', {
|
|
duration,
|
|
speed: duration !== 0 ? (size * 1e3) / 1024 / 1024 / duration : 0,
|
|
size,
|
|
})
|
|
this._healthCheck()
|
|
}
|
|
}
|
|
exports.FullXapiVmBackup = FullXapiVmBackup
|