Lines Matching refs:sk_receive_queue

279 	kfree_skb(__skb_dequeue(&sk->sk_receive_queue));  in tsk_advance_rx_queue()
310 while ((skb = __skb_dequeue(&sk->sk_receive_queue))) in tsk_rej_rx_queue()
567 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()
811 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
819 if (skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
1839 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_rcvmsg()
1852 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_rcvmsg()
1911 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
2041 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
2099 } while (!skb_queue_empty(&sk->sk_receive_queue) || copied < required); in tipc_recvstream()
2141 __skb_queue_purge(&sk->sk_receive_queue); in tipc_sock_destruct()
2382 __skb_queue_tail(&sk->sk_receive_queue, skb); in tipc_sk_filter_rcv()
2686 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_accept()
2694 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_accept()
2736 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2773 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
2774 __skb_queue_head(&new_sk->sk_receive_queue, buf); in tipc_accept()
2810 __skb_queue_purge(&sk->sk_receive_queue); in tipc_shutdown()
3269 value = skb_queue_len(&sk->sk_receive_queue); in tipc_getsockopt()
3656 skb_queue_len(&sk->sk_receive_queue)) || in tipc_sk_fill_sock_diag()
3996 i += tipc_list_dump(&sk->sk_receive_queue, false, buf + i); in tipc_sk_dump()