Lines Matching refs:transport
336 void vsock_for_each_connected_socket(struct vsock_transport *transport,
347 if (vsk->transport != transport)
413 if (!vsk->transport)
416 vsk->transport->destruct(vsk);
417 module_put(vsk->transport->module);
418 vsk->transport = NULL;
421 /* Assign a transport to a socket and call the .init transport callback.
426 * The vsk->remote_addr is used to decide which transport to use:
428 * g2h is not loaded, will use local transport;
429 * - remote CID <= VMADDR_CID_HOST will use guest->host transport;
430 * - remote CID > VMADDR_CID_HOST will use host->guest transport;
455 if (vsk->transport) {
456 if (vsk->transport == new_transport)
459 /* transport->release() must be called with sock lock acquired.
463 * which is not assigned to any transport.
465 vsk->transport->release(vsk);
469 /* We increase the module refcnt to prevent the transport unloading
481 vsk->transport = new_transport;
540 if (!vsk->transport)
543 return vsk->transport->shutdown(vsk, mode);
653 return vsk->transport->dgram_bind(vsk, addr);
775 if (vsk->transport)
776 vsk->transport->release(vsk);
831 return vsk->transport->stream_has_data(vsk);
837 return vsk->transport->stream_has_space(vsk);
1008 const struct vsock_transport *transport;
1012 transport = vsk->transport;
1022 if (transport && transport->stream_is_active(vsk) &&
1025 int ret = transport->notify_poll_in(
1046 if (transport && sk->sk_state == TCP_ESTABLISHED) {
1049 int ret = transport->notify_poll_out(
1087 const struct vsock_transport *transport;
1099 transport = vsk->transport;
1117 remote_addr->svm_cid = transport->get_local_cid();
1127 remote_addr->svm_cid = transport->get_local_cid();
1141 if (!transport->dgram_allow(remote_addr->svm_cid,
1147 err = transport->dgram_enqueue(vsk, remote_addr, msg, len);
1182 if (!vsk->transport->dgram_allow(remote_addr->svm_cid,
1201 return vsk->transport->dgram_dequeue(vsk, msg, len, flags);
1225 const struct vsock_transport *transport = vsk->transport;
1227 if (!transport || !transport->cancel_pkt)
1230 return transport->cancel_pkt(vsk);
1261 const struct vsock_transport *transport;
1306 transport = vsk->transport;
1311 if (!transport ||
1312 !transport->stream_allow(remote_addr->svm_cid,
1324 err = transport->connect(vsk);
1521 const struct vsock_transport *transport,
1531 transport && transport->notify_buffer_size)
1532 transport->notify_buffer_size(vsk, &val);
1546 const struct vsock_transport *transport;
1570 transport = vsk->transport;
1575 vsock_update_buffer_size(vsk, transport, val);
1581 vsock_update_buffer_size(vsk, transport, vsk->buffer_size);
1587 vsock_update_buffer_size(vsk, transport, vsk->buffer_size);
1695 const struct vsock_transport *transport;
1712 transport = vsk->transport;
1727 if (!transport || sk->sk_state != TCP_ESTABLISHED ||
1741 err = transport->notify_send_init(vsk, &send_data);
1761 err = transport->notify_send_pre_block(vsk, &send_data);
1795 err = transport->notify_send_pre_enqueue(vsk, &send_data);
1805 written = transport->stream_enqueue(
1815 err = transport->notify_send_post_enqueue(
1837 const struct vsock_transport *transport;
1852 transport = vsk->transport;
1854 if (!transport || sk->sk_state != TCP_ESTABLISHED) {
1897 if (target >= transport->stream_rcvhiwat(vsk)) {
1904 err = transport->notify_recv_init(vsk, target, &recv_data);
1929 err = transport->notify_recv_pre_block(
1963 err = transport->notify_recv_pre_dequeue(
1968 read = transport->stream_dequeue(
1978 err = transport->notify_recv_post_dequeue(
2179 return vsk->transport;