|
@@ -550,6 +550,7 @@ void multifd_save_cleanup(void)
|
|
|
multifd_send_state->ops->send_cleanup(p, &local_err);
|
|
|
if (local_err) {
|
|
|
migrate_set_error(migrate_get_current(), local_err);
|
|
|
+ error_free(local_err);
|
|
|
}
|
|
|
}
|
|
|
qemu_sem_destroy(&multifd_send_state->channels_ready);
|
|
@@ -688,6 +689,7 @@ out:
|
|
|
if (local_err) {
|
|
|
trace_multifd_send_error(p->id);
|
|
|
multifd_send_terminate_threads(local_err);
|
|
|
+ error_free(local_err);
|
|
|
}
|
|
|
|
|
|
/*
|
|
@@ -965,6 +967,7 @@ static void *multifd_recv_thread(void *opaque)
|
|
|
|
|
|
if (local_err) {
|
|
|
multifd_recv_terminate_threads(local_err);
|
|
|
+ error_free(local_err);
|
|
|
}
|
|
|
qemu_mutex_lock(&p->mutex);
|
|
|
p->running = false;
|