Unverified Commit 955edfba authored by openeuler-ci-bot's avatar openeuler-ci-bot Committed by Gitee
Browse files

!4448 [sync] PR-4321: io_uring/af_unix: disable sending io_uring over sockets 

Merge Pull Request from: @openeuler-sync-bot 
 

Origin pull request: 
https://gitee.com/openeuler/kernel/pulls/4321 
 
PR sync from: Liu Jian <liujian56@huawei.com>
https://mailweb.openeuler.org/hyperkitty/list/kernel@openeuler.org/message/HYDXTDCF4UCPC3JDBMM27IAK2CIPUDXI/ 
 
https://gitee.com/src-openeuler/kernel/issues/I8RWPE 
 
Link:https://gitee.com/openeuler/kernel/pulls/4448

 

Reviewed-by: default avatarYue Haibing <yuehaibing@huawei.com>
Signed-off-by: default avatarJialin Zhang <zhangjialin11@huawei.com>
parents 508ce6ae 37647b2f

io_uring/io_uring.c

+0 −55
Original line number Diff line number Diff line
@@ -8407,49 +8407,6 @@ static int io_sqe_files_register(struct io_ring_ctx *ctx, void __user *arg, 
	return ret;

}



static int io_sqe_file_register(struct io_ring_ctx *ctx, struct file *file,

				int index)

{

#if defined(CONFIG_UNIX)

	struct sock *sock = ctx->ring_sock->sk;

	struct sk_buff_head *head = &sock->sk_receive_queue;

	struct sk_buff *skb;



	/*

	 * See if we can merge this file into an existing skb SCM_RIGHTS

	 * file set. If there's no room, fall back to allocating a new skb

	 * and filling it in.

	 */

	spin_lock_irq(&head->lock);

	skb = skb_peek(head);

	if (skb) {

		struct scm_fp_list *fpl = UNIXCB(skb).fp;



		if (fpl->count < SCM_MAX_FD) {

			__skb_unlink(skb, head);

			spin_unlock_irq(&head->lock);

			fpl->fp[fpl->count] = get_file(file);

			unix_inflight(fpl->user, fpl->fp[fpl->count]);

			fpl->count++;

			spin_lock_irq(&head->lock);

			__skb_queue_head(head, skb);

		} else {

			skb = NULL;

		}

	}

	spin_unlock_irq(&head->lock);



	if (skb) {

		fput(file);

		return 0;

	}



	return __io_sqe_files_scm(ctx, 1, index);

#else

	return 0;

#endif

}



static int io_queue_rsrc_removal(struct io_rsrc_data *data, unsigned idx,

				 struct io_rsrc_node *node, void *rsrc)

{
@@ -8507,12 +8464,6 @@ static int io_install_fixed_file(struct io_kiocb *req, struct file *file, 


	*io_get_tag_slot(ctx->file_data, slot_index) = 0;

	io_fixed_file_set(file_slot, file);

	ret = io_sqe_file_register(ctx, file, slot_index);

	if (ret) {

		file_slot->file_ptr = 0;

		goto err;

	}



	ret = 0;

err:

	if (needs_switch)
@@ -8626,12 +8577,6 @@ static int __io_sqe_files_update(struct io_ring_ctx *ctx, 
			}

			*io_get_tag_slot(data, i) = tag;

			io_fixed_file_set(file_slot, file);

			err = io_sqe_file_register(ctx, file, i);

			if (err) {

				file_slot->file_ptr = 0;

				fput(file);

				break;

			}

		}

	}

net/core/scm.c

+6 −0
Original line number Diff line number Diff line
@@ -26,6 +26,7 @@ 
#include <linux/nsproxy.h>

#include <linux/slab.h>

#include <linux/errqueue.h>

#include <linux/io_uring.h>



#include <linux/uaccess.h>
@@ -103,6 +104,11 @@ static int scm_fp_copy(struct cmsghdr *cmsg, struct scm_fp_list **fplp) 


		if (fd < 0 || !(file = fget_raw(fd)))

			return -EBADF;

		/* don't allow io_uring files */

		if (io_uring_get_socket(file)) {

			fput(file);

			return -EINVAL;

		}

		*fpp++ = file;

		fpl->count++;

	}