Home
last modified time | relevance | path

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

1234

/linux/net/mptcp/
A Dfastopen.c28 skb = skb_peek(&ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
33 __skb_unlink(skb, &ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
54 __skb_queue_tail(&sk->sk_receive_queue, skb); in mptcp_fastopen_subflow_synack_set_params()
68 skb = skb_peek_tail(&sk->sk_receive_queue); in __mptcp_fastopen_gen_msk_ackseq()
A Dsubflow.c1061 if (skb_queue_is_last(&ssk->sk_receive_queue, skb)) { in validate_data_csum()
1067 while ((skb = skb_peek(&ssk->sk_receive_queue))) in validate_data_csum()
1108 skb = skb_peek(&ssk->sk_receive_queue); in get_mapping_status()
1282 if (skb_queue_empty(&ssk->sk_receive_queue) && in subflow_sched_work_if_closed()
1333 if (!skb_peek(&ssk->sk_receive_queue)) in subflow_check_data_avail()
1344 trace_subflow_check_data_avail(status, skb_peek(&ssk->sk_receive_queue)); in subflow_check_data_avail()
1352 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
1404 while ((skb = skb_peek(&ssk->sk_receive_queue))) in subflow_check_data_avail()
1414 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
/linux/net/phonet/
A Ddatagram.c37 spin_lock_bh(&sk->sk_receive_queue.lock); in pn_ioctl()
38 skb = skb_peek(&sk->sk_receive_queue); in pn_ioctl()
40 spin_unlock_bh(&sk->sk_receive_queue.lock); in pn_ioctl()
61 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()
940 q = &sk->sk_receive_queue; in pep_first_packet_length()
1256 struct sk_buff *skb = skb_dequeue(&sk->sk_receive_queue); in pep_read()
/linux/net/unix/
A Ddiag.c67 spin_lock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
70 sk->sk_receive_queue.qlen * sizeof(u32)); in sk_diag_dump_icons()
76 skb_queue_walk(&sk->sk_receive_queue, skb) in sk_diag_dump_icons()
79 spin_unlock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
85 spin_unlock(&sk->sk_receive_queue.lock); in sk_diag_dump_icons()
94 rql.udiag_rqueue = skb_queue_len_lockless(&sk->sk_receive_queue); in sk_diag_show_rqlen()
A Daf_unix.c630 skb_queue_purge(&sk->sk_receive_queue); in unix_dgram_disconnected()
648 skb_queue_purge(&sk->sk_receive_queue); in unix_sock_destructor()
847 spin_lock(&sk->sk_receive_queue.lock); in unix_count_nr_fds()
848 skb = skb_peek(&sk->sk_receive_queue); in unix_count_nr_fds()
854 spin_unlock(&sk->sk_receive_queue.lock); in unix_count_nr_fds()
2623 spin_lock(&sk->sk_receive_queue.lock); in unix_stream_recv_urg()
2637 spin_unlock(&sk->sk_receive_queue.lock); in unix_stream_recv_urg()
2663 spin_lock(&sk->sk_receive_queue.lock); in manage_oob()
2734 spin_lock(&sk->sk_receive_queue.lock); in unix_stream_read_skb()
3088 spin_lock(&sk->sk_receive_queue.lock); in unix_inq_len()
[all …]
A Dunix_bpf.c10 ({ !skb_queue_empty(&__sk->sk_receive_queue) || \
68 if (!skb_queue_empty(&sk->sk_receive_queue) && in unix_bpf_recvmsg()
/linux/net/bluetooth/
A Daf_bluetooth.c383 if (!skb_queue_empty(&sk->sk_receive_queue)) in bt_sock_data_wait()
426 skb = skb_dequeue(&sk->sk_receive_queue); in bt_sock_stream_recvmsg()
452 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
491 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
498 skb_queue_head(&sk->sk_receive_queue, skb); in bt_sock_stream_recvmsg()
546 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in bt_sock_poll()
590 spin_lock(&sk->sk_receive_queue.lock); in bt_sock_ioctl()
591 skb = skb_peek(&sk->sk_receive_queue); in bt_sock_ioctl()
593 spin_unlock(&sk->sk_receive_queue.lock); in bt_sock_ioctl()
/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 Dioctl.c82 spin_lock_irq(&sk->sk_receive_queue.lock); in do_vcc_ioctl()
83 skb = skb_peek(&sk->sk_receive_queue); in do_vcc_ioctl()
85 spin_unlock_irq(&sk->sk_receive_queue.lock); in do_vcc_ioctl()
A Draw.c28 skb_queue_tail(&sk->sk_receive_queue, skb); in atm_push_raw()
/linux/net/sctp/
A Dulpqueue.c135 &sk->sk_receive_queue); in sctp_clear_pd()
152 __skb_queue_tail(&sk->sk_receive_queue, in sctp_clear_pd()
213 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
227 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
236 queue = &sk->sk_receive_queue; in sctp_ulpq_tail_event()
251 if (queue == &sk->sk_receive_queue && !sp->data_ready_signalled) { in sctp_ulpq_tail_event()
1079 if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) { in sctp_ulpq_renege()
1119 __skb_queue_tail(&sk->sk_receive_queue, sctp_event2skb(ev)); in sctp_ulpq_abort_pd()
/linux/net/caif/
A Dcaif_socket.c124 struct sk_buff_head *list = &sk->sk_receive_queue; in caif_queue_rcv_skb()
313 if (!skb_queue_empty(&sk->sk_receive_queue) || in caif_stream_data_wait()
377 skb = skb_dequeue(&sk->sk_receive_queue); in caif_stream_recvmsg()
422 skb_queue_head(&sk->sk_receive_queue, skb); in caif_stream_recvmsg()
436 skb_queue_head(&sk->sk_receive_queue, skb); in caif_stream_recvmsg()
446 skb_queue_head(&sk->sk_receive_queue, skb); in caif_stream_recvmsg()
906 spin_lock_bh(&sk->sk_receive_queue.lock); in caif_release()
908 spin_unlock_bh(&sk->sk_receive_queue.lock); in caif_release()
949 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/tipc/
A Dsocket.c567 skb = skb_peek(&sk->sk_receive_queue); in __tipc_shutdown()
569 __skb_unlink(skb, &sk->sk_receive_queue); in __tipc_shutdown()
585 skb = __skb_dequeue(&sk->sk_receive_queue); in __tipc_shutdown()
587 __skb_queue_purge(&sk->sk_receive_queue); in __tipc_shutdown()
603 __skb_queue_purge(&sk->sk_receive_queue); in __tipc_shutdown()
1911 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
2041 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
2141 __skb_queue_purge(&sk->sk_receive_queue); in tipc_sock_destruct()
2736 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2773 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
[all …]
/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.c1378 skb = skb_peek(&sk->sk_receive_queue); in chtls_pt_recvmsg()
1439 __skb_unlink(skb, &sk->sk_receive_queue); in chtls_pt_recvmsg()
1519 next_skb = skb_peek(&sk->sk_receive_queue); in chtls_pt_recvmsg()
1564 skb_queue_walk(&sk->sk_receive_queue, skb) { in peekmsg()
1686 skb_queue_empty_lockless(&sk->sk_receive_queue) && in chtls_recvmsg()
1716 skb = skb_peek(&sk->sk_receive_queue); in chtls_recvmsg()
1832 !skb_peek(&sk->sk_receive_queue)) in chtls_recvmsg()
/linux/net/ipv4/
A Dtcp_bpf.c194 !skb_queue_empty_lockless(&sk->sk_receive_queue), &wait); in tcp_msg_wait_data()
250 if (unlikely(!skb_queue_empty(&sk->sk_receive_queue))) { in tcp_bpf_recvmsg_parser()
256 if (unlikely(!skb_queue_empty(&sk->sk_receive_queue))) { in tcp_bpf_recvmsg_parser()
347 if (!skb_queue_empty(&sk->sk_receive_queue) && in tcp_bpf_recvmsg()
/linux/drivers/xen/
A Dpvcalls-back.c117 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
118 if (skb_queue_empty(&map->sock->sk->sk_receive_queue)) { in pvcalls_conn_back_read()
120 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, in pvcalls_conn_back_read()
124 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
149 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
150 if (ret > 0 && !skb_queue_empty(&map->sock->sk->sk_receive_queue)) in pvcalls_conn_back_read()
152 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags); in pvcalls_conn_back_read()
/linux/net/nfc/
A Dllcp_sock.c572 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in llcp_sock_poll()
841 skb_queue_empty(&sk->sk_receive_queue)) { in llcp_sock_recvmsg()
868 skb_queue_head(&sk->sk_receive_queue, skb); in llcp_sock_recvmsg()
899 skb_queue_head(&sk->sk_receive_queue, skb); in llcp_sock_recvmsg()
964 skb_queue_purge(&sk->sk_receive_queue); in llcp_sock_destruct()
/linux/net/packet/
A Daf_packet.c744 spin_lock(&po->sk.sk_receive_queue.lock); in prb_retire_rx_blk_timer_expired()
806 spin_unlock(&po->sk.sk_receive_queue.lock); in prb_retire_rx_blk_timer_expired()
2270 spin_lock(&sk->sk_receive_queue.lock); in packet_rcv()
2275 spin_unlock(&sk->sk_receive_queue.lock); in packet_rcv()
2415 spin_lock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2455 spin_unlock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2548 spin_lock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2551 spin_unlock(&sk->sk_receive_queue.lock); in tpacket_rcv()
2567 spin_unlock(&sk->sk_receive_queue.lock); in tpacket_rcv()
3246 skb_queue_purge(&sk->sk_receive_queue); in packet_release()
[all …]
/linux/net/l2tp/
A Dl2tp_ip.c599 spin_lock_bh(&sk->sk_receive_queue.lock); in l2tp_ioctl()
600 skb = skb_peek(&sk->sk_receive_queue); in l2tp_ioctl()
602 spin_unlock_bh(&sk->sk_receive_queue.lock); in l2tp_ioctl()
/linux/net/llc/
A Daf_llc.c714 if (skb_queue_empty(&sk->sk_receive_queue)) { in llc_ui_accept()
721 skb = skb_dequeue(&sk->sk_receive_queue); in llc_ui_accept()
807 skb = skb_peek(&sk->sk_receive_queue); in llc_ui_recvmsg()
891 skb_unlink(skb, &sk->sk_receive_queue); in llc_ui_recvmsg()
913 skb_unlink(skb, &sk->sk_receive_queue); in llc_ui_recvmsg()
/linux/net/core/
A Ddatagram.c316 return __skb_recv_datagram(sk, &sk->sk_receive_queue, flags, in skb_recv_datagram()
375 int err = __sk_queue_drop_skb(sk, &sk->sk_receive_queue, skb, flags, in skb_kill_datagram()
905 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in datagram_poll()
/linux/net/rose/
A Daf_rose.c370 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) { in rose_destroy_socket()
952 skb = skb_dequeue(&sk->sk_receive_queue); in rose_accept()
1091 skb_queue_head(&sk->sk_receive_queue, skb); in rose_rx_call_request()
1348 spin_lock_irq(&sk->sk_receive_queue.lock); in rose_ioctl()
1349 if ((skb = skb_peek(&sk->sk_receive_queue)) != NULL) in rose_ioctl()
1351 spin_unlock_irq(&sk->sk_receive_queue.lock); in rose_ioctl()

Completed in 660 milliseconds

1234