133 /* Transport used for host->guest communication */
135 /* Transport used for guest->host communication */
137 /* Transport used for DGRAM communication */
139 /* Transport used for local communication */
408 	if (!vsk->transport)  in vsock_deassign_transport()
411 	vsk->transport->destruct(vsk);  in vsock_deassign_transport()
412 	module_put(vsk->transport->module);  in vsock_deassign_transport()
413 	vsk->transport = NULL;  in vsock_deassign_transport()
416 /* Assign a transport to a socket and call the .init transport callback.
421  * The vsk->remote_addr is used to decide which transport to use:
423  *    g2h is not loaded, will use local transport;
425  *    includes VMADDR_FLAG_TO_HOST flag value, will use guest->host transport;
426  *  - remote CID > VMADDR_CID_HOST will use host->guest transport;
468 	if (vsk->transport) {  in vsock_assign_transport()
469 		if (vsk->transport == new_transport)  in vsock_assign_transport()
472 		/* transport->release() must be called with sock lock acquired.  in vsock_assign_transport()
476 		 * any transport.  in vsock_assign_transport()
478 		vsk->transport->release(vsk);  in vsock_assign_transport()
482 	/* We increase the module refcnt to prevent the transport unloading  in vsock_assign_transport()
502 	vsk->transport = new_transport;  in vsock_assign_transport()
561 	if (!vsk->transport)  in vsock_send_shutdown()
564 	return vsk->transport->shutdown(vsk, mode);  in vsock_send_shutdown()
675 	return vsk->transport->dgram_bind(vsk, addr);  in __vsock_bind_dgram()
803 		if (vsk->transport)  in __vsock_release()
804 			vsk->transport->release(vsk);  in __vsock_release()
859 	return vsk->transport->stream_has_data(vsk);  in vsock_stream_has_data()
868 		return vsk->transport->seqpacket_has_data(vsk);  in vsock_connectible_has_data()
875 	return vsk->transport->stream_has_space(vsk);  in vsock_stream_has_space()
1046 		const struct vsock_transport *transport;  in vsock_poll()  local
1050 		transport = vsk->transport;  in vsock_poll()
1060 		if (transport && transport->stream_is_active(vsk) &&  in vsock_poll()
1063 			int ret = transport->notify_poll_in(  in vsock_poll()
1084 		if (transport && sk->sk_state == TCP_ESTABLISHED) {  in vsock_poll()
1087 				int ret = transport->notify_poll_out(  in vsock_poll()
1125 	const struct vsock_transport *transport;  in vsock_dgram_sendmsg()  local
1137 	transport = vsk->transport;  in vsock_dgram_sendmsg()
1155 			remote_addr->svm_cid = transport->get_local_cid();  in vsock_dgram_sendmsg()
1165 			remote_addr->svm_cid = transport->get_local_cid();  in vsock_dgram_sendmsg()
1179 	if (!transport->dgram_allow(remote_addr->svm_cid,  in vsock_dgram_sendmsg()
1185 	err = transport->dgram_enqueue(vsk, remote_addr, msg, len);  in vsock_dgram_sendmsg()
1220 	if (!vsk->transport->dgram_allow(remote_addr->svm_cid,  in vsock_dgram_connect()
1239 	return vsk->transport->dgram_dequeue(vsk, msg, len, flags);  in vsock_dgram_recvmsg()
1263 	const struct vsock_transport *transport = vsk->transport;  in vsock_transport_cancel_pkt()  local
1265 	if (!transport || !transport->cancel_pkt)  in vsock_transport_cancel_pkt()
1268 	return transport->cancel_pkt(vsk);  in vsock_transport_cancel_pkt()
1298 	const struct vsock_transport *transport;  in vsock_connect()  local
1341 		transport = vsk->transport;  in vsock_connect()
1346 		if (!transport ||  in vsock_connect()
1347 		    !transport->stream_allow(remote_addr->svm_cid,  in vsock_connect()
1359 		err = transport->connect(vsk);  in vsock_connect()
1548 				     const struct vsock_transport *transport,  in vsock_update_buffer_size()  argument
1558 	    transport && transport->notify_buffer_size)  in vsock_update_buffer_size()
1559 		transport->notify_buffer_size(vsk, &val);  in vsock_update_buffer_size()
1573 	const struct vsock_transport *transport;  in vsock_connectible_setsockopt()  local
1597 	transport = vsk->transport;  in vsock_connectible_setsockopt()
1602 		vsock_update_buffer_size(vsk, transport, val);  in vsock_connectible_setsockopt()
1608 		vsock_update_buffer_size(vsk, transport, vsk->buffer_size);  in vsock_connectible_setsockopt()
1614 		vsock_update_buffer_size(vsk, transport, vsk->buffer_size);  in vsock_connectible_setsockopt()
1722 	const struct vsock_transport *transport;  in vsock_connectible_sendmsg()  local
1739 	transport = vsk->transport;  in vsock_connectible_sendmsg()
1756 	if (!transport || sk->sk_state != TCP_ESTABLISHED ||  in vsock_connectible_sendmsg()
1770 	err = transport->notify_send_init(vsk, &send_data);  in vsock_connectible_sendmsg()
1790 			err = transport->notify_send_pre_block(vsk, &send_data);  in vsock_connectible_sendmsg()
1824 		err = transport->notify_send_pre_enqueue(vsk, &send_data);  in vsock_connectible_sendmsg()
1835 			written = transport->seqpacket_enqueue(vsk,  in vsock_connectible_sendmsg()
1838 			written = transport->stream_enqueue(vsk,  in vsock_connectible_sendmsg()
1848 		err = transport->notify_send_post_enqueue(  in vsock_connectible_sendmsg()
1875 	const struct vsock_transport *transport;  in vsock_connectible_wait_data()  local
1882 	transport = vsk->transport;  in vsock_connectible_wait_data()
1900 			err = transport->notify_recv_pre_block(vsk, target, recv_data);  in vsock_connectible_wait_data()
1923 	/* Internal transport error when checking for available  in vsock_connectible_wait_data()
1937 	const struct vsock_transport *transport;  in __vsock_stream_recvmsg()  local
1947 	transport = vsk->transport;  in __vsock_stream_recvmsg()
1956 	if (target >= transport->stream_rcvhiwat(vsk)) {  in __vsock_stream_recvmsg()
1963 	err = transport->notify_recv_init(vsk, target, &recv_data);  in __vsock_stream_recvmsg()
1976 		err = transport->notify_recv_pre_dequeue(vsk, target,  in __vsock_stream_recvmsg()
1981 		read = transport->stream_dequeue(vsk, msg, len - copied, flags);  in __vsock_stream_recvmsg()
1989 		err = transport->notify_recv_post_dequeue(vsk, target, read,  in __vsock_stream_recvmsg()
2015 	const struct vsock_transport *transport;  in __vsock_seqpacket_recvmsg()  local
2023 	transport = vsk->transport;  in __vsock_seqpacket_recvmsg()
2031 	msg_len = transport->seqpacket_dequeue(vsk, msg, flags);  in __vsock_seqpacket_recvmsg()
2068 	const struct vsock_transport *transport;  in vsock_connectible_recvmsg()  local
2079 	transport = vsk->transport;  in vsock_connectible_recvmsg()
2081 	if (!transport || sk->sk_state != TCP_ESTABLISHED) {  in vsock_connectible_recvmsg()
2325 	return vsk->transport;  in vsock_core_get_transport()