Home
last modified time | relevance | path

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

12

/drivers/net/ethernet/sfc/
Drx.c137 static int efx_init_rx_buffers_skb(struct efx_rx_queue *rx_queue) in efx_init_rx_buffers_skb() argument
139 struct efx_nic *efx = rx_queue->efx; in efx_init_rx_buffers_skb()
147 index = rx_queue->added_count & rx_queue->ptr_mask; in efx_init_rx_buffers_skb()
148 rx_buf = efx_rx_buffer(rx_queue, index); in efx_init_rx_buffers_skb()
169 ++rx_queue->added_count; in efx_init_rx_buffers_skb()
170 ++rx_queue->alloc_skb_count; in efx_init_rx_buffers_skb()
186 static int efx_init_rx_buffers_page(struct efx_rx_queue *rx_queue) in efx_init_rx_buffers_page() argument
188 struct efx_nic *efx = rx_queue->efx; in efx_init_rx_buffers_page()
222 index = rx_queue->added_count & rx_queue->ptr_mask; in efx_init_rx_buffers_page()
223 rx_buf = efx_rx_buffer(rx_queue, index); in efx_init_rx_buffers_page()
[all …]
Dnic.c535 efx_rx_desc(struct efx_rx_queue *rx_queue, unsigned int index) in efx_rx_desc() argument
537 return ((efx_qword_t *) (rx_queue->rxd.addr)) + index; in efx_rx_desc()
542 efx_build_rx_desc(struct efx_rx_queue *rx_queue, unsigned index) in efx_build_rx_desc() argument
547 rxd = efx_rx_desc(rx_queue, index); in efx_build_rx_desc()
548 rx_buf = efx_rx_buffer(rx_queue, index); in efx_build_rx_desc()
552 rx_queue->efx->type->rx_buffer_padding, in efx_build_rx_desc()
560 void efx_nic_notify_rx_desc(struct efx_rx_queue *rx_queue) in efx_nic_notify_rx_desc() argument
562 struct efx_nic *efx = rx_queue->efx; in efx_nic_notify_rx_desc()
566 while (rx_queue->notified_count != rx_queue->added_count) { in efx_nic_notify_rx_desc()
568 rx_queue, in efx_nic_notify_rx_desc()
[all …]
Defx.h36 extern int efx_probe_rx_queue(struct efx_rx_queue *rx_queue);
37 extern void efx_remove_rx_queue(struct efx_rx_queue *rx_queue);
38 extern void efx_init_rx_queue(struct efx_rx_queue *rx_queue);
39 extern void efx_fini_rx_queue(struct efx_rx_queue *rx_queue);
41 extern void efx_fast_push_rx_descriptors(struct efx_rx_queue *rx_queue);
45 extern void efx_rx_packet(struct efx_rx_queue *rx_queue, unsigned int index,
47 extern void efx_schedule_slow_fill(struct efx_rx_queue *rx_queue);
Defx.c232 struct efx_rx_queue *rx_queue = in efx_process_channel() local
240 if (rx_queue->enabled) { in efx_process_channel()
242 efx_fast_push_rx_descriptors(rx_queue); in efx_process_channel()
450 struct efx_rx_queue *rx_queue; in efx_alloc_channel() local
469 rx_queue = &channel->rx_queue; in efx_alloc_channel()
470 rx_queue->efx = efx; in efx_alloc_channel()
471 setup_timer(&rx_queue->slow_fill, efx_rx_slow_fill, in efx_alloc_channel()
472 (unsigned long)rx_queue); in efx_alloc_channel()
484 struct efx_rx_queue *rx_queue; in efx_copy_channel() local
505 rx_queue = &channel->rx_queue; in efx_copy_channel()
[all …]
Dnet_driver.h386 struct efx_rx_queue rx_queue; member
1057 return &channel->rx_queue; in efx_channel_get_rx_queue()
1065 for (_rx_queue = &(_channel)->rx_queue; \
1070 efx_rx_queue_channel(struct efx_rx_queue *rx_queue) in efx_rx_queue_channel() argument
1072 return container_of(rx_queue, struct efx_channel, rx_queue); in efx_rx_queue_channel()
1075 static inline int efx_rx_queue_index(struct efx_rx_queue *rx_queue) in efx_rx_queue_index() argument
1077 return efx_rx_queue_channel(rx_queue)->channel; in efx_rx_queue_index()
1083 static inline struct efx_rx_buffer *efx_rx_buffer(struct efx_rx_queue *rx_queue, in efx_rx_buffer() argument
1086 return &rx_queue->buffer[index]; in efx_rx_buffer()
Dnic.h274 extern int efx_nic_probe_rx(struct efx_rx_queue *rx_queue);
275 extern void efx_nic_init_rx(struct efx_rx_queue *rx_queue);
276 extern void efx_nic_fini_rx(struct efx_rx_queue *rx_queue);
277 extern void efx_nic_remove_rx(struct efx_rx_queue *rx_queue);
278 extern void efx_nic_notify_rx_desc(struct efx_rx_queue *rx_queue);
279 extern void efx_nic_generate_fill_event(struct efx_rx_queue *rx_queue);
Dmcdi.c1167 struct efx_rx_queue *rx_queue; in efx_mcdi_flush_rxqs() local
1180 efx_for_each_channel_rx_queue(rx_queue, channel) { in efx_mcdi_flush_rxqs()
1181 if (rx_queue->flush_pending) { in efx_mcdi_flush_rxqs()
1182 rx_queue->flush_pending = false; in efx_mcdi_flush_rxqs()
1185 efx_rx_queue_index(rx_queue)); in efx_mcdi_flush_rxqs()
/drivers/net/ethernet/freescale/
Dgianfar.c116 static void gfar_new_rxbdp(struct gfar_priv_rx_q *rx_queue, struct rxbd8 *bdp,
136 int gfar_clean_rx_ring(struct gfar_priv_rx_q *rx_queue, int rx_work_limit);
152 static void gfar_init_rxbdp(struct gfar_priv_rx_q *rx_queue, struct rxbd8 *bdp, in gfar_init_rxbdp() argument
160 if (bdp == rx_queue->rx_bd_base + rx_queue->rx_ring_size - 1) in gfar_init_rxbdp()
172 struct gfar_priv_rx_q *rx_queue = NULL; in gfar_init_bds() local
200 rx_queue = priv->rx_queue[i]; in gfar_init_bds()
201 rx_queue->cur_rx = rx_queue->rx_bd_base; in gfar_init_bds()
202 rx_queue->skb_currx = 0; in gfar_init_bds()
203 rxbdp = rx_queue->rx_bd_base; in gfar_init_bds()
205 for (j = 0; j < rx_queue->rx_ring_size; j++) { in gfar_init_bds()
[all …]
Dgianfar_ethtool.c48 extern int gfar_clean_rx_ring(struct gfar_priv_rx_q *rx_queue, int rx_work_limit);
205 struct gfar_priv_rx_q *rx_queue = NULL; in gfar_gsettings() local
211 rx_queue = priv->rx_queue[0]; in gfar_gsettings()
216 cmd->maxrxpkt = get_icft_value(rx_queue->rxic); in gfar_gsettings()
293 struct gfar_priv_rx_q *rx_queue = NULL; in gfar_gcoalesce() local
306 rx_queue = priv->rx_queue[0]; in gfar_gcoalesce()
309 rxtime = get_ictt_value(rx_queue->rxic); in gfar_gcoalesce()
310 rxcount = get_icft_value(rx_queue->rxic); in gfar_gcoalesce()
370 priv->rx_queue[i]->rxcoalescing = 0; in gfar_scoalesce()
373 priv->rx_queue[i]->rxcoalescing = 1; in gfar_scoalesce()
[all …]
/drivers/net/ethernet/ibm/
Dibmveth.c109 return adapter->rx_queue.queue_addr[adapter->rx_queue.index].flags_off; in ibmveth_rxq_flags()
120 return ibmveth_rxq_toggle(adapter) == adapter->rx_queue.toggle; in ibmveth_rxq_pending_buffer()
135 return adapter->rx_queue.queue_addr[adapter->rx_queue.index].length; in ibmveth_rxq_frame_length()
387 u64 correlator = adapter->rx_queue.queue_addr[adapter->rx_queue.index].correlator; in ibmveth_rxq_get_buffer()
400 u32 q_index = adapter->rx_queue.index; in ibmveth_rxq_recycle_buffer()
401 u64 correlator = adapter->rx_queue.queue_addr[q_index].correlator; in ibmveth_rxq_recycle_buffer()
426 …ibmveth_remove_buffer_from_pool(adapter, adapter->rx_queue.queue_addr[adapter->rx_queue.index].cor… in ibmveth_rxq_recycle_buffer()
430 if (++adapter->rx_queue.index == adapter->rx_queue.num_slots) { in ibmveth_rxq_recycle_buffer()
431 adapter->rx_queue.index = 0; in ibmveth_rxq_recycle_buffer()
432 adapter->rx_queue.toggle = !adapter->rx_queue.toggle; in ibmveth_rxq_recycle_buffer()
[all …]
Dibmveth.h148 struct ibmveth_rx_q rx_queue; member
/drivers/net/vmxnet3/
Dvmxnet3_ethtool.c150 drvRxStats = &adapter->rx_queue[i].stats; in vmxnet3_get_stats64()
332 base = (u8 *)&adapter->rx_queue[j].stats; in vmxnet3_get_ethtool_stats()
371 buf[j++] = adapter->rx_queue[i].rx_ring[0].next2fill; in vmxnet3_get_regs()
372 buf[j++] = adapter->rx_queue[i].rx_ring[0].next2comp; in vmxnet3_get_regs()
373 buf[j++] = adapter->rx_queue[i].rx_ring[0].gen; in vmxnet3_get_regs()
376 buf[j++] = adapter->rx_queue[i].rx_ring[1].next2fill; in vmxnet3_get_regs()
377 buf[j++] = adapter->rx_queue[i].rx_ring[1].next2comp; in vmxnet3_get_regs()
378 buf[j++] = adapter->rx_queue[i].rx_ring[1].gen; in vmxnet3_get_regs()
381 buf[j++] = adapter->rx_queue[i].comp_ring.next2proc; in vmxnet3_get_regs()
382 buf[j++] = adapter->rx_queue[i].comp_ring.gen; in vmxnet3_get_regs()
[all …]
Dvmxnet3_drv.c1370 vmxnet3_rq_cleanup(&adapter->rx_queue[i], adapter); in vmxnet3_rq_cleanup_all()
1470 err = vmxnet3_rq_init(&adapter->rx_queue[i], adapter); in vmxnet3_rq_init_all()
1534 err = vmxnet3_rq_create(&adapter->rx_queue[i], adapter); in vmxnet3_rq_create_all()
1561 rcd_done += vmxnet3_rq_rx_complete(&adapter->rx_queue[i], in vmxnet3_do_poll()
1570 struct vmxnet3_rx_queue *rx_queue = container_of(napi, in vmxnet3_poll() local
1574 rxd_done = vmxnet3_do_poll(rx_queue->adapter, budget); in vmxnet3_poll()
1578 vmxnet3_enable_all_intrs(rx_queue->adapter); in vmxnet3_poll()
1601 &adapter->tx_queue[rq - adapter->rx_queue]; in vmxnet3_poll_rx_only()
1719 napi_schedule(&adapter->rx_queue[0].napi); in vmxnet3_intr()
1735 vmxnet3_do_poll(adapter, adapter->rx_queue[0].rx_ring[0].size); in vmxnet3_netpoll()
[all …]
Dvmxnet3_int.h319 struct vmxnet3_rx_queue rx_queue[VMXNET3_DEVICE_MAX_RX_QUEUES]; member
/drivers/net/wireless/p54/
Dp54usb.c151 skb_unlink(skb, &priv->rx_queue); in p54u_rx_cb()
190 skb_queue_tail(&priv->rx_queue, skb); in p54u_rx_cb()
193 skb_unlink(skb, &priv->rx_queue); in p54u_rx_cb()
224 while (skb_queue_len(&priv->rx_queue) < 32) { in p54u_init_urbs()
243 skb_queue_tail(&priv->rx_queue, skb); in p54u_init_urbs()
248 skb_unlink(skb, &priv->rx_queue); in p54u_init_urbs()
933 skb_queue_head_init(&priv->rx_queue); in p54u_probe()
Dp54usb.h143 struct sk_buff_head rx_queue; member
/drivers/net/wireless/rtl818x/rtl8187/
Ddev.c332 spin_lock_irqsave(&priv->rx_queue.lock, f); in rtl8187_rx_cb()
333 __skb_unlink(skb, &priv->rx_queue); in rtl8187_rx_cb()
334 spin_unlock_irqrestore(&priv->rx_queue.lock, f); in rtl8187_rx_cb()
398 skb_queue_tail(&priv->rx_queue, skb); in rtl8187_rx_cb()
403 skb_unlink(skb, &priv->rx_queue); in rtl8187_rx_cb()
416 while (skb_queue_len(&priv->rx_queue) < 16) { in rtl8187_init_urbs()
435 skb_queue_tail(&priv->rx_queue, skb); in rtl8187_init_urbs()
439 skb_unlink(skb, &priv->rx_queue); in rtl8187_init_urbs()
1448 skb_queue_head_init(&priv->rx_queue); in rtl8187_probe()
/drivers/net/wireless/rtlwifi/
Dusb.c548 struct sk_buff_head rx_queue; in _rtl_rx_pre_process() local
551 skb_queue_head_init(&rx_queue); in _rtl_rx_pre_process()
553 rtlusb->usb_rx_segregate_hdl(hw, skb, &rx_queue); in _rtl_rx_pre_process()
554 WARN_ON(skb_queue_empty(&rx_queue)); in _rtl_rx_pre_process()
555 while (!skb_queue_empty(&rx_queue)) { in _rtl_rx_pre_process()
556 _skb = skb_dequeue(&rx_queue); in _rtl_rx_pre_process()
/drivers/tty/ipwireless/
Dhardware.c245 struct list_head rx_queue; member
689 list_add_tail(&packet->queue, &hw->rx_queue); in queue_received_packet()
709 while (!list_empty(&hw->rx_queue)) { in ipw_receive_data_work()
711 list_first_entry(&hw->rx_queue, in ipw_receive_data_work()
1627 INIT_LIST_HEAD(&hw->rx_queue); in ipwireless_hardware_create()
1744 list_for_each_entry_safe(rp, rq, &hw->rx_queue, queue) { in ipwireless_hardware_free()
/drivers/atm/
Deni.h100 struct sk_buff_head rx_queue; /* PDUs currently being RX-DMAed */ member
/drivers/net/ethernet/marvell/
Dmv643xx_eth.c349 struct rx_queue { struct
424 struct rx_queue rxq[8];
460 static struct mv643xx_eth_private *rxq_to_mp(struct rx_queue *rxq) in rxq_to_mp()
470 static void rxq_enable(struct rx_queue *rxq) in rxq_enable()
476 static void rxq_disable(struct rx_queue *rxq) in rxq_disable()
553 static int rxq_process(struct rx_queue *rxq, int budget) in rxq_process()
655 static int rxq_refill(struct rx_queue *rxq, int budget) in rxq_refill()
1209 struct rx_queue *rxq = mp->rxq + i; in mv643xx_eth_grab_lro_stats()
1849 struct rx_queue *rxq = mp->rxq + index; in rxq_init()
1929 static void rxq_deinit(struct rx_queue *rxq) in rxq_deinit()
[all …]
/drivers/net/phy/
Ddp83640.c106 struct sk_buff_head rx_queue; member
973 skb_queue_head_init(&dp83640->rx_queue); in dp83640_probe()
1018 while ((skb = skb_dequeue(&dp83640->rx_queue)) != NULL) in dp83640_remove()
1147 while ((skb = skb_dequeue(&dp83640->rx_queue)) != NULL) { in rx_timestamp_work()
1187 skb_queue_tail(&dp83640->rx_queue, skb); in dp83640_rxtstamp()
/drivers/net/xen-netback/
Dnetback.c87 struct sk_buff_head rx_queue; member
618 while ((skb = skb_dequeue(&netbk->rx_queue)) != NULL) { in xen_netbk_rx_action()
725 if (!skb_queue_empty(&netbk->rx_queue) && in xen_netbk_rx_action()
734 skb_queue_tail(&netbk->rx_queue, skb); in xen_netbk_queue_tx_skb()
1576 return !skb_queue_empty(&netbk->rx_queue); in rx_work_todo()
1673 skb_queue_head_init(&netbk->rx_queue); in netback_init()
/drivers/net/wireless/b43/
Dpio.c240 destroy_queue_rx(pio, rx_queue); in b43_pio_free()
277 pio->rx_queue = b43_setup_pioqueue_rx(dev, 0); in b43_pio_init()
278 if (!pio->rx_queue) in b43_pio_init()
/drivers/net/ethernet/chelsio/cxgb3/
Dadapter.h145 struct sk_buff_head rx_queue; /* offload packet receive queue */ member

12