| /linux-3.4.99/drivers/net/ethernet/sfc/ |
| D | rx.c | 137 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 …]
|
| D | nic.c | 535 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 …]
|
| D | efx.h | 36 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);
|
| D | net_driver.h | 386 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()
|
| D | efx.c | 232 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 …]
|
| D | nic.h | 274 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);
|
| D | mcdi.c | 1167 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()
|
| /linux-3.4.99/drivers/net/ethernet/freescale/ |
| D | gianfar.c | 116 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 …]
|
| D | gianfar_ethtool.c | 48 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 …]
|
| /linux-3.4.99/drivers/net/ethernet/ibm/ |
| D | ibmveth.c | 109 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 …]
|
| D | ibmveth.h | 148 struct ibmveth_rx_q rx_queue; member
|
| /linux-3.4.99/drivers/net/vmxnet3/ |
| D | vmxnet3_ethtool.c | 150 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 …]
|
| D | vmxnet3_drv.c | 1370 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()
1737 vmxnet3_msix_rx(0, &adapter->rx_queue[i]); in vmxnet3_netpoll()
[all …]
|
| /linux-3.4.99/fs/afs/ |
| D | rxrpc.c | 179 ASSERT(skb_queue_empty(&call->rx_queue)); in afs_free_call()
219 skb_queue_head_init(&call->rx_queue); in afs_alloc_flat_call()
384 while ((skb = skb_dequeue(&call->rx_queue))) in afs_make_call()
419 skb_queue_tail(&call->rx_queue, skb); in afs_rx_interceptor()
442 (skb = skb_dequeue(&call->rx_queue))) { in afs_deliver_to_call()
510 while ((skb = skb_dequeue(&call->rx_queue))) in afs_deliver_to_call()
540 if (!skb_queue_empty(&call->rx_queue)) { in afs_wait_for_call_to_complete()
562 while ((skb = skb_dequeue(&call->rx_queue))) in afs_wait_for_call_to_complete()
630 if (!skb_queue_empty(&call->rx_queue)) in afs_process_async_call()
692 skb_queue_head_init(&call->rx_queue); in afs_collect_incoming_call()
|
| /linux-3.4.99/drivers/net/wireless/p54/ |
| D | p54usb.c | 151 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()
|
| D | p54usb.h | 143 struct sk_buff_head rx_queue; member
|
| /linux-3.4.99/net/irda/ |
| D | irttp.c | 220 while ((skb = skb_dequeue(&self->rx_queue)) != NULL) in irttp_flush_queues()
382 skb_queue_head_init(&tsap->rx_queue); in irttp_init_tsap()
944 skb_queue_tail(&self->rx_queue, skb); in irttp_data_indication()
1672 skb_queue_head(&self->rx_queue, skb); in irttp_do_data_indication()
1697 while (!self->rx_sdu_busy && (skb = skb_dequeue(&self->rx_queue))) { in irttp_run_rx_queue()
1784 skb_queue_len(&self->rx_queue) + in irttp_run_rx_queue()
1876 skb_queue_len(&self->rx_queue)); in irttp_seq_show()
|
| /linux-3.4.99/net/rxrpc/ |
| D | ar-call.c | 80 skb_queue_head_init(&call->rx_queue); in rxrpc_alloc_call()
502 if (!skb_queue_empty(&call->rx_queue) || in rxrpc_release_call()
510 while ((skb = skb_dequeue(&call->rx_queue)) || in rxrpc_release_call()
691 rxrpc_purge_queue(&call->rx_queue); in rxrpc_cleanup_call()
752 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()
|
| /linux-3.4.99/drivers/net/wireless/rtl818x/rtl8187/ |
| D | dev.c | 332 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()
|
| /linux-3.4.99/drivers/atm/ |
| D | eni.h | 100 struct sk_buff_head rx_queue; /* PDUs currently being RX-DMAed */ member
|
| /linux-3.4.99/drivers/net/wireless/rtlwifi/ |
| D | usb.c | 548 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()
|
| /linux-3.4.99/include/net/irda/ |
| D | irttp.h | 121 struct sk_buff_head rx_queue; /* Received frames */ member
|
| /linux-3.4.99/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()
1744 list_for_each_entry_safe(rp, rq, &hw->rx_queue, queue) { in ipwireless_hardware_free()
|
| /linux-3.4.99/drivers/net/ethernet/marvell/ |
| D | mv643xx_eth.c | 349 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()
1847 struct rx_queue *rxq = mp->rxq + index; in rxq_init()
1927 static void rxq_deinit(struct rx_queue *rxq) in rxq_deinit()
[all …]
|