net/vmw_vsock/vmci_transport_notify_qstate.c

15 #define PKT_FIELD(vsk, field_name) \
16 	(vmci_trans(vsk)->notify.pkt_q_state.field_name)
18 static bool vmci_transport_notify_waiting_write(struct vsock_sock *vsk)
23 	if (!PKT_FIELD(vsk, peer_waiting_write))
33 	if (!PKT_FIELD(vsk, peer_waiting_write_detected)) {
34 		PKT_FIELD(vsk, peer_waiting_write_detected) = true;
35 		if (PKT_FIELD(vsk, write_notify_window) < PAGE_SIZE) {
36 			PKT_FIELD(vsk, write_notify_window) =
37 			    PKT_FIELD(vsk, write_notify_min_window);
39 			PKT_FIELD(vsk, write_notify_window) -= PAGE_SIZE;
40 			if (PKT_FIELD(vsk, write_notify_window) <
41 			    PKT_FIELD(vsk, write_notify_min_window))
42 				PKT_FIELD(vsk, write_notify_window) =
43 				    PKT_FIELD(vsk, write_notify_min_window);
47 	notify_limit = vmci_trans(vsk)->consume_size -
48 		PKT_FIELD(vsk, write_notify_window);
59 	retval = vmci_qpair_consume_free_space(vmci_trans(vsk)->qpair) >
67 		PKT_FIELD(vsk, peer_waiting_write_detected) = false;
92 	struct vsock_sock *vsk = vsock_sk(sk);
94 	if (PKT_FIELD(vsk, write_notify_window) < vmci_trans(vsk)->consume_size)
95 		PKT_FIELD(vsk, write_notify_window) =
96 		    min(PKT_FIELD(vsk, write_notify_window) + PAGE_SIZE,
97 			vmci_trans(vsk)->consume_size);
102 	struct vsock_sock *vsk;
107 	vsk = vsock_sk(sk);
112 	if (vmci_transport_notify_waiting_write(vsk)) {
117 		 * keeping track of work items in the vsk and cleaning them up
120 		while (!(vsk->peer_shutdown & RCV_SHUTDOWN) &&
134 			PKT_FIELD(vsk, peer_waiting_write) = false;
142 	struct vsock_sock *vsk = vsock_sk(sk);
144 	PKT_FIELD(vsk, write_notify_window) = PAGE_SIZE;
145 	PKT_FIELD(vsk, write_notify_min_window) = PAGE_SIZE;
146 	PKT_FIELD(vsk, peer_waiting_write) = false;
147 	PKT_FIELD(vsk, peer_waiting_write_detected) = false;
150 static void vmci_transport_notify_pkt_socket_destruct(struct vsock_sock *vsk)
152 	PKT_FIELD(vsk, write_notify_window) = PAGE_SIZE;
153 	PKT_FIELD(vsk, write_notify_min_window) = PAGE_SIZE;
154 	PKT_FIELD(vsk, peer_waiting_write) = false;
155 	PKT_FIELD(vsk, peer_waiting_write_detected) = false;
162 	struct vsock_sock *vsk = vsock_sk(sk);
164 	if (vsock_stream_has_data(vsk) >= target) {
184 	struct vsock_sock *vsk = vsock_sk(sk);
186 	produce_q_free_space = vsock_stream_has_space(vsk);
206 	struct vsock_sock *vsk = vsock_sk(sk);
212 	if (PKT_FIELD(vsk, write_notify_min_window) < target + 1) {
213 		PKT_FIELD(vsk, write_notify_min_window) = target + 1;
214 		if (PKT_FIELD(vsk, write_notify_window) <
215 		    PKT_FIELD(vsk, write_notify_min_window)) {
223 			PKT_FIELD(vsk, write_notify_window) =
224 			    PKT_FIELD(vsk, write_notify_min_window);
260 	struct vsock_sock *vsk;
265 	vsk = vsock_sk(sk);
272 			vmci_qpair_consume_free_space(vmci_trans(vsk)->qpair);
276 			PKT_FIELD(vsk, peer_waiting_write) = true;
309 	struct vsock_sock *vsk;
314 	vsk = vsock_sk(sk);
319 		vmci_qpair_produce_buf_ready(vmci_trans(vsk)->qpair) == written;
321 		while (!(vsk->peer_shutdown & RCV_SHUTDOWN) &&
368 	struct vsock_sock *vsk = vsock_sk(sk);
370 	PKT_FIELD(vsk, write_notify_window) = vmci_trans(vsk)->consume_size;
371 	if (vmci_trans(vsk)->consume_size <
372 		PKT_FIELD(vsk, write_notify_min_window))
373 		PKT_FIELD(vsk, write_notify_min_window) =
374 			vmci_trans(vsk)->consume_size;
379 	struct vsock_sock *vsk = vsock_sk(sk);
381 	PKT_FIELD(vsk, write_notify_window) = vmci_trans(vsk)->consume_size;
382 	if (vmci_trans(vsk)->consume_size <
383 		PKT_FIELD(vsk, write_notify_min_window))
384 		PKT_FIELD(vsk, write_notify_min_window) =
385 			vmci_trans(vsk)->consume_size;