Home
last modified time | relevance | path

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

/linux-4.4.14/drivers/net/ethernet/sfc/
Drx.c79 efx_rx_buf_next(struct efx_rx_queue *rx_queue, struct efx_rx_buffer *rx_buf) in efx_rx_buf_next() argument
81 if (unlikely(rx_buf == efx_rx_buffer(rx_queue, rx_queue->ptr_mask))) in efx_rx_buf_next()
82 return efx_rx_buffer(rx_queue, 0); in efx_rx_buf_next()
109 static struct page *efx_reuse_page(struct efx_rx_queue *rx_queue) in efx_reuse_page() argument
111 struct efx_nic *efx = rx_queue->efx; in efx_reuse_page()
116 index = rx_queue->page_remove & rx_queue->page_ptr_mask; in efx_reuse_page()
117 page = rx_queue->page_ring[index]; in efx_reuse_page()
121 rx_queue->page_ring[index] = NULL; in efx_reuse_page()
123 if (rx_queue->page_remove != rx_queue->page_add) in efx_reuse_page()
124 ++rx_queue->page_remove; in efx_reuse_page()
[all …]
Dfarch.c467 efx_farch_build_rx_desc(struct efx_rx_queue *rx_queue, unsigned index) in efx_farch_build_rx_desc() argument
472 rxd = efx_rx_desc(rx_queue, index); in efx_farch_build_rx_desc()
473 rx_buf = efx_rx_buffer(rx_queue, index); in efx_farch_build_rx_desc()
477 rx_queue->efx->type->rx_buffer_padding, in efx_farch_build_rx_desc()
485 void efx_farch_rx_write(struct efx_rx_queue *rx_queue) in efx_farch_rx_write() argument
487 struct efx_nic *efx = rx_queue->efx; in efx_farch_rx_write()
491 while (rx_queue->notified_count != rx_queue->added_count) { in efx_farch_rx_write()
493 rx_queue, in efx_farch_rx_write()
494 rx_queue->notified_count & rx_queue->ptr_mask); in efx_farch_rx_write()
495 ++rx_queue->notified_count; in efx_farch_rx_write()
[all …]
Dnic.h130 efx_rx_desc(struct efx_rx_queue *rx_queue, unsigned int index) in efx_rx_desc() argument
132 return ((efx_qword_t *) (rx_queue->rxd.buf.addr)) + index; in efx_rx_desc()
619 static inline int efx_nic_probe_rx(struct efx_rx_queue *rx_queue) in efx_nic_probe_rx() argument
621 return rx_queue->efx->type->rx_probe(rx_queue); in efx_nic_probe_rx()
623 static inline void efx_nic_init_rx(struct efx_rx_queue *rx_queue) in efx_nic_init_rx() argument
625 rx_queue->efx->type->rx_init(rx_queue); in efx_nic_init_rx()
627 static inline void efx_nic_remove_rx(struct efx_rx_queue *rx_queue) in efx_nic_remove_rx() argument
629 rx_queue->efx->type->rx_remove(rx_queue); in efx_nic_remove_rx()
631 static inline void efx_nic_notify_rx_desc(struct efx_rx_queue *rx_queue) in efx_nic_notify_rx_desc() argument
633 rx_queue->efx->type->rx_write(rx_queue); in efx_nic_notify_rx_desc()
[all …]
Defx.h43 int efx_probe_rx_queue(struct efx_rx_queue *rx_queue);
44 void efx_remove_rx_queue(struct efx_rx_queue *rx_queue);
45 void efx_init_rx_queue(struct efx_rx_queue *rx_queue);
46 void efx_fini_rx_queue(struct efx_rx_queue *rx_queue);
47 void efx_fast_push_rx_descriptors(struct efx_rx_queue *rx_queue, bool atomic);
50 void efx_rx_packet(struct efx_rx_queue *rx_queue, unsigned int index,
57 void efx_schedule_slow_fill(struct efx_rx_queue *rx_queue);
Def10.c2125 static int efx_ef10_rx_probe(struct efx_rx_queue *rx_queue) in efx_ef10_rx_probe() argument
2127 return efx_nic_alloc_buffer(rx_queue->efx, &rx_queue->rxd.buf, in efx_ef10_rx_probe()
2128 (rx_queue->ptr_mask + 1) * in efx_ef10_rx_probe()
2133 static void efx_ef10_rx_init(struct efx_rx_queue *rx_queue) in efx_ef10_rx_init() argument
2138 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in efx_ef10_rx_init()
2139 size_t entries = rx_queue->rxd.buf.len / EFX_BUF_SIZE; in efx_ef10_rx_init()
2140 struct efx_nic *efx = rx_queue->efx; in efx_ef10_rx_init()
2148 rx_queue->scatter_n = 0; in efx_ef10_rx_init()
2149 rx_queue->scatter_len = 0; in efx_ef10_rx_init()
2151 MCDI_SET_DWORD(inbuf, INIT_RXQ_IN_SIZE, rx_queue->ptr_mask + 1); in efx_ef10_rx_init()
[all …]
Dnet_driver.h463 struct efx_rx_queue rx_queue; member
1277 int (*rx_probe)(struct efx_rx_queue *rx_queue);
1278 void (*rx_init)(struct efx_rx_queue *rx_queue);
1279 void (*rx_remove)(struct efx_rx_queue *rx_queue);
1280 void (*rx_write)(struct efx_rx_queue *rx_queue);
1281 void (*rx_defer_refill)(struct efx_rx_queue *rx_queue);
1449 return channel->rx_queue.core_index >= 0; in efx_channel_has_rx_queue()
1456 return &channel->rx_queue; in efx_channel_get_rx_queue()
1464 for (_rx_queue = &(_channel)->rx_queue; \
1469 efx_rx_queue_channel(struct efx_rx_queue *rx_queue) in efx_rx_queue_channel() argument
[all …]
Defx.c261 struct efx_rx_queue *rx_queue = in efx_process_channel() local
265 efx_fast_push_rx_descriptors(rx_queue, true); in efx_process_channel()
437 struct efx_rx_queue *rx_queue; in efx_alloc_channel() local
456 rx_queue = &channel->rx_queue; in efx_alloc_channel()
457 rx_queue->efx = efx; in efx_alloc_channel()
458 setup_timer(&rx_queue->slow_fill, efx_rx_slow_fill, in efx_alloc_channel()
459 (unsigned long)rx_queue); in efx_alloc_channel()
471 struct efx_rx_queue *rx_queue; in efx_copy_channel() local
492 rx_queue = &channel->rx_queue; in efx_copy_channel()
493 rx_queue->buffer = NULL; in efx_copy_channel()
[all …]
Dmcdi.c1756 struct efx_rx_queue *rx_queue; in efx_mcdi_flush_rxqs() local
1766 efx_for_each_channel_rx_queue(rx_queue, channel) { in efx_mcdi_flush_rxqs()
1767 if (rx_queue->flush_pending) { in efx_mcdi_flush_rxqs()
1768 rx_queue->flush_pending = false; in efx_mcdi_flush_rxqs()
1772 count, efx_rx_queue_index(rx_queue)); in efx_mcdi_flush_rxqs()
Dethtool.c446 struct efx_rx_queue *rx_queue; in efx_ethtool_get_stats() local
494 efx_for_each_channel_rx_queue(rx_queue, channel) { in efx_ethtool_get_stats()
495 *data += rx_queue->rx_packets; in efx_ethtool_get_stats()
Dptp.c1310 channel->rx_queue.core_index = 0; in efx_ptp_probe_channel()
/linux-4.4.14/drivers/net/ethernet/freescale/
Dgianfar.c119 static void gfar_alloc_rx_buffs(struct gfar_priv_rx_q *rx_queue,
142 int gfar_clean_rx_ring(struct gfar_priv_rx_q *rx_queue, int rx_work_limit);
155 static void gfar_init_rxbdp(struct gfar_priv_rx_q *rx_queue, struct rxbd8 *bdp, in gfar_init_rxbdp() argument
163 if (bdp == rx_queue->rx_bd_base + rx_queue->rx_ring_size - 1) in gfar_init_rxbdp()
176 struct gfar_priv_rx_q *rx_queue = NULL; in gfar_init_bds() local
206 rx_queue = priv->rx_queue[i]; in gfar_init_bds()
208 rx_queue->next_to_clean = 0; in gfar_init_bds()
209 rx_queue->next_to_use = 0; in gfar_init_bds()
210 rx_queue->next_to_alloc = 0; in gfar_init_bds()
215 gfar_alloc_rx_buffs(rx_queue, gfar_rxbd_unused(rx_queue)); in gfar_init_bds()
[all …]
Dgianfar_ethtool.c205 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()
297 struct gfar_priv_rx_q *rx_queue = NULL; in gfar_gcoalesce() local
310 rx_queue = priv->rx_queue[0]; in gfar_gcoalesce()
313 rxtime = get_ictt_value(rx_queue->rxic); in gfar_gcoalesce()
314 rxcount = get_icft_value(rx_queue->rxic); in gfar_gcoalesce()
404 priv->rx_queue[i]->rxcoalescing = 0; in gfar_scoalesce()
407 priv->rx_queue[i]->rxcoalescing = 1; in gfar_scoalesce()
411 priv->rx_queue[i]->rxic = mk_ic_value( in gfar_scoalesce()
[all …]
Dfec_main.c231 struct fec_enet_priv_rx_q *rxq = fep->rx_queue[queue_id]; in fec_enet_get_nextdesc()
262 struct fec_enet_priv_rx_q *rxq = fep->rx_queue[queue_id]; in fec_enet_get_prevdesc()
818 rxq = fep->rx_queue[q]; in fec_enet_bd_init()
879 rxq = fep->rx_queue[i]; in fec_enet_enable_ring()
1391 rxq = fep->rx_queue[queue_id]; in fec_enet_rx_queue()
2681 rxq = fep->rx_queue[q]; in fec_enet_free_buffers()
2726 kfree(fep->rx_queue[i]); in fec_enet_free_queue()
2764 fep->rx_queue[i] = kzalloc(sizeof(*fep->rx_queue[i]), in fec_enet_alloc_queue()
2766 if (!fep->rx_queue[i]) { in fec_enet_alloc_queue()
2771 fep->rx_queue[i]->rx_ring_size = RX_RING_SIZE; in fec_enet_alloc_queue()
[all …]
Dfec.h490 struct fec_enet_priv_rx_q *rx_queue[FEC_ENET_MAX_RX_QS]; member
Dgianfar.h1086 struct gfar_priv_rx_q *rx_queue; member
1137 struct gfar_priv_rx_q *rx_queue[MAX_RX_QS]; member
/linux-4.4.14/drivers/net/ethernet/ibm/
Dibmveth.c116 return be32_to_cpu(adapter->rx_queue.queue_addr[adapter->rx_queue.index].flags_off); in ibmveth_rxq_flags()
127 return ibmveth_rxq_toggle(adapter) == adapter->rx_queue.toggle; in ibmveth_rxq_pending_buffer()
142 return be32_to_cpu(adapter->rx_queue.queue_addr[adapter->rx_queue.index].length); in ibmveth_rxq_frame_length()
405 u64 correlator = adapter->rx_queue.queue_addr[adapter->rx_queue.index].correlator; in ibmveth_rxq_get_buffer()
418 u32 q_index = adapter->rx_queue.index; in ibmveth_rxq_recycle_buffer()
419 u64 correlator = adapter->rx_queue.queue_addr[q_index].correlator; in ibmveth_rxq_recycle_buffer()
444 …ibmveth_remove_buffer_from_pool(adapter, adapter->rx_queue.queue_addr[adapter->rx_queue.index].cor… in ibmveth_rxq_recycle_buffer()
448 if (++adapter->rx_queue.index == adapter->rx_queue.num_slots) { in ibmveth_rxq_recycle_buffer()
449 adapter->rx_queue.index = 0; in ibmveth_rxq_recycle_buffer()
450 adapter->rx_queue.toggle = !adapter->rx_queue.toggle; in ibmveth_rxq_recycle_buffer()
[all …]
Dibmveth.h156 struct ibmveth_rx_q rx_queue; member
/linux-4.4.14/fs/afs/
Drxrpc.c186 ASSERT(skb_queue_empty(&call->rx_queue)); in afs_free_call()
248 skb_queue_head_init(&call->rx_queue); in afs_alloc_flat_call()
414 while ((skb = skb_dequeue(&call->rx_queue))) in afs_make_call()
446 skb_queue_tail(&call->rx_queue, skb); in afs_rx_interceptor()
469 (skb = skb_dequeue(&call->rx_queue))) { in afs_deliver_to_call()
537 while ((skb = skb_dequeue(&call->rx_queue))) in afs_deliver_to_call()
563 if (!skb_queue_empty(&call->rx_queue)) { in afs_wait_for_call_to_complete()
585 while ((skb = skb_dequeue(&call->rx_queue))) in afs_wait_for_call_to_complete()
644 if (!skb_queue_empty(&call->rx_queue)) in afs_process_async_call()
704 skb_queue_head_init(&call->rx_queue); in afs_collect_incoming_call()
Dinternal.h81 struct sk_buff_head rx_queue; /* received packets */ member
/linux-4.4.14/drivers/net/vmxnet3/
Dvmxnet3_drv.c1538 vmxnet3_rq_cleanup(&adapter->rx_queue[i], adapter); in vmxnet3_rq_cleanup_all()
1643 err = vmxnet3_rq_init(&adapter->rx_queue[i], adapter); in vmxnet3_rq_init_all()
1710 err = vmxnet3_rq_create(&adapter->rx_queue[i], adapter); in vmxnet3_rq_create_all()
1737 rcd_done += vmxnet3_rq_rx_complete(&adapter->rx_queue[i], in vmxnet3_do_poll()
1746 struct vmxnet3_rx_queue *rx_queue = container_of(napi, in vmxnet3_poll() local
1750 rxd_done = vmxnet3_do_poll(rx_queue->adapter, budget); in vmxnet3_poll()
1754 vmxnet3_enable_all_intrs(rx_queue->adapter); in vmxnet3_poll()
1777 &adapter->tx_queue[rq - adapter->rx_queue]; in vmxnet3_poll_rx_only()
1895 napi_schedule(&adapter->rx_queue[0].napi); in vmxnet3_intr()
1913 vmxnet3_msix_rx(0, &adapter->rx_queue[i]); in vmxnet3_netpoll()
[all …]
Dvmxnet3_ethtool.c150 drvRxStats = &adapter->rx_queue[i].stats; in vmxnet3_get_stats64()
335 base = (u8 *)&adapter->rx_queue[j].stats; in vmxnet3_get_ethtool_stats()
413 struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i]; in vmxnet3_get_regs()
Dvmxnet3_int.h318 struct vmxnet3_rx_queue rx_queue[VMXNET3_DEVICE_MAX_RX_QUEUES]; member
/linux-4.4.14/drivers/net/wireless/realtek/rtlwifi/
Dusb.c338 skb_queue_head_init(&rtlusb->rx_queue); in _rtl_usb_init_rx()
542 struct sk_buff_head rx_queue; in _rtl_rx_pre_process() local
545 skb_queue_head_init(&rx_queue); in _rtl_rx_pre_process()
547 rtlusb->usb_rx_segregate_hdl(hw, skb, &rx_queue); in _rtl_rx_pre_process()
548 WARN_ON(skb_queue_empty(&rx_queue)); in _rtl_rx_pre_process()
549 while (!skb_queue_empty(&rx_queue)) { in _rtl_rx_pre_process()
550 _skb = skb_dequeue(&rx_queue); in _rtl_rx_pre_process()
564 while ((skb = skb_dequeue(&rtlusb->rx_queue))) { in _rtl_rx_work()
641 qlen = skb_queue_len(&rtlusb->rx_queue); in _rtl_rx_completed()
669 skb_queue_tail(&rtlusb->rx_queue, skb); in _rtl_rx_completed()
[all …]
Dusb.h146 struct sk_buff_head rx_queue; member
/linux-4.4.14/drivers/net/phy/
Ddp83640.c130 struct sk_buff_head rx_queue; member
866 spin_lock(&dp83640->rx_queue.lock); in decode_rxts()
867 skb_queue_walk(&dp83640->rx_queue, skb) { in decode_rxts()
872 __skb_unlink(skb, &dp83640->rx_queue); in decode_rxts()
881 spin_unlock(&dp83640->rx_queue.lock); in decode_rxts()
1145 skb_queue_head_init(&dp83640->rx_queue); in dp83640_probe()
1184 skb_queue_purge(&dp83640->rx_queue); in dp83640_remove()
1380 while ((skb = skb_dequeue(&dp83640->rx_queue))) { in rx_timestamp_work()
1385 skb_queue_head(&dp83640->rx_queue, skb); in rx_timestamp_work()
1392 if (!skb_queue_empty(&dp83640->rx_queue)) in rx_timestamp_work()
[all …]
/linux-4.4.14/drivers/net/ethernet/ti/
Dnetcp_core.c603 dma = knav_queue_pop(netcp->rx_queue, &dma_sz); in netcp_empty_rx_queue()
631 dma_desc = knav_queue_pop(netcp->rx_queue, &dma_sz); in netcp_process_one_rx_packet()
909 knav_queue_enable_notify(netcp->rx_queue); in netcp_rx_poll()
919 knav_queue_disable_notify(netcp->rx_queue); in netcp_rx_notify()
1476 if (!IS_ERR_OR_NULL(netcp->rx_queue)) { in netcp_free_navigator_resources()
1477 knav_queue_close(netcp->rx_queue); in netcp_free_navigator_resources()
1478 netcp->rx_queue = NULL; in netcp_free_navigator_resources()
1549 netcp->rx_queue = knav_queue_open(name, netcp->rx_queue_id, 0); in netcp_setup_navigator_resources()
1550 if (IS_ERR_OR_NULL(netcp->rx_queue)) { in netcp_setup_navigator_resources()
1551 ret = PTR_ERR(netcp->rx_queue); in netcp_setup_navigator_resources()
[all …]
Dnetcp.h83 void *rx_queue; member
/linux-4.4.14/drivers/net/wireless/p54/
Dp54usb.c147 skb_unlink(skb, &priv->rx_queue); in p54u_rx_cb()
186 skb_queue_tail(&priv->rx_queue, skb); in p54u_rx_cb()
189 skb_unlink(skb, &priv->rx_queue); in p54u_rx_cb()
230 while (skb_queue_len(&priv->rx_queue) < 32) { in p54u_init_urbs()
249 skb_queue_tail(&priv->rx_queue, skb); in p54u_init_urbs()
254 skb_unlink(skb, &priv->rx_queue); in p54u_init_urbs()
1011 skb_queue_head_init(&priv->rx_queue); in p54u_probe()
Dp54usb.h154 struct sk_buff_head rx_queue; member
/linux-4.4.14/drivers/net/xen-netback/
Dnetback.c189 spin_lock_irqsave(&queue->rx_queue.lock, flags); in xenvif_rx_queue_tail()
191 __skb_queue_tail(&queue->rx_queue, skb); in xenvif_rx_queue_tail()
197 spin_unlock_irqrestore(&queue->rx_queue.lock, flags); in xenvif_rx_queue_tail()
204 spin_lock_irq(&queue->rx_queue.lock); in xenvif_rx_dequeue()
206 skb = __skb_dequeue(&queue->rx_queue); in xenvif_rx_dequeue()
210 spin_unlock_irq(&queue->rx_queue.lock); in xenvif_rx_dequeue()
217 spin_lock_irq(&queue->rx_queue.lock); in xenvif_rx_queue_maybe_wake()
222 spin_unlock_irq(&queue->rx_queue.lock); in xenvif_rx_queue_maybe_wake()
238 skb = skb_peek(&queue->rx_queue); in xenvif_rx_queue_drop_expired()
2008 return (!skb_queue_empty(&queue->rx_queue) in xenvif_have_rx_work()
[all …]
Dcommon.h184 struct sk_buff_head rx_queue; member
Dinterface.c485 skb_queue_head_init(&queue->rx_queue); in xenvif_init_queue()
Dxenbus.c123 skb_queue_len(&queue->rx_queue), in xenvif_read_io_ring()
/linux-4.4.14/net/irda/
Dirttp.c220 while ((skb = skb_dequeue(&self->rx_queue)) != NULL) in irttp_flush_queues()
379 skb_queue_head_init(&tsap->rx_queue); in irttp_init_tsap()
932 skb_queue_tail(&self->rx_queue, skb); in irttp_data_indication()
1650 skb_queue_head(&self->rx_queue, skb); in irttp_do_data_indication()
1675 while (!self->rx_sdu_busy && (skb = skb_dequeue(&self->rx_queue))) { in irttp_run_rx_queue()
1761 skb_queue_len(&self->rx_queue) + in irttp_run_rx_queue()
1853 skb_queue_len(&self->rx_queue)); in irttp_seq_show()
/linux-4.4.14/drivers/atm/
Deni.h100 struct sk_buff_head rx_queue; /* PDUs currently being RX-DMAed */ member
Deni.c338 skb_queue_head_init(&ENI_DEV(dev)->rx_queue); in rx_ident_err()
474 skb_queue_tail(&eni_dev->rx_queue,skb); in do_rx_dma()
736 skb = skb_dequeue(&eni_dev->rx_queue); in dequeue_rx()
756 skb_queue_head(&eni_dev->rx_queue,skb); in dequeue_rx()
919 skb_queue_head_init(&eni_dev->rx_queue); in start_rx()
/linux-4.4.14/drivers/net/wireless/realtek/rtl818x/rtl8187/
Ddev.c341 spin_lock_irqsave(&priv->rx_queue.lock, f); in rtl8187_rx_cb()
342 __skb_unlink(skb, &priv->rx_queue); in rtl8187_rx_cb()
343 spin_unlock_irqrestore(&priv->rx_queue.lock, f); in rtl8187_rx_cb()
409 skb_queue_tail(&priv->rx_queue, skb); in rtl8187_rx_cb()
414 skb_unlink(skb, &priv->rx_queue); in rtl8187_rx_cb()
427 while (skb_queue_len(&priv->rx_queue) < 32) { in rtl8187_init_urbs()
446 skb_queue_tail(&priv->rx_queue, skb); in rtl8187_init_urbs()
451 skb_unlink(skb, &priv->rx_queue); in rtl8187_init_urbs()
1464 skb_queue_head_init(&priv->rx_queue); in rtl8187_probe()
Drtl8187.h137 struct sk_buff_head rx_queue; member
/linux-4.4.14/net/rxrpc/
Dar-call.c229 skb_queue_head_init(&call->rx_queue); in rxrpc_alloc_call()
696 if (!skb_queue_empty(&call->rx_queue) || in rxrpc_release_call()
704 while ((skb = skb_dequeue(&call->rx_queue)) || in rxrpc_release_call()
888 rxrpc_purge_queue(&call->rx_queue); in rxrpc_cleanup_call()
949 if (!skb_queue_empty(&call->rx_queue)) in rxrpc_destroy_all_calls()
Dar-connevent.c277 while ((skb = skb_dequeue(&conn->rx_queue))) { in rxrpc_process_connection()
300 skb_queue_head(&conn->rx_queue, skb); in rxrpc_process_connection()
Dar-input.c266 skb_queue_tail(&call->rx_queue, skb); in rxrpc_fast_process_data()
421 skb_queue_tail(&call->rx_queue, skb); in rxrpc_fast_process_packet()
592 skb_queue_tail(&conn->rx_queue, skb); in rxrpc_post_packet_to_conn()
Dar-internal.h250 struct sk_buff_head rx_queue; /* received conn-level packets */ member
313 struct sk_buff_head rx_queue; /* received packets */ member
Dar-ack.c644 skb = skb_dequeue(&call->rx_queue); in rxrpc_process_rx_queue()
1058 if (!skb_queue_empty(&call->rx_queue)) { in rxrpc_process_call()
1318 if (call->events || !skb_queue_empty(&call->rx_queue)) { in rxrpc_process_call()
Dar-connection.c209 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
835 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_destroy_connection()
/linux-4.4.14/include/net/irda/
Dirttp.h121 struct sk_buff_head rx_queue; /* Received frames */ member
/linux-4.4.14/drivers/net/usb/
Dr8152.c602 struct sk_buff_head tx_queue, rx_queue; member
1281 skb_queue_head_init(&tp->rx_queue); in alloc_all_mem()
1677 struct list_head *cursor, *next, rx_queue; in rx_bottom() local
1680 if (!skb_queue_empty(&tp->rx_queue)) { in rx_bottom()
1682 struct sk_buff *skb = __skb_dequeue(&tp->rx_queue); in rx_bottom()
1701 INIT_LIST_HEAD(&rx_queue); in rx_bottom()
1703 list_splice_init(&tp->rx_done, &rx_queue); in rx_bottom()
1706 list_for_each_safe(cursor, next, &rx_queue) { in rx_bottom()
1758 __skb_queue_tail(&tp->rx_queue, skb); in rx_bottom()
1777 if (!list_empty(&rx_queue)) { in rx_bottom()
[all …]
/linux-4.4.14/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()
1743 list_for_each_entry_safe(rp, rq, &hw->rx_queue, queue) { in ipwireless_hardware_free()
/linux-4.4.14/drivers/staging/wilc1000/
Dwilc_wfi_netdevice.h116 struct WILC_WFI_packet *rx_queue; /* List of incoming packets */ member
/linux-4.4.14/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()
Db43.h683 struct b43_pio_rxqueue *rx_queue; member
Dmain.c2037 b43_pio_rx(dev->pio.rx_queue); in b43_do_interrupt_thread()
/linux-4.4.14/drivers/net/ethernet/marvell/
Dmv643xx_eth.c338 struct rx_queue { struct
414 struct rx_queue rxq[8];
456 static struct mv643xx_eth_private *rxq_to_mp(struct rx_queue *rxq) in rxq_to_mp()
466 static void rxq_enable(struct rx_queue *rxq) in rxq_enable()
472 static void rxq_disable(struct rx_queue *rxq) in rxq_disable()
521 static int rxq_process(struct rx_queue *rxq, int budget) in rxq_process()
613 static int rxq_refill(struct rx_queue *rxq, int budget) in rxq_refill()
1949 struct rx_queue *rxq = mp->rxq + index; in rxq_init()
2014 static void rxq_deinit(struct rx_queue *rxq) in rxq_deinit()
2390 struct rx_queue *rxq = mp->rxq + i; in port_start()
/linux-4.4.14/drivers/net/wireless/cw1200/
Dcw1200.h91 struct sk_buff_head rx_queue; member
Dtxrx.c1213 skb_queue_tail(&entry->rx_queue, skb); in cw1200_rx_cb()
1354 skb_queue_head_init(&entry->rx_queue); in cw1200_alloc_link_id()
1462 skb_queue_purge(&priv->link_id_db[i].rx_queue); in cw1200_link_id_gc_work()
Dsta.c1573 while ((skb = skb_dequeue(&entry->rx_queue))) in cw1200_sta_add()
/linux-4.4.14/drivers/net/ethernet/chelsio/cxgb3/
Dadapter.h145 struct sk_buff_head rx_queue; /* offload packet receive queue */ member
Dsge.c1789 int was_empty = skb_queue_empty(&q->rx_queue); in offload_enqueue()
1791 __skb_queue_tail(&q->rx_queue, skb); in offload_enqueue()
1844 skb_queue_splice_init(&q->rx_queue, &queue); in ofld_poll()
1871 skb_queue_splice(&queue, &q->rx_queue); in ofld_poll()
3034 skb_queue_head_init(&q->rspq.rx_queue); in t3_sge_alloc_qset()
/linux-4.4.14/drivers/net/wireless/ipw2x00/
Dipw2100.c2530 priv->rx_queue.drv[i].host_addr = packet->dma_addr; in isr_rx()
2612 priv->rx_queue.drv[i].host_addr = packet->dma_addr; in isr_rx_monitor()
2675 struct ipw2100_bd_queue *rxq = &priv->rx_queue; in __ipw2100_rx_process()
4570 err = bd_queue_allocate(priv, &priv->rx_queue, RX_QUEUE_LENGTH); in ipw2100_rx_allocate()
4579 bd_queue_free(priv, &priv->rx_queue); in ipw2100_rx_allocate()
4592 bd_queue_free(priv, &priv->rx_queue); in ipw2100_rx_allocate()
4609 priv->rx_queue.drv[i].host_addr = packet->dma_addr; in ipw2100_rx_allocate()
4610 priv->rx_queue.drv[i].buf_length = IPW_RX_NIC_BUFFER_LENGTH; in ipw2100_rx_allocate()
4627 bd_queue_free(priv, &priv->rx_queue); in ipw2100_rx_allocate()
4638 priv->rx_queue.oldest = 0; in ipw2100_rx_initialize()
[all …]
Dipw2100.h543 struct ipw2100_bd_queue rx_queue; member
/linux-4.4.14/drivers/net/ethernet/intel/igbvf/
Dnetdev.c944 static void igbvf_assign_vector(struct igbvf_adapter *adapter, int rx_queue, in igbvf_assign_vector() argument
955 if (rx_queue > IGBVF_NO_QUEUE) { in igbvf_assign_vector()
956 index = (rx_queue >> 1); in igbvf_assign_vector()
958 if (rx_queue & 0x1) { in igbvf_assign_vector()
967 adapter->rx_ring[rx_queue].eims_value = 1 << msix_vector; in igbvf_assign_vector()
/linux-4.4.14/net/ipv6/
Dtcp_ipv6.c1701 int rx_queue; in get_tcp6_sock() local
1727 rx_queue = sp->sk_ack_backlog; in get_tcp6_sock()
1732 rx_queue = max_t(int, tp->rcv_nxt - tp->copied_seq, 0); in get_tcp6_sock()
1744 rx_queue, in get_tcp6_sock()
/linux-4.4.14/net/mac80211/
Drx.c1739 unsigned int frag, unsigned int seq, int rx_queue, in ieee80211_reassemble_add() argument
1755 entry->rx_queue = rx_queue; in ieee80211_reassemble_add()
1766 int rx_queue, struct ieee80211_hdr *hdr) in ieee80211_reassemble_find() argument
1781 entry->rx_queue != rx_queue || in ieee80211_reassemble_find()
Dieee80211_i.h94 u8 rx_queue; member
/linux-4.4.14/drivers/staging/rtl8192u/
Dr8192U_core.c789 while (skb_queue_len(&priv->rx_queue) < MAX_RX_URB) { in rtl8192_rx_initiate()
806 skb_queue_tail(&priv->rx_queue, skb); in rtl8192_rx_initiate()
811 while (skb_queue_len(&priv->rx_queue) < MAX_RX_URB + 3) { in rtl8192_rx_initiate()
828 skb_queue_tail(&priv->rx_queue, skb); in rtl8192_rx_initiate()
902 while ((skb = __skb_dequeue(&priv->rx_queue))) { in rtl8192_rtx_disable()
978 skb_unlink(skb, &priv->rx_queue); in rtl8192_rx_isr()
1004 skb_queue_tail(&priv->rx_queue, skb); in rtl8192_rx_isr()
2353 skb_queue_head_init(&priv->rx_queue); in rtl8192_init_priv_variable()
Dr8192U.h911 struct sk_buff_head rx_queue; member
/linux-4.4.14/net/ipv4/
Dtcp_ipv4.c2168 int rx_queue; in get_tcp4_sock() local
2189 rx_queue = sk->sk_ack_backlog; in get_tcp4_sock()
2194 rx_queue = max_t(int, tp->rcv_nxt - tp->copied_seq, 0); in get_tcp4_sock()
2200 rx_queue, in get_tcp4_sock()
/linux-4.4.14/drivers/net/ethernet/intel/igb/
Digb_main.c799 int rx_queue = IGB_N0_QUEUE; in igb_assign_vector() local
804 rx_queue = q_vector->rx.ring->reg_idx; in igb_assign_vector()
815 if (rx_queue > IGB_N0_QUEUE) in igb_assign_vector()
816 msixbm = E1000_EICR_RX_QUEUE0 << rx_queue; in igb_assign_vector()
830 if (rx_queue > IGB_N0_QUEUE) in igb_assign_vector()
832 rx_queue & 0x7, in igb_assign_vector()
833 (rx_queue & 0x8) << 1); in igb_assign_vector()
851 if (rx_queue > IGB_N0_QUEUE) in igb_assign_vector()
853 rx_queue >> 1, in igb_assign_vector()
854 (rx_queue & 0x1) << 4); in igb_assign_vector()
/linux-4.4.14/drivers/net/ethernet/broadcom/genet/
Dbcmgenet.c2666 u32 f_index, u32 rx_queue) in bcmgenet_hfb_set_filter_rx_queue_mapping() argument
2674 reg |= ((rx_queue & 0xF) << (4 * (f_index % 8))); in bcmgenet_hfb_set_filter_rx_queue_mapping()
2740 u32 f_length, u32 rx_queue) in bcmgenet_hfb_add_filter() argument
2758 bcmgenet_hfb_set_filter_rx_queue_mapping(priv, f_index, rx_queue); in bcmgenet_hfb_add_filter()
/linux-4.4.14/drivers/net/wireless/iwlegacy/
Ddebug.c1325 DEBUGFS_READ_FILE_OPS(rx_queue);
1378 DEBUGFS_ADD_FILE(rx_queue, dir_debug, S_IRUSR); in il_dbgfs_register()
/linux-4.4.14/include/linux/
Dskbuff.h3456 static inline void skb_record_rx_queue(struct sk_buff *skb, u16 rx_queue) in skb_record_rx_queue() argument
3458 skb->queue_mapping = rx_queue + 1; in skb_record_rx_queue()
/linux-4.4.14/Documentation/nfc/
Dnfc-hci.txt250 queued to HCI rx_queue and will be dispatched from HCI rx worker
/linux-4.4.14/drivers/net/wireless/iwlwifi/pcie/
Dtrans.c2117 DEBUGFS_READ_FILE_OPS(rx_queue);
2128 DEBUGFS_ADD_FILE(rx_queue, dir, S_IRUSR); in iwl_trans_pcie_dbgfs_register()
/linux-4.4.14/drivers/net/ethernet/broadcom/bnx2x/
Dbnx2x.h583 u8 rx_queue; /* index for skb_record */ member
Dbnx2x_cmn.c755 skb_record_rx_queue(skb, fp->rx_queue); in bnx2x_gro_receive()
1085 skb_record_rx_queue(skb, fp->rx_queue); in bnx2x_rx_int()
Dbnx2x_main.c6344 fp->rx_queue = fp_idx; in bnx2x_init_eth_fp()
6447 bnx2x_fcoe(bp, rx_queue) = BNX2X_NUM_ETH_QUEUES(bp); in bnx2x_init_fcoe_fp()