348 void vsock_for_each_connected_socket(struct vsock_transport *transport,  in vsock_for_each_connected_socket()  argument
359 			if (vsk->transport != transport)  in vsock_for_each_connected_socket()
427 	if (!vsk->transport)  in vsock_deassign_transport()
430 	vsk->transport->destruct(vsk);  in vsock_deassign_transport()
431 	module_put(vsk->transport->module);  in vsock_deassign_transport()
432 	vsk->transport = NULL;  in vsock_deassign_transport()
490 	if (vsk->transport) {  in vsock_assign_transport()
491 		if (vsk->transport == new_transport) {  in vsock_assign_transport()
502 		vsk->transport->release(vsk);  in vsock_assign_transport()
543 	vsk->transport = new_transport;  in vsock_assign_transport()
556 static u32 vsock_registered_transport_cid(const struct vsock_transport **transport)  in vsock_registered_transport_cid()  argument
561 	if (*transport)  in vsock_registered_transport_cid()
562 		cid = (*transport)->get_local_cid();  in vsock_registered_transport_cid()
621 	if (!vsk->transport)  in vsock_send_shutdown()
624 	return vsk->transport->shutdown(vsk, mode);  in vsock_send_shutdown()
734 	return vsk->transport->dgram_bind(vsk, addr);  in __vsock_bind_dgram()
868 	if (vsk->transport)  in __vsock_release()
869 		vsk->transport->release(vsk);  in __vsock_release()
926 	if (WARN_ON(!vsk->transport))  in vsock_stream_has_data()
929 	return vsk->transport->stream_has_data(vsk);  in vsock_stream_has_data()
937 	if (WARN_ON(!vsk->transport))  in vsock_connectible_has_data()
941 		return vsk->transport->seqpacket_has_data(vsk);  in vsock_connectible_has_data()
949 	if (WARN_ON(!vsk->transport))  in vsock_stream_has_space()
952 	return vsk->transport->stream_has_space(vsk);  in vsock_stream_has_space()
1063 	unsent = vsk->transport->unsent_bytes;  in vsock_linger()
1177 		const struct vsock_transport *transport;  in vsock_poll()  local
1181 		transport = vsk->transport;  in vsock_poll()
1191 		if (transport && transport->stream_is_active(vsk) &&  in vsock_poll()
1195 			int ret = transport->notify_poll_in(  in vsock_poll()
1216 		if (transport && sk->sk_state == TCP_ESTABLISHED) {  in vsock_poll()
1219 				int ret = transport->notify_poll_out(  in vsock_poll()
1254 	if (WARN_ON_ONCE(!vsk->transport))  in vsock_read_skb()
1257 	return vsk->transport->read_skb(vsk, read_actor);  in vsock_read_skb()
1267 	const struct vsock_transport *transport;  in vsock_dgram_sendmsg()  local
1279 	transport = vsk->transport;  in vsock_dgram_sendmsg()
1297 			remote_addr->svm_cid = transport->get_local_cid();  in vsock_dgram_sendmsg()
1307 			remote_addr->svm_cid = transport->get_local_cid();  in vsock_dgram_sendmsg()
1321 	if (!transport->dgram_allow(remote_addr->svm_cid,  in vsock_dgram_sendmsg()
1327 	err = transport->dgram_enqueue(vsk, remote_addr, msg, len);  in vsock_dgram_sendmsg()
1362 	if (!vsk->transport->dgram_allow(remote_addr->svm_cid,  in vsock_dgram_connect()
1392 	return vsk->transport->dgram_dequeue(vsk, msg, len, flags);  in __vsock_dgram_recvmsg()
1424 		if (!vsk->transport) {  in vsock_do_ioctl()
1446 		if (!vsk->transport || !vsk->transport->unsent_bytes) {  in vsock_do_ioctl()
1456 		n_bytes = vsk->transport->unsent_bytes(vsk);  in vsock_do_ioctl()
1505 	const struct vsock_transport *transport = vsk->transport;  in vsock_transport_cancel_pkt()  local
1507 	if (!transport || !transport->cancel_pkt)  in vsock_transport_cancel_pkt()
1510 	return transport->cancel_pkt(vsk);  in vsock_transport_cancel_pkt()
1541 	const struct vsock_transport *transport;  in vsock_connect()  local
1586 		transport = vsk->transport;  in vsock_connect()
1591 		if (!transport ||  in vsock_connect()
1592 		    !transport->stream_allow(remote_addr->svm_cid,  in vsock_connect()
1598 		if (vsock_msgzerocopy_allow(transport)) {  in vsock_connect()
1615 		err = transport->connect(vsk);  in vsock_connect()
1772 			if (vsock_msgzerocopy_allow(vconnected->transport))  in vsock_accept()
1824 				     const struct vsock_transport *transport,  in vsock_update_buffer_size()  argument
1834 	    transport && transport->notify_buffer_size)  in vsock_update_buffer_size()
1835 		transport->notify_buffer_size(vsk, &val);  in vsock_update_buffer_size()
1849 	const struct vsock_transport *transport;  in vsock_connectible_setsockopt()  local
1873 	transport = vsk->transport;  in vsock_connectible_setsockopt()
1893 		if (transport && !vsock_msgzerocopy_allow(transport)) {  in vsock_connectible_setsockopt()
1905 		vsock_update_buffer_size(vsk, transport, val);  in vsock_connectible_setsockopt()
1911 		vsock_update_buffer_size(vsk, transport, vsk->buffer_size);  in vsock_connectible_setsockopt()
1917 		vsock_update_buffer_size(vsk, transport, vsk->buffer_size);  in vsock_connectible_setsockopt()
2021 	const struct vsock_transport *transport;  in vsock_connectible_sendmsg()  local
2038 	transport = vsk->transport;  in vsock_connectible_sendmsg()
2055 	if (!transport || sk->sk_state != TCP_ESTABLISHED ||  in vsock_connectible_sendmsg()
2067 	    !vsock_msgzerocopy_allow(transport)) {  in vsock_connectible_sendmsg()
2075 	err = transport->notify_send_init(vsk, &send_data);  in vsock_connectible_sendmsg()
2095 			err = transport->notify_send_pre_block(vsk, &send_data);  in vsock_connectible_sendmsg()
2129 		err = transport->notify_send_pre_enqueue(vsk, &send_data);  in vsock_connectible_sendmsg()
2140 			written = transport->seqpacket_enqueue(vsk,  in vsock_connectible_sendmsg()
2143 			written = transport->stream_enqueue(vsk,  in vsock_connectible_sendmsg()
2154 		err = transport->notify_send_post_enqueue(  in vsock_connectible_sendmsg()
2184 	const struct vsock_transport *transport;  in vsock_connectible_wait_data()  local
2191 	transport = vsk->transport;  in vsock_connectible_wait_data()
2212 			err = transport->notify_recv_pre_block(vsk, target, recv_data);  in vsock_connectible_wait_data()
2249 	const struct vsock_transport *transport;  in __vsock_stream_recvmsg()  local
2259 	transport = vsk->transport;  in __vsock_stream_recvmsg()
2268 	if (target >= transport->stream_rcvhiwat(vsk)) {  in __vsock_stream_recvmsg()
2275 	err = transport->notify_recv_init(vsk, target, &recv_data);  in __vsock_stream_recvmsg()
2288 		err = transport->notify_recv_pre_dequeue(vsk, target,  in __vsock_stream_recvmsg()
2293 		read = transport->stream_dequeue(vsk, msg, len - copied, flags);  in __vsock_stream_recvmsg()
2301 		err = transport->notify_recv_post_dequeue(vsk, target, read,  in __vsock_stream_recvmsg()
2327 	const struct vsock_transport *transport;  in __vsock_seqpacket_recvmsg()  local
2335 	transport = vsk->transport;  in __vsock_seqpacket_recvmsg()
2343 	msg_len = transport->seqpacket_dequeue(vsk, msg, flags);  in __vsock_seqpacket_recvmsg()
2380 	const struct vsock_transport *transport;  in __vsock_connectible_recvmsg()  local
2393 	transport = vsk->transport;  in __vsock_connectible_recvmsg()
2395 	if (!transport || sk->sk_state != TCP_ESTABLISHED) {  in __vsock_connectible_recvmsg()
2460 	const struct vsock_transport *transport;  in vsock_set_rcvlowat()  local
2468 	transport = vsk->transport;  in vsock_set_rcvlowat()
2470 	if (transport && transport->notify_set_rcvlowat) {  in vsock_set_rcvlowat()
2473 		err = transport->notify_set_rcvlowat(vsk, val);  in vsock_set_rcvlowat()
2691 	return vsk->transport;  in vsock_core_get_transport()