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;
424  *  - remote CID <= VMADDR_CID_HOST will use guest->host transport;
425  *  - remote CID > VMADDR_CID_HOST will use host->guest transport;
450 	if (vsk->transport) {  in vsock_assign_transport()
451 		if (vsk->transport == new_transport)  in vsock_assign_transport()
454 		/* transport->release() must be called with sock lock acquired.  in vsock_assign_transport()
458 		 * which is not assigned to any transport.  in vsock_assign_transport()
460 		vsk->transport->release(vsk);  in vsock_assign_transport()
464 	/* We increase the module refcnt to prevent the transport unloading  in vsock_assign_transport()
476 	vsk->transport = new_transport;  in vsock_assign_transport()
535 	if (!vsk->transport)  in vsock_send_shutdown()
538 	return vsk->transport->shutdown(vsk, mode);  in vsock_send_shutdown()
648 	return vsk->transport->dgram_bind(vsk, addr);  in __vsock_bind_dgram()
770 		if (vsk->transport)  in __vsock_release()
771 			vsk->transport->release(vsk);  in __vsock_release()
826 	return vsk->transport->stream_has_data(vsk);  in vsock_stream_has_data()
832 	return vsk->transport->stream_has_space(vsk);  in vsock_stream_has_space()
1003 		const struct vsock_transport *transport;  in vsock_poll()  local
1007 		transport = vsk->transport;  in vsock_poll()
1017 		if (transport && transport->stream_is_active(vsk) &&  in vsock_poll()
1020 			int ret = transport->notify_poll_in(  in vsock_poll()
1041 		if (transport && sk->sk_state == TCP_ESTABLISHED) {  in vsock_poll()
1044 				int ret = transport->notify_poll_out(  in vsock_poll()
1082 	const struct vsock_transport *transport;  in vsock_dgram_sendmsg()  local
1094 	transport = vsk->transport;  in vsock_dgram_sendmsg()
1112 			remote_addr->svm_cid = transport->get_local_cid();  in vsock_dgram_sendmsg()
1122 			remote_addr->svm_cid = transport->get_local_cid();  in vsock_dgram_sendmsg()
1136 	if (!transport->dgram_allow(remote_addr->svm_cid,  in vsock_dgram_sendmsg()
1142 	err = transport->dgram_enqueue(vsk, remote_addr, msg, len);  in vsock_dgram_sendmsg()
1177 	if (!vsk->transport->dgram_allow(remote_addr->svm_cid,  in vsock_dgram_connect()
1196 	return vsk->transport->dgram_dequeue(vsk, msg, len, flags);  in vsock_dgram_recvmsg()
1220 	const struct vsock_transport *transport = vsk->transport;  in vsock_transport_cancel_pkt()  local
1222 	if (!transport || !transport->cancel_pkt)  in vsock_transport_cancel_pkt()
1225 	return transport->cancel_pkt(vsk);  in vsock_transport_cancel_pkt()
1256 	const struct vsock_transport *transport;  in vsock_stream_connect()  local
1301 		transport = vsk->transport;  in vsock_stream_connect()
1306 		if (!transport ||  in vsock_stream_connect()
1307 		    !transport->stream_allow(remote_addr->svm_cid,  in vsock_stream_connect()
1319 		err = transport->connect(vsk);  in vsock_stream_connect()
1516 				     const struct vsock_transport *transport,  in vsock_update_buffer_size()  argument
1526 	    transport && transport->notify_buffer_size)  in vsock_update_buffer_size()
1527 		transport->notify_buffer_size(vsk, &val);  in vsock_update_buffer_size()
1541 	const struct vsock_transport *transport;  in vsock_stream_setsockopt()  local
1565 	transport = vsk->transport;  in vsock_stream_setsockopt()
1570 		vsock_update_buffer_size(vsk, transport, val);  in vsock_stream_setsockopt()
1576 		vsock_update_buffer_size(vsk, transport, vsk->buffer_size);  in vsock_stream_setsockopt()
1582 		vsock_update_buffer_size(vsk, transport, vsk->buffer_size);  in vsock_stream_setsockopt()
1690 	const struct vsock_transport *transport;  in vsock_stream_sendmsg()  local
1707 	transport = vsk->transport;  in vsock_stream_sendmsg()
1722 	if (!transport || sk->sk_state != TCP_ESTABLISHED ||  in vsock_stream_sendmsg()
1736 	err = transport->notify_send_init(vsk, &send_data);  in vsock_stream_sendmsg()
1756 			err = transport->notify_send_pre_block(vsk, &send_data);  in vsock_stream_sendmsg()
1790 		err = transport->notify_send_pre_enqueue(vsk, &send_data);  in vsock_stream_sendmsg()
1800 		written = transport->stream_enqueue(  in vsock_stream_sendmsg()
1810 		err = transport->notify_send_post_enqueue(  in vsock_stream_sendmsg()
1832 	const struct vsock_transport *transport;  in vsock_stream_recvmsg()  local
1847 	transport = vsk->transport;  in vsock_stream_recvmsg()
1849 	if (!transport || sk->sk_state != TCP_ESTABLISHED) {  in vsock_stream_recvmsg()
1892 	if (target >= transport->stream_rcvhiwat(vsk)) {  in vsock_stream_recvmsg()
1899 	err = transport->notify_recv_init(vsk, target, &recv_data);  in vsock_stream_recvmsg()
1924 			err = transport->notify_recv_pre_block(  in vsock_stream_recvmsg()
1958 			err = transport->notify_recv_pre_dequeue(  in vsock_stream_recvmsg()
1963 			read = transport->stream_dequeue(  in vsock_stream_recvmsg()
1973 			err = transport->notify_recv_post_dequeue(  in vsock_stream_recvmsg()
2174 	return vsk->transport;  in vsock_core_get_transport()