Home
last modified time | relevance | path

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

/net/rxrpc/
A Dio_thread.c28 struct sk_buff_head *rx_queue; in rxrpc_encap_rcv() local
46 rx_queue = &local->rx_queue; in rxrpc_encap_rcv()
51 rx_queue = &local->rx_delay_queue; in rxrpc_encap_rcv()
55 skb_queue_tail(rx_queue, skb); in rxrpc_encap_rcv()
78 skb_queue_tail(&local->rx_queue, skb); in rxrpc_error_report()
452 struct sk_buff_head rx_queue; in rxrpc_io_thread() local
465 skb_queue_head_init(&rx_queue); in rxrpc_io_thread()
479 skb_queue_tail(&local->rx_queue, skb); in rxrpc_io_thread()
484 spin_lock_irq(&local->rx_queue.lock); in rxrpc_io_thread()
485 skb_queue_splice_tail_init(&local->rx_queue, &rx_queue); in rxrpc_io_thread()
[all …]
A Dconn_event.c288 skb_queue_head(&conn->local->rx_queue, skb); in rxrpc_process_event()
362 while ((skb = skb_dequeue(&conn->rx_queue))) { in rxrpc_do_process_connection()
368 skb_queue_head(&conn->rx_queue, skb); in rxrpc_do_process_connection()
402 skb_queue_tail(&conn->rx_queue, skb); in rxrpc_post_packet_to_conn()
A Dconn_object.c73 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
332 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_clean_up_connection()
347 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_clean_up_connection()
A Dlocal_object.c126 skb_queue_head_init(&local->rx_queue); in rxrpc_alloc_local()
450 rxrpc_purge_queue(&local->rx_queue); in rxrpc_destroy_local()
A Dcall_event.c323 skb = __skb_dequeue(&call->rx_queue); in rxrpc_input_call_event()
348 } while (!skb_queue_empty(&call->rx_queue)); in rxrpc_input_call_event()
A Dar-internal.h344 struct sk_buff_head rx_queue; /* Received packets */ member
559 struct sk_buff_head rx_queue; /* received conn-level packets */ member
775 struct sk_buff_head rx_queue; /* Queue of packets for this call to receive */ member
1556 __skb_queue_tail(&call->rx_queue, skb); in rxrpc_queue_rx_call_packet()
A Dcall_object.c149 skb_queue_head_init(&call->rx_queue); in rxrpc_alloc_call()
554 rxrpc_purge_queue(&call->rx_queue); in rxrpc_cleanup_rx_buffers()
A Dproc.c422 local->rx_queue.qlen); in rxrpc_local_seq_show()
/net/vmw_vsock/
A Dvirtio_transport_common.c545 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_stream_do_peek()
595 if (WARN_ONCE(skb_queue_empty(&vvs->rx_queue) && vvs->rx_bytes, in virtio_transport_stream_do_dequeue()
601 while (total < len && !skb_queue_empty(&vvs->rx_queue)) { in virtio_transport_stream_do_dequeue()
604 skb = skb_peek(&vvs->rx_queue); in virtio_transport_stream_do_dequeue()
628 __skb_unlink(skb, &vvs->rx_queue); in virtio_transport_stream_do_dequeue()
681 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_seqpacket_do_peek()
742 skb = __skb_dequeue(&vvs->rx_queue); in virtio_transport_seqpacket_do_dequeue()
927 skb_queue_head_init(&vvs->rx_queue); in virtio_transport_do_socket_init()
1195 __skb_queue_purge(&vvs->rx_queue); in virtio_transport_remove_sock()
1366 last_skb = skb_peek_tail(&vvs->rx_queue); in virtio_transport_recv_enqueue()
[all …]
/net/qrtr/
A Daf_qrtr.c135 struct sk_buff_head rx_queue; member
189 skb_queue_purge(&node->rx_queue); in __qrtr_node_release()
598 skb_queue_head_init(&node->rx_queue); in qrtr_endpoint_register()
/net/ipv6/
A Dtcp_ipv6.c2185 int rx_queue; local
2212 rx_queue = READ_ONCE(sp->sk_ack_backlog);
2217 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) -
2230 rx_queue,
/net/sched/
A Dact_skbedit.c387 entry->rx_queue = tcf_skbedit_rx_queue_mapping(act); in tcf_skbedit_offload_act_setup()
/net/mac80211/
A Dsta_info.h457 u8 rx_queue; member
A Drx.c2185 unsigned int frag, unsigned int seq, int rx_queue, in ieee80211_reassemble_add() argument
2200 entry->rx_queue = rx_queue; in ieee80211_reassemble_add()
2211 int rx_queue, struct ieee80211_hdr *hdr) in ieee80211_reassemble_find() argument
2227 entry->rx_queue != rx_queue || in ieee80211_reassemble_find()
/net/ipv4/
A Dtcp_ipv4.c2924 int rx_queue; local
2946 rx_queue = READ_ONCE(sk->sk_ack_backlog);
2951 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) -
2958 rx_queue,

Completed in 56 milliseconds