Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
qemu-file: remove shutdown member
The first thing that we do after setting the shutdown value is set the
error as -EIO if there is not a previous error.

So this value is redundant.  Just remove it and use
qemu_file_get_error() in the places that it was tested.

Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Daniel P. Berrangé <berrange@redhat.com>
Reviewed-by: Peter Xu <peterx@redhat.com>
Message-Id: <20230504113841.23130-7-quintela@redhat.com>
  • Loading branch information
Juan Quintela committed May 5, 2023
1 parent 27a1243 commit ac7d25b
Showing 1 changed file with 3 additions and 7 deletions.
10 changes: 3 additions & 7 deletions migration/qemu-file.c
Expand Up @@ -63,8 +63,6 @@ struct QEMUFile {

int last_error;
Error *last_error_obj;
/* has the file has been shutdown */
bool shutdown;
};

/*
Expand All @@ -78,8 +76,6 @@ int qemu_file_shutdown(QEMUFile *f)
{
int ret = 0;

f->shutdown = true;

/*
* We must set qemufile error before the real shutdown(), otherwise
* there can be a race window where we thought IO all went though
Expand Down Expand Up @@ -294,7 +290,7 @@ void qemu_fflush(QEMUFile *f)
return;
}

if (f->shutdown) {
if (qemu_file_get_error(f)) {
return;
}
if (f->iovcnt > 0) {
Expand Down Expand Up @@ -397,7 +393,7 @@ static ssize_t coroutine_mixed_fn qemu_fill_buffer(QEMUFile *f)
f->buf_index = 0;
f->buf_size = pending;

if (f->shutdown) {
if (qemu_file_get_error(f)) {
return 0;
}

Expand Down Expand Up @@ -486,7 +482,7 @@ static int add_to_iovec(QEMUFile *f, const uint8_t *buf, size_t size,
} else {
if (f->iovcnt >= MAX_IOV_SIZE) {
/* Should only happen if a previous fflush failed */
assert(f->shutdown || !qemu_file_is_writable(f));
assert(qemu_file_get_error(f) || !qemu_file_is_writable(f));
return 1;
}
if (may_free) {
Expand Down

0 comments on commit ac7d25b

Please sign in to comment.