Home
last modified time | relevance | path

Searched refs:reader_queue (Results 1 – 8 of 8) sorted by relevance

/openbmc/qemu/block/
H A Dgraph-lock.c48 static CoQueue reader_queue; variable
72 qemu_co_queue_init(&reader_queue); in bdrv_init_graph_lock()
158 qemu_co_enter_all(&reader_queue, &aio_context_list_lock); in bdrv_graph_wrunlock()
231 qemu_co_queue_wait(&reader_queue, &aio_context_list_lock); in bdrv_graph_co_rdlock()
/openbmc/linux/net/ipv4/
H A Dudp_bpf.c25 return !skb_queue_empty(&udp_sk(sk)->reader_queue) || in udp_sk_has_data()
H A Dudp.c1426 !skb_queue_empty(&up->reader_queue)) in udp_rmem_release()
1451 skb_queue_splice_tail_init(sk_queue, &up->reader_queue); in udp_rmem_release()
1587 skb_queue_splice_tail_init(&sk->sk_receive_queue, &up->reader_queue); in udp_destruct_common()
1588 while ((skb = __skb_dequeue(&up->reader_queue)) != NULL) { in udp_destruct_common()
1664 struct sk_buff_head *rcvq = &udp_sk(sk)->reader_queue; in first_packet_length()
1722 queue = &udp_sk(sk)->reader_queue; in __skb_recv_udp()
1910 if (!__sk_queue_drop_skb(sk, &udp_sk(sk)->reader_queue, skb, flags, in udp_recvmsg()
2882 if (!skb_queue_empty_lockless(&udp_sk(sk)->reader_queue)) in udp_poll()
/openbmc/linux/include/linux/
H A Dudp.h88 struct sk_buff_head reader_queue ____cacheline_aligned_in_smp;
/openbmc/linux/include/net/
H A Dudp.h182 skb_queue_head_init(&up->reader_queue); in udp_lib_init_sock()
/openbmc/linux/net/netfilter/ipvs/
H A Dip_vs_sync.c1721 !skb_queue_empty_lockless(&up->reader_queue) || in sync_thread_backup()
1726 !skb_queue_empty_lockless(&up->reader_queue)) { in sync_thread_backup()
/openbmc/linux/net/ipv6/
H A Dudp.c453 if (!__sk_queue_drop_skb(sk, &udp_sk(sk)->reader_queue, skb, flags, in udpv6_recvmsg()
/openbmc/linux/net/core/
H A Dsock.c4140 !skb_queue_empty_lockless(&udp_sk(sk)->reader_queue)) in sk_busy_loop_end()