Home
last modified time | relevance | path

Searched refs:sk_receive_queue (Results 1 – 25 of 88) sorted by relevance

1234

/linux/net/unix/
A Dgarbage.c97 spin_lock(&x->sk_receive_queue.lock); in scan_inflight()
98 skb_queue_walk_safe(&x->sk_receive_queue, skb, next) { in scan_inflight()
125 __skb_unlink(skb, &x->sk_receive_queue); in scan_inflight()
130 spin_unlock(&x->sk_receive_queue.lock); in scan_inflight()
147 spin_lock(&x->sk_receive_queue.lock); in scan_children()
148 skb_queue_walk_safe(&x->sk_receive_queue, skb, next) { in scan_children()
157 spin_unlock(&x->sk_receive_queue.lock); in scan_children()
A Ddiag.c68 spin_lock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
71 sk->sk_receive_queue.qlen * sizeof(u32)); in sk_diag_dump_icons()
77 skb_queue_walk(&sk->sk_receive_queue, skb) { in sk_diag_dump_icons()
91 spin_unlock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
97 spin_unlock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
106 rql.udiag_rqueue = sk->sk_receive_queue.qlen; in sk_diag_show_rqlen()
A Daf_unix.c486 skb_queue_purge(&sk->sk_receive_queue); in unix_dgram_disconnected()
505 skb_queue_purge(&sk->sk_receive_queue); in unix_sock_destructor()
1491 spin_lock(&other->sk_receive_queue.lock); in unix_stream_connect()
2217 spin_lock(&other->sk_receive_queue.lock); in unix_stream_sendpage()
2545 skb_unlink(skb, &sk->sk_receive_queue); in manage_oob()
2560 skb = skb_peek(&sk->sk_receive_queue); in manage_oob()
2754 skb_unlink(skb, &sk->sk_receive_queue); in unix_stream_read_generic()
2926 spin_lock(&sk->sk_receive_queue.lock); in unix_inq_len()
2932 skb = skb_peek(&sk->sk_receive_queue); in unix_inq_len()
2936 spin_unlock(&sk->sk_receive_queue.lock); in unix_inq_len()
[all …]
A Dunix_bpf.c10 ({ !skb_queue_empty(&__sk->sk_receive_queue) || \
63 if (!skb_queue_empty(&sk->sk_receive_queue) && in unix_bpf_recvmsg()
/linux/net/atm/
A Dsignaling.c33 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()
A Draw.c28 skb_queue_tail(&sk->sk_receive_queue, skb); in atm_push_raw()
/linux/net/bluetooth/
A Daf_bluetooth.c311 if (!skb_queue_empty(&sk->sk_receive_queue)) in bt_sock_data_wait()
354 skb = skb_dequeue(&sk->sk_receive_queue); in bt_sock_stream_recvmsg()
380 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
419 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
426 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
474 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in bt_sock_poll()
519 skb = skb_peek(&sk->sk_receive_queue); in bt_sock_ioctl()
/linux/net/sctp/
A Dulpqueue.c138 &sk->sk_receive_queue); in sctp_clear_pd()
155 __skb_queue_tail(&sk->sk_receive_queue, in sctp_clear_pd()
216 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
230 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
239 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
254 if (queue == &sk->sk_receive_queue && !sp->data_ready_signalled) { in sctp_ulpq_tail_event()
1085 if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) { in sctp_ulpq_renege()
1129 __skb_queue_tail(&sk->sk_receive_queue, sctp_event2skb(ev)); in sctp_ulpq_abort_pd()
/linux/net/caif/
A Dcaif_socket.c128 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()
914 spin_lock_bh(&sk->sk_receive_queue.lock); in caif_release()
916 spin_unlock_bh(&sk->sk_receive_queue.lock); in caif_release()
957 if (!skb_queue_empty_lockless(&sk->sk_receive_queue) || in caif_poll()
/linux/net/kcm/
A Dkcmproc.c119 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()
/linux/net/phonet/
A Ddatagram.c39 skb = skb_peek(&sk->sk_receive_queue); in pn_ioctl()
64 skb_queue_purge(&sk->sk_receive_queue); in pn_destruct()
A Dpep.c405 queue = &sk->sk_receive_queue; in pipe_do_rcv()
464 skb_queue_purge(&sk->sk_receive_queue); in pipe_destruct()
577 skb_queue_tail(&sk->sk_receive_queue, skb); in pipe_handler_do_rcv()
684 skb_queue_head(&sk->sk_receive_queue, skb); in pep_do_rcv()
936 else if (!skb_queue_empty(&sk->sk_receive_queue)) in pep_ioctl()
937 answ = skb_peek(&sk->sk_receive_queue)->len; in pep_ioctl()
1233 struct sk_buff *skb = skb_dequeue(&sk->sk_receive_queue); in pep_read()
/linux/net/tipc/
A Dsocket.c568 skb = skb_peek(&sk->sk_receive_queue); in __tipc_shutdown()
570 __skb_unlink(skb, &sk->sk_receive_queue); in __tipc_shutdown()
586 skb = __skb_dequeue(&sk->sk_receive_queue); in __tipc_shutdown()
588 __skb_queue_purge(&sk->sk_receive_queue); in __tipc_shutdown()
604 __skb_queue_purge(&sk->sk_receive_queue); in __tipc_shutdown()
1914 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
2044 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
2142 __skb_queue_purge(&sk->sk_receive_queue); in tipc_sock_destruct()
2737 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2774 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
[all …]
/linux/net/rxrpc/
A Daf_rxrpc.c814 spin_lock_bh(&sk->sk_receive_queue.lock); in rxrpc_shutdown()
821 spin_unlock_bh(&sk->sk_receive_queue.lock); in rxrpc_shutdown()
836 rxrpc_purge_queue(&sk->sk_receive_queue); in rxrpc_sock_destructor()
874 spin_lock_bh(&sk->sk_receive_queue.lock); in rxrpc_release_sock()
876 spin_unlock_bh(&sk->sk_receive_queue.lock); in rxrpc_release_sock()
888 rxrpc_purge_queue(&sk->sk_receive_queue); in rxrpc_release_sock()
/linux/drivers/net/ethernet/chelsio/inline_crypto/chtls/
A Dchtls_cm.h175 __skb_unlink(skb, &sk->sk_receive_queue); in chtls_free_skb()
182 __skb_unlink(skb, &sk->sk_receive_queue); in chtls_kfree_skb()
A Dchtls_io.c1464 skb = skb_peek(&sk->sk_receive_queue); in chtls_pt_recvmsg()
1521 __skb_unlink(skb, &sk->sk_receive_queue); in chtls_pt_recvmsg()
1601 next_skb = skb_peek(&sk->sk_receive_queue); in chtls_pt_recvmsg()
1643 skb_queue_walk(&sk->sk_receive_queue, skb) { in peekmsg()
1760 skb_queue_empty_lockless(&sk->sk_receive_queue) && in chtls_recvmsg()
1791 skb = skb_peek(&sk->sk_receive_queue); in chtls_recvmsg()
1903 !skb_peek(&sk->sk_receive_queue)) in chtls_recvmsg()
/linux/net/mptcp/
A Dsubflow.c887 if (skb_queue_is_last(&ssk->sk_receive_queue, skb)) { in validate_data_csum()
893 while ((skb = skb_peek(&ssk->sk_receive_queue))) in validate_data_csum()
937 skb = skb_peek(&ssk->sk_receive_queue); in get_mapping_status()
1097 if (skb_queue_empty(&ssk->sk_receive_queue) && in subflow_sched_work_if_closed()
1112 if (!skb_peek(&ssk->sk_receive_queue)) in subflow_check_data_avail()
1123 trace_subflow_check_data_avail(status, skb_peek(&ssk->sk_receive_queue)); in subflow_check_data_avail()
1133 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
1170 while ((skb = skb_peek(&ssk->sk_receive_queue))) in subflow_check_data_avail()
1196 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
A Dprotocol.c347 __skb_unlink(skb, &ssk->sk_receive_queue); in __mptcp_move_skb()
370 tail = skb_peek_tail(&sk->sk_receive_queue); in __mptcp_move_skb()
375 __skb_queue_tail(&sk->sk_receive_queue, skb); in __mptcp_move_skb()
648 skb = skb_peek(&ssk->sk_receive_queue); in __mptcp_move_skbs_from_subflow()
732 tail = skb_peek_tail(&sk->sk_receive_queue); in __mptcp_ofo_queue()
741 __skb_queue_tail(&sk->sk_receive_queue, skb); in __mptcp_ofo_queue()
1921 skb_queue_splice_tail_init(&sk->sk_receive_queue, &msk->receive_queue); in __mptcp_splice_receive_queue()
1956 !skb_queue_empty_lockless(&sk->sk_receive_queue)) { in __mptcp_move_skbs()
2068 msk, skb_queue_empty_lockless(&sk->sk_receive_queue), in mptcp_recvmsg()
2282 if (!skb_queue_empty_lockless(&ssk->sk_receive_queue)) in __mptcp_close_subflow()
[all …]
/linux/net/packet/
A Daf_packet.c686 spin_lock(&po->sk.sk_receive_queue.lock); in prb_retire_rx_blk_timer_expired()
748 spin_unlock(&po->sk.sk_receive_queue.lock); in prb_retire_rx_blk_timer_expired()
2194 spin_lock(&sk->sk_receive_queue.lock); in packet_rcv()
2198 spin_unlock(&sk->sk_receive_queue.lock); in packet_rcv()
2338 spin_lock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2377 spin_unlock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2464 spin_lock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2467 spin_unlock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2486 spin_unlock(&sk->sk_receive_queue.lock); in tpacket_rcv()
3150 skb_queue_purge(&sk->sk_receive_queue); in packet_release()
[all …]
/linux/drivers/xen/
A Dpvcalls-back.c116 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
117 if (skb_queue_empty(&map->sock->sk->sk_receive_queue)) { in pvcalls_conn_back_read()
119 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, in pvcalls_conn_back_read()
123 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
148 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
149 if (ret > 0 && !skb_queue_empty(&map->sock->sk->sk_receive_queue)) in pvcalls_conn_back_read()
151 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
/linux/net/nfc/
A Dllcp_sock.c567 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in llcp_sock_poll()
831 skb_queue_empty(&sk->sk_receive_queue)) { in llcp_sock_recvmsg()
858 skb_queue_head(&sk->sk_receive_queue, skb); in llcp_sock_recvmsg()
889 skb_queue_head(&sk->sk_receive_queue, skb); in llcp_sock_recvmsg()
954 skb_queue_purge(&sk->sk_receive_queue); in llcp_sock_destruct()
/linux/net/l2tp/
A Dl2tp_ip.c573 spin_lock_bh(&sk->sk_receive_queue.lock); in l2tp_ioctl()
574 skb = skb_peek(&sk->sk_receive_queue); in l2tp_ioctl()
576 spin_unlock_bh(&sk->sk_receive_queue.lock); in l2tp_ioctl()
/linux/net/core/
A Ddatagram.c317 return __skb_recv_datagram(sk, &sk->sk_receive_queue, in skb_recv_datagram()
398 int err = __sk_queue_drop_skb(sk, &sk->sk_receive_queue, skb, flags, in skb_kill_datagram()
818 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in datagram_poll()
/linux/net/llc/
A Daf_llc.c693 if (skb_queue_empty(&sk->sk_receive_queue)) { in llc_ui_accept()
700 skb = skb_dequeue(&sk->sk_receive_queue); in llc_ui_accept()
786 skb = skb_peek(&sk->sk_receive_queue); in llc_ui_recvmsg()
870 skb_unlink(skb, &sk->sk_receive_queue); in llc_ui_recvmsg()
892 skb_unlink(skb, &sk->sk_receive_queue); in llc_ui_recvmsg()
/linux/net/ieee802154/
A Dsocket.c542 spin_lock_bh(&sk->sk_receive_queue.lock); in dgram_ioctl()
543 skb = skb_peek(&sk->sk_receive_queue); in dgram_ioctl()
551 spin_unlock_bh(&sk->sk_receive_queue.lock); in dgram_ioctl()
988 skb_queue_purge(&sk->sk_receive_queue); in ieee802154_sock_destruct()

Completed in 67 milliseconds

1234