Lines Matching refs:sk_receive_queue
347 __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()
2906 skb_queue_splice_tail_init(&msk->receive_queue, &sk->sk_receive_queue); in mptcp_destroy_common()
2907 __skb_queue_purge(&sk->sk_receive_queue); in mptcp_destroy_common()
3400 if (skb_queue_empty_lockless(&((struct sock *)msk)->sk_receive_queue) && in mptcp_check_readable()