Home
last modified time | relevance | path

Searched refs:skb_queue_empty_lockless (Results 1 – 25 of 31) sorted by relevance

12

/linux/drivers/net/wireless/silabs/wfx/
H A Dqueue.c78 return skb_queue_empty_lockless(&queue->normal) && in wfx_tx_queue_empty()
79 skb_queue_empty_lockless(&queue->cab) && in wfx_tx_queue_empty()
80 skb_queue_empty_lockless(&queue->offchan); in wfx_tx_queue_empty()
221 if (!skb_queue_empty_lockless(&wvif->tx_queue[i].cab)) in wfx_tx_queues_has_cab()
H A Dsta.c840 WARN_ON(!skb_queue_empty_lockless(&wdev->tx_pending)); in wfx_stop()
/linux/net/rxrpc/
H A Drecvmsg.c381 !skb_queue_empty_lockless(&rx->recvmsg_oobq)) { in rxrpc_recvmsg_data()
433 skb_queue_empty_lockless(&rx->recvmsg_oobq) && in rxrpc_recvmsg()
440 skb_queue_empty_lockless(&rx->recvmsg_oobq)) { in rxrpc_recvmsg()
457 skb_queue_empty_lockless(&rx->recvmsg_oobq)) { in rxrpc_recvmsg()
468 if (!skb_queue_empty_lockless(&rx->recvmsg_oobq)) { in rxrpc_recvmsg()
/linux/drivers/net/can/dev/
H A Drx-offload.c313 if (skb_queue_empty_lockless(&offload->skb_irq_queue)) in can_rx_offload_irq_finish()
334 if (skb_queue_empty_lockless(&offload->skb_irq_queue)) in can_rx_offload_threaded_irq_finish()
/linux/io_uring/
H A Dcmd_net.c122 if (skb_queue_empty_lockless(q)) in io_uring_cmd_timestamp()
/linux/net/phonet/
H A Dsocket.c346 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in pn_socket_poll()
348 if (!skb_queue_empty_lockless(&pn->ctrlreq_queue)) in pn_socket_poll()
/linux/net/core/
H A Ddatagram.c952 !skb_queue_empty_lockless(&sk->sk_error_queue)) in datagram_poll_queue()
963 if (!skb_queue_empty_lockless(rcv_queue)) in datagram_poll_queue()
H A Dsock.c4514 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in sk_busy_loop_end()
4518 !skb_queue_empty_lockless(&udp_sk(sk)->reader_queue)) in sk_busy_loop_end()
H A Dskbuff.c4035 if (skb_queue_empty_lockless(list)) in skb_queue_purge_reason()
5534 if (skb_queue_empty_lockless(q)) in sock_dequeue_err_skb()
/linux/net/netfilter/ipvs/
H A Dip_vs_sync.c1739 !skb_queue_empty_lockless(&sk->sk_receive_queue) || in sync_thread_backup()
1740 !skb_queue_empty_lockless(&up->reader_queue) || in sync_thread_backup()
1744 while (!skb_queue_empty_lockless(&sk->sk_receive_queue) || in sync_thread_backup()
1745 !skb_queue_empty_lockless(&up->reader_queue)) { in sync_thread_backup()
/linux/net/bluetooth/
H A Daf_bluetooth.c586 if (sk->sk_err || !skb_queue_empty_lockless(&sk->sk_error_queue)) in bt_sock_poll()
596 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in bt_sock_poll()
/linux/drivers/net/wireguard/
H A Dsend.c225 if (skb_queue_empty_lockless(&peer->staged_packet_queue)) { in wg_packet_send_keepalive()
/linux/net/nfc/
H A Dllcp_sock.c590 if (sk->sk_err || !skb_queue_empty_lockless(&sk->sk_error_queue)) in llcp_sock_poll()
594 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in llcp_sock_poll()
/linux/net/vmw_vsock/
H A Dvirtio_transport.c265 if (!skb_queue_empty_lockless(&vsock->send_pkt_queue) || in virtio_transport_send_pkt()
H A Daf_vsock.c1317 if (sk->sk_err || !skb_queue_empty_lockless(&sk->sk_error_queue)) in vsock_poll()
1336 if (!skb_queue_empty_lockless(&sk->sk_receive_queue) || in vsock_poll()
/linux/net/ipv4/
H A Dtcp_bpf.c197 !skb_queue_empty_lockless(&sk->sk_receive_queue), &wait); in tcp_msg_wait_data()
H A Dudp.c1905 if (!skb && !skb_queue_empty_lockless(sk_queue)) { in first_packet_length()
1975 if (skb_queue_empty_lockless(sk_queue)) { in __skb_recv_udp()
2002 } while (!skb_queue_empty_lockless(sk_queue)); in __skb_recv_udp()
3137 if (!skb_queue_empty_lockless(&udp_sk(sk)->reader_queue)) in udp_poll()
H A Dtcp.c632 !skb_queue_empty_lockless(&sk->sk_error_queue)) in tcp_poll()
2941 skb_queue_empty_lockless(&sk->sk_receive_queue) && in tcp_recvmsg()
/linux/net/atm/
H A Dcommon.c659 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in vcc_poll()
/linux/net/unix/
H A Daf_unix.c3390 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in unix_poll()
3430 !skb_queue_empty_lockless(&sk->sk_error_queue)) in unix_dgram_poll()
3440 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in unix_dgram_poll()
/linux/net/tls/
H A Dtls_main.c419 if ((skb_queue_empty_lockless(&ctx->rx_list) && in tls_sk_poll()
/linux/net/kcm/
H A Dkcmsock.c986 if (skb_queue_empty_lockless(&sk->sk_write_queue)) in kcm_splice_eof()
/linux/net/tipc/
H A Dsocket.c813 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
821 if (skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
/linux/net/sctp/
H A Dsocket.c2124 skb_queue_empty_lockless(&sk->sk_receive_queue)) in sctp_recvmsg()
8737 if (sk->sk_err || !skb_queue_empty_lockless(&sk->sk_error_queue)) in sctp_poll()
8746 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in sctp_poll()
/linux/net/netlink/
H A Daf_netlink.c367 if (skb_queue_empty_lockless(&sk->sk_receive_queue)) in netlink_rcv_wake()

12