Searched refs:rx_queue (Results 1 – 10 of 10) sorted by relevance
| /net/vmw_vsock/ |
| D | virtio_transport_common.c | 288 while (total < len && !list_empty(&vvs->rx_queue)) { in virtio_transport_stream_do_dequeue()
289 pkt = list_first_entry(&vvs->rx_queue, in virtio_transport_stream_do_dequeue()
434 INIT_LIST_HEAD(&vvs->rx_queue); in virtio_transport_do_socket_init()
844 list_for_each_entry_safe(pkt, tmp, &vvs->rx_queue, list) { in virtio_transport_release()
913 if (pkt->len <= GOOD_COPY_LEN && !list_empty(&vvs->rx_queue)) { in virtio_transport_recv_enqueue()
916 last_pkt = list_last_entry(&vvs->rx_queue, in virtio_transport_recv_enqueue()
931 list_add_tail(&pkt->list, &vvs->rx_queue); in virtio_transport_recv_enqueue()
|
| /net/rxrpc/ |
| D | conn_object.c | 50 skb_queue_head_init(&conn->rx_queue); in rxrpc_alloc_connection()
253 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_kill_connection()
363 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_destroy_connection()
|
| D | conn_event.c | 464 while ((skb = skb_dequeue(&conn->rx_queue))) { in rxrpc_do_process_connection()
485 skb_queue_head(&conn->rx_queue, skb); in rxrpc_do_process_connection()
|
| D | ar-internal.h | 446 struct sk_buff_head rx_queue; /* received conn-level packets */ member
|
| D | input.c | 1127 skb_queue_tail(&conn->rx_queue, skb); in rxrpc_post_packet_to_conn()
|
| /net/qrtr/ |
| D | qrtr.c | 126 struct sk_buff_head rx_queue; member
154 skb_queue_purge(&node->rx_queue); in __qrtr_node_release()
325 skb_queue_tail(&node->rx_queue, skb); in qrtr_endpoint_post()
376 while ((skb = skb_dequeue(&node->rx_queue)) != NULL) { in qrtr_node_rx_work()
438 skb_queue_head_init(&node->rx_queue); in qrtr_endpoint_register()
|
| /net/ipv6/ |
| D | tcp_ipv6.c | 1895 int rx_queue; in get_tcp6_sock() local
1921 rx_queue = sp->sk_ack_backlog; in get_tcp6_sock()
1926 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) - in get_tcp6_sock()
1939 rx_queue, in get_tcp6_sock()
|
| /net/mac80211/ |
| D | sta_info.h | 446 u8 rx_queue; member
|
| D | rx.c | 2104 unsigned int frag, unsigned int seq, int rx_queue, in ieee80211_reassemble_add() argument
2119 entry->rx_queue = rx_queue; in ieee80211_reassemble_add()
2130 int rx_queue, struct ieee80211_hdr *hdr) in ieee80211_reassemble_find() argument
2146 entry->rx_queue != rx_queue || in ieee80211_reassemble_find()
|
| /net/ipv4/ |
| D | tcp_ipv4.c | 2463 int rx_queue; in get_tcp4_sock() local
2484 rx_queue = sk->sk_ack_backlog; in get_tcp4_sock()
2489 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) - in get_tcp4_sock()
2496 rx_queue, in get_tcp4_sock()
|