@@ -181,6 +181,7 @@ void qemu_file_set_rate_limit(QEMUFile *f, int64_t new_rate);
int64_t qemu_file_get_rate_limit(QEMUFile *f);
int qemu_file_get_error(QEMUFile *f);
void qemu_file_set_error(QEMUFile *f, int ret);
+void qemu_file_clear_error(QEMUFile *f);
int qemu_file_shutdown(QEMUFile *f);
QEMUFile *qemu_file_get_return_path(QEMUFile *f);
void qemu_fflush(QEMUFile *f);
@@ -63,6 +63,9 @@ static NotifierList migration_state_notifiers =
static bool deferred_incoming;
+static QemuMutex migration_recovery_mutex;
+static QemuCond migration_recovery_cond;
+
/*
* Current state of incoming postcopy; note this is not part of
* MigrationIncomingState since it's state is used during cleanup
@@ -127,6 +127,11 @@ void qemu_file_set_error(QEMUFile *f, int ret)
}
}
+void qemu_file_clear_error(QEMUFile *f)
+{
+ f->last_error = 0;
+}
+
bool qemu_file_is_writable(QEMUFile *f)
{
return f->ops->writev_buffer;
Signed-off-by: Md Haris Iqbal <haris.phnx@gmail.com> --- include/migration/qemu-file.h | 1 + migration/migration.c | 3 +++ migration/qemu-file.c | 5 +++++ 3 files changed, 9 insertions(+)