net/vmw_vsock/vmci_transport_notify.c

15 #define PKT_FIELD(vsk, field_name) (vmci_trans(vsk)->notify.pkt.field_name)
23 	if (!PKT_FIELD(vsk, peer_waiting_write))
34 	if (!PKT_FIELD(vsk, peer_waiting_write_detected)) {
35 		PKT_FIELD(vsk, peer_waiting_write_detected) = true;
36 		if (PKT_FIELD(vsk, write_notify_window) < PAGE_SIZE) {
37 			PKT_FIELD(vsk, write_notify_window) =
38 			    PKT_FIELD(vsk, write_notify_min_window);
40 			PKT_FIELD(vsk, write_notify_window) -= PAGE_SIZE;
41 			if (PKT_FIELD(vsk, write_notify_window) <
42 			    PKT_FIELD(vsk, write_notify_min_window))
43 				PKT_FIELD(vsk, write_notify_window) =
44 				    PKT_FIELD(vsk, write_notify_min_window);
49 		PKT_FIELD(vsk, write_notify_window);
77 		PKT_FIELD(vsk, peer_waiting_write_detected) = false;
89 	if (!PKT_FIELD(vsk, peer_waiting_read))
116 	PKT_FIELD(vsk, peer_waiting_read) = true;
117 	memcpy(&PKT_FIELD(vsk, peer_waiting_read_info), &pkt->u.wait,
118 	       sizeof(PKT_FIELD(vsk, peer_waiting_read_info)));
129 			PKT_FIELD(vsk, peer_waiting_read) = false;
146 	PKT_FIELD(vsk, peer_waiting_write) = true;
147 	memcpy(&PKT_FIELD(vsk, peer_waiting_write_info), &pkt->u.wait,
148 	       sizeof(PKT_FIELD(vsk, peer_waiting_write_info)));
159 			PKT_FIELD(vsk, peer_waiting_write) = false;
174 	PKT_FIELD(vsk, sent_waiting_write) = false;
192 	if (PKT_FIELD(vsk, sent_waiting_read))
195 	if (PKT_FIELD(vsk, write_notify_window) <
197 		PKT_FIELD(vsk, write_notify_window) =
198 		    min(PKT_FIELD(vsk, write_notify_window) + PAGE_SIZE,
206 		    PKT_FIELD(vsk, consume_q_generation) + 1;
209 		waiting_info.generation = PKT_FIELD(vsk, consume_q_generation);
214 		PKT_FIELD(vsk, sent_waiting_read) = true;
234 	if (PKT_FIELD(vsk, sent_waiting_write))
242 		waiting_info.generation = PKT_FIELD(vsk, produce_q_generation);
246 		    PKT_FIELD(vsk, produce_q_generation) - 1;
251 		PKT_FIELD(vsk, sent_waiting_write) = true;
293 			PKT_FIELD(vsk, peer_waiting_write) = false;
308 	PKT_FIELD(vsk, sent_waiting_read) = false;
317 	PKT_FIELD(vsk, write_notify_window) = PAGE_SIZE;
318 	PKT_FIELD(vsk, write_notify_min_window) = PAGE_SIZE;
319 	PKT_FIELD(vsk, peer_waiting_read) = false;
320 	PKT_FIELD(vsk, peer_waiting_write) = false;
321 	PKT_FIELD(vsk, peer_waiting_write_detected) = false;
322 	PKT_FIELD(vsk, sent_waiting_read) = false;
323 	PKT_FIELD(vsk, sent_waiting_write) = false;
324 	PKT_FIELD(vsk, produce_q_generation) = 0;
325 	PKT_FIELD(vsk, consume_q_generation) = 0;
327 	memset(&PKT_FIELD(vsk, peer_waiting_read_info), 0,
328 	       sizeof(PKT_FIELD(vsk, peer_waiting_read_info)));
329 	memset(&PKT_FIELD(vsk, peer_waiting_write_info), 0,
330 	       sizeof(PKT_FIELD(vsk, peer_waiting_write_info)));
404 	if (PKT_FIELD(vsk, write_notify_min_window) < target + 1) {
405 		PKT_FIELD(vsk, write_notify_min_window) = target + 1;
406 		if (PKT_FIELD(vsk, write_notify_window) <
407 		    PKT_FIELD(vsk, write_notify_min_window)) {
415 			PKT_FIELD(vsk, write_notify_window) =
416 			    PKT_FIELD(vsk, write_notify_min_window);
494 			PKT_FIELD(vsk, consume_q_generation)++;
565 		PKT_FIELD(vsk, produce_q_generation)++;
590 			PKT_FIELD(vsk, peer_waiting_read) = false;
637 	PKT_FIELD(vsk, write_notify_window) = vmci_trans(vsk)->consume_size;
639 		PKT_FIELD(vsk, write_notify_min_window))
640 		PKT_FIELD(vsk, write_notify_min_window) =
648 	PKT_FIELD(vsk, write_notify_window) = vmci_trans(vsk)->consume_size;
650 		PKT_FIELD(vsk, write_notify_min_window))
651 		PKT_FIELD(vsk, write_notify_min_window) =