Lines Matching refs:transport
342 void vsock_for_each_connected_socket(struct vsock_transport *transport,
353 if (vsk->transport != transport)
419 if (!vsk->transport)
422 vsk->transport->destruct(vsk);
423 module_put(vsk->transport->module);
424 vsk->transport = NULL;
427 /* Assign a transport to a socket and call the .init transport callback.
432 * The vsk->remote_addr is used to decide which transport to use:
434 * g2h is not loaded, will use local transport;
436 * includes VMADDR_FLAG_TO_HOST flag value, will use guest->host transport;
437 * - remote CID > VMADDR_CID_HOST will use host->guest transport;
479 if (vsk->transport) {
480 if (vsk->transport == new_transport)
483 /* transport->release() must be called with sock lock acquired.
487 * any transport.
489 vsk->transport->release(vsk);
493 /* We increase the module refcnt to prevent the transport unloading
513 vsk->transport = new_transport;
572 if (!vsk->transport)
575 return vsk->transport->shutdown(vsk, mode);
685 return vsk->transport->dgram_bind(vsk, addr);
813 if (vsk->transport)
814 vsk->transport->release(vsk);
869 return vsk->transport->stream_has_data(vsk);
878 return vsk->transport->seqpacket_has_data(vsk);
886 return vsk->transport->stream_has_space(vsk);
1067 const struct vsock_transport *transport;
1071 transport = vsk->transport;
1081 if (transport && transport->stream_is_active(vsk) &&
1085 int ret = transport->notify_poll_in(
1106 if (transport && sk->sk_state == TCP_ESTABLISHED) {
1109 int ret = transport->notify_poll_out(
1144 return vsk->transport->read_skb(vsk, read_actor);
1154 const struct vsock_transport *transport;
1166 transport = vsk->transport;
1184 remote_addr->svm_cid = transport->get_local_cid();
1194 remote_addr->svm_cid = transport->get_local_cid();
1208 if (!transport->dgram_allow(remote_addr->svm_cid,
1214 err = transport->dgram_enqueue(vsk, remote_addr, msg, len);
1249 if (!vsk->transport->dgram_allow(remote_addr->svm_cid,
1291 return vsk->transport->dgram_dequeue(vsk, msg, len, flags);
1316 const struct vsock_transport *transport = vsk->transport;
1318 if (!transport || !transport->cancel_pkt)
1321 return transport->cancel_pkt(vsk);
1352 const struct vsock_transport *transport;
1397 transport = vsk->transport;
1402 if (!transport ||
1403 !transport->stream_allow(remote_addr->svm_cid,
1415 err = transport->connect(vsk);
1612 const struct vsock_transport *transport,
1622 transport && transport->notify_buffer_size)
1623 transport->notify_buffer_size(vsk, &val);
1637 const struct vsock_transport *transport;
1661 transport = vsk->transport;
1666 vsock_update_buffer_size(vsk, transport, val);
1672 vsock_update_buffer_size(vsk, transport, vsk->buffer_size);
1678 vsock_update_buffer_size(vsk, transport, vsk->buffer_size);
1782 const struct vsock_transport *transport;
1799 transport = vsk->transport;
1816 if (!transport || sk->sk_state != TCP_ESTABLISHED ||
1830 err = transport->notify_send_init(vsk, &send_data);
1850 err = transport->notify_send_pre_block(vsk, &send_data);
1884 err = transport->notify_send_pre_enqueue(vsk, &send_data);
1895 written = transport->seqpacket_enqueue(vsk,
1898 written = transport->stream_enqueue(vsk,
1909 err = transport->notify_send_post_enqueue(
1936 const struct vsock_transport *transport;
1943 transport = vsk->transport;
1964 err = transport->notify_recv_pre_block(vsk, target, recv_data);
1987 /* Internal transport error when checking for available
2001 const struct vsock_transport *transport;
2011 transport = vsk->transport;
2020 if (target >= transport->stream_rcvhiwat(vsk)) {
2027 err = transport->notify_recv_init(vsk, target, &recv_data);
2040 err = transport->notify_recv_pre_dequeue(vsk, target,
2045 read = transport->stream_dequeue(vsk, msg, len - copied, flags);
2053 err = transport->notify_recv_post_dequeue(vsk, target, read,
2079 const struct vsock_transport *transport;
2087 transport = vsk->transport;
2095 msg_len = transport->seqpacket_dequeue(vsk, msg, flags);
2132 const struct vsock_transport *transport;
2148 transport = vsk->transport;
2150 if (!transport || sk->sk_state != TCP_ESTABLISHED) {
2207 const struct vsock_transport *transport;
2215 transport = vsk->transport;
2217 if (transport && transport->notify_set_rcvlowat) {
2220 err = transport->notify_set_rcvlowat(vsk, val);
2430 return vsk->transport;