| /linux-4.1.27/drivers/net/ethernet/sfc/ |
| D | rx.c | 79 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 …]
|
| D | farch.c | 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()
[all …]
|
| D | nic.h | 130 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()
686 static inline int efx_nic_probe_rx(struct efx_rx_queue *rx_queue) in efx_nic_probe_rx() argument
688 return rx_queue->efx->type->rx_probe(rx_queue); in efx_nic_probe_rx()
690 static inline void efx_nic_init_rx(struct efx_rx_queue *rx_queue) in efx_nic_init_rx() argument
692 rx_queue->efx->type->rx_init(rx_queue); in efx_nic_init_rx()
694 static inline void efx_nic_remove_rx(struct efx_rx_queue *rx_queue) in efx_nic_remove_rx() argument
696 rx_queue->efx->type->rx_remove(rx_queue); in efx_nic_remove_rx()
698 static inline void efx_nic_notify_rx_desc(struct efx_rx_queue *rx_queue) in efx_nic_notify_rx_desc() argument
700 rx_queue->efx->type->rx_write(rx_queue); in efx_nic_notify_rx_desc()
[all …]
|
| D | ef10.c | 1488 static int efx_ef10_rx_probe(struct efx_rx_queue *rx_queue) in efx_ef10_rx_probe() argument
1490 return efx_nic_alloc_buffer(rx_queue->efx, &rx_queue->rxd.buf, in efx_ef10_rx_probe()
1491 (rx_queue->ptr_mask + 1) * in efx_ef10_rx_probe()
1496 static void efx_ef10_rx_init(struct efx_rx_queue *rx_queue) in efx_ef10_rx_init() argument
1502 struct efx_channel *channel = efx_rx_queue_channel(rx_queue); in efx_ef10_rx_init()
1503 size_t entries = rx_queue->rxd.buf.len / EFX_BUF_SIZE; in efx_ef10_rx_init()
1504 struct efx_nic *efx = rx_queue->efx; in efx_ef10_rx_init()
1510 rx_queue->scatter_n = 0; in efx_ef10_rx_init()
1511 rx_queue->scatter_len = 0; in efx_ef10_rx_init()
1513 MCDI_SET_DWORD(inbuf, INIT_RXQ_IN_SIZE, rx_queue->ptr_mask + 1); in efx_ef10_rx_init()
[all …]
|
| D | efx.h | 36 int efx_probe_rx_queue(struct efx_rx_queue *rx_queue);
37 void efx_remove_rx_queue(struct efx_rx_queue *rx_queue);
38 void efx_init_rx_queue(struct efx_rx_queue *rx_queue);
39 void efx_fini_rx_queue(struct efx_rx_queue *rx_queue);
40 void efx_fast_push_rx_descriptors(struct efx_rx_queue *rx_queue, bool atomic);
43 void efx_rx_packet(struct efx_rx_queue *rx_queue, unsigned int index,
50 void efx_schedule_slow_fill(struct efx_rx_queue *rx_queue);
|
| D | net_driver.h | 473 struct efx_rx_queue rx_queue; member
1283 int (*rx_probe)(struct efx_rx_queue *rx_queue);
1284 void (*rx_init)(struct efx_rx_queue *rx_queue);
1285 void (*rx_remove)(struct efx_rx_queue *rx_queue);
1286 void (*rx_write)(struct efx_rx_queue *rx_queue);
1287 void (*rx_defer_refill)(struct efx_rx_queue *rx_queue);
1438 return channel->rx_queue.core_index >= 0; in efx_channel_has_rx_queue()
1445 return &channel->rx_queue; in efx_channel_get_rx_queue()
1453 for (_rx_queue = &(_channel)->rx_queue; \
1458 efx_rx_queue_channel(struct efx_rx_queue *rx_queue) in efx_rx_queue_channel() argument
[all …]
|
| D | efx.c | 253 struct efx_rx_queue *rx_queue = in efx_process_channel() local
257 efx_fast_push_rx_descriptors(rx_queue, true); in efx_process_channel()
421 struct efx_rx_queue *rx_queue; in efx_alloc_channel() local
440 rx_queue = &channel->rx_queue; in efx_alloc_channel()
441 rx_queue->efx = efx; in efx_alloc_channel()
442 setup_timer(&rx_queue->slow_fill, efx_rx_slow_fill, in efx_alloc_channel()
443 (unsigned long)rx_queue); in efx_alloc_channel()
455 struct efx_rx_queue *rx_queue; in efx_copy_channel() local
476 rx_queue = &channel->rx_queue; in efx_copy_channel()
477 rx_queue->buffer = NULL; in efx_copy_channel()
[all …]
|
| D | mcdi.c | 1643 struct efx_rx_queue *rx_queue; in efx_mcdi_flush_rxqs() local
1653 efx_for_each_channel_rx_queue(rx_queue, channel) { in efx_mcdi_flush_rxqs()
1654 if (rx_queue->flush_pending) { in efx_mcdi_flush_rxqs()
1655 rx_queue->flush_pending = false; in efx_mcdi_flush_rxqs()
1659 count, efx_rx_queue_index(rx_queue)); in efx_mcdi_flush_rxqs()
|
| D | ethtool.c | 446 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()
|
| D | ptp.c | 1300 channel->rx_queue.core_index = 0; in efx_ptp_probe_channel()
|
| /linux-4.1.27/drivers/net/ethernet/freescale/ |
| D | gianfar.c | 142 int gfar_clean_rx_ring(struct gfar_priv_rx_q *rx_queue, int rx_work_limit);
156 static void gfar_init_rxbdp(struct gfar_priv_rx_q *rx_queue, struct rxbd8 *bdp, in gfar_init_rxbdp() argument
164 if (bdp == rx_queue->rx_bd_base + rx_queue->rx_ring_size - 1) in gfar_init_rxbdp()
177 struct gfar_priv_rx_q *rx_queue = NULL; in gfar_init_bds() local
209 rx_queue = priv->rx_queue[i]; in gfar_init_bds()
210 rx_queue->cur_rx = rx_queue->rx_bd_base; in gfar_init_bds()
211 rx_queue->skb_currx = 0; in gfar_init_bds()
212 rxbdp = rx_queue->rx_bd_base; in gfar_init_bds()
214 for (j = 0; j < rx_queue->rx_ring_size; j++) { in gfar_init_bds()
215 struct sk_buff *skb = rx_queue->rx_skbuff[j]; in gfar_init_bds()
[all …]
|
| D | gianfar_ethtool.c | 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()
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 …]
|
| D | fec_main.c | 227 struct fec_enet_priv_rx_q *rxq = fep->rx_queue[queue_id]; in fec_enet_get_nextdesc()
258 struct fec_enet_priv_rx_q *rxq = fep->rx_queue[queue_id]; in fec_enet_get_prevdesc()
814 rxq = fep->rx_queue[q]; in fec_enet_bd_init()
875 rxq = fep->rx_queue[i]; in fec_enet_enable_ring()
1380 rxq = fep->rx_queue[queue_id]; in fec_enet_rx_queue()
2569 rxq = fep->rx_queue[q]; in fec_enet_free_buffers()
2614 kfree(fep->rx_queue[i]); in fec_enet_free_queue()
2652 fep->rx_queue[i] = kzalloc(sizeof(*fep->rx_queue[i]), in fec_enet_alloc_queue()
2654 if (!fep->rx_queue[i]) { in fec_enet_alloc_queue()
2659 fep->rx_queue[i]->rx_ring_size = RX_RING_SIZE; in fec_enet_alloc_queue()
[all …]
|
| D | fec.h | 488 struct fec_enet_priv_rx_q *rx_queue[FEC_ENET_MAX_RX_QS]; member
|
| D | gianfar.h | 1071 struct gfar_priv_rx_q *rx_queue; member
1123 struct gfar_priv_rx_q *rx_queue[MAX_RX_QS]; member
|
| /linux-4.1.27/drivers/net/ethernet/ibm/ |
| D | ibmveth.c | 108 return be32_to_cpu(adapter->rx_queue.queue_addr[adapter->rx_queue.index].flags_off); in ibmveth_rxq_flags()
119 return ibmveth_rxq_toggle(adapter) == adapter->rx_queue.toggle; in ibmveth_rxq_pending_buffer()
134 return be32_to_cpu(adapter->rx_queue.queue_addr[adapter->rx_queue.index].length); in ibmveth_rxq_frame_length()
397 u64 correlator = adapter->rx_queue.queue_addr[adapter->rx_queue.index].correlator; in ibmveth_rxq_get_buffer()
410 u32 q_index = adapter->rx_queue.index; in ibmveth_rxq_recycle_buffer()
411 u64 correlator = adapter->rx_queue.queue_addr[q_index].correlator; in ibmveth_rxq_recycle_buffer()
436 …ibmveth_remove_buffer_from_pool(adapter, adapter->rx_queue.queue_addr[adapter->rx_queue.index].cor… in ibmveth_rxq_recycle_buffer()
440 if (++adapter->rx_queue.index == adapter->rx_queue.num_slots) { in ibmveth_rxq_recycle_buffer()
441 adapter->rx_queue.index = 0; in ibmveth_rxq_recycle_buffer()
442 adapter->rx_queue.toggle = !adapter->rx_queue.toggle; in ibmveth_rxq_recycle_buffer()
[all …]
|
| D | ibmveth.h | 146 struct ibmveth_rx_q rx_queue; member
|
| /linux-4.1.27/drivers/net/vmxnet3/ |
| D | vmxnet3_ethtool.c | 150 drvRxStats = &adapter->rx_queue[i].stats; in vmxnet3_get_stats64()
333 base = (u8 *)&adapter->rx_queue[j].stats; in vmxnet3_get_ethtool_stats()
372 buf[j++] = adapter->rx_queue[i].rx_ring[0].next2fill; in vmxnet3_get_regs()
373 buf[j++] = adapter->rx_queue[i].rx_ring[0].next2comp; in vmxnet3_get_regs()
374 buf[j++] = adapter->rx_queue[i].rx_ring[0].gen; in vmxnet3_get_regs()
377 buf[j++] = adapter->rx_queue[i].rx_ring[1].next2fill; in vmxnet3_get_regs()
378 buf[j++] = adapter->rx_queue[i].rx_ring[1].next2comp; in vmxnet3_get_regs()
379 buf[j++] = adapter->rx_queue[i].rx_ring[1].gen; in vmxnet3_get_regs()
382 buf[j++] = adapter->rx_queue[i].comp_ring.next2proc; in vmxnet3_get_regs()
383 buf[j++] = adapter->rx_queue[i].comp_ring.gen; in vmxnet3_get_regs()
|
| D | vmxnet3_drv.c | 1406 vmxnet3_rq_cleanup(&adapter->rx_queue[i], adapter); in vmxnet3_rq_cleanup_all()
1511 err = vmxnet3_rq_init(&adapter->rx_queue[i], adapter); in vmxnet3_rq_init_all()
1578 err = vmxnet3_rq_create(&adapter->rx_queue[i], adapter); in vmxnet3_rq_create_all()
1605 rcd_done += vmxnet3_rq_rx_complete(&adapter->rx_queue[i], in vmxnet3_do_poll()
1614 struct vmxnet3_rx_queue *rx_queue = container_of(napi, in vmxnet3_poll() local
1618 rxd_done = vmxnet3_do_poll(rx_queue->adapter, budget); in vmxnet3_poll()
1622 vmxnet3_enable_all_intrs(rx_queue->adapter); in vmxnet3_poll()
1645 &adapter->tx_queue[rq - adapter->rx_queue]; in vmxnet3_poll_rx_only()
1763 napi_schedule(&adapter->rx_queue[0].napi); in vmxnet3_intr()
1781 vmxnet3_msix_rx(0, &adapter->rx_queue[i]); in vmxnet3_netpoll()
[all …]
|
| D | vmxnet3_int.h | 318 struct vmxnet3_rx_queue rx_queue[VMXNET3_DEVICE_MAX_RX_QUEUES]; member
|
| /linux-4.1.27/fs/afs/ |
| D | rxrpc.c | 186 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()
|
| D | internal.h | 81 struct sk_buff_head rx_queue; /* received packets */ member
|
| /linux-4.1.27/drivers/net/wireless/rtlwifi/ |
| D | usb.c | 338 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 …]
|
| D | usb.h | 146 struct sk_buff_head rx_queue; member
|
| /linux-4.1.27/drivers/net/phy/ |
| D | dp83640.c | 129 struct sk_buff_head rx_queue; member
854 spin_lock(&dp83640->rx_queue.lock); in decode_rxts()
855 skb_queue_walk(&dp83640->rx_queue, skb) { in decode_rxts()
860 __skb_unlink(skb, &dp83640->rx_queue); in decode_rxts()
869 spin_unlock(&dp83640->rx_queue.lock); in decode_rxts()
1133 skb_queue_head_init(&dp83640->rx_queue); in dp83640_probe()
1172 skb_queue_purge(&dp83640->rx_queue); in dp83640_remove()
1368 while ((skb = skb_dequeue(&dp83640->rx_queue))) { in rx_timestamp_work()
1373 skb_queue_head(&dp83640->rx_queue, skb); in rx_timestamp_work()
1380 if (!skb_queue_empty(&dp83640->rx_queue)) in rx_timestamp_work()
[all …]
|
| /linux-4.1.27/drivers/net/ethernet/ti/ |
| D | netcp_core.c | 582 dma = knav_queue_pop(netcp->rx_queue, &dma_sz); in netcp_empty_rx_queue()
610 dma_desc = knav_queue_pop(netcp->rx_queue, &dma_sz); in netcp_process_one_rx_packet()
889 knav_queue_enable_notify(netcp->rx_queue); in netcp_rx_poll()
900 knav_queue_disable_notify(netcp->rx_queue); in netcp_rx_notify()
1458 if (!IS_ERR_OR_NULL(netcp->rx_queue)) { in netcp_free_navigator_resources()
1459 knav_queue_close(netcp->rx_queue); in netcp_free_navigator_resources()
1460 netcp->rx_queue = NULL; in netcp_free_navigator_resources()
1531 netcp->rx_queue = knav_queue_open(name, netcp->rx_queue_id, 0); in netcp_setup_navigator_resources()
1532 if (IS_ERR_OR_NULL(netcp->rx_queue)) { in netcp_setup_navigator_resources()
1533 ret = PTR_ERR(netcp->rx_queue); in netcp_setup_navigator_resources()
[all …]
|
| D | netcp.h | 83 void *rx_queue; member
|
| /linux-4.1.27/drivers/net/xen-netback/ |
| D | netback.c | 178 spin_lock_irqsave(&queue->rx_queue.lock, flags); in xenvif_rx_queue_tail()
180 __skb_queue_tail(&queue->rx_queue, skb); in xenvif_rx_queue_tail()
186 spin_unlock_irqrestore(&queue->rx_queue.lock, flags); in xenvif_rx_queue_tail()
193 spin_lock_irq(&queue->rx_queue.lock); in xenvif_rx_dequeue()
195 skb = __skb_dequeue(&queue->rx_queue); in xenvif_rx_dequeue()
199 spin_unlock_irq(&queue->rx_queue.lock); in xenvif_rx_dequeue()
206 spin_lock_irq(&queue->rx_queue.lock); in xenvif_rx_queue_maybe_wake()
211 spin_unlock_irq(&queue->rx_queue.lock); in xenvif_rx_queue_maybe_wake()
227 skb = skb_peek(&queue->rx_queue); in xenvif_rx_queue_drop_expired()
1862 return (!skb_queue_empty(&queue->rx_queue) in xenvif_have_rx_work()
[all …]
|
| D | common.h | 178 struct sk_buff_head rx_queue; member
|
| D | interface.c | 471 skb_queue_head_init(&queue->rx_queue); in xenvif_init_queue()
|
| D | xenbus.c | 123 skb_queue_len(&queue->rx_queue), in xenvif_read_io_ring()
|
| /linux-4.1.27/drivers/net/wireless/p54/ |
| D | p54usb.c | 147 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()
|
| D | p54usb.h | 154 struct sk_buff_head rx_queue; member
|
| /linux-4.1.27/net/irda/ |
| D | irttp.c | 220 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.1.27/drivers/atm/ |
| D | eni.h | 100 struct sk_buff_head rx_queue; /* PDUs currently being RX-DMAed */ member
|
| D | eni.c | 338 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.1.27/drivers/net/wireless/rtl818x/rtl8187/ |
| D | dev.c | 341 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()
|
| D | rtl8187.h | 137 struct sk_buff_head rx_queue; member
|
| /linux-4.1.27/net/rxrpc/ |
| D | ar-call.c | 229 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()
|
| D | ar-connevent.c | 277 while ((skb = skb_dequeue(&conn->rx_queue))) { in rxrpc_process_connection()
300 skb_queue_head(&conn->rx_queue, skb); in rxrpc_process_connection()
|
| D | ar-input.c | 266 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()
|
| D | ar-internal.h | 250 struct sk_buff_head rx_queue; /* received conn-level packets */ member
313 struct sk_buff_head rx_queue; /* received packets */ member
|
| D | ar-ack.c | 644 skb = skb_dequeue(&call->rx_queue); in rxrpc_process_rx_queue()
1056 if (!skb_queue_empty(&call->rx_queue)) { in rxrpc_process_call()
1316 if (call->events || !skb_queue_empty(&call->rx_queue)) { in rxrpc_process_call()
|
| D | ar-connection.c | 209 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
835 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_destroy_connection()
|
| /linux-4.1.27/include/net/irda/ |
| D | irttp.h | 121 struct sk_buff_head rx_queue; /* Received frames */ member
|
| /linux-4.1.27/drivers/net/usb/ |
| D | r8152.c | 590 struct sk_buff_head tx_queue, rx_queue; member
1267 skb_queue_head_init(&tp->rx_queue); in alloc_all_mem()
1663 struct list_head *cursor, *next, rx_queue; in rx_bottom() local
1666 if (!skb_queue_empty(&tp->rx_queue)) { in rx_bottom()
1668 struct sk_buff *skb = __skb_dequeue(&tp->rx_queue); in rx_bottom()
1687 INIT_LIST_HEAD(&rx_queue); in rx_bottom()
1689 list_splice_init(&tp->rx_done, &rx_queue); in rx_bottom()
1692 list_for_each_safe(cursor, next, &rx_queue) { in rx_bottom()
1744 __skb_queue_tail(&tp->rx_queue, skb); in rx_bottom()
1763 if (!list_empty(&rx_queue)) { in rx_bottom()
[all …]
|
| /linux-4.1.27/drivers/tty/ipwireless/ |
| D | hardware.c | 245 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.1.27/drivers/net/ethernet/marvell/ |
| D | mv643xx_eth.c | 338 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()
1920 struct rx_queue *rxq = mp->rxq + index; in rxq_init()
1985 static void rxq_deinit(struct rx_queue *rxq) in rxq_deinit()
2361 struct rx_queue *rxq = mp->rxq + i; in port_start()
|
| /linux-4.1.27/drivers/net/wireless/b43/ |
| D | pio.c | 240 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()
|
| D | b43.h | 683 struct b43_pio_rxqueue *rx_queue; member
|
| D | main.c | 2037 b43_pio_rx(dev->pio.rx_queue); in b43_do_interrupt_thread()
|
| /linux-4.1.27/drivers/net/wireless/cw1200/ |
| D | cw1200.h | 91 struct sk_buff_head rx_queue; member
|
| D | txrx.c | 1213 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()
|
| D | sta.c | 1577 while ((skb = skb_dequeue(&entry->rx_queue))) in cw1200_sta_add()
|
| /linux-4.1.27/drivers/net/ethernet/chelsio/cxgb3/ |
| D | adapter.h | 145 struct sk_buff_head rx_queue; /* offload packet receive queue */ member
|
| D | sge.c | 1789 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.1.27/drivers/net/wireless/ipw2x00/ |
| D | ipw2100.c | 2530 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 …]
|
| D | ipw2100.h | 543 struct ipw2100_bd_queue rx_queue; member
|
| /linux-4.1.27/drivers/net/ethernet/intel/igbvf/ |
| D | netdev.c | 943 static void igbvf_assign_vector(struct igbvf_adapter *adapter, int rx_queue, in igbvf_assign_vector() argument
954 if (rx_queue > IGBVF_NO_QUEUE) { in igbvf_assign_vector()
955 index = (rx_queue >> 1); in igbvf_assign_vector()
957 if (rx_queue & 0x1) { in igbvf_assign_vector()
966 adapter->rx_ring[rx_queue].eims_value = 1 << msix_vector; in igbvf_assign_vector()
|
| /linux-4.1.27/net/mac80211/ |
| D | rx.c | 1710 unsigned int frag, unsigned int seq, int rx_queue, in ieee80211_reassemble_add() argument
1726 entry->rx_queue = rx_queue; in ieee80211_reassemble_add()
1737 int rx_queue, struct ieee80211_hdr *hdr) in ieee80211_reassemble_find() argument
1752 entry->rx_queue != rx_queue || in ieee80211_reassemble_find()
|
| D | ieee80211_i.h | 89 unsigned int rx_queue; member
|
| /linux-4.1.27/drivers/staging/rtl8192u/ |
| D | r8192U_core.c | 705 while (skb_queue_len(&priv->rx_queue) < MAX_RX_URB) { in rtl8192_rx_initiate()
721 skb_queue_tail(&priv->rx_queue, skb); in rtl8192_rx_initiate()
726 while (skb_queue_len(&priv->rx_queue) < MAX_RX_URB + 3) { in rtl8192_rx_initiate()
742 skb_queue_tail(&priv->rx_queue, skb); in rtl8192_rx_initiate()
816 while ((skb = __skb_dequeue(&priv->rx_queue))) { in rtl8192_rtx_disable()
890 skb_unlink(skb, &priv->rx_queue); in rtl8192_rx_isr()
915 skb_queue_tail(&priv->rx_queue, skb); in rtl8192_rx_isr()
2222 skb_queue_head_init(&priv->rx_queue); in rtl8192_init_priv_variable()
|
| D | r8192U.h | 944 struct sk_buff_head rx_queue; member
|
| /linux-4.1.27/net/ipv4/ |
| D | tcp_ipv4.c | 2199 int rx_queue; in get_tcp4_sock() local
2218 rx_queue = sk->sk_ack_backlog; in get_tcp4_sock()
2223 rx_queue = max_t(int, tp->rcv_nxt - tp->copied_seq, 0); in get_tcp4_sock()
2229 rx_queue, in get_tcp4_sock()
|
| /linux-4.1.27/drivers/net/ethernet/intel/igb/ |
| D | igb_main.c | 797 int rx_queue = IGB_N0_QUEUE; in igb_assign_vector() local
802 rx_queue = q_vector->rx.ring->reg_idx; in igb_assign_vector()
813 if (rx_queue > IGB_N0_QUEUE) in igb_assign_vector()
814 msixbm = E1000_EICR_RX_QUEUE0 << rx_queue; in igb_assign_vector()
828 if (rx_queue > IGB_N0_QUEUE) in igb_assign_vector()
830 rx_queue & 0x7, in igb_assign_vector()
831 (rx_queue & 0x8) << 1); in igb_assign_vector()
849 if (rx_queue > IGB_N0_QUEUE) in igb_assign_vector()
851 rx_queue >> 1, in igb_assign_vector()
852 (rx_queue & 0x1) << 4); in igb_assign_vector()
|
| /linux-4.1.27/drivers/net/ethernet/broadcom/genet/ |
| D | bcmgenet.c | 2477 u32 f_index, u32 rx_queue) in bcmgenet_hfb_set_filter_rx_queue_mapping() argument
2485 reg |= ((rx_queue & 0xF) << (4 * (f_index % 8))); in bcmgenet_hfb_set_filter_rx_queue_mapping()
2551 u32 f_length, u32 rx_queue) in bcmgenet_hfb_add_filter() argument
2569 bcmgenet_hfb_set_filter_rx_queue_mapping(priv, f_index, rx_queue); in bcmgenet_hfb_add_filter()
|
| /linux-4.1.27/drivers/staging/rtl8192e/rtl8192e/ |
| D | rtl_core.h | 594 struct sk_buff_head rx_queue; member
|
| D | rtl_core.c | 1207 skb_queue_head_init(&priv->rx_queue); in rtl8192_init_priv_variable()
|
| /linux-4.1.27/drivers/net/wireless/iwlegacy/ |
| D | debug.c | 1329 DEBUGFS_READ_FILE_OPS(rx_queue);
1382 DEBUGFS_ADD_FILE(rx_queue, dir_debug, S_IRUSR); in il_dbgfs_register()
|
| /linux-4.1.27/include/linux/ |
| D | skbuff.h | 3286 static inline void skb_record_rx_queue(struct sk_buff *skb, u16 rx_queue) in skb_record_rx_queue() argument
3288 skb->queue_mapping = rx_queue + 1; in skb_record_rx_queue()
|
| /linux-4.1.27/drivers/net/wireless/iwlwifi/pcie/ |
| D | trans.c | 1997 DEBUGFS_READ_FILE_OPS(rx_queue);
2008 DEBUGFS_ADD_FILE(rx_queue, dir, S_IRUSR); in iwl_trans_pcie_dbgfs_register()
|
| /linux-4.1.27/Documentation/nfc/ |
| D | nfc-hci.txt | 250 queued to HCI rx_queue and will be dispatched from HCI rx worker
|
| /linux-4.1.27/drivers/net/ethernet/broadcom/bnx2x/ |
| D | bnx2x_cmn.c | 735 skb_record_rx_queue(skb, fp->rx_queue); in bnx2x_gro_receive()
1065 skb_record_rx_queue(skb, fp->rx_queue); in bnx2x_rx_int()
|
| D | bnx2x.h | 574 u8 rx_queue; /* index for skb_record */ member
|
| D | bnx2x_main.c | 6301 fp->rx_queue = fp_idx; in bnx2x_init_eth_fp()
6404 bnx2x_fcoe(bp, rx_queue) = BNX2X_NUM_ETH_QUEUES(bp); in bnx2x_init_fcoe_fp()
|