Skip to content

Commit

Permalink
savevm: Only qemu_fflush() can generate errors
Browse files Browse the repository at this point in the history
Move the error check to the beggining of the callers.  Once this is fixed
qemu_file_set_if_error() is not used anymore, so remove it.

Signed-off-by: Juan Quintela <quintela@redhat.com>

Reviewed-by: Paolo Bonzini <pbonzini@redhat.com>
  • Loading branch information
Juan Quintela committed Oct 17, 2012
1 parent 02c4a05 commit c10682c
Showing 1 changed file with 18 additions and 17 deletions.
35 changes: 18 additions & 17 deletions savevm.c
Expand Up @@ -445,18 +445,6 @@ void qemu_file_set_error(QEMUFile *f, int ret)
f->last_error = ret;
}

/** Sets last_error conditionally
*
* Sets last_error only if ret is negative _and_ no error
* was set before.
*/
static void qemu_file_set_if_error(QEMUFile *f, int ret)
{
if (ret < 0 && !f->last_error) {
qemu_file_set_error(f, ret);
}
}

/** Flushes QEMUFile buffer
*
*/
Expand Down Expand Up @@ -544,13 +532,17 @@ void qemu_put_buffer(QEMUFile *f, const uint8_t *buf, int size)
{
int l;

if (!f->last_error && f->is_write == 0 && f->buf_index > 0) {
if (f->last_error) {
return;
}

if (f->is_write == 0 && f->buf_index > 0) {
fprintf(stderr,
"Attempted to write to buffer while read buffer is not empty\n");
abort();
}

while (!f->last_error && size > 0) {
while (size > 0) {
l = IO_BUF_SIZE - f->buf_index;
if (l > size)
l = size;
Expand All @@ -561,14 +553,21 @@ void qemu_put_buffer(QEMUFile *f, const uint8_t *buf, int size)
size -= l;
if (f->buf_index >= IO_BUF_SIZE) {
int ret = qemu_fflush(f);
qemu_file_set_if_error(f, ret);
if (ret < 0) {
qemu_file_set_error(f, ret);
break;
}
}
}
}

void qemu_put_byte(QEMUFile *f, int v)
{
if (!f->last_error && f->is_write == 0 && f->buf_index > 0) {
if (f->last_error) {
return;
}

if (f->is_write == 0 && f->buf_index > 0) {
fprintf(stderr,
"Attempted to write to buffer while read buffer is not empty\n");
abort();
Expand All @@ -578,7 +577,9 @@ void qemu_put_byte(QEMUFile *f, int v)
f->is_write = 1;
if (f->buf_index >= IO_BUF_SIZE) {
int ret = qemu_fflush(f);
qemu_file_set_if_error(f, ret);
if (ret < 0) {
qemu_file_set_error(f, ret);
}
}
}

Expand Down

0 comments on commit c10682c

Please sign in to comment.