Lines Matching refs:rx_head
92 static int i_ldc_rx_ackpeek(ldc_chan_t *ldcp, uint64_t rx_head,
617 uint64_t rx_head, rx_tail; in i_ldc_rxq_reconf() local
620 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_rxq_reconf()
653 uint64_t rx_head, rx_tail; in i_ldc_rxq_drain() local
657 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_rxq_drain()
666 if (rx_head == rx_tail) in i_ldc_rxq_drain()
2230 uint64_t rx_head, rx_tail; in i_ldc_rx_process_hvq() local
2245 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_rx_process_hvq()
2309 TRACE_RXHVQ_LENGTH(ldcp, rx_head, rx_tail); in i_ldc_rx_process_hvq()
2313 if (rx_head == rx_tail) { in i_ldc_rx_process_hvq()
2320 "tail=0x%llx\n", rx_head, rx_tail); in i_ldc_rx_process_hvq()
2322 ldcp->rx_q_va + rx_head); in i_ldc_rx_process_hvq()
2325 msg = (ldc_msg_t *)(ldcp->rx_q_va + rx_head); in i_ldc_rx_process_hvq()
2340 rx_head = (rx_head + LDC_PACKET_SIZE) % in i_ldc_rx_process_hvq()
2343 if (rv = i_ldc_set_rx_head(ldcp, rx_head)) in i_ldc_rx_process_hvq()
2377 rx_head, rx_tail); in i_ldc_rx_process_hvq()
2471 i_ldc_rxdq_copy(ldcp, &rx_head); in i_ldc_rx_process_hvq()
2477 rx_head = (rx_head + LDC_PACKET_SIZE) % in i_ldc_rx_process_hvq()
2482 if (rv = i_ldc_set_rx_head(ldcp, rx_head)) { in i_ldc_rx_process_hvq()
2518 if (i_ldc_rx_ackpeek(ldcp, rx_head, rx_tail) != 0) { in i_ldc_rx_process_hvq()
2546 i_ldc_rx_ackpeek(ldc_chan_t *ldcp, uint64_t rx_head, uint64_t rx_tail) in i_ldc_rx_ackpeek() argument
2552 ldcp->rx_ack_head = rx_head; in i_ldc_rx_ackpeek()
3617 uint64_t rx_head, rx_tail; in ldc_chkq() local
3638 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in ldc_chkq()
3663 *hasdata = (rx_head != rx_tail); in ldc_chkq()
3672 if (rx_head != rx_tail) { in ldc_chkq()
3724 uint64_t rx_head = 0, rx_tail = 0; in ldc_read() local
3772 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in ldc_read()
3794 (rx_head == rx_tail)) { in ldc_read()
3816 uint64_t rx_head, rx_tail; in i_ldc_read_raw() local
3831 rv = hv_ldc_rx_get_state(ldcp->id, &rx_head, &rx_tail, in i_ldc_read_raw()
3841 ldcp->id, rx_head, rx_tail, ldcp->link_state); in i_ldc_read_raw()
3855 if (rx_head == rx_tail) { in i_ldc_read_raw()
3861 msgp = (ldc_msg_t *)(ldcp->rx_q_va + rx_head); in i_ldc_read_raw()
3872 rx_head = (rx_head + LDC_PACKET_SIZE) & q_size_mask; in i_ldc_read_raw()
3873 rv = i_ldc_set_rx_head(ldcp, rx_head); in i_ldc_read_raw()
3888 uint64_t rx_head = 0, rx_tail = 0; in i_ldc_read_packet() local
3949 &rx_head, &rx_tail, &ldcp->link_state); in i_ldc_read_packet()
3990 ldcp->id, curr_head, rx_head, rx_tail); in i_ldc_read_packet()
4004 ldcp->id, rx_head, rx_tail); in i_ldc_read_packet()