Searched refs:rx_queue (Results 26 - 50 of 135) sorted by relevance

123456

/linux-master/net/rxrpc/
H A Dio_thread.c28 struct sk_buff_head *rx_queue; local
40 rx_queue = &local->rx_queue;
45 rx_queue = &local->rx_delay_queue;
49 skb_queue_tail(rx_queue, skb);
72 skb_queue_tail(&local->rx_queue, skb);
427 struct sk_buff_head rx_queue; local
438 skb_queue_head_init(&rx_queue);
481 if ((skb = __skb_dequeue(&rx_queue))) {
515 skb_queue_tail(&local->rx_queue, sk
[all...]
/linux-master/tools/testing/selftests/bpf/progs/
H A Dbpf_iter_tcp6.c85 int rx_queue; local
116 rx_queue = sp->sk_ack_backlog;
118 rx_queue = tp->tcp.rcv_nxt - tp->tcp.copied_seq;
119 if (rx_queue < 0)
120 rx_queue = 0;
131 tp->tcp.write_seq - tp->tcp.snd_una, rx_queue,
230 "st tx_queue rx_queue tr tm->when retrnsmt"
H A Dbpf_iter_tcp4.c85 int rx_queue; local
116 rx_queue = sp->sk_ack_backlog;
118 rx_queue = tp->rcv_nxt - tp->copied_seq;
119 if (rx_queue < 0)
120 rx_queue = 0;
127 tp->write_seq - tp->snd_una, rx_queue,
214 "st tx_queue rx_queue tr tm->when retrnsmt"
/linux-master/drivers/net/ethernet/ibm/
H A Dibmveth.c105 return be32_to_cpu(adapter->rx_queue.queue_addr[adapter->rx_queue.index].flags_off);
116 return ibmveth_rxq_toggle(adapter) == adapter->rx_queue.toggle;
136 return be32_to_cpu(adapter->rx_queue.queue_addr[adapter->rx_queue.index].length);
404 u64 correlator = adapter->rx_queue.queue_addr[adapter->rx_queue.index].correlator;
417 u32 q_index = adapter->rx_queue.index;
418 u64 correlator = adapter->rx_queue.queue_addr[q_index].correlator;
443 ibmveth_remove_buffer_from_pool(adapter, adapter->rx_queue
[all...]
/linux-master/drivers/net/ethernet/sfc/
H A Dnet_driver.h476 * @rx_queue: RX queue for this channel
540 struct efx_rx_queue rx_queue; member in struct:efx_channel
848 * @rx_queue: RX DMA queues
1425 int (*rx_probe)(struct efx_rx_queue *rx_queue);
1426 void (*rx_init)(struct efx_rx_queue *rx_queue);
1427 void (*rx_remove)(struct efx_rx_queue *rx_queue);
1428 void (*rx_write)(struct efx_rx_queue *rx_queue);
1429 void (*rx_defer_refill)(struct efx_rx_queue *rx_queue);
1616 return channel->rx_queue.core_index >= 0;
1623 return &channel->rx_queue;
1636 efx_rx_queue_channel(struct efx_rx_queue *rx_queue) argument
1641 efx_rx_queue_index(struct efx_rx_queue *rx_queue) argument
1649 efx_rx_buffer(struct efx_rx_queue *rx_queue, unsigned int index) argument
1656 efx_rx_buf_next(struct efx_rx_queue *rx_queue, struct efx_rx_buffer *rx_buf) argument
[all...]
H A Def10.c2588 efx_ef10_build_rx_desc(struct efx_rx_queue *rx_queue, unsigned int index) argument
2593 rxd = efx_rx_desc(rx_queue, index);
2594 rx_buf = efx_rx_buffer(rx_queue, index);
2600 static void efx_ef10_rx_write(struct efx_rx_queue *rx_queue) argument
2602 struct efx_nic *efx = rx_queue->efx;
2607 write_count = rx_queue->added_count & ~7;
2608 if (rx_queue->notified_count == write_count)
2613 rx_queue,
2614 rx_queue->notified_count & rx_queue
2626 efx_ef10_rx_defer_refill(struct efx_rx_queue *rx_queue) argument
2671 efx_ef10_handle_rx_wrong_queue(struct efx_rx_queue *rx_queue, unsigned int rx_queue_label) argument
2684 efx_ef10_handle_rx_bad_lbits(struct efx_rx_queue *rx_queue, unsigned int actual, unsigned int expected) argument
2698 efx_ef10_handle_rx_abort(struct efx_rx_queue *rx_queue) argument
2816 struct efx_rx_queue *rx_queue; local
[all...]
H A Dmae.h65 int efx_mae_start_counters(struct efx_nic *efx, struct efx_rx_queue *rx_queue);
66 int efx_mae_stop_counters(struct efx_nic *efx, struct efx_rx_queue *rx_queue);
/linux-master/drivers/net/ethernet/sfc/siena/
H A Dnet_driver.h484 * @rx_queue: RX queue for this channel
547 struct efx_rx_queue rx_queue; member in struct:efx_channel
816 * @rx_queue: RX DMA queues
1376 int (*rx_probe)(struct efx_rx_queue *rx_queue);
1377 void (*rx_init)(struct efx_rx_queue *rx_queue);
1378 void (*rx_remove)(struct efx_rx_queue *rx_queue);
1379 void (*rx_write)(struct efx_rx_queue *rx_queue);
1380 void (*rx_defer_refill)(struct efx_rx_queue *rx_queue);
1569 return channel->rx_queue.core_index >= 0;
1576 return &channel->rx_queue;
1589 efx_rx_queue_channel(struct efx_rx_queue *rx_queue) argument
1594 efx_rx_queue_index(struct efx_rx_queue *rx_queue) argument
1602 efx_rx_buffer(struct efx_rx_queue *rx_queue, unsigned int index) argument
1609 efx_rx_buf_next(struct efx_rx_queue *rx_queue, struct efx_rx_buffer *rx_buf) argument
[all...]
/linux-master/drivers/net/xen-netback/
H A Drx.c90 spin_lock_irqsave(&queue->rx_queue.lock, flags);
98 if (skb_queue_empty(&queue->rx_queue))
101 __skb_queue_tail(&queue->rx_queue, skb);
106 spin_unlock_irqrestore(&queue->rx_queue.lock, flags);
115 spin_lock_irq(&queue->rx_queue.lock);
117 skb = __skb_dequeue(&queue->rx_queue);
119 xenvif_update_needed_slots(queue, skb_peek(&queue->rx_queue));
130 spin_unlock_irq(&queue->rx_queue.lock);
148 skb = skb_peek(&queue->rx_queue);
500 !skb_queue_empty(&queue->rx_queue)
[all...]
/linux-master/drivers/net/wan/
H A Dhdlc_x25.c28 struct sk_buff_head rx_queue; member in struct:x25_state
42 struct sk_buff *skb = skb_dequeue(&x25st->rx_queue);
46 skb = skb_dequeue(&x25st->rx_queue);
67 skb_queue_tail(&x25st->rx_queue, skb);
98 skb_queue_tail(&x25st->rx_queue, skb);
348 skb_queue_head_init(&state(hdlc)->rx_queue);
H A Dlapbether.c57 struct sk_buff_head rx_queue; member in struct:lapbethdev
96 skb = skb_dequeue(&lapbeth->rx_queue);
177 skb_queue_tail(&lapbeth->rx_queue, skb);
276 skb_queue_tail(&lapbeth->rx_queue, skb);
294 skb_queue_tail(&lapbeth->rx_queue, skb);
414 skb_queue_head_init(&lapbeth->rx_queue);
/linux-master/drivers/net/wireguard/
H A Dpeer.h39 struct prev_queue tx_queue, rx_queue; member in struct:wg_peer
/linux-master/drivers/net/wireless/realtek/rtw88/
H A Dusb.h83 struct sk_buff_head rx_queue; member in struct:rtw_usb
/linux-master/drivers/net/ethernet/sfc/falcon/
H A Defx.c247 struct ef4_rx_queue *rx_queue = local
251 ef4_fast_push_rx_descriptors(rx_queue, true);
422 struct ef4_rx_queue *rx_queue; local
441 rx_queue = &channel->rx_queue;
442 rx_queue->efx = efx;
443 timer_setup(&rx_queue->slow_fill, ef4_rx_slow_fill, 0);
455 struct ef4_rx_queue *rx_queue; local
479 rx_queue = &channel->rx_queue;
490 struct ef4_rx_queue *rx_queue; local
592 struct ef4_rx_queue *rx_queue; local
683 struct ef4_rx_queue *rx_queue; local
736 struct ef4_rx_queue *rx_queue; local
773 struct ef4_rx_queue *rx_queue; local
863 ef4_schedule_slow_fill(struct ef4_rx_queue *rx_queue) argument
[all...]
/linux-master/arch/um/drivers/
H A Dvector_kern.h88 struct vector_queue *rx_queue; member in struct:vector_private
/linux-master/drivers/net/dsa/hirschmann/
H A Dhellcreek_hwtstamp.c337 skb = skb_dequeue(&ps->rx_queue);
339 hellcreek_get_rxts(hellcreek, ps, skb, &ps->rx_queue, port);
433 skb_queue_tail(&ps->rx_queue, skb);
445 skb_queue_head_init(&ps->rx_queue);
/linux-master/drivers/net/wireless/realtek/rtlwifi/
H A Dusb.c228 skb_queue_head_init(&rtlusb->rx_queue);
448 struct sk_buff_head rx_queue; local
451 skb_queue_head_init(&rx_queue);
453 rtlusb->usb_rx_segregate_hdl(hw, skb, &rx_queue);
454 WARN_ON(skb_queue_empty(&rx_queue));
455 while (!skb_queue_empty(&rx_queue)) {
456 _skb = skb_dequeue(&rx_queue);
470 while ((skb = skb_dequeue(&rtlusb->rx_queue))) {
544 qlen = skb_queue_len(&rtlusb->rx_queue);
570 skb_queue_tail(&rtlusb->rx_queue, sk
[all...]
H A Dusb.h123 struct sk_buff_head rx_queue; member in struct:rtl_usb
/linux-master/drivers/net/ethernet/freescale/
H A Dgianfar_ethtool.c253 struct gfar_priv_rx_q *rx_queue = NULL; local
266 rx_queue = priv->rx_queue[0];
269 rxtime = get_ictt_value(rx_queue->rxic);
270 rxcount = get_icft_value(rx_queue->rxic);
333 priv->rx_queue[i]->rxcoalescing = 0;
336 priv->rx_queue[i]->rxcoalescing = 1;
340 priv->rx_queue[i]->rxic = mk_ic_value(
383 struct gfar_priv_rx_q *rx_queue = NULL; local
386 rx_queue
[all...]
/linux-master/drivers/net/ethernet/qlogic/qed/
H A Dqed_ll2.c41 #define QED_LL2_RX_REGISTERED(ll2) ((ll2)->rx_queue.b_cb_registered)
452 struct qed_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
487 struct qed_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
529 struct qed_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
592 p_rx = &p_ll2_conn->rx_queue;
649 struct qed_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
963 struct qed_ll2_rx_queue *p_rx = &p_ll2_conn->rx_queue;
1191 rc = qed_chain_alloc(cdev, &p_ll2_info->rx_queue.rxq_chain, &params);
1197 capacity = qed_chain_get_capacity(&p_ll2_info->rx_queue.rxq_chain);
1205 p_ll2_info->rx_queue
[all...]
H A Dqed_ll2.h114 struct qed_ll2_rx_queue rx_queue; member in struct:qed_ll2_info
/linux-master/net/vmw_vsock/
H A Dvirtio_transport_common.c517 skb_queue_walk(&vvs->rx_queue, skb) {
567 if (WARN_ONCE(skb_queue_empty(&vvs->rx_queue) && vvs->rx_bytes,
568 "rx_queue is empty, but rx_bytes is non-zero\n")) {
573 while (total < len && !skb_queue_empty(&vvs->rx_queue)) {
574 skb = skb_peek(&vvs->rx_queue);
600 __skb_unlink(skb, &vvs->rx_queue);
651 skb_queue_walk(&vvs->rx_queue, skb) {
712 skb = __skb_dequeue(&vvs->rx_queue);
897 skb_queue_head_init(&vvs->rx_queue);
1149 __skb_queue_purge(&vvs->rx_queue);
[all...]
/linux-master/drivers/net/vmxnet3/
H A Dvmxnet3_drv.c1967 vmxnet3_rq_cleanup(&adapter->rx_queue[i], adapter);
2028 struct vmxnet3_rx_queue *rq = &adapter->rx_queue[i];
2113 err = vmxnet3_rq_init(&adapter->rx_queue[i], adapter);
2197 err = vmxnet3_rq_create(&adapter->rx_queue[i], adapter);
2228 rcd_done += vmxnet3_rq_rx_complete(&adapter->rx_queue[i],
2237 struct vmxnet3_rx_queue *rx_queue = container_of(napi, local
2241 rxd_done = vmxnet3_do_poll(rx_queue->adapter, budget);
2245 vmxnet3_enable_all_intrs(rx_queue->adapter);
2268 &adapter->tx_queue[rq - adapter->rx_queue];
2386 napi_schedule(&adapter->rx_queue[
[all...]
/linux-master/drivers/atm/
H A Deni.h101 struct sk_buff_head rx_queue; /* PDUs currently being RX-DMAed */ member in struct:eni_dev
/linux-master/drivers/net/wireless/intersil/p54/
H A Dp54usb.h151 struct sk_buff_head rx_queue; member in struct:p54u_priv

Completed in 445 milliseconds

123456