Lines Matching refs:rx_queue

465 efx_farch_build_rx_desc(struct efx_rx_queue *rx_queue, unsigned index)  in efx_farch_build_rx_desc()  argument
470 rxd = efx_rx_desc(rx_queue, index); in efx_farch_build_rx_desc()
471 rx_buf = efx_rx_buffer(rx_queue, index); in efx_farch_build_rx_desc()
475 rx_queue->efx->type->rx_buffer_padding, in efx_farch_build_rx_desc()
483 void efx_farch_rx_write(struct efx_rx_queue *rx_queue) in efx_farch_rx_write() argument
485 struct efx_nic *efx = rx_queue->efx; in efx_farch_rx_write()
489 while (rx_queue->notified_count != rx_queue->added_count) { in efx_farch_rx_write()
491 rx_queue, in efx_farch_rx_write()
492 rx_queue->notified_count & rx_queue->ptr_mask); in efx_farch_rx_write()
493 ++rx_queue->notified_count; in efx_farch_rx_write()
497 write_ptr = rx_queue->added_count & rx_queue->ptr_mask; in efx_farch_rx_write()
500 efx_rx_queue_index(rx_queue)); in efx_farch_rx_write()
503 int efx_farch_rx_probe(struct efx_rx_queue *rx_queue) in efx_farch_rx_probe() argument
505 struct efx_nic *efx = rx_queue->efx; in efx_farch_rx_probe()
508 entries = rx_queue->ptr_mask + 1; in efx_farch_rx_probe()
509 return efx_alloc_special_buffer(efx, &rx_queue->rxd, in efx_farch_rx_probe()
513 void efx_farch_rx_init(struct efx_rx_queue *rx_queue) in efx_farch_rx_init() argument
516 struct efx_nic *efx = rx_queue->efx; in efx_farch_rx_init()
524 efx_rx_queue_index(rx_queue), rx_queue->rxd.index, in efx_farch_rx_init()
525 rx_queue->rxd.index + rx_queue->rxd.entries - 1); in efx_farch_rx_init()
527 rx_queue->scatter_n = 0; in efx_farch_rx_init()
530 efx_init_special_buffer(efx, &rx_queue->rxd); in efx_farch_rx_init()
536 FRF_AZ_RX_DESCQ_BUF_BASE_ID, rx_queue->rxd.index, in efx_farch_rx_init()
538 efx_rx_queue_channel(rx_queue)->channel, in efx_farch_rx_init()
541 efx_rx_queue_index(rx_queue), in efx_farch_rx_init()
543 __ffs(rx_queue->rxd.entries), in efx_farch_rx_init()
548 efx_rx_queue_index(rx_queue)); in efx_farch_rx_init()
551 static void efx_farch_flush_rx_queue(struct efx_rx_queue *rx_queue) in efx_farch_flush_rx_queue() argument
553 struct efx_nic *efx = rx_queue->efx; in efx_farch_flush_rx_queue()
559 efx_rx_queue_index(rx_queue)); in efx_farch_flush_rx_queue()
563 void efx_farch_rx_fini(struct efx_rx_queue *rx_queue) in efx_farch_rx_fini() argument
566 struct efx_nic *efx = rx_queue->efx; in efx_farch_rx_fini()
571 efx_rx_queue_index(rx_queue)); in efx_farch_rx_fini()
574 efx_fini_special_buffer(efx, &rx_queue->rxd); in efx_farch_rx_fini()
578 void efx_farch_rx_remove(struct efx_rx_queue *rx_queue) in efx_farch_rx_remove() argument
580 efx_free_special_buffer(rx_queue->efx, &rx_queue->rxd); in efx_farch_rx_remove()
650 struct efx_rx_queue *rx_queue; in efx_farch_do_flush() local
658 efx_for_each_channel_rx_queue(rx_queue, channel) { in efx_farch_do_flush()
659 rx_queue->flush_pending = true; in efx_farch_do_flush()
680 efx_for_each_channel_rx_queue(rx_queue, channel) { in efx_farch_do_flush()
685 if (rx_queue->flush_pending) { in efx_farch_do_flush()
686 rx_queue->flush_pending = false; in efx_farch_do_flush()
689 efx_farch_flush_rx_queue(rx_queue); in efx_farch_do_flush()
720 struct efx_rx_queue *rx_queue; in efx_farch_fini_dmaq() local
733 efx_for_each_channel_rx_queue(rx_queue, channel) in efx_farch_fini_dmaq()
734 efx_farch_rx_fini(rx_queue); in efx_farch_fini_dmaq()
863 static u16 efx_farch_handle_rx_not_ok(struct efx_rx_queue *rx_queue, in efx_farch_handle_rx_not_ok() argument
866 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in efx_farch_handle_rx_not_ok()
867 struct efx_nic *efx = rx_queue->efx; in efx_farch_handle_rx_not_ok()
911 efx_rx_queue_index(rx_queue), EFX_QWORD_VAL(*event), in efx_farch_handle_rx_not_ok()
941 efx_farch_handle_rx_bad_index(struct efx_rx_queue *rx_queue, unsigned index) in efx_farch_handle_rx_bad_index() argument
943 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in efx_farch_handle_rx_bad_index()
944 struct efx_nic *efx = rx_queue->efx; in efx_farch_handle_rx_bad_index()
947 if (rx_queue->scatter_n && in efx_farch_handle_rx_bad_index()
948 index == ((rx_queue->removed_count + rx_queue->scatter_n - 1) & in efx_farch_handle_rx_bad_index()
949 rx_queue->ptr_mask)) { in efx_farch_handle_rx_bad_index()
954 expected = rx_queue->removed_count & rx_queue->ptr_mask; in efx_farch_handle_rx_bad_index()
955 dropped = (index - expected) & rx_queue->ptr_mask; in efx_farch_handle_rx_bad_index()
979 struct efx_rx_queue *rx_queue; in efx_farch_handle_rx_event() local
990 rx_queue = efx_channel_get_rx_queue(channel); in efx_farch_handle_rx_event()
993 expected_ptr = ((rx_queue->removed_count + rx_queue->scatter_n) & in efx_farch_handle_rx_event()
994 rx_queue->ptr_mask); in efx_farch_handle_rx_event()
998 unlikely(rx_ev_sop != (rx_queue->scatter_n == 0))) { in efx_farch_handle_rx_event()
1000 !efx_farch_handle_rx_bad_index(rx_queue, rx_ev_desc_ptr)) in efx_farch_handle_rx_event()
1004 if (rx_queue->scatter_n) { in efx_farch_handle_rx_event()
1006 rx_queue, in efx_farch_handle_rx_event()
1007 rx_queue->removed_count & rx_queue->ptr_mask, in efx_farch_handle_rx_event()
1008 rx_queue->scatter_n, 0, EFX_RX_PKT_DISCARD); in efx_farch_handle_rx_event()
1009 rx_queue->removed_count += rx_queue->scatter_n; in efx_farch_handle_rx_event()
1010 rx_queue->scatter_n = 0; in efx_farch_handle_rx_event()
1020 rx_queue, in efx_farch_handle_rx_event()
1021 rx_queue->removed_count & rx_queue->ptr_mask, in efx_farch_handle_rx_event()
1023 ++rx_queue->removed_count; in efx_farch_handle_rx_event()
1028 ++rx_queue->scatter_n; in efx_farch_handle_rx_event()
1053 flags = efx_farch_handle_rx_not_ok(rx_queue, event); in efx_farch_handle_rx_event()
1071 efx_siena_rx_packet(rx_queue, in efx_farch_handle_rx_event()
1072 rx_queue->removed_count & rx_queue->ptr_mask, in efx_farch_handle_rx_event()
1073 rx_queue->scatter_n, rx_ev_byte_cnt, flags); in efx_farch_handle_rx_event()
1074 rx_queue->removed_count += rx_queue->scatter_n; in efx_farch_handle_rx_event()
1075 rx_queue->scatter_n = 0; in efx_farch_handle_rx_event()
1107 struct efx_rx_queue *rx_queue; in efx_farch_handle_rx_flush_done() local
1118 rx_queue = efx_channel_get_rx_queue(channel); in efx_farch_handle_rx_flush_done()
1123 rx_queue->flush_pending = true; in efx_farch_handle_rx_flush_done()
1126 efx_farch_magic_event(efx_rx_queue_channel(rx_queue), in efx_farch_handle_rx_flush_done()
1127 EFX_CHANNEL_MAGIC_RX_DRAIN(rx_queue)); in efx_farch_handle_rx_flush_done()
1149 struct efx_rx_queue *rx_queue = in efx_farch_handle_generated_event() local
1159 } else if (rx_queue && magic == EFX_CHANNEL_MAGIC_FILL(rx_queue)) { in efx_farch_handle_generated_event()
1163 efx_siena_fast_push_rx_descriptors(rx_queue, true); in efx_farch_handle_generated_event()
1164 } else if (rx_queue && magic == EFX_CHANNEL_MAGIC_RX_DRAIN(rx_queue)) { in efx_farch_handle_generated_event()
1407 void efx_farch_rx_defer_refill(struct efx_rx_queue *rx_queue) in efx_farch_rx_defer_refill() argument
1409 efx_farch_magic_event(efx_rx_queue_channel(rx_queue), in efx_farch_rx_defer_refill()
1410 EFX_CHANNEL_MAGIC_FILL(rx_queue)); in efx_farch_rx_defer_refill()