Unverified Commit 0b1154c7 authored by openeuler-ci-bot's avatar openeuler-ci-bot Committed by Gitee
Browse files

!11648 vsock: fix recursive ->recvmsg calls 

Merge Pull Request from: @ci-robot 
 
PR sync from: Zhang Changzhong <zhangchangzhong@huawei.com>
https://mailweb.openeuler.org/hyperkitty/list/kernel@openeuler.org/message/IS7VYEXTJ7Z6IITUEADYMVNBUSZOXFE4/ 
 
https://gitee.com/src-openeuler/kernel/issues/IAOXZC 
 
Link:https://gitee.com/openeuler/kernel/pulls/11648

 

Reviewed-by: default avatarZhang Peng <zhangpeng362@huawei.com>
Signed-off-by: default avatarZhang Peng <zhangpeng362@huawei.com>
parents 734745d1 51b33086

include/net/af_vsock.h

+4 −0
Original line number Diff line number Diff line
@@ -227,8 +227,12 @@ struct vsock_tap { 
int vsock_add_tap(struct vsock_tap *vt);

int vsock_remove_tap(struct vsock_tap *vt);

void vsock_deliver_tap(struct sk_buff *build_skb(void *opaque), void *opaque);

int __vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len,

				int flags);

int vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len,

			      int flags);

int __vsock_dgram_recvmsg(struct socket *sock, struct msghdr *msg,

			  size_t len, int flags);

int vsock_dgram_recvmsg(struct socket *sock, struct msghdr *msg,

			size_t len, int flags);

net/vmw_vsock/af_vsock.c

+29 −21
Original line number Diff line number Diff line
@@ -1270,25 +1270,28 @@ static int vsock_dgram_connect(struct socket *sock, 
	return err;

}



int __vsock_dgram_recvmsg(struct socket *sock, struct msghdr *msg,

			  size_t len, int flags)

{

	struct sock *sk = sock->sk;

	struct vsock_sock *vsk = vsock_sk(sk);



	return vsk->transport->dgram_dequeue(vsk, msg, len, flags);

}



int vsock_dgram_recvmsg(struct socket *sock, struct msghdr *msg,

			size_t len, int flags)

{

#ifdef CONFIG_BPF_SYSCALL

	struct sock *sk = sock->sk;

	const struct proto *prot;

#endif

	struct vsock_sock *vsk;

	struct sock *sk;



	sk = sock->sk;

	vsk = vsock_sk(sk);



#ifdef CONFIG_BPF_SYSCALL

	prot = READ_ONCE(sk->sk_prot);

	if (prot != &vsock_proto)

		return prot->recvmsg(sk, msg, len, flags, NULL);

#endif



	return vsk->transport->dgram_dequeue(vsk, msg, len, flags);

	return __vsock_dgram_recvmsg(sock, msg, len, flags);

}

EXPORT_SYMBOL_GPL(vsock_dgram_recvmsg);
@@ -2124,15 +2127,12 @@ static int __vsock_seqpacket_recvmsg(struct sock *sk, struct msghdr *msg, 
}



int

vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len,

__vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len,

			    int flags)

{

	struct sock *sk;

	struct vsock_sock *vsk;

	const struct vsock_transport *transport;

#ifdef CONFIG_BPF_SYSCALL

	const struct proto *prot;

#endif

	int err;



	sk = sock->sk;
@@ -2183,14 +2183,6 @@ vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len, 
		goto out;

	}



#ifdef CONFIG_BPF_SYSCALL

	prot = READ_ONCE(sk->sk_prot);

	if (prot != &vsock_proto) {

		release_sock(sk);

		return prot->recvmsg(sk, msg, len, flags, NULL);

	}

#endif



	if (sk->sk_type == SOCK_STREAM)

		err = __vsock_stream_recvmsg(sk, msg, len, flags);

	else
@@ -2200,6 +2192,22 @@ vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len, 
	release_sock(sk);

	return err;

}



int

vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len,

			  int flags)

{

#ifdef CONFIG_BPF_SYSCALL

	struct sock *sk = sock->sk;

	const struct proto *prot;



	prot = READ_ONCE(sk->sk_prot);

	if (prot != &vsock_proto)

		return prot->recvmsg(sk, msg, len, flags, NULL);

#endif



	return __vsock_connectible_recvmsg(sock, msg, len, flags);

}

EXPORT_SYMBOL_GPL(vsock_connectible_recvmsg);



static int vsock_set_rcvlowat(struct sock *sk, int val)

net/vmw_vsock/vsock_bpf.c

+2 −2
Original line number Diff line number Diff line
@@ -64,9 +64,9 @@ static int __vsock_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int 
	int err;



	if (sk->sk_type == SOCK_STREAM || sk->sk_type == SOCK_SEQPACKET)

		err = vsock_connectible_recvmsg(sock, msg, len, flags);

		err = __vsock_connectible_recvmsg(sock, msg, len, flags);

	else if (sk->sk_type == SOCK_DGRAM)

		err = vsock_dgram_recvmsg(sock, msg, len, flags);

		err = __vsock_dgram_recvmsg(sock, msg, len, flags);

	else

		err = -EPROTOTYPE;