projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add some new code comments on the log compress/decompress
[fio.git]
/
verify.c
diff --git
a/verify.c
b/verify.c
index 184f3a7f821b52487557b352e3b2f201a475905c..11963e15072d78b43d263cbe258bda90cbf4c0b9 100644
(file)
--- a/
verify.c
+++ b/
verify.c
@@
-720,7
+720,7
@@
static int verify_header(struct io_u *io_u, struct verify_header *hdr,
hdr->magic, FIO_HDR_MAGIC);
goto err;
}
hdr->magic, FIO_HDR_MAGIC);
goto err;
}
- if (hdr->len
> io_u->buf
len) {
+ if (hdr->len
!= hdr_
len) {
log_err("verify: bad header length %u, wanted %u",
hdr->len, hdr_len);
goto err;
log_err("verify: bad header length %u, wanted %u",
hdr->len, hdr_len);
goto err;
@@
-1082,7
+1082,7
@@
int get_next_verify(struct thread_data *td, struct io_u *io_u)
assert(ipo->flags & IP_F_ONRB);
ipo->flags &= ~IP_F_ONRB;
} else if (!flist_empty(&td->io_hist_list)) {
assert(ipo->flags & IP_F_ONRB);
ipo->flags &= ~IP_F_ONRB;
} else if (!flist_empty(&td->io_hist_list)) {
- ipo = flist_
entry(td->io_hist_list.nex
t, struct io_piece, list);
+ ipo = flist_
first_entry(&td->io_hist_lis
t, struct io_piece, list);
/*
* Ensure that the associated IO has completed
/*
* Ensure that the associated IO has completed
@@
-1187,7
+1187,7
@@
static void *verify_async_thread(void *data)
continue;
while (!flist_empty(&list)) {
continue;
while (!flist_empty(&list)) {
- io_u = flist_
entry(list.nex
t, struct io_u, verify_list);
+ io_u = flist_
first_entry(&lis
t, struct io_u, verify_list);
flist_del(&io_u->verify_list);
ret = verify_io_u(td, io_u);
flist_del(&io_u->verify_list);
ret = verify_io_u(td, io_u);