Lines Matching refs:PKT_FIELD
23 #define PKT_FIELD(vsk, field_name) (vmci_trans(vsk)->notify.pkt.field_name) macro
31 if (!PKT_FIELD(vsk, peer_waiting_write)) in vmci_transport_notify_waiting_write()
42 if (!PKT_FIELD(vsk, peer_waiting_write_detected)) { in vmci_transport_notify_waiting_write()
43 PKT_FIELD(vsk, peer_waiting_write_detected) = true; in vmci_transport_notify_waiting_write()
44 if (PKT_FIELD(vsk, write_notify_window) < PAGE_SIZE) { in vmci_transport_notify_waiting_write()
45 PKT_FIELD(vsk, write_notify_window) = in vmci_transport_notify_waiting_write()
46 PKT_FIELD(vsk, write_notify_min_window); in vmci_transport_notify_waiting_write()
48 PKT_FIELD(vsk, write_notify_window) -= PAGE_SIZE; in vmci_transport_notify_waiting_write()
49 if (PKT_FIELD(vsk, write_notify_window) < in vmci_transport_notify_waiting_write()
50 PKT_FIELD(vsk, write_notify_min_window)) in vmci_transport_notify_waiting_write()
51 PKT_FIELD(vsk, write_notify_window) = in vmci_transport_notify_waiting_write()
52 PKT_FIELD(vsk, write_notify_min_window); in vmci_transport_notify_waiting_write()
57 PKT_FIELD(vsk, write_notify_window); in vmci_transport_notify_waiting_write()
85 PKT_FIELD(vsk, peer_waiting_write_detected) = false; in vmci_transport_notify_waiting_write()
97 if (!PKT_FIELD(vsk, peer_waiting_read)) in vmci_transport_notify_waiting_read()
124 PKT_FIELD(vsk, peer_waiting_read) = true; in vmci_transport_handle_waiting_read()
125 memcpy(&PKT_FIELD(vsk, peer_waiting_read_info), &pkt->u.wait, in vmci_transport_handle_waiting_read()
126 sizeof(PKT_FIELD(vsk, peer_waiting_read_info))); in vmci_transport_handle_waiting_read()
137 PKT_FIELD(vsk, peer_waiting_read) = false; in vmci_transport_handle_waiting_read()
154 PKT_FIELD(vsk, peer_waiting_write) = true; in vmci_transport_handle_waiting_write()
155 memcpy(&PKT_FIELD(vsk, peer_waiting_write_info), &pkt->u.wait, in vmci_transport_handle_waiting_write()
156 sizeof(PKT_FIELD(vsk, peer_waiting_write_info))); in vmci_transport_handle_waiting_write()
167 PKT_FIELD(vsk, peer_waiting_write) = false; in vmci_transport_handle_waiting_write()
182 PKT_FIELD(vsk, sent_waiting_write) = false; in vmci_transport_handle_read()
200 if (PKT_FIELD(vsk, sent_waiting_read)) in send_waiting_read()
203 if (PKT_FIELD(vsk, write_notify_window) < in send_waiting_read()
205 PKT_FIELD(vsk, write_notify_window) = in send_waiting_read()
206 min(PKT_FIELD(vsk, write_notify_window) + PAGE_SIZE, in send_waiting_read()
214 PKT_FIELD(vsk, consume_q_generation) + 1; in send_waiting_read()
217 waiting_info.generation = PKT_FIELD(vsk, consume_q_generation); in send_waiting_read()
222 PKT_FIELD(vsk, sent_waiting_read) = true; in send_waiting_read()
242 if (PKT_FIELD(vsk, sent_waiting_write)) in send_waiting_write()
250 waiting_info.generation = PKT_FIELD(vsk, produce_q_generation); in send_waiting_write()
254 PKT_FIELD(vsk, produce_q_generation) - 1; in send_waiting_write()
259 PKT_FIELD(vsk, sent_waiting_write) = true; in send_waiting_write()
301 PKT_FIELD(vsk, peer_waiting_write) = false; in vmci_transport_send_read_notification()
316 PKT_FIELD(vsk, sent_waiting_read) = false; in vmci_transport_handle_wrote()
325 PKT_FIELD(vsk, write_notify_window) = PAGE_SIZE; in vmci_transport_notify_pkt_socket_init()
326 PKT_FIELD(vsk, write_notify_min_window) = PAGE_SIZE; in vmci_transport_notify_pkt_socket_init()
327 PKT_FIELD(vsk, peer_waiting_read) = false; in vmci_transport_notify_pkt_socket_init()
328 PKT_FIELD(vsk, peer_waiting_write) = false; in vmci_transport_notify_pkt_socket_init()
329 PKT_FIELD(vsk, peer_waiting_write_detected) = false; in vmci_transport_notify_pkt_socket_init()
330 PKT_FIELD(vsk, sent_waiting_read) = false; in vmci_transport_notify_pkt_socket_init()
331 PKT_FIELD(vsk, sent_waiting_write) = false; in vmci_transport_notify_pkt_socket_init()
332 PKT_FIELD(vsk, produce_q_generation) = 0; in vmci_transport_notify_pkt_socket_init()
333 PKT_FIELD(vsk, consume_q_generation) = 0; in vmci_transport_notify_pkt_socket_init()
335 memset(&PKT_FIELD(vsk, peer_waiting_read_info), 0, in vmci_transport_notify_pkt_socket_init()
336 sizeof(PKT_FIELD(vsk, peer_waiting_read_info))); in vmci_transport_notify_pkt_socket_init()
337 memset(&PKT_FIELD(vsk, peer_waiting_write_info), 0, in vmci_transport_notify_pkt_socket_init()
338 sizeof(PKT_FIELD(vsk, peer_waiting_write_info))); in vmci_transport_notify_pkt_socket_init()
412 if (PKT_FIELD(vsk, write_notify_min_window) < target + 1) { in vmci_transport_notify_pkt_recv_init()
413 PKT_FIELD(vsk, write_notify_min_window) = target + 1; in vmci_transport_notify_pkt_recv_init()
414 if (PKT_FIELD(vsk, write_notify_window) < in vmci_transport_notify_pkt_recv_init()
415 PKT_FIELD(vsk, write_notify_min_window)) { in vmci_transport_notify_pkt_recv_init()
423 PKT_FIELD(vsk, write_notify_window) = in vmci_transport_notify_pkt_recv_init()
424 PKT_FIELD(vsk, write_notify_min_window); in vmci_transport_notify_pkt_recv_init()
502 PKT_FIELD(vsk, consume_q_generation)++; in vmci_transport_notify_pkt_recv_post_dequeue()
573 PKT_FIELD(vsk, produce_q_generation)++; in vmci_transport_notify_pkt_send_post_enqueue()
598 PKT_FIELD(vsk, peer_waiting_read) = false; in vmci_transport_notify_pkt_send_post_enqueue()
645 PKT_FIELD(vsk, write_notify_window) = vmci_trans(vsk)->consume_size; in vmci_transport_notify_pkt_process_request()
647 PKT_FIELD(vsk, write_notify_min_window)) in vmci_transport_notify_pkt_process_request()
648 PKT_FIELD(vsk, write_notify_min_window) = in vmci_transport_notify_pkt_process_request()
656 PKT_FIELD(vsk, write_notify_window) = vmci_trans(vsk)->consume_size; in vmci_transport_notify_pkt_process_negotiate()
658 PKT_FIELD(vsk, write_notify_min_window)) in vmci_transport_notify_pkt_process_negotiate()
659 PKT_FIELD(vsk, write_notify_min_window) = in vmci_transport_notify_pkt_process_negotiate()