Home
last modified time | relevance | path

Searched refs:rx_queue (Results 1 – 25 of 127) sorted by relevance

123456

/linux/drivers/net/ethernet/sfc/falcon/
H A Drx.c76 ef4_rx_buf_next(struct ef4_rx_queue *rx_queue, struct ef4_rx_buffer *rx_buf) in ef4_rx_buf_next() argument
78 if (unlikely(rx_buf == ef4_rx_buffer(rx_queue, rx_queue->ptr_mask))) in ef4_rx_buf_next()
79 return ef4_rx_buffer(rx_queue, 0); in ef4_rx_buf_next()
106 static struct page *ef4_reuse_page(struct ef4_rx_queue *rx_queue) in ef4_reuse_page() argument
108 struct ef4_nic *efx = rx_queue->efx; in ef4_reuse_page()
113 if (unlikely(!rx_queue->page_ring)) in ef4_reuse_page()
115 index = rx_queue->page_remove & rx_queue->page_ptr_mask; in ef4_reuse_page()
116 page = rx_queue in ef4_reuse_page()
152 ef4_init_rx_buffers(struct ef4_rx_queue * rx_queue,bool atomic) ef4_init_rx_buffers() argument
227 ef4_free_rx_buffers(struct ef4_rx_queue * rx_queue,struct ef4_rx_buffer * rx_buf,unsigned int num_bufs) ef4_free_rx_buffers() argument
248 struct ef4_rx_queue *rx_queue = ef4_channel_get_rx_queue(channel); ef4_recycle_rx_page() local
276 ef4_fini_rx_buffer(struct ef4_rx_queue * rx_queue,struct ef4_rx_buffer * rx_buf) ef4_fini_rx_buffer() argument
296 struct ef4_rx_queue *rx_queue = ef4_channel_get_rx_queue(channel); ef4_recycle_rx_pages() local
311 struct ef4_rx_queue *rx_queue = ef4_channel_get_rx_queue(channel); ef4_discard_rx_packet() local
331 ef4_fast_push_rx_descriptors(struct ef4_rx_queue * rx_queue,bool atomic) ef4_fast_push_rx_descriptors() argument
385 struct ef4_rx_queue *rx_queue = timer_container_of(rx_queue, t, ef4_rx_slow_fill() local
393 ef4_rx_packet__check_len(struct ef4_rx_queue * rx_queue,struct ef4_rx_buffer * rx_buf,int len) ef4_rx_packet__check_len() argument
440 struct ef4_rx_queue *rx_queue; ef4_rx_packet_gro() local
531 ef4_rx_packet(struct ef4_rx_queue * rx_queue,unsigned int index,unsigned int n_frags,unsigned int len,u16 flags) ef4_rx_packet() argument
627 struct ef4_rx_queue *rx_queue; ef4_rx_deliver() local
667 struct ef4_rx_queue *rx_queue; __ef4_rx_packet() local
687 ef4_probe_rx_queue(struct ef4_rx_queue * rx_queue) ef4_probe_rx_queue() argument
719 ef4_init_rx_recycle_ring(struct ef4_nic * efx,struct ef4_rx_queue * rx_queue) ef4_init_rx_recycle_ring() argument
745 ef4_init_rx_queue(struct ef4_rx_queue * rx_queue) ef4_init_rx_queue() argument
786 ef4_fini_rx_queue(struct ef4_rx_queue * rx_queue) ef4_fini_rx_queue() argument
825 ef4_remove_rx_queue(struct ef4_rx_queue * rx_queue) ef4_remove_rx_queue() argument
[all...]
H A Dnic.h110 ef4_rx_desc(struct ef4_rx_queue *rx_queue, unsigned int index) in ef4_rx_desc() argument
112 return ((ef4_qword_t *) (rx_queue->rxd.buf.addr)) + index; in ef4_rx_desc()
333 static inline int ef4_nic_probe_rx(struct ef4_rx_queue *rx_queue) in ef4_nic_probe_rx() argument
335 return rx_queue->efx->type->rx_probe(rx_queue); in ef4_nic_probe_rx()
337 static inline void ef4_nic_init_rx(struct ef4_rx_queue *rx_queue) in ef4_nic_init_rx() argument
339 rx_queue->efx->type->rx_init(rx_queue); in ef4_nic_init_rx()
341 static inline void ef4_nic_remove_rx(struct ef4_rx_queue *rx_queue) in ef4_nic_remove_rx() argument
343 rx_queue in ef4_nic_remove_rx()
345 ef4_nic_notify_rx_desc(struct ef4_rx_queue * rx_queue) ef4_nic_notify_rx_desc() argument
349 ef4_nic_generate_fill_event(struct ef4_rx_queue * rx_queue) ef4_nic_generate_fill_event() argument
[all...]
H A Dfarch.c471 ef4_farch_build_rx_desc(struct ef4_rx_queue *rx_queue, unsigned index) in ef4_farch_build_rx_desc() argument
476 rxd = ef4_rx_desc(rx_queue, index); in ef4_farch_build_rx_desc()
477 rx_buf = ef4_rx_buffer(rx_queue, index); in ef4_farch_build_rx_desc()
481 rx_queue->efx->type->rx_buffer_padding, in ef4_farch_build_rx_desc()
489 void ef4_farch_rx_write(struct ef4_rx_queue *rx_queue) in ef4_farch_rx_write() argument
491 struct ef4_nic *efx = rx_queue->efx; in ef4_farch_rx_write()
495 while (rx_queue->notified_count != rx_queue->added_count) { in ef4_farch_rx_write()
497 rx_queue, in ef4_farch_rx_write()
498 rx_queue in ef4_farch_rx_write()
509 ef4_farch_rx_probe(struct ef4_rx_queue * rx_queue) ef4_farch_rx_probe() argument
519 ef4_farch_rx_init(struct ef4_rx_queue * rx_queue) ef4_farch_rx_init() argument
563 ef4_farch_flush_rx_queue(struct ef4_rx_queue * rx_queue) ef4_farch_flush_rx_queue() argument
575 ef4_farch_rx_fini(struct ef4_rx_queue * rx_queue) ef4_farch_rx_fini() argument
590 ef4_farch_rx_remove(struct ef4_rx_queue * rx_queue) ef4_farch_rx_remove() argument
662 struct ef4_rx_queue *rx_queue; ef4_farch_do_flush() local
721 struct ef4_rx_queue *rx_queue; ef4_farch_fini_dmaq() local
868 ef4_farch_handle_rx_not_ok(struct ef4_rx_queue * rx_queue,const ef4_qword_t * event) ef4_farch_handle_rx_not_ok() argument
947 ef4_farch_handle_rx_bad_index(struct ef4_rx_queue * rx_queue,unsigned index) ef4_farch_handle_rx_bad_index() argument
986 struct ef4_rx_queue *rx_queue; ef4_farch_handle_rx_event() local
1114 struct ef4_rx_queue *rx_queue; ef4_farch_handle_rx_flush_done() local
1156 struct ef4_rx_queue *rx_queue = ef4_farch_handle_generated_event() local
1390 ef4_farch_rx_defer_refill(struct ef4_rx_queue * rx_queue) ef4_farch_rx_defer_refill() argument
[all...]
H A Dnet_driver.h401 * @rx_queue: RX queue for this channel
444 struct ef4_rx_queue rx_queue; member
665 * @rx_queue: RX DMA queues
1090 int (*rx_probe)(struct ef4_rx_queue *rx_queue);
1091 void (*rx_init)(struct ef4_rx_queue *rx_queue);
1092 void (*rx_remove)(struct ef4_rx_queue *rx_queue);
1093 void (*rx_write)(struct ef4_rx_queue *rx_queue);
1094 void (*rx_defer_refill)(struct ef4_rx_queue *rx_queue);
1236 return channel->rx_queue.core_index >= 0; in ef4_channel_has_rx_queue()
1243 return &channel->rx_queue; in ef4_channel_get_rx_queue()
1256 ef4_rx_queue_channel(struct ef4_rx_queue * rx_queue) ef4_rx_queue_channel() argument
1261 ef4_rx_queue_index(struct ef4_rx_queue * rx_queue) ef4_rx_queue_index() argument
1269 ef4_rx_buffer(struct ef4_rx_queue * rx_queue,unsigned int index) ef4_rx_buffer() argument
[all...]
H A Defx.h40 int ef4_probe_rx_queue(struct ef4_rx_queue *rx_queue);
41 void ef4_remove_rx_queue(struct ef4_rx_queue *rx_queue);
42 void ef4_init_rx_queue(struct ef4_rx_queue *rx_queue);
43 void ef4_fini_rx_queue(struct ef4_rx_queue *rx_queue);
44 void ef4_fast_push_rx_descriptors(struct ef4_rx_queue *rx_queue, bool atomic);
47 void ef4_rx_packet(struct ef4_rx_queue *rx_queue, unsigned int index,
54 void ef4_schedule_slow_fill(struct ef4_rx_queue *rx_queue);
/linux/drivers/net/ethernet/sfc/
H A Drx_common.c35 static struct page *efx_reuse_page(struct efx_rx_queue *rx_queue) in efx_reuse_page() argument
37 struct efx_nic *efx = rx_queue->efx; in efx_reuse_page()
42 if (unlikely(!rx_queue->page_ring)) in efx_reuse_page()
44 index = rx_queue->page_remove & rx_queue->page_ptr_mask; in efx_reuse_page()
45 page = rx_queue->page_ring[index]; in efx_reuse_page()
49 rx_queue->page_ring[index] = NULL; in efx_reuse_page()
51 if (rx_queue->page_remove != rx_queue->page_add) in efx_reuse_page()
52 ++rx_queue in efx_reuse_page()
77 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); efx_recycle_rx_page() local
111 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); efx_recycle_rx_pages() local
126 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); efx_discard_rx_packet() local
133 efx_init_rx_recycle_ring(struct efx_rx_queue * rx_queue) efx_init_rx_recycle_ring() argument
149 efx_fini_rx_recycle_ring(struct efx_rx_queue * rx_queue) efx_fini_rx_recycle_ring() argument
175 efx_fini_rx_buffer(struct efx_rx_queue * rx_queue,struct efx_rx_buffer * rx_buf) efx_fini_rx_buffer() argument
190 efx_probe_rx_queue(struct efx_rx_queue * rx_queue) efx_probe_rx_queue() argument
221 efx_init_rx_queue(struct efx_rx_queue * rx_queue) efx_init_rx_queue() argument
278 efx_fini_rx_queue(struct efx_rx_queue * rx_queue) efx_fini_rx_queue() argument
307 efx_remove_rx_queue(struct efx_rx_queue * rx_queue) efx_remove_rx_queue() argument
336 efx_free_rx_buffers(struct efx_rx_queue * rx_queue,struct efx_rx_buffer * rx_buf,unsigned int num_bufs) efx_free_rx_buffers() argument
351 struct efx_rx_queue *rx_queue = timer_container_of(rx_queue, t, efx_rx_slow_fill() local
359 efx_schedule_slow_fill(struct efx_rx_queue * rx_queue) efx_schedule_slow_fill() argument
373 efx_init_rx_buffers(struct efx_rx_queue * rx_queue,bool atomic) efx_init_rx_buffers() argument
457 efx_fast_push_rx_descriptors(struct efx_rx_queue * rx_queue,bool atomic) efx_fast_push_rx_descriptors() argument
520 struct efx_rx_queue *rx_queue; efx_rx_packet_gro() local
[all...]
H A Def100_rx.c58 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); in __ef100_rx_packet() local
59 struct efx_rx_buffer *rx_buf = efx_rx_buffer(rx_queue, in __ef100_rx_packet()
73 if (channel->type->receive_raw(rx_queue, mark)) in __ef100_rx_packet()
137 ++rx_queue->rx_packets; in __ef100_rx_packet()
138 rx_queue->rx_bytes += rx_buf->len; in __ef100_rx_packet()
144 efx_free_rx_buffers(rx_queue, rx_buf, 1); in __ef100_rx_packet()
149 static void ef100_rx_packet(struct efx_rx_queue *rx_queue, unsigned int index) in ef100_rx_packet() argument
151 struct efx_rx_buffer *rx_buf = efx_rx_buffer(rx_queue, index); in ef100_rx_packet()
152 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in ef100_rx_packet()
153 struct efx_nic *efx = rx_queue in ef100_rx_packet()
174 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); efx_ef100_ev_rx() local
192 ef100_rx_write(struct efx_rx_queue * rx_queue) ef100_rx_write() argument
[all...]
H A Drx.c43 static void efx_rx_packet__check_len(struct efx_rx_queue *rx_queue, in efx_rx_packet__check_len() argument
47 struct efx_nic *efx = rx_queue->efx; in efx_rx_packet__check_len()
61 efx_rx_queue_index(rx_queue), len, max_len); in efx_rx_packet__check_len()
63 efx_rx_queue_channel(rx_queue)->n_rx_overlength++; in efx_rx_packet__check_len()
105 rx_buf = efx_rx_buf_next(&channel->rx_queue, rx_buf); in efx_rx_mk_skb()
121 void efx_rx_packet(struct efx_rx_queue *rx_queue, unsigned int index, in efx_rx_packet() argument
124 struct efx_nic *efx = rx_queue->efx; in efx_rx_packet()
125 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in efx_rx_packet()
128 rx_buf = efx_rx_buffer(rx_queue, index); in efx_rx_packet()
134 efx_rx_packet__check_len(rx_queue, rx_bu in efx_rx_packet()
215 struct efx_rx_queue *rx_queue; efx_rx_deliver() local
253 struct efx_rx_queue *rx_queue; efx_do_xdp() local
360 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); __efx_rx_packet() local
[all...]
H A Dnic_common.h98 efx_rx_desc(struct efx_rx_queue *rx_queue, unsigned int index) in efx_rx_desc() argument
100 return ((efx_qword_t *)(rx_queue->rxd.addr)) + index; in efx_rx_desc()
138 static inline int efx_nic_probe_rx(struct efx_rx_queue *rx_queue) in efx_nic_probe_rx() argument
140 return rx_queue->efx->type->rx_probe(rx_queue); in efx_nic_probe_rx()
142 static inline void efx_nic_init_rx(struct efx_rx_queue *rx_queue) in efx_nic_init_rx() argument
144 rx_queue->efx->type->rx_init(rx_queue); in efx_nic_init_rx()
146 static inline void efx_nic_remove_rx(struct efx_rx_queue *rx_queue) in efx_nic_remove_rx() argument
148 rx_queue in efx_nic_remove_rx()
150 efx_nic_notify_rx_desc(struct efx_rx_queue * rx_queue) efx_nic_notify_rx_desc() argument
154 efx_nic_generate_fill_event(struct efx_rx_queue * rx_queue) efx_nic_generate_fill_event() argument
[all...]
H A Dmcdi_functions.c270 int efx_mcdi_rx_probe(struct efx_rx_queue *rx_queue) in efx_mcdi_rx_probe() argument
272 return efx_nic_alloc_buffer(rx_queue->efx, &rx_queue->rxd, in efx_mcdi_rx_probe()
273 (rx_queue->ptr_mask + 1) * in efx_mcdi_rx_probe()
278 void efx_mcdi_rx_init(struct efx_rx_queue *rx_queue) in efx_mcdi_rx_init() argument
280 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in efx_mcdi_rx_init()
281 size_t entries = rx_queue->rxd.len / EFX_BUF_SIZE; in efx_mcdi_rx_init()
283 struct efx_nic *efx = rx_queue->efx; in efx_mcdi_rx_init()
290 rx_queue->scatter_n = 0; in efx_mcdi_rx_init()
291 rx_queue in efx_mcdi_rx_init()
326 efx_mcdi_rx_remove(struct efx_rx_queue * rx_queue) efx_mcdi_rx_remove() argument
331 efx_mcdi_rx_fini(struct efx_rx_queue * rx_queue) efx_mcdi_rx_fini() argument
358 struct efx_rx_queue *rx_queue; efx_fini_dmaq() local
[all...]
H A Drx_common.h55 int efx_probe_rx_queue(struct efx_rx_queue *rx_queue);
56 void efx_init_rx_queue(struct efx_rx_queue *rx_queue);
57 void efx_fini_rx_queue(struct efx_rx_queue *rx_queue);
58 void efx_remove_rx_queue(struct efx_rx_queue *rx_queue);
59 void efx_destroy_rx_queue(struct efx_rx_queue *rx_queue);
61 void efx_init_rx_buffer(struct efx_rx_queue *rx_queue,
75 void efx_free_rx_buffers(struct efx_rx_queue *rx_queue,
79 void efx_schedule_slow_fill(struct efx_rx_queue *rx_queue);
81 void efx_fast_push_rx_descriptors(struct efx_rx_queue *rx_queue, bool atomic);
H A Defx_channels.c532 struct efx_rx_queue *rx_queue; in efx_alloc_channel() local
557 rx_queue = &channel->rx_queue; in efx_alloc_channel()
558 rx_queue->efx = efx; in efx_alloc_channel()
559 timer_setup(&rx_queue->slow_fill, efx_rx_slow_fill, 0); in efx_alloc_channel()
602 struct efx_rx_queue *rx_queue; in efx_copy_channel() local
628 rx_queue = &channel->rx_queue; in efx_copy_channel()
629 rx_queue->buffer = NULL; in efx_copy_channel()
630 memset(&rx_queue in efx_copy_channel()
642 struct efx_rx_queue *rx_queue; efx_probe_channel() local
742 struct efx_rx_queue *rx_queue; efx_remove_channel() local
1092 struct efx_rx_queue *rx_queue; efx_start_channels() local
1122 struct efx_rx_queue *rx_queue; efx_stop_channels() local
1202 struct efx_rx_queue *rx_queue = efx_process_channel() local
[all...]
H A Dmcdi_functions.h25 int efx_mcdi_rx_probe(struct efx_rx_queue *rx_queue);
26 void efx_mcdi_rx_init(struct efx_rx_queue *rx_queue);
27 void efx_mcdi_rx_remove(struct efx_rx_queue *rx_queue);
28 void efx_mcdi_rx_fini(struct efx_rx_queue *rx_queue);
H A Dtc_counters.c280 struct efx_rx_queue *rx_queue = &channel->rx_queue; in efx_tc_probe_channel() local
283 rx_queue->core_index = 0; in efx_tc_probe_channel()
285 INIT_WORK(&rx_queue->grant_work, efx_mae_counters_grant_credits); in efx_tc_probe_channel()
292 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); in efx_tc_start_channel() local
295 return efx_mae_start_counters(efx, rx_queue); in efx_tc_start_channel()
300 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); in efx_tc_stop_channel() local
304 rc = efx_mae_stop_counters(efx, rx_queue); in efx_tc_stop_channel()
309 rx_queue->grant_credits = false; in efx_tc_stop_channel()
310 flush_work(&rx_queue in efx_tc_stop_channel()
510 efx_tc_rx(struct efx_rx_queue * rx_queue,u32 mark) efx_tc_rx() argument
[all...]
H A Dnet_driver.h512 * @rx_queue: RX queue for this channel
577 struct efx_rx_queue rx_queue; member
890 * @rx_queue: RX DMA queues
1464 int (*rx_probe)(struct efx_rx_queue *rx_queue);
1465 void (*rx_init)(struct efx_rx_queue *rx_queue);
1466 void (*rx_remove)(struct efx_rx_queue *rx_queue);
1467 void (*rx_write)(struct efx_rx_queue *rx_queue);
1468 void (*rx_defer_refill)(struct efx_rx_queue *rx_queue);
1656 return channel->rx_queue.core_index >= 0; in efx_channel_has_rx_queue()
1663 return &channel->rx_queue; in efx_channel_get_rx_queue()
1676 efx_rx_queue_channel(struct efx_rx_queue * rx_queue) efx_rx_queue_channel() argument
1681 efx_rx_queue_index(struct efx_rx_queue * rx_queue) efx_rx_queue_index() argument
1689 efx_rx_buffer(struct efx_rx_queue * rx_queue,unsigned int index) efx_rx_buffer() argument
1696 efx_rx_buf_next(struct efx_rx_queue * rx_queue,struct efx_rx_buffer * rx_buf) efx_rx_buf_next() argument
[all...]
/linux/drivers/net/ethernet/sfc/siena/
H A Drx_common.c38 static struct page *efx_reuse_page(struct efx_rx_queue *rx_queue) in efx_reuse_page() argument
40 struct efx_nic *efx = rx_queue->efx; in efx_reuse_page()
45 if (unlikely(!rx_queue->page_ring)) in efx_reuse_page()
47 index = rx_queue->page_remove & rx_queue->page_ptr_mask; in efx_reuse_page()
48 page = rx_queue->page_ring[index]; in efx_reuse_page()
52 rx_queue->page_ring[index] = NULL; in efx_reuse_page()
54 if (rx_queue->page_remove != rx_queue->page_add) in efx_reuse_page()
55 ++rx_queue in efx_reuse_page()
80 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); efx_recycle_rx_page() local
114 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); efx_siena_recycle_rx_pages() local
129 struct efx_rx_queue *rx_queue = efx_channel_get_rx_queue(channel); efx_siena_discard_rx_packet() local
136 efx_init_rx_recycle_ring(struct efx_rx_queue * rx_queue) efx_init_rx_recycle_ring() argument
152 efx_fini_rx_recycle_ring(struct efx_rx_queue * rx_queue) efx_fini_rx_recycle_ring() argument
178 efx_fini_rx_buffer(struct efx_rx_queue * rx_queue,struct efx_rx_buffer * rx_buf) efx_fini_rx_buffer() argument
193 efx_siena_probe_rx_queue(struct efx_rx_queue * rx_queue) efx_siena_probe_rx_queue() argument
224 efx_siena_init_rx_queue(struct efx_rx_queue * rx_queue) efx_siena_init_rx_queue() argument
277 efx_siena_fini_rx_queue(struct efx_rx_queue * rx_queue) efx_siena_fini_rx_queue() argument
304 efx_siena_remove_rx_queue(struct efx_rx_queue * rx_queue) efx_siena_remove_rx_queue() argument
333 efx_siena_free_rx_buffers(struct efx_rx_queue * rx_queue,struct efx_rx_buffer * rx_buf,unsigned int num_bufs) efx_siena_free_rx_buffers() argument
348 struct efx_rx_queue *rx_queue = timer_container_of(rx_queue, t, efx_siena_rx_slow_fill() local
356 efx_schedule_slow_fill(struct efx_rx_queue * rx_queue) efx_schedule_slow_fill() argument
370 efx_init_rx_buffers(struct efx_rx_queue * rx_queue,bool atomic) efx_init_rx_buffers() argument
454 efx_siena_fast_push_rx_descriptors(struct efx_rx_queue * rx_queue,bool atomic) efx_siena_fast_push_rx_descriptors() argument
519 struct efx_rx_queue *rx_queue; efx_siena_rx_packet_gro() local
[all...]
H A Drx.c43 static void efx_rx_packet__check_len(struct efx_rx_queue *rx_queue, in efx_rx_packet__check_len() argument
47 struct efx_nic *efx = rx_queue->efx; in efx_rx_packet__check_len()
61 efx_rx_queue_index(rx_queue), len, max_len); in efx_rx_packet__check_len()
63 efx_rx_queue_channel(rx_queue)->n_rx_overlength++; in efx_rx_packet__check_len()
105 rx_buf = efx_rx_buf_next(&channel->rx_queue, rx_buf); in efx_rx_mk_skb()
121 void efx_siena_rx_packet(struct efx_rx_queue *rx_queue, unsigned int index, in efx_siena_rx_packet() argument
124 struct efx_nic *efx = rx_queue->efx; in efx_siena_rx_packet()
125 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in efx_siena_rx_packet()
128 rx_queue->rx_packets++; in efx_siena_rx_packet()
130 rx_buf = efx_rx_buffer(rx_queue, inde in efx_siena_rx_packet()
217 struct efx_rx_queue *rx_queue; efx_rx_deliver() local
255 struct efx_rx_queue *rx_queue; efx_do_xdp() local
378 struct efx_rx_queue *rx_queue; __efx_siena_rx_packet() local
[all...]
H A Dnic_common.h97 efx_rx_desc(struct efx_rx_queue *rx_queue, unsigned int index) in efx_rx_desc() argument
99 return ((efx_qword_t *) (rx_queue->rxd.buf.addr)) + index; in efx_rx_desc()
137 static inline int efx_nic_probe_rx(struct efx_rx_queue *rx_queue) in efx_nic_probe_rx() argument
139 return rx_queue->efx->type->rx_probe(rx_queue); in efx_nic_probe_rx()
141 static inline void efx_nic_init_rx(struct efx_rx_queue *rx_queue) in efx_nic_init_rx() argument
143 rx_queue->efx->type->rx_init(rx_queue); in efx_nic_init_rx()
145 static inline void efx_nic_remove_rx(struct efx_rx_queue *rx_queue) in efx_nic_remove_rx() argument
147 rx_queue in efx_nic_remove_rx()
149 efx_nic_notify_rx_desc(struct efx_rx_queue * rx_queue) efx_nic_notify_rx_desc() argument
153 efx_nic_generate_fill_event(struct efx_rx_queue * rx_queue) efx_nic_generate_fill_event() argument
[all...]
H A Dfarch.c465 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 in efx_farch_rx_write()
503 efx_farch_rx_probe(struct efx_rx_queue * rx_queue) efx_farch_rx_probe() argument
513 efx_farch_rx_init(struct efx_rx_queue * rx_queue) efx_farch_rx_init() argument
551 efx_farch_flush_rx_queue(struct efx_rx_queue * rx_queue) efx_farch_flush_rx_queue() argument
563 efx_farch_rx_fini(struct efx_rx_queue * rx_queue) efx_farch_rx_fini() argument
578 efx_farch_rx_remove(struct efx_rx_queue * rx_queue) efx_farch_rx_remove() argument
650 struct efx_rx_queue *rx_queue; efx_farch_do_flush() local
720 struct efx_rx_queue *rx_queue; efx_farch_fini_dmaq() local
863 efx_farch_handle_rx_not_ok(struct efx_rx_queue * rx_queue,const efx_qword_t * event) efx_farch_handle_rx_not_ok() argument
941 efx_farch_handle_rx_bad_index(struct efx_rx_queue * rx_queue,unsigned index) efx_farch_handle_rx_bad_index() argument
979 struct efx_rx_queue *rx_queue; efx_farch_handle_rx_event() local
1107 struct efx_rx_queue *rx_queue; efx_farch_handle_rx_flush_done() local
1149 struct efx_rx_queue *rx_queue = efx_farch_handle_generated_event() local
1407 efx_farch_rx_defer_refill(struct efx_rx_queue * rx_queue) efx_farch_rx_defer_refill() argument
[all...]
H A Defx_channels.c534 struct efx_rx_queue *rx_queue; in efx_alloc_channel() local
559 rx_queue = &channel->rx_queue; in efx_alloc_channel()
560 rx_queue->efx = efx; in efx_alloc_channel()
561 timer_setup(&rx_queue->slow_fill, efx_siena_rx_slow_fill, 0); in efx_alloc_channel()
605 struct efx_rx_queue *rx_queue; in efx_copy_channel() local
631 rx_queue = &channel->rx_queue; in efx_copy_channel()
632 rx_queue->buffer = NULL; in efx_copy_channel()
633 memset(&rx_queue in efx_copy_channel()
645 struct efx_rx_queue *rx_queue; efx_probe_channel() local
748 struct efx_rx_queue *rx_queue; efx_siena_remove_channel() local
871 struct efx_rx_queue *rx_queue; efx_siena_realloc_channels() local
1124 struct efx_rx_queue *rx_queue; efx_siena_start_channels() local
1148 struct efx_rx_queue *rx_queue; efx_siena_stop_channels() local
1223 struct efx_rx_queue *rx_queue = efx_process_channel() local
[all...]
H A Drx_common.h55 int efx_siena_probe_rx_queue(struct efx_rx_queue *rx_queue);
56 void efx_siena_init_rx_queue(struct efx_rx_queue *rx_queue);
57 void efx_siena_fini_rx_queue(struct efx_rx_queue *rx_queue);
58 void efx_siena_remove_rx_queue(struct efx_rx_queue *rx_queue);
68 void efx_siena_free_rx_buffers(struct efx_rx_queue *rx_queue,
73 void efx_siena_fast_push_rx_descriptors(struct efx_rx_queue *rx_queue,
H A Dnet_driver.h482 * @rx_queue: RX queue for this channel
545 struct efx_rx_queue rx_queue; member
810 * @rx_queue: RX DMA queues
1356 int (*rx_probe)(struct efx_rx_queue *rx_queue);
1357 void (*rx_init)(struct efx_rx_queue *rx_queue);
1358 void (*rx_remove)(struct efx_rx_queue *rx_queue);
1359 void (*rx_write)(struct efx_rx_queue *rx_queue);
1360 void (*rx_defer_refill)(struct efx_rx_queue *rx_queue);
1549 return channel->rx_queue.core_index >= 0; in efx_channel_has_rx_queue()
1556 return &channel->rx_queue; in efx_channel_get_rx_queue()
1569 efx_rx_queue_channel(struct efx_rx_queue * rx_queue) efx_rx_queue_channel() argument
1574 efx_rx_queue_index(struct efx_rx_queue * rx_queue) efx_rx_queue_index() argument
1582 efx_rx_buffer(struct efx_rx_queue * rx_queue,unsigned int index) efx_rx_buffer() argument
1589 efx_rx_buf_next(struct efx_rx_queue * rx_queue,struct efx_rx_buffer * rx_buf) efx_rx_buf_next() argument
[all...]
H A Dnic.h131 int efx_farch_rx_probe(struct efx_rx_queue *rx_queue);
132 void efx_farch_rx_init(struct efx_rx_queue *rx_queue);
133 void efx_farch_rx_fini(struct efx_rx_queue *rx_queue);
134 void efx_farch_rx_remove(struct efx_rx_queue *rx_queue);
135 void efx_farch_rx_write(struct efx_rx_queue *rx_queue);
136 void efx_farch_rx_defer_refill(struct efx_rx_queue *rx_queue);
/linux/drivers/net/ethernet/freescale/
H A Dgianfar.c110 static void gfar_init_rxbdp(struct gfar_priv_rx_q *rx_queue, struct rxbd8 *bdp, in gfar_init_rxbdp() argument
118 if (bdp == rx_queue->rx_bd_base + rx_queue->rx_ring_size - 1) in gfar_init_rxbdp()
140 gfar_write(baddr, priv->rx_queue[i]->rx_bd_dma_base); in gfar_init_tx_rx_base()
153 gfar_write(baddr, priv->rx_queue[i]->rx_ring_size | in gfar_init_rqprm()
256 if (likely(priv->rx_queue[i]->rxcoalescing)) in gfar_configure_coalescing()
257 gfar_write(baddr + i, priv->rx_queue[i]->rxic); in gfar_configure_coalescing()
268 if (unlikely(priv->rx_queue[0]->rxcoalescing)) in gfar_configure_coalescing()
269 gfar_write(&regs->rxic, priv->rx_queue[0]->rxic); in gfar_configure_coalescing()
284 stats->rx_packets += priv->rx_queue[ in gfar_get_stats64()
1085 free_skb_rx_queue(struct gfar_priv_rx_q * rx_queue) free_skb_rx_queue() argument
1120 struct gfar_priv_rx_q *rx_queue = NULL; free_skb_resources() local
1227 gfar_rx_alloc_err(struct gfar_priv_rx_q * rx_queue) gfar_rx_alloc_err() argument
1236 gfar_alloc_rx_buffs(struct gfar_priv_rx_q * rx_queue,int alloc_cnt) gfar_alloc_rx_buffs() argument
1280 struct gfar_priv_rx_q *rx_queue = NULL; gfar_init_bds() local
1334 struct gfar_priv_rx_q *rx_queue = NULL; gfar_alloc_skb_resources() local
1482 struct gfar_priv_rx_q *rx_queue = NULL; gfar_update_link_state() local
2365 gfar_get_next_rxbuff(struct gfar_priv_rx_q * rx_queue,u32 lstatus,struct sk_buff * skb) gfar_get_next_rxbuff() argument
2462 gfar_clean_rx_ring(struct gfar_priv_rx_q * rx_queue,int rx_work_limit) gfar_clean_rx_ring() argument
2570 struct gfar_priv_rx_q *rx_queue = gfargrp->rx_queue; gfar_poll_rx_sq() local
[all...]
/linux/net/rxrpc/
H A Dio_thread.c28 struct sk_buff_head *rx_queue; in rxrpc_encap_rcv() local
46 rx_queue = &local->rx_queue; in rxrpc_encap_rcv()
51 rx_queue = &local->rx_delay_queue; in rxrpc_encap_rcv()
55 skb_queue_tail(rx_queue, skb); in rxrpc_encap_rcv()
78 skb_queue_tail(&local->rx_queue, skb); in rxrpc_error_report()
452 struct sk_buff_head rx_queue; in rxrpc_io_thread() local
465 skb_queue_head_init(&rx_queue); in rxrpc_io_thread()
479 skb_queue_tail(&local->rx_queue, skb); in rxrpc_io_thread()
483 if (!skb_queue_empty(&local->rx_queue)) { in rxrpc_io_thread()
[all...]

123456