Lines Matching refs:rx_head
92 static int i_ldc_rx_ackpeek(ldc_chan_t *ldcp, uint64_t rx_head,
601 uint64_t rx_head, rx_tail; in i_ldc_rxq_reconf() local
604 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_rxq_reconf()
637 uint64_t rx_head, rx_tail; in i_ldc_rxq_drain() local
641 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_rxq_drain()
650 if (rx_head == rx_tail) in i_ldc_rxq_drain()
2214 uint64_t rx_head, rx_tail; in i_ldc_rx_process_hvq() local
2229 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_rx_process_hvq()
2293 TRACE_RXHVQ_LENGTH(ldcp, rx_head, rx_tail); in i_ldc_rx_process_hvq()
2297 if (rx_head == rx_tail) { in i_ldc_rx_process_hvq()
2304 "tail=0x%llx\n", rx_head, rx_tail); in i_ldc_rx_process_hvq()
2306 ldcp->rx_q_va + rx_head); in i_ldc_rx_process_hvq()
2309 msg = (ldc_msg_t *)(ldcp->rx_q_va + rx_head); in i_ldc_rx_process_hvq()
2324 rx_head = (rx_head + LDC_PACKET_SIZE) % in i_ldc_rx_process_hvq()
2327 if (rv = i_ldc_set_rx_head(ldcp, rx_head)) in i_ldc_rx_process_hvq()
2361 rx_head, rx_tail); in i_ldc_rx_process_hvq()
2455 i_ldc_rxdq_copy(ldcp, &rx_head); in i_ldc_rx_process_hvq()
2461 rx_head = (rx_head + LDC_PACKET_SIZE) % in i_ldc_rx_process_hvq()
2466 if (rv = i_ldc_set_rx_head(ldcp, rx_head)) { in i_ldc_rx_process_hvq()
2502 if (i_ldc_rx_ackpeek(ldcp, rx_head, rx_tail) != 0) { in i_ldc_rx_process_hvq()
2530 i_ldc_rx_ackpeek(ldc_chan_t *ldcp, uint64_t rx_head, uint64_t rx_tail) in i_ldc_rx_ackpeek() argument
2536 ldcp->rx_ack_head = rx_head; in i_ldc_rx_ackpeek()
3600 uint64_t rx_head, rx_tail; in ldc_chkq() local
3621 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in ldc_chkq()
3646 *hasdata = (rx_head != rx_tail); in ldc_chkq()
3655 if (rx_head != rx_tail) { in ldc_chkq()
3707 uint64_t rx_head = 0, rx_tail = 0; in ldc_read() local
3755 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in ldc_read()
3777 (rx_head == rx_tail)) { in ldc_read()
3799 uint64_t rx_head, rx_tail; in i_ldc_read_raw() local
3814 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_read_raw()
3824 ldcp->id, rx_head, rx_tail, ldcp->link_state); in i_ldc_read_raw()
3838 if (rx_head == rx_tail) { in i_ldc_read_raw()
3844 msgp = (ldc_msg_t *)(ldcp->rx_q_va + rx_head); in i_ldc_read_raw()
3855 rx_head = (rx_head + LDC_PACKET_SIZE) & q_size_mask; in i_ldc_read_raw()
3856 rv = i_ldc_set_rx_head(ldcp, rx_head); in i_ldc_read_raw()
3871 uint64_t rx_head = 0, rx_tail = 0; in i_ldc_read_packet() local
3932 &rx_head, &rx_tail, &ldcp->link_state); in i_ldc_read_packet()
3973 ldcp->id, curr_head, rx_head, rx_tail); in i_ldc_read_packet()
3987 ldcp->id, rx_head, rx_tail); in i_ldc_read_packet()