mirror of
https://github.com/tbsdtv/linux_media.git
synced 2025-07-23 12:43:29 +02:00
io_uring/net: use proper value for msg_inq
struct msghdr->msg_inq is a signed type, yet we attempt to store what is essentially an unsigned bitmask in there. We only really need to know if the field was stored or not, but let's use the proper type to avoid any misunderstandings on what is being attempted here. Link: https://lore.kernel.org/io-uring/CAHk-=wjKb24aSe6fE4zDH-eh8hr-FB9BbukObUVSMGOrsBHCRQ@mail.gmail.com/ Reported-by: Linus Torvalds <torvalds@linux-foundation.org> Signed-off-by: Jens Axboe <axboe@kernel.dk>
This commit is contained in:
@@ -630,7 +630,7 @@ static inline bool io_recv_finish(struct io_kiocb *req, int *ret,
|
|||||||
unsigned int cflags;
|
unsigned int cflags;
|
||||||
|
|
||||||
cflags = io_put_kbuf(req, issue_flags);
|
cflags = io_put_kbuf(req, issue_flags);
|
||||||
if (msg->msg_inq && msg->msg_inq != -1U)
|
if (msg->msg_inq && msg->msg_inq != -1)
|
||||||
cflags |= IORING_CQE_F_SOCK_NONEMPTY;
|
cflags |= IORING_CQE_F_SOCK_NONEMPTY;
|
||||||
|
|
||||||
if (!(req->flags & REQ_F_APOLL_MULTISHOT)) {
|
if (!(req->flags & REQ_F_APOLL_MULTISHOT)) {
|
||||||
@@ -645,7 +645,7 @@ static inline bool io_recv_finish(struct io_kiocb *req, int *ret,
|
|||||||
io_recv_prep_retry(req);
|
io_recv_prep_retry(req);
|
||||||
/* Known not-empty or unknown state, retry */
|
/* Known not-empty or unknown state, retry */
|
||||||
if (cflags & IORING_CQE_F_SOCK_NONEMPTY ||
|
if (cflags & IORING_CQE_F_SOCK_NONEMPTY ||
|
||||||
msg->msg_inq == -1U)
|
msg->msg_inq == -1)
|
||||||
return false;
|
return false;
|
||||||
if (issue_flags & IO_URING_F_MULTISHOT)
|
if (issue_flags & IO_URING_F_MULTISHOT)
|
||||||
*ret = IOU_ISSUE_SKIP_COMPLETE;
|
*ret = IOU_ISSUE_SKIP_COMPLETE;
|
||||||
@@ -804,7 +804,7 @@ retry_multishot:
|
|||||||
flags |= MSG_DONTWAIT;
|
flags |= MSG_DONTWAIT;
|
||||||
|
|
||||||
kmsg->msg.msg_get_inq = 1;
|
kmsg->msg.msg_get_inq = 1;
|
||||||
kmsg->msg.msg_inq = -1U;
|
kmsg->msg.msg_inq = -1;
|
||||||
if (req->flags & REQ_F_APOLL_MULTISHOT) {
|
if (req->flags & REQ_F_APOLL_MULTISHOT) {
|
||||||
ret = io_recvmsg_multishot(sock, sr, kmsg, flags,
|
ret = io_recvmsg_multishot(sock, sr, kmsg, flags,
|
||||||
&mshot_finished);
|
&mshot_finished);
|
||||||
@@ -902,7 +902,7 @@ retry_multishot:
|
|||||||
if (unlikely(ret))
|
if (unlikely(ret))
|
||||||
goto out_free;
|
goto out_free;
|
||||||
|
|
||||||
msg.msg_inq = -1U;
|
msg.msg_inq = -1;
|
||||||
msg.msg_flags = 0;
|
msg.msg_flags = 0;
|
||||||
|
|
||||||
flags = sr->msg_flags;
|
flags = sr->msg_flags;
|
||||||
|
Reference in New Issue
Block a user