{
size_t i;
size_t notReady = 0;
- int status;
for (i = 0; i < vm->def->ndisks; i++) {
virDomainDiskDefPtr disk = vm->def->disks[i];
return -1;
}
- status = qemuBlockJobUpdate(vm, job, asyncJob);
- if (status == VIR_DOMAIN_BLOCK_JOB_FAILED) {
+ qemuBlockJobUpdate(vm, job, asyncJob);
+ if (job->state == VIR_DOMAIN_BLOCK_JOB_FAILED) {
qemuMigrationNBDReportMirrorError(job, disk->dst);
virObjectUnref(job);
return -1;
size_t i;
size_t active = 0;
size_t completed = 0;
- int status;
bool failed = false;
retry:
if (!(job = qemuBlockJobDiskGetJob(disk)))
continue;
- status = qemuBlockJobUpdate(vm, job, asyncJob);
- switch (status) {
+ qemuBlockJobUpdate(vm, job, asyncJob);
+ switch (job->state) {
case VIR_DOMAIN_BLOCK_JOB_FAILED:
if (check) {
qemuMigrationNBDReportMirrorError(job, disk->dst);
active++;
}
- if (status == VIR_DOMAIN_BLOCK_JOB_COMPLETED)
+ if (job->state == VIR_DOMAIN_BLOCK_JOB_COMPLETED)
completed++;
virObjectUnref(job);
qemuDomainAsyncJob asyncJob)
{
qemuDomainObjPrivatePtr priv = vm->privateData;
- int status;
int rv;
- status = qemuBlockJobUpdate(vm, job, asyncJob);
- switch (status) {
+ qemuBlockJobUpdate(vm, job, asyncJob);
+ switch (job->state) {
case VIR_DOMAIN_BLOCK_JOB_FAILED:
case VIR_DOMAIN_BLOCK_JOB_CANCELED:
if (failNoJob) {