48 static int vmci_transport_recv_listen(struct sock *sk,
51 					struct sock *sk,
55 					struct sock *sk,
58 					struct sock *sk,
61 					struct sock *sk,
63 static int vmci_transport_recv_connected(struct sock *sk,
67 static bool vmci_transport_proto_to_notify_struct(struct sock *sk, u16 *proto,
72 	struct sock *sk;  member
276 vmci_transport_send_control_pkt(struct sock *sk,  in vmci_transport_send_control_pkt()  argument
288 	vsk = vsock_sk(sk);  in vmci_transport_send_control_pkt()
321 static int vmci_transport_send_reset(struct sock *sk,  in vmci_transport_send_reset()  argument
326 	return vmci_transport_send_control_pkt(sk,  in vmci_transport_send_reset()
332 static int vmci_transport_send_negotiate(struct sock *sk, size_t size)  in vmci_transport_send_negotiate()  argument
335 					sk,  in vmci_transport_send_negotiate()
342 static int vmci_transport_send_negotiate2(struct sock *sk, size_t size,  in vmci_transport_send_negotiate2()  argument
346 					sk,  in vmci_transport_send_negotiate2()
352 static int vmci_transport_send_qp_offer(struct sock *sk,  in vmci_transport_send_qp_offer()  argument
356 					sk, VMCI_TRANSPORT_PACKET_TYPE_OFFER, 0,  in vmci_transport_send_qp_offer()
361 static int vmci_transport_send_attach(struct sock *sk,  in vmci_transport_send_attach()  argument
365 					sk, VMCI_TRANSPORT_PACKET_TYPE_ATTACH,  in vmci_transport_send_attach()
406 int vmci_transport_send_wrote(struct sock *sk)  in vmci_transport_send_wrote()  argument
409 					sk, VMCI_TRANSPORT_PACKET_TYPE_WROTE, 0,  in vmci_transport_send_wrote()
414 int vmci_transport_send_read(struct sock *sk)  in vmci_transport_send_read()  argument
417 					sk, VMCI_TRANSPORT_PACKET_TYPE_READ, 0,  in vmci_transport_send_read()
422 int vmci_transport_send_waiting_write(struct sock *sk,  in vmci_transport_send_waiting_write()  argument
426 				sk, VMCI_TRANSPORT_PACKET_TYPE_WAITING_WRITE,  in vmci_transport_send_waiting_write()
431 int vmci_transport_send_waiting_read(struct sock *sk,  in vmci_transport_send_waiting_read()  argument
435 				sk, VMCI_TRANSPORT_PACKET_TYPE_WAITING_READ,  in vmci_transport_send_waiting_read()
443 					&vsk->sk,  in vmci_transport_shutdown()
450 static int vmci_transport_send_conn_request(struct sock *sk, size_t size)  in vmci_transport_send_conn_request()  argument
452 	return vmci_transport_send_control_pkt(sk,  in vmci_transport_send_conn_request()
459 static int vmci_transport_send_conn_request2(struct sock *sk, size_t size,  in vmci_transport_send_conn_request2()  argument
463 					sk, VMCI_TRANSPORT_PACKET_TYPE_REQUEST2,  in vmci_transport_send_conn_request2()
604 	struct sock *sk;  in vmci_transport_recv_dgram_cb()  local
609 	sk = (struct sock *)data;  in vmci_transport_recv_dgram_cb()
620 	vsk = vsock_sk(sk);  in vmci_transport_recv_dgram_cb()
632 	sock_hold(sk);  in vmci_transport_recv_dgram_cb()
635 	sk_receive_skb(sk, skb, 0);  in vmci_transport_recv_dgram_cb()
664 	struct sock *sk;  in vmci_transport_recv_stream_cb()  local
672 	sk = NULL;  in vmci_transport_recv_stream_cb()
697 	sk = vsock_find_connected_socket(&src, &dst);  in vmci_transport_recv_stream_cb()
698 	if (!sk) {  in vmci_transport_recv_stream_cb()
699 		sk = vsock_find_bound_socket(&dst);  in vmci_transport_recv_stream_cb()
700 		if (!sk) {  in vmci_transport_recv_stream_cb()
737 	vsk = vsock_sk(sk);  in vmci_transport_recv_stream_cb()
748 	bh_lock_sock(sk);  in vmci_transport_recv_stream_cb()
750 	if (!sock_owned_by_user(sk)) {  in vmci_transport_recv_stream_cb()
754 		if (sk->sk_state == SS_CONNECTED)  in vmci_transport_recv_stream_cb()
756 					sk, pkt, true, &dst, &src,  in vmci_transport_recv_stream_cb()
760 	bh_unlock_sock(sk);  in vmci_transport_recv_stream_cb()
774 		recv_pkt_info->sk = sk;  in vmci_transport_recv_stream_cb()
784 		sk = NULL;  in vmci_transport_recv_stream_cb()
788 	if (sk)  in vmci_transport_recv_stream_cb()
789 		sock_put(sk);  in vmci_transport_recv_stream_cb()
794 static void vmci_transport_handle_detach(struct sock *sk)  in vmci_transport_handle_detach()  argument
798 	vsk = vsock_sk(sk);  in vmci_transport_handle_detach()
800 		sock_set_flag(sk, SOCK_DONE);  in vmci_transport_handle_detach()
812 			if (sk->sk_state == SS_CONNECTING) {  in vmci_transport_handle_detach()
821 				sk->sk_state = SS_UNCONNECTED;  in vmci_transport_handle_detach()
822 				sk->sk_err = ECONNRESET;  in vmci_transport_handle_detach()
823 				sk->sk_error_report(sk);  in vmci_transport_handle_detach()
826 			sk->sk_state = SS_UNCONNECTED;  in vmci_transport_handle_detach()
828 		sk->sk_state_change(sk);  in vmci_transport_handle_detach()
855 	if (!trans->sk)  in vmci_transport_peer_detach_cb()
861 	bh_lock_sock(trans->sk);  in vmci_transport_peer_detach_cb()
863 	vmci_transport_handle_detach(trans->sk);  in vmci_transport_peer_detach_cb()
865 	bh_unlock_sock(trans->sk);  in vmci_transport_peer_detach_cb()
881 	struct sock *sk;  in vmci_transport_recv_pkt_work()  local
885 	sk = recv_pkt_info->sk;  in vmci_transport_recv_pkt_work()
888 	lock_sock(sk);  in vmci_transport_recv_pkt_work()
891 	vsock_sk(sk)->local_addr.svm_cid = pkt->dg.dst.context;  in vmci_transport_recv_pkt_work()
893 	switch (sk->sk_state) {  in vmci_transport_recv_pkt_work()
895 		vmci_transport_recv_listen(sk, pkt);  in vmci_transport_recv_pkt_work()
902 		vmci_transport_recv_connecting_client(sk, pkt);  in vmci_transport_recv_pkt_work()
905 		vmci_transport_recv_connected(sk, pkt);  in vmci_transport_recv_pkt_work()
914 		vmci_transport_send_reset(sk, pkt);  in vmci_transport_recv_pkt_work()
918 	release_sock(sk);  in vmci_transport_recv_pkt_work()
923 	sock_put(sk);  in vmci_transport_recv_pkt_work()
926 static int vmci_transport_recv_listen(struct sock *sk,  in vmci_transport_recv_listen()  argument
945 	pending = vmci_transport_get_pending(sk, pkt);  in vmci_transport_recv_listen()
954 			err = vmci_transport_recv_connecting_server(sk,  in vmci_transport_recv_listen()
964 			vsock_remove_pending(sk, pending);  in vmci_transport_recv_listen()
991 	if (sk->sk_ack_backlog >= sk->sk_max_ack_backlog) {  in vmci_transport_recv_listen()
996 	pending = __vsock_create(sock_net(sk), NULL, sk, GFP_KERNEL,  in vmci_transport_recv_listen()
997 				 sk->sk_type, 0);  in vmci_transport_recv_listen()
999 		vmci_transport_send_reset(sk, pkt);  in vmci_transport_recv_listen()
1074 		vmci_transport_send_reset(sk, pkt);  in vmci_transport_recv_listen()
1080 	vsock_add_pending(sk, pending);  in vmci_transport_recv_listen()
1081 	sk->sk_ack_backlog++;  in vmci_transport_recv_listen()
1099 	vpending->listener = sk;  in vmci_transport_recv_listen()
1100 	sock_hold(sk);  in vmci_transport_recv_listen()
1257 vmci_transport_recv_connecting_client(struct sock *sk,  in vmci_transport_recv_connecting_client()  argument
1264 	vsk = vsock_sk(sk);  in vmci_transport_recv_connecting_client()
1281 		sk->sk_state = SS_CONNECTED;  in vmci_transport_recv_connecting_client()
1282 		sk->sk_socket->state = SS_CONNECTED;  in vmci_transport_recv_connecting_client()
1284 		sk->sk_state_change(sk);  in vmci_transport_recv_connecting_client()
1303 		err = vmci_transport_recv_connecting_client_negotiate(sk, pkt);  in vmci_transport_recv_connecting_client()
1311 		err = vmci_transport_recv_connecting_client_invalid(sk, pkt);  in vmci_transport_recv_connecting_client()
1347 	vmci_transport_send_reset(sk, pkt);  in vmci_transport_recv_connecting_client()
1349 	sk->sk_state = SS_UNCONNECTED;  in vmci_transport_recv_connecting_client()
1350 	sk->sk_err = skerr;  in vmci_transport_recv_connecting_client()
1351 	sk->sk_error_report(sk);  in vmci_transport_recv_connecting_client()
1356 					struct sock *sk,  in vmci_transport_recv_connecting_client_negotiate()  argument
1370 	vsk = vsock_sk(sk);  in vmci_transport_recv_connecting_client_negotiate()
1411 	if (!vmci_transport_proto_to_notify_struct(sk, &version, old_proto)) {  in vmci_transport_recv_connecting_client_negotiate()
1448 	err = vmci_transport_send_qp_offer(sk, handle);  in vmci_transport_recv_connecting_client_negotiate()
1462 	vmci_trans(vsk)->notify_ops->process_negotiate(sk);  in vmci_transport_recv_connecting_client_negotiate()
1477 vmci_transport_recv_connecting_client_invalid(struct sock *sk,  in vmci_transport_recv_connecting_client_invalid()  argument
1481 	struct vsock_sock *vsk = vsock_sk(sk);  in vmci_transport_recv_connecting_client_invalid()
1488 			sk, vmci_trans(vsk)->queue_pair_size);  in vmci_transport_recv_connecting_client_invalid()
1499 static int vmci_transport_recv_connected(struct sock *sk,  in vmci_transport_recv_connected()  argument
1516 			vsk = vsock_sk(sk);  in vmci_transport_recv_connected()
1519 			sk->sk_state_change(sk);  in vmci_transport_recv_connected()
1524 		vsk = vsock_sk(sk);  in vmci_transport_recv_connected()
1534 		sock_set_flag(sk, SOCK_DONE);  in vmci_transport_recv_connected()
1537 			sk->sk_state = SS_DISCONNECTING;  in vmci_transport_recv_connected()
1539 		sk->sk_state_change(sk);  in vmci_transport_recv_connected()
1543 		vsk = vsock_sk(sk);  in vmci_transport_recv_connected()
1545 				sk, pkt, false, NULL, NULL,  in vmci_transport_recv_connected()
1570 	vmci_trans(vsk)->sk = &vsk->sk;  in vmci_transport_socket_init()
1631 	vmci_trans(vsk)->sk = NULL;  in vmci_transport_destruct()
1674 						 &vsk->sk,  in vmci_transport_dgram_bind()
1737 	skb = skb_recv_datagram(&vsk->sk, flags, noblock, &err);  in vmci_transport_dgram_dequeue()
1775 	skb_free_datagram(&vsk->sk, skb);  in vmci_transport_dgram_dequeue()
1795 	struct sock *sk = &vsk->sk;  in vmci_transport_connect()  local
1800 			sk, vmci_trans(vsk)->queue_pair_size);  in vmci_transport_connect()
1802 			sk->sk_state = SS_UNCONNECTED;  in vmci_transport_connect()
1809 				sk, vmci_trans(vsk)->queue_pair_size,  in vmci_transport_connect()
1812 			sk->sk_state = SS_UNCONNECTED;  in vmci_transport_connect()
1908 			&vsk->sk, target, data_ready_now);  in vmci_transport_notify_poll_in()
1917 			&vsk->sk, target, space_available_now);  in vmci_transport_notify_poll_out()
1926 			&vsk->sk, target,  in vmci_transport_notify_recv_init()
1936 			&vsk->sk, target,  in vmci_transport_notify_recv_pre_block()
1946 			&vsk->sk, target,  in vmci_transport_notify_recv_pre_dequeue()
1958 			&vsk->sk, target, copied, data_read,  in vmci_transport_notify_recv_post_dequeue()
1967 			&vsk->sk,  in vmci_transport_notify_send_init()
1976 			&vsk->sk,  in vmci_transport_notify_send_pre_block()
1985 			&vsk->sk,  in vmci_transport_notify_send_pre_enqueue()
1995 			&vsk->sk, written,  in vmci_transport_notify_send_post_enqueue()
2014 static bool vmci_transport_proto_to_notify_struct(struct sock *sk,  in vmci_transport_proto_to_notify_struct()  argument
2018 	struct vsock_sock *vsk = vsock_sk(sk);  in vmci_transport_proto_to_notify_struct()
2040 	vmci_trans(vsk)->notify_ops->socket_init(sk);  in vmci_transport_proto_to_notify_struct()