net/vmw_vsock/af_vsock.c

112 #include <net/sock.h>
116 static int __vsock_bind(struct sock *sk, struct sockaddr_vm *addr);
117 static void vsock_sk_destruct(struct sock *sk);
118 static int vsock_queue_rcv_skb(struct sock *sk, struct sk_buff *skb);
189 	struct sock *sk = sk_vsock(vsk);
235 static struct sock *__vsock_find_bound_socket(struct sockaddr_vm *addr)
252 static struct sock *__vsock_find_connected_socket(struct sockaddr_vm *src,
304 struct sock *vsock_find_bound_socket(struct sockaddr_vm *addr)
306 	struct sock *sk;
319 struct sock *vsock_find_connected_socket(struct sockaddr_vm *src,
322 	struct sock *sk;
343 				     void (*fn)(struct sock *sk))
364 void vsock_add_pending(struct sock *listener, struct sock *pending)
378 void vsock_remove_pending(struct sock *listener, struct sock *pending)
388 void vsock_enqueue_accept(struct sock *listener, struct sock *connected)
442 	struct sock *sk = sk_vsock(vsk);
483 		/* transport->release() must be called with sock lock acquired.
485 		 * have already held the sock lock. In the other cases, this
534 static struct sock *vsock_dequeue_accept(struct sock *listener)
556 static bool vsock_is_accept_queue_empty(struct sock *sk)
562 static bool vsock_is_pending(struct sock *sk)
568 static int vsock_send_shutdown(struct sock *sk, int mode)
580 	struct sock *sk;
581 	struct sock *listener;
688 static int __vsock_bind(struct sock *sk, struct sockaddr_vm *addr)
727 static struct sock *__vsock_create(struct net *net,
728 				   struct socket *sock,
729 				   struct sock *parent,
734 	struct sock *sk;
742 	sock_init_data(sock, sk);
744 	/* sk->sk_type is normally set in sock_init_data, but only if sock is
748 	if (!sock)
797 static void __vsock_release(struct sock *sk, int level)
800 		struct sock *pending;
834 static void vsock_sk_destruct(struct sock *sk)
849 static int vsock_queue_rcv_skb(struct sock *sk, struct sk_buff *skb)
860 struct sock *vsock_create_connected(struct sock *parent)
875 	struct sock *sk = sk_vsock(vsk);
890 void vsock_data_ready(struct sock *sk)
900 static int vsock_release(struct socket *sock)
902 	__vsock_release(sock->sk, 0);
903 	sock->sk = NULL;
904 	sock->state = SS_FREE;
910 vsock_bind(struct socket *sock, struct sockaddr *addr, int addr_len)
913 	struct sock *sk;
916 	sk = sock->sk;
928 static int vsock_getname(struct socket *sock,
932 	struct sock *sk;
936 	sk = sock->sk;
943 		if (sock->state != SS_CONNECTED) {
971 static int vsock_shutdown(struct socket *sock, int mode)
974 	struct sock *sk;
993 	sk = sock->sk;
996 	if (sock->state == SS_UNCONNECTED) {
1001 		sock->state = SS_DISCONNECTING;
1022 static __poll_t vsock_poll(struct file *file, struct socket *sock,
1025 	struct sock *sk;
1029 	sk = sock->sk;
1053 	if (sock->type == SOCK_DGRAM) {
1140 static int vsock_read_skb(struct sock *sk, skb_read_actor_t read_actor)
1147 static int vsock_dgram_sendmsg(struct socket *sock, struct msghdr *msg,
1151 	struct sock *sk;
1161 	sk = sock->sk;
1190 	} else if (sock->state == SS_CONNECTED) {
1221 static int vsock_dgram_connect(struct socket *sock,
1225 	struct sock *sk;
1229 	sk = sock->sk;
1237 		sock->state = SS_UNCONNECTED;
1256 	sock->state = SS_CONNECTED;
1258 	/* sock map disallows redirection of non-TCP sockets with sk_state !=
1273 int vsock_dgram_recvmsg(struct socket *sock, struct msghdr *msg,
1280 	struct sock *sk;
1282 	sk = sock->sk;
1326 	struct sock *sk;
1346 static int vsock_connect(struct socket *sock, struct sockaddr *addr,
1350 	struct sock *sk;
1358 	sk = sock->sk;
1364 	switch (sock->state) {
1372 		/* This continues on so we can move sock into the SS_CONNECTED
1430 		/* Mark sock as connecting and set the error code to in
1433 		sock->state = SS_CONNECTING;
1473 			sock->state = SS_UNCONNECTED;
1480 			sock->state = SS_UNCONNECTED;
1491 		sock->state = SS_UNCONNECTED;
1503 static int vsock_accept(struct socket *sock, struct socket *newsock, int flags,
1506 	struct sock *listener;
1508 	struct sock *connected;
1514 	listener = sock->sk;
1518 	if (!sock_type_connectible(sock->type)) {
1588 static int vsock_listen(struct socket *sock, int backlog)
1591 	struct sock *sk;
1594 	sk = sock->sk;
1603 	if (sock->state != SS_UNCONNECTED) {
1642 static int vsock_connectible_setsockopt(struct socket *sock,
1649 	struct sock *sk;
1670 	sk = sock->sk;
1682 			return sock_setsockopt(sock, level, optname, optval, optlen);
1756 static int vsock_connectible_getsockopt(struct socket *sock,
1761 	struct sock *sk = sock->sk;
1818 static int vsock_connectible_sendmsg(struct socket *sock, struct msghdr *msg,
1821 	struct sock *sk;
1830 	sk = sock->sk;
1980 static int vsock_connectible_wait_data(struct sock *sk,
2047 static int __vsock_stream_recvmsg(struct sock *sk, struct msghdr *msg,
2126 static int __vsock_seqpacket_recvmsg(struct sock *sk, struct msghdr *msg,
2177 vsock_connectible_recvmsg(struct socket *sock, struct msghdr *msg, size_t len,
2180 	struct sock *sk;
2188 	sk = sock->sk;
2255 static int vsock_set_rcvlowat(struct sock *sk, int val)
2322 static int vsock_create(struct net *net, struct socket *sock,
2326 	struct sock *sk;
2329 	if (!sock)
2335 	switch (sock->type) {
2337 		sock->ops = &vsock_dgram_ops;
2340 		sock->ops = &vsock_stream_ops;
2343 		sock->ops = &vsock_seqpacket_ops;
2349 	sock->state = SS_UNCONNECTED;
2351 	sk = __vsock_create(net, sock, NULL, GFP_KERNEL, 0, kern);
2357 	if (sock->type == SOCK_DGRAM) {
2368 	if (sock_type_connectible(sock->type))