1/* SPDX-License-Identifier: GPL-2.0 */
2#ifndef _LINUX_VIRTIO_VSOCK_H
3#define _LINUX_VIRTIO_VSOCK_H
4
5#include <uapi/linux/virtio_vsock.h>
6#include <linux/socket.h>
7#include <net/sock.h>
8#include <net/af_vsock.h>
9
10#define VIRTIO_VSOCK_SKB_HEADROOM (sizeof(struct virtio_vsock_hdr))
11
12struct virtio_vsock_skb_cb {
13 bool reply;
14 bool tap_delivered;
15 u32 offset;
16};
17
18#define VIRTIO_VSOCK_SKB_CB(skb) ((struct virtio_vsock_skb_cb *)((skb)->cb))
19
20static inline struct virtio_vsock_hdr *virtio_vsock_hdr(struct sk_buff *skb)
21{
22 return (struct virtio_vsock_hdr *)skb->head;
23}
24
25static inline bool virtio_vsock_skb_reply(struct sk_buff *skb)
26{
27 return VIRTIO_VSOCK_SKB_CB(skb)->reply;
28}
29
30static inline void virtio_vsock_skb_set_reply(struct sk_buff *skb)
31{
32 VIRTIO_VSOCK_SKB_CB(skb)->reply = true;
33}
34
35static inline bool virtio_vsock_skb_tap_delivered(struct sk_buff *skb)
36{
37 return VIRTIO_VSOCK_SKB_CB(skb)->tap_delivered;
38}
39
40static inline void virtio_vsock_skb_set_tap_delivered(struct sk_buff *skb)
41{
42 VIRTIO_VSOCK_SKB_CB(skb)->tap_delivered = true;
43}
44
45static inline void virtio_vsock_skb_clear_tap_delivered(struct sk_buff *skb)
46{
47 VIRTIO_VSOCK_SKB_CB(skb)->tap_delivered = false;
48}
49
50static inline void virtio_vsock_skb_rx_put(struct sk_buff *skb)
51{
52 u32 len;
53
54 len = le32_to_cpu(virtio_vsock_hdr(skb)->len);
55
56 if (len > 0)
57 skb_put(skb, len);
58}
59
60static inline struct sk_buff *virtio_vsock_alloc_skb(unsigned int size, gfp_t mask)
61{
62 struct sk_buff *skb;
63
64 if (size < VIRTIO_VSOCK_SKB_HEADROOM)
65 return NULL;
66
67 skb = alloc_skb(size, priority: mask);
68 if (!skb)
69 return NULL;
70
71 skb_reserve(skb, VIRTIO_VSOCK_SKB_HEADROOM);
72 return skb;
73}
74
75static inline void
76virtio_vsock_skb_queue_head(struct sk_buff_head *list, struct sk_buff *skb)
77{
78 spin_lock_bh(lock: &list->lock);
79 __skb_queue_head(list, newsk: skb);
80 spin_unlock_bh(lock: &list->lock);
81}
82
83static inline void
84virtio_vsock_skb_queue_tail(struct sk_buff_head *list, struct sk_buff *skb)
85{
86 spin_lock_bh(lock: &list->lock);
87 __skb_queue_tail(list, newsk: skb);
88 spin_unlock_bh(lock: &list->lock);
89}
90
91static inline struct sk_buff *virtio_vsock_skb_dequeue(struct sk_buff_head *list)
92{
93 struct sk_buff *skb;
94
95 spin_lock_bh(lock: &list->lock);
96 skb = __skb_dequeue(list);
97 spin_unlock_bh(lock: &list->lock);
98
99 return skb;
100}
101
102static inline void virtio_vsock_skb_queue_purge(struct sk_buff_head *list)
103{
104 spin_lock_bh(lock: &list->lock);
105 __skb_queue_purge(list);
106 spin_unlock_bh(lock: &list->lock);
107}
108
109static inline size_t virtio_vsock_skb_len(struct sk_buff *skb)
110{
111 return (size_t)(skb_end_pointer(skb) - skb->head);
112}
113
114#define VIRTIO_VSOCK_DEFAULT_RX_BUF_SIZE (1024 * 4)
115#define VIRTIO_VSOCK_MAX_BUF_SIZE 0xFFFFFFFFUL
116#define VIRTIO_VSOCK_MAX_PKT_BUF_SIZE (1024 * 64)
117
118enum {
119 VSOCK_VQ_RX = 0, /* for host to guest data */
120 VSOCK_VQ_TX = 1, /* for guest to host data */
121 VSOCK_VQ_EVENT = 2,
122 VSOCK_VQ_MAX = 3,
123};
124
125/* Per-socket state (accessed via vsk->trans) */
126struct virtio_vsock_sock {
127 struct vsock_sock *vsk;
128
129 spinlock_t tx_lock;
130 spinlock_t rx_lock;
131
132 /* Protected by tx_lock */
133 u32 tx_cnt;
134 u32 peer_fwd_cnt;
135 u32 peer_buf_alloc;
136 size_t bytes_unsent;
137
138 /* Protected by rx_lock */
139 u32 fwd_cnt;
140 u32 last_fwd_cnt;
141 u32 rx_bytes;
142 u32 buf_alloc;
143 u32 buf_used;
144 struct sk_buff_head rx_queue;
145 u32 msg_count;
146};
147
148struct virtio_vsock_pkt_info {
149 u32 remote_cid, remote_port;
150 struct vsock_sock *vsk;
151 struct msghdr *msg;
152 u32 pkt_len;
153 u16 type;
154 u16 op;
155 u32 flags;
156 bool reply;
157};
158
159struct virtio_transport {
160 /* This must be the first field */
161 struct vsock_transport transport;
162
163 /* Takes ownership of the packet */
164 int (*send_pkt)(struct sk_buff *skb);
165
166 /* Used in MSG_ZEROCOPY mode. Checks, that provided data
167 * (number of buffers) could be transmitted with zerocopy
168 * mode. If this callback is not implemented for the current
169 * transport - this means that this transport doesn't need
170 * extra checks and can perform zerocopy transmission by
171 * default.
172 */
173 bool (*can_msgzerocopy)(int bufs_num);
174};
175
176ssize_t
177virtio_transport_stream_dequeue(struct vsock_sock *vsk,
178 struct msghdr *msg,
179 size_t len,
180 int type);
181int
182virtio_transport_dgram_dequeue(struct vsock_sock *vsk,
183 struct msghdr *msg,
184 size_t len, int flags);
185
186int
187virtio_transport_seqpacket_enqueue(struct vsock_sock *vsk,
188 struct msghdr *msg,
189 size_t len);
190ssize_t
191virtio_transport_seqpacket_dequeue(struct vsock_sock *vsk,
192 struct msghdr *msg,
193 int flags);
194s64 virtio_transport_stream_has_data(struct vsock_sock *vsk);
195s64 virtio_transport_stream_has_space(struct vsock_sock *vsk);
196u32 virtio_transport_seqpacket_has_data(struct vsock_sock *vsk);
197
198ssize_t virtio_transport_unsent_bytes(struct vsock_sock *vsk);
199
200void virtio_transport_consume_skb_sent(struct sk_buff *skb,
201 bool consume);
202
203int virtio_transport_do_socket_init(struct vsock_sock *vsk,
204 struct vsock_sock *psk);
205int
206virtio_transport_notify_poll_in(struct vsock_sock *vsk,
207 size_t target,
208 bool *data_ready_now);
209int
210virtio_transport_notify_poll_out(struct vsock_sock *vsk,
211 size_t target,
212 bool *space_available_now);
213
214int virtio_transport_notify_recv_init(struct vsock_sock *vsk,
215 size_t target, struct vsock_transport_recv_notify_data *data);
216int virtio_transport_notify_recv_pre_block(struct vsock_sock *vsk,
217 size_t target, struct vsock_transport_recv_notify_data *data);
218int virtio_transport_notify_recv_pre_dequeue(struct vsock_sock *vsk,
219 size_t target, struct vsock_transport_recv_notify_data *data);
220int virtio_transport_notify_recv_post_dequeue(struct vsock_sock *vsk,
221 size_t target, ssize_t copied, bool data_read,
222 struct vsock_transport_recv_notify_data *data);
223int virtio_transport_notify_send_init(struct vsock_sock *vsk,
224 struct vsock_transport_send_notify_data *data);
225int virtio_transport_notify_send_pre_block(struct vsock_sock *vsk,
226 struct vsock_transport_send_notify_data *data);
227int virtio_transport_notify_send_pre_enqueue(struct vsock_sock *vsk,
228 struct vsock_transport_send_notify_data *data);
229int virtio_transport_notify_send_post_enqueue(struct vsock_sock *vsk,
230 ssize_t written, struct vsock_transport_send_notify_data *data);
231void virtio_transport_notify_buffer_size(struct vsock_sock *vsk, u64 *val);
232
233u64 virtio_transport_stream_rcvhiwat(struct vsock_sock *vsk);
234bool virtio_transport_stream_is_active(struct vsock_sock *vsk);
235bool virtio_transport_stream_allow(u32 cid, u32 port);
236int virtio_transport_dgram_bind(struct vsock_sock *vsk,
237 struct sockaddr_vm *addr);
238bool virtio_transport_dgram_allow(u32 cid, u32 port);
239
240int virtio_transport_connect(struct vsock_sock *vsk);
241
242int virtio_transport_shutdown(struct vsock_sock *vsk, int mode);
243
244void virtio_transport_release(struct vsock_sock *vsk);
245
246ssize_t
247virtio_transport_stream_enqueue(struct vsock_sock *vsk,
248 struct msghdr *msg,
249 size_t len);
250int
251virtio_transport_dgram_enqueue(struct vsock_sock *vsk,
252 struct sockaddr_vm *remote_addr,
253 struct msghdr *msg,
254 size_t len);
255
256void virtio_transport_destruct(struct vsock_sock *vsk);
257
258void virtio_transport_recv_pkt(struct virtio_transport *t,
259 struct sk_buff *skb);
260void virtio_transport_inc_tx_pkt(struct virtio_vsock_sock *vvs, struct sk_buff *skb);
261u32 virtio_transport_get_credit(struct virtio_vsock_sock *vvs, u32 wanted);
262void virtio_transport_put_credit(struct virtio_vsock_sock *vvs, u32 credit);
263void virtio_transport_deliver_tap_pkt(struct sk_buff *skb);
264int virtio_transport_purge_skbs(void *vsk, struct sk_buff_head *list);
265int virtio_transport_read_skb(struct vsock_sock *vsk, skb_read_actor_t read_actor);
266int virtio_transport_notify_set_rcvlowat(struct vsock_sock *vsk, int val);
267#endif /* _LINUX_VIRTIO_VSOCK_H */
268

source code of linux/include/linux/virtio_vsock.h

Morty Proxy This is a proxified and sanitized view of the page, visit original site.