| /Linux-v4.19/net/unix/ |
| D | garbage.c | 166 spin_lock(&x->sk_receive_queue.lock); in scan_inflight()
167 skb_queue_walk_safe(&x->sk_receive_queue, skb, next) { in scan_inflight()
194 __skb_unlink(skb, &x->sk_receive_queue); in scan_inflight()
199 spin_unlock(&x->sk_receive_queue.lock); in scan_inflight()
216 spin_lock(&x->sk_receive_queue.lock); in scan_children()
217 skb_queue_walk_safe(&x->sk_receive_queue, skb, next) { in scan_children()
226 spin_unlock(&x->sk_receive_queue.lock); in scan_children()
|
| D | diag.c | 64 spin_lock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
67 sk->sk_receive_queue.qlen * sizeof(u32)); in sk_diag_dump_icons()
73 skb_queue_walk(&sk->sk_receive_queue, skb) { in sk_diag_dump_icons()
87 spin_unlock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
93 spin_unlock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
102 rql.udiag_rqueue = sk->sk_receive_queue.qlen; in sk_diag_show_rqlen()
|
| D | af_unix.c | 197 return skb_queue_len(&sk->sk_receive_queue) > sk->sk_max_ack_backlog; in unix_recvq_full()
474 if (!skb_queue_empty(&sk->sk_receive_queue)) { in unix_dgram_disconnected()
475 skb_queue_purge(&sk->sk_receive_queue); in unix_dgram_disconnected()
493 skb_queue_purge(&sk->sk_receive_queue); in unix_sock_destructor()
546 if (!skb_queue_empty(&sk->sk_receive_queue) || embrion) in unix_release_sock()
560 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) { in unix_release_sock()
1355 spin_lock(&other->sk_receive_queue.lock); in unix_stream_connect()
1356 __skb_queue_tail(&other->sk_receive_queue, skb); in unix_stream_connect()
1357 spin_unlock(&other->sk_receive_queue.lock); in unix_stream_connect()
1802 skb_queue_tail(&other->sk_receive_queue, skb); in unix_dgram_sendmsg()
[all …]
|
| /Linux-v4.19/net/atm/ |
| D | signaling.c | 33 skb_queue_tail(&sk_atm(sigd)->sk_receive_queue, skb); in sigd_put_skb()
113 skb_queue_tail(&sk->sk_receive_queue, skb); in sigd_send()
204 if (skb_peek(&sk_atm(vcc)->sk_receive_queue)) in sigd_close()
206 skb_queue_purge(&sk_atm(vcc)->sk_receive_queue); in sigd_close()
|
| D | raw.c | 28 skb_queue_tail(&sk->sk_receive_queue, skb); in atm_push_raw()
|
| /Linux-v4.19/net/bluetooth/ |
| D | af_bluetooth.c | 298 if (!skb_queue_empty(&sk->sk_receive_queue)) in bt_sock_data_wait()
341 skb = skb_dequeue(&sk->sk_receive_queue); in bt_sock_stream_recvmsg()
367 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
406 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
413 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
463 if (!skb_queue_empty(&sk->sk_receive_queue)) in bt_sock_poll()
508 skb = skb_peek(&sk->sk_receive_queue); in bt_sock_ioctl()
|
| /Linux-v4.19/net/sctp/ |
| D | ulpqueue.c | 152 &sk->sk_receive_queue); in sctp_clear_pd()
169 __skb_queue_tail(&sk->sk_receive_queue, in sctp_clear_pd()
231 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
245 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
254 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
275 if (queue == &sk->sk_receive_queue && !sp->data_ready_signalled) { in sctp_ulpq_tail_event()
1103 if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) { in sctp_ulpq_renege()
1146 __skb_queue_tail(&sk->sk_receive_queue, sctp_event2skb(ev)); in sctp_ulpq_abort_pd()
|
| /Linux-v4.19/net/caif/ |
| D | caif_socket.c | 128 struct sk_buff_head *list = &sk->sk_receive_queue; in caif_queue_rcv_skb()
317 if (!skb_queue_empty(&sk->sk_receive_queue) || in caif_stream_data_wait()
381 skb = skb_dequeue(&sk->sk_receive_queue); in caif_stream_recvmsg()
426 skb_queue_head(&sk->sk_receive_queue, skb); in caif_stream_recvmsg()
440 skb_queue_head(&sk->sk_receive_queue, skb); in caif_stream_recvmsg()
450 skb_queue_head(&sk->sk_receive_queue, skb); in caif_stream_recvmsg()
913 spin_lock_bh(&sk->sk_receive_queue.lock); in caif_release()
915 spin_unlock_bh(&sk->sk_receive_queue.lock); in caif_release()
956 if (!skb_queue_empty(&sk->sk_receive_queue) || in caif_poll()
|
| /Linux-v4.19/net/phonet/ |
| D | datagram.c | 52 skb = skb_peek(&sk->sk_receive_queue); in pn_ioctl()
77 skb_queue_purge(&sk->sk_receive_queue); in pn_destruct()
|
| D | pep.c | 418 queue = &sk->sk_receive_queue; in pipe_do_rcv()
477 skb_queue_purge(&sk->sk_receive_queue); in pipe_destruct()
590 skb_queue_tail(&sk->sk_receive_queue, skb); in pipe_handler_do_rcv()
697 skb_queue_head(&sk->sk_receive_queue, skb); in pep_do_rcv()
948 else if (!skb_queue_empty(&sk->sk_receive_queue)) in pep_ioctl()
949 answ = skb_peek(&sk->sk_receive_queue)->len; in pep_ioctl()
1243 struct sk_buff *skb = skb_dequeue(&sk->sk_receive_queue); in pep_read()
|
| /Linux-v4.19/net/kcm/ |
| D | kcmproc.c | 119 kcm->sk.sk_receive_queue.qlen, in kcm_format_sock()
149 psock->sk->sk_receive_queue.qlen, in kcm_format_psock()
167 if (psock->sk->sk_receive_queue.qlen) { in kcm_format_psock()
|
| D | kcmsock.c | 193 struct sk_buff_head *list = &sk->sk_receive_queue; in kcm_queue_rcv_skb()
334 requeue_rx_msgs(mux, &kcm->sk.sk_receive_queue); in unreserve_rx_kcm()
1088 while (!(skb = skb_peek(&sk->sk_receive_queue))) { in kcm_wait_data()
1160 skb_unlink(skb, &sk->sk_receive_queue); in kcm_recvmsg()
1246 requeue_rx_msgs(mux, &kcm->sk.sk_receive_queue); in kcm_recv_disable()
1800 requeue_rx_msgs(mux, &sk->sk_receive_queue); in kcm_done()
|
| /Linux-v4.19/net/core/ |
| D | datagram.c | 98 if (sk->sk_receive_queue.prev != skb) in __skb_wait_for_more_packets()
250 struct sk_buff_head *queue = &sk->sk_receive_queue; in __skb_try_recv_datagram()
282 } while (!skb_queue_empty(&sk->sk_receive_queue)); in __skb_try_recv_datagram()
402 int err = __sk_queue_drop_skb(sk, &sk->sk_receive_queue, skb, flags, in skb_kill_datagram()
854 if (!skb_queue_empty(&sk->sk_receive_queue)) in datagram_poll()
|
| D | stream.c | 194 __skb_queue_purge(&sk->sk_receive_queue); in sk_stream_kill_queues()
|
| /Linux-v4.19/drivers/crypto/chelsio/chtls/ |
| D | chtls_cm.h | 180 __skb_unlink(skb, &sk->sk_receive_queue); in chtls_free_skb()
187 __skb_unlink(skb, &sk->sk_receive_queue); in chtls_kfree_skb()
|
| D | chtls_io.c | 1443 skb = skb_peek(&sk->sk_receive_queue); in chtls_pt_recvmsg()
1500 __skb_unlink(skb, &sk->sk_receive_queue); in chtls_pt_recvmsg()
1561 !skb_peek(&sk->sk_receive_queue)) in chtls_pt_recvmsg()
1600 skb_queue_walk(&sk->sk_receive_queue, skb) { in peekmsg()
1719 skb_queue_empty(&sk->sk_receive_queue) && in chtls_recvmsg()
1752 skb = skb_peek(&sk->sk_receive_queue); in chtls_recvmsg()
1865 !skb_peek(&sk->sk_receive_queue)) in chtls_recvmsg()
|
| /Linux-v4.19/net/rxrpc/ |
| D | af_rxrpc.c | 832 spin_lock_bh(&sk->sk_receive_queue.lock); in rxrpc_shutdown()
839 spin_unlock_bh(&sk->sk_receive_queue.lock); in rxrpc_shutdown()
854 rxrpc_purge_queue(&sk->sk_receive_queue); in rxrpc_sock_destructor()
893 spin_lock_bh(&sk->sk_receive_queue.lock); in rxrpc_release_sock()
895 spin_unlock_bh(&sk->sk_receive_queue.lock); in rxrpc_release_sock()
907 rxrpc_purge_queue(&sk->sk_receive_queue); in rxrpc_release_sock()
|
| /Linux-v4.19/net/llc/ |
| D | af_llc.c | 680 if (skb_queue_empty(&sk->sk_receive_queue)) { in llc_ui_accept()
687 skb = skb_dequeue(&sk->sk_receive_queue); in llc_ui_accept()
774 skb = skb_peek(&sk->sk_receive_queue); in llc_ui_recvmsg()
858 spin_lock_irqsave(&sk->sk_receive_queue.lock, cpu_flags); in llc_ui_recvmsg()
860 spin_unlock_irqrestore(&sk->sk_receive_queue.lock, cpu_flags); in llc_ui_recvmsg()
881 spin_lock_irqsave(&sk->sk_receive_queue.lock, cpu_flags); in llc_ui_recvmsg()
883 spin_unlock_irqrestore(&sk->sk_receive_queue.lock, cpu_flags); in llc_ui_recvmsg()
|
| /Linux-v4.19/net/tipc/ |
| D | socket.c | 237 kfree_skb(__skb_dequeue(&sk->sk_receive_queue)); in tsk_advance_rx_queue()
265 while ((skb = __skb_dequeue(&sk->sk_receive_queue))) in tsk_rej_rx_queue()
513 while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) { in __tipc_shutdown()
732 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_poll()
740 if (skb_queue_empty(&sk->sk_receive_queue)) in tipc_poll()
1659 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_rcvmsg()
1669 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_rcvmsg()
1727 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
1836 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
1893 } while (!skb_queue_empty(&sk->sk_receive_queue) || copied < required); in tipc_recvstream()
[all …]
|
| /Linux-v4.19/drivers/xen/ |
| D | pvcalls-back.c | 124 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
125 if (skb_queue_empty(&map->sock->sk->sk_receive_queue)) { in pvcalls_conn_back_read()
127 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, in pvcalls_conn_back_read()
131 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
156 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
157 if (ret > 0 && !skb_queue_empty(&map->sock->sk->sk_receive_queue)) in pvcalls_conn_back_read()
159 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
|
| /Linux-v4.19/net/packet/ |
| D | af_packet.c | 650 spin_lock(&po->sk.sk_receive_queue.lock); in prb_retire_rx_blk_timer_expired()
713 spin_unlock(&po->sk.sk_receive_queue.lock); in prb_retire_rx_blk_timer_expired()
1272 spin_lock_bh(&po->sk.sk_receive_queue.lock); in packet_rcv_has_room()
1277 spin_unlock_bh(&po->sk.sk_receive_queue.lock); in packet_rcv_has_room()
2117 spin_lock(&sk->sk_receive_queue.lock); in packet_rcv()
2120 __skb_queue_tail(&sk->sk_receive_queue, skb); in packet_rcv()
2121 spin_unlock(&sk->sk_receive_queue.lock); in packet_rcv()
2127 spin_lock(&sk->sk_receive_queue.lock); in packet_rcv()
2130 spin_unlock(&sk->sk_receive_queue.lock); in packet_rcv()
2251 spin_lock(&sk->sk_receive_queue.lock); in tpacket_rcv()
[all …]
|
| /Linux-v4.19/net/nfc/ |
| D | llcp_sock.c | 568 if (!skb_queue_empty(&sk->sk_receive_queue)) in llcp_sock_poll()
817 skb_queue_empty(&sk->sk_receive_queue)) { in llcp_sock_recvmsg()
844 skb_queue_head(&sk->sk_receive_queue, skb); in llcp_sock_recvmsg()
875 skb_queue_head(&sk->sk_receive_queue, skb); in llcp_sock_recvmsg()
942 skb_queue_purge(&sk->sk_receive_queue); in llcp_sock_destruct()
|
| /Linux-v4.19/net/l2tp/ |
| D | l2tp_ip.c | 569 spin_lock_bh(&sk->sk_receive_queue.lock); in l2tp_ioctl()
570 skb = skb_peek(&sk->sk_receive_queue); in l2tp_ioctl()
572 spin_unlock_bh(&sk->sk_receive_queue.lock); in l2tp_ioctl()
|
| /Linux-v4.19/net/dccp/ |
| D | proto.c | 288 __skb_queue_purge(&sk->sk_receive_queue); in dccp_disconnect()
386 skb = skb_peek(&sk->sk_receive_queue); in dccp_ioctl()
843 struct sk_buff *skb = skb_peek(&sk->sk_receive_queue); in dccp_recvmsg()
1027 while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) { in dccp_close()
|
| /Linux-v4.19/net/x25/ |
| D | af_x25.c | 401 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) { in __x25_destroy_socket()
844 if (skb_queue_empty(&sk->sk_receive_queue)) { in x25_wait_for_data()
879 skb = skb_dequeue(&sk->sk_receive_queue); in x25_accept()
1064 skb_queue_head(&sk->sk_receive_queue, skb); in x25_rx_call_request()
1384 if ((skb = skb_peek(&sk->sk_receive_queue)) != NULL) in x25_ioctl()
|
