git: c369cdd69656 - stable/13 - bhyve: Address warnings in blockif_proc()
- Go to: [ bottom of page ] [ top of archives ] [ this month ]
Date: Thu, 26 Jan 2023 19:47:58 UTC
The branch stable/13 has been updated by jhb:
URL: https://cgit.FreeBSD.org/src/commit/?id=c369cdd696568cc037958413ead78f7225193302
commit c369cdd696568cc037958413ead78f7225193302
Author: Mark Johnston <markj@FreeBSD.org>
AuthorDate: 2022-10-25 13:16:23 +0000
Commit: John Baldwin <jhb@FreeBSD.org>
CommitDate: 2023-01-26 19:42:43 +0000
bhyve: Address warnings in blockif_proc()
- Use unsigned types for all arithmetic. Use a new signed variable for
holding the return value of pread() and pwrite().
- Handle short I/O from pwrite().
MFC after: 1 week
(cherry picked from commit 46f5c828961e64646c46ff9e3bc8e55f46f3e7bb)
---
usr.sbin/bhyve/block_if.c | 31 ++++++++++++++++++-------------
1 file changed, 18 insertions(+), 13 deletions(-)
diff --git a/usr.sbin/bhyve/block_if.c b/usr.sbin/bhyve/block_if.c
index 558a1629f074..a13f7f0744c6 100644
--- a/usr.sbin/bhyve/block_if.c
+++ b/usr.sbin/bhyve/block_if.c
@@ -235,32 +235,36 @@ blockif_proc(struct blockif_ctxt *bc, struct blockif_elem *be, uint8_t *buf)
{
struct blockif_req *br;
off_t arg[2];
- ssize_t clen, len, off, boff, voff;
+ ssize_t n;
+ size_t clen, len, off, boff, voff;
int i, err;
br = be->be_req;
+ assert(br->br_resid >= 0);
+
if (br->br_iovcnt <= 1)
buf = NULL;
err = 0;
switch (be->be_op) {
case BOP_READ:
if (buf == NULL) {
- if ((len = preadv(bc->bc_fd, br->br_iov, br->br_iovcnt,
- br->br_offset)) < 0)
+ if ((n = preadv(bc->bc_fd, br->br_iov, br->br_iovcnt,
+ br->br_offset)) < 0)
err = errno;
else
- br->br_resid -= len;
+ br->br_resid -= n;
break;
}
i = 0;
off = voff = 0;
while (br->br_resid > 0) {
len = MIN(br->br_resid, MAXPHYS);
- if (pread(bc->bc_fd, buf, len, br->br_offset +
- off) < 0) {
+ n = pread(bc->bc_fd, buf, len, br->br_offset + off);
+ if (n < 0) {
err = errno;
break;
}
+ len = (size_t)n;
boff = 0;
do {
clen = MIN(len - boff, br->br_iov[i].iov_len -
@@ -285,11 +289,11 @@ blockif_proc(struct blockif_ctxt *bc, struct blockif_elem *be, uint8_t *buf)
break;
}
if (buf == NULL) {
- if ((len = pwritev(bc->bc_fd, br->br_iov, br->br_iovcnt,
- br->br_offset)) < 0)
+ if ((n = pwritev(bc->bc_fd, br->br_iov, br->br_iovcnt,
+ br->br_offset)) < 0)
err = errno;
else
- br->br_resid -= len;
+ br->br_resid -= n;
break;
}
i = 0;
@@ -311,13 +315,14 @@ blockif_proc(struct blockif_ctxt *bc, struct blockif_elem *be, uint8_t *buf)
}
boff += clen;
} while (boff < len);
- if (pwrite(bc->bc_fd, buf, len, br->br_offset +
- off) < 0) {
+
+ n = pwrite(bc->bc_fd, buf, len, br->br_offset + off);
+ if (n < 0) {
err = errno;
break;
}
- off += len;
- br->br_resid -= len;
+ off += n;
+ br->br_resid -= n;
}
break;
case BOP_FLUSH: