Home
last modified time | relevance | path

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

/net/rxrpc/
Dio_thread.c28 struct sk_buff_head *rx_queue; in rxrpc_encap_rcv() local
40 rx_queue = &local->rx_queue; in rxrpc_encap_rcv()
45 rx_queue = &local->rx_delay_queue; in rxrpc_encap_rcv()
49 skb_queue_tail(rx_queue, skb); in rxrpc_encap_rcv()
72 skb_queue_tail(&local->rx_queue, skb); in rxrpc_error_report()
416 struct sk_buff_head rx_queue; in rxrpc_io_thread() local
427 skb_queue_head_init(&rx_queue); in rxrpc_io_thread()
470 if ((skb = __skb_dequeue(&rx_queue))) { in rxrpc_io_thread()
504 skb_queue_tail(&local->rx_queue, skb); in rxrpc_io_thread()
508 if (!skb_queue_empty(&local->rx_queue)) { in rxrpc_io_thread()
[all …]
Dconn_event.c267 skb_queue_head(&conn->local->rx_queue, skb); in rxrpc_process_event()
341 while ((skb = skb_dequeue(&conn->rx_queue))) { in rxrpc_do_process_connection()
347 skb_queue_head(&conn->rx_queue, skb); in rxrpc_do_process_connection()
381 skb_queue_tail(&conn->rx_queue, skb); in rxrpc_post_packet_to_conn()
Dconn_object.c71 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
323 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_clean_up_connection()
337 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_clean_up_connection()
Dlocal_object.c126 skb_queue_head_init(&local->rx_queue); in rxrpc_alloc_local()
453 rxrpc_purge_queue(&local->rx_queue); in rxrpc_destroy_local()
Dar-internal.h298 struct sk_buff_head rx_queue; /* Received packets */ member
498 struct sk_buff_head rx_queue; /* received conn-level packets */ member
Dproc.c351 local->rx_queue.qlen); in rxrpc_local_seq_show()
/net/vmw_vsock/
Dvirtio_transport_common.c363 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_stream_do_peek()
412 if (WARN_ONCE(skb_queue_empty(&vvs->rx_queue) && vvs->rx_bytes, in virtio_transport_stream_do_dequeue()
418 while (total < len && !skb_queue_empty(&vvs->rx_queue)) { in virtio_transport_stream_do_dequeue()
419 skb = skb_peek(&vvs->rx_queue); in virtio_transport_stream_do_dequeue()
443 __skb_unlink(skb, &vvs->rx_queue); in virtio_transport_stream_do_dequeue()
494 skb_queue_walk(&vvs->rx_queue, skb) { in virtio_transport_seqpacket_do_peek()
554 skb = __skb_dequeue(&vvs->rx_queue); in virtio_transport_seqpacket_do_dequeue()
737 skb_queue_head_init(&vvs->rx_queue); in virtio_transport_do_socket_init()
989 __skb_queue_purge(&vvs->rx_queue); in virtio_transport_remove_sock()
1165 if (len <= GOOD_COPY_LEN && !skb_queue_empty(&vvs->rx_queue)) { in virtio_transport_recv_enqueue()
[all …]
/net/qrtr/
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/
Dtcp_ipv6.c2002 int rx_queue; in get_tcp6_sock() local
2028 rx_queue = READ_ONCE(sp->sk_ack_backlog); in get_tcp6_sock()
2033 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) - in get_tcp6_sock()
2046 rx_queue, in get_tcp6_sock()
/net/sched/
Dact_skbedit.c389 entry->rx_queue = tcf_skbedit_rx_queue_mapping(act); in tcf_skbedit_offload_act_setup()
/net/mac80211/
Dsta_info.h460 u8 rx_queue; member
Drx.c2141 unsigned int frag, unsigned int seq, int rx_queue, in ieee80211_reassemble_add() argument
2156 entry->rx_queue = rx_queue; in ieee80211_reassemble_add()
2167 int rx_queue, struct ieee80211_hdr *hdr) in ieee80211_reassemble_find() argument
2183 entry->rx_queue != rx_queue || in ieee80211_reassemble_find()
/net/ipv4/
Dtcp_ipv4.c2681 int rx_queue; in get_tcp4_sock() local
2702 rx_queue = READ_ONCE(sk->sk_ack_backlog); in get_tcp4_sock()
2707 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) - in get_tcp4_sock()
2714 rx_queue, in get_tcp4_sock()