Now the function returned errno, so it is better the new name.
Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Anthony Liguori <aliguori@us.ibm.com>
qemu_get_buffer(f, host, TARGET_PAGE_SIZE);
}
- if (qemu_file_has_error(f)) {
+ if (qemu_file_get_error(f)) {
return -EIO;
}
} while (!(flags & RAM_SAVE_FLAG_EOS));
flush_blks(f);
- if (qemu_file_has_error(f)) {
+ if (qemu_file_get_error(f)) {
blk_mig_cleanup(mon);
return 0;
}
flush_blks(f);
- if (qemu_file_has_error(f)) {
+ if (qemu_file_get_error(f)) {
blk_mig_cleanup(mon);
return 0;
}
/* report completion */
qemu_put_be64(f, (100 << BDRV_SECTOR_BITS) | BLK_MIG_FLAG_PROGRESS);
- if (qemu_file_has_error(f)) {
+ if (qemu_file_get_error(f)) {
return 0;
}
fprintf(stderr, "Unknown flags\n");
return -EINVAL;
}
- if (qemu_file_has_error(f)) {
+ if (qemu_file_get_error(f)) {
return -EIO;
}
} while (!(flags & BLK_MIG_FLAG_EOS));
{
size_t offset = 0;
- if (qemu_file_has_error(s->file)) {
+ if (qemu_file_get_error(s->file)) {
DPRINTF("flush when error, bailing\n");
return;
}
DPRINTF("putting %d bytes at %" PRId64 "\n", size, pos);
- if (qemu_file_has_error(s->file)) {
+ if (qemu_file_get_error(s->file)) {
DPRINTF("flush when error, bailing\n");
return -EINVAL;
}
DPRINTF("closing\n");
- while (!qemu_file_has_error(s->file) && s->buffer_size) {
+ while (!qemu_file_get_error(s->file) && s->buffer_size) {
buffered_flush(s);
if (s->freeze_output)
s->wait_for_unfreeze(s->opaque);
{
QEMUFileBuffered *s = opaque;
- if (qemu_file_has_error(s->file)) {
+ if (qemu_file_get_error(s->file)) {
return -1;
}
if (s->freeze_output)
static int64_t buffered_set_rate_limit(void *opaque, int64_t new_rate)
{
QEMUFileBuffered *s = opaque;
- if (qemu_file_has_error(s->file))
+ if (qemu_file_get_error(s->file)) {
goto out;
-
+ }
if (new_rate > SIZE_MAX) {
new_rate = SIZE_MAX;
}
{
QEMUFileBuffered *s = opaque;
- if (qemu_file_has_error(s->file)) {
+ if (qemu_file_get_error(s->file)) {
buffered_close(s);
return;
}
int qemu_file_rate_limit(QEMUFile *f);
int64_t qemu_file_set_rate_limit(QEMUFile *f, int64_t new_rate);
int64_t qemu_file_get_rate_limit(QEMUFile *f);
-int qemu_file_has_error(QEMUFile *f);
+int qemu_file_get_error(QEMUFile *f);
void qemu_file_set_error(QEMUFile *f, int error);
/* Try to send any outstanding data. This function is useful when output is
qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL);
qemu_file_put_notify(s->file);
- if (qemu_file_has_error(s->file)) {
+ if (qemu_file_get_error(s->file)) {
migrate_fd_error(s);
}
}
return f;
}
-int qemu_file_has_error(QEMUFile *f)
+int qemu_file_get_error(QEMUFile *f)
{
return f->has_error;
}
se->save_live_state(mon, f, QEMU_VM_SECTION_START, se->opaque);
}
- ret = qemu_file_has_error(f);
+ ret = qemu_file_get_error(f);
if (ret != 0) {
qemu_savevm_state_cancel(mon, f);
}
if (ret != 0) {
return ret;
}
- ret = qemu_file_has_error(f);
+ ret = qemu_file_get_error(f);
if (ret != 0) {
qemu_savevm_state_cancel(mon, f);
}
qemu_put_byte(f, QEMU_VM_EOF);
- return qemu_file_has_error(f);
+ return qemu_file_get_error(f);
}
void qemu_savevm_state_cancel(Monitor *mon, QEMUFile *f)
out:
if (ret == 0) {
- ret = qemu_file_has_error(f);
+ ret = qemu_file_get_error(f);
}
if (!ret && saved_vm_running)
g_free(le);
}
- if (qemu_file_has_error(f))
+ if (qemu_file_get_error(f)) {
ret = -EIO;
+ }
return ret;
}