Searched refs:rx_queue (Results 1 – 10 of 10) sorted by relevance
| /net/vmw_vsock/ |
| D | virtio_transport_common.c | 316 list_for_each_entry(pkt, &vvs->rx_queue, list) { in virtio_transport_stream_do_peek()
367 while (total < len && !list_empty(&vvs->rx_queue)) { in virtio_transport_stream_do_dequeue()
368 pkt = list_first_entry(&vvs->rx_queue, in virtio_transport_stream_do_dequeue()
441 pkt = list_first_entry(&vvs->rx_queue, struct virtio_vsock_pkt, list); in virtio_transport_seqpacket_do_dequeue()
623 INIT_LIST_HEAD(&vvs->rx_queue); in virtio_transport_do_socket_init()
880 list_for_each_entry_safe(pkt, tmp, &vvs->rx_queue, list) { in virtio_transport_remove_sock()
1057 if (pkt->len <= GOOD_COPY_LEN && !list_empty(&vvs->rx_queue)) { in virtio_transport_recv_enqueue()
1060 last_pkt = list_last_entry(&vvs->rx_queue, in virtio_transport_recv_enqueue()
1080 list_add_tail(&pkt->list, &vvs->rx_queue); in virtio_transport_recv_enqueue()
|
| /net/rxrpc/ |
| D | conn_object.c | 48 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
250 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_kill_connection()
362 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_destroy_connection()
|
| D | conn_event.c | 461 while ((skb = skb_dequeue(&conn->rx_queue))) { in rxrpc_do_process_connection()
482 skb_queue_head(&conn->rx_queue, skb); in rxrpc_do_process_connection()
|
| D | ar-internal.h | 448 struct sk_buff_head rx_queue; /* received conn-level packets */ member
|
| D | input.c | 1167 skb_queue_tail(&conn->rx_queue, skb); in rxrpc_post_packet_to_conn()
|
| /net/qrtr/ |
| D | af_qrtr.c | 133 struct sk_buff_head rx_queue; member
187 skb_queue_purge(&node->rx_queue); in __qrtr_node_release()
593 skb_queue_head_init(&node->rx_queue); in qrtr_endpoint_register()
|
| /net/ipv6/ |
| D | tcp_ipv6.c | 2019 int rx_queue; in get_tcp6_sock() local
2045 rx_queue = READ_ONCE(sp->sk_ack_backlog); in get_tcp6_sock()
2050 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) - in get_tcp6_sock()
2063 rx_queue, in get_tcp6_sock()
|
| /net/mac80211/ |
| D | sta_info.h | 465 u8 rx_queue; member
|
| D | rx.c | 2163 unsigned int frag, unsigned int seq, int rx_queue, in ieee80211_reassemble_add() argument
2178 entry->rx_queue = rx_queue; in ieee80211_reassemble_add()
2189 int rx_queue, struct ieee80211_hdr *hdr) in ieee80211_reassemble_find() argument
2205 entry->rx_queue != rx_queue || in ieee80211_reassemble_find()
|
| /net/ipv4/ |
| D | tcp_ipv4.c | 2633 int rx_queue; in get_tcp4_sock() local
2654 rx_queue = READ_ONCE(sk->sk_ack_backlog); in get_tcp4_sock()
2659 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) - in get_tcp4_sock()
2666 rx_queue, in get_tcp4_sock()
|