Lines Matching refs:sk_receive_queue
249 kfree_skb(__skb_dequeue(&sk->sk_receive_queue)); in tsk_advance_rx_queue()
277 while ((skb = __skb_dequeue(&sk->sk_receive_queue))) in tsk_rej_rx_queue()
446 skb = __skb_dequeue(&sk->sk_receive_queue); in tipc_release()
647 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_poll()
1253 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_rcvmsg()
1263 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_rcvmsg()
1320 buf = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
1417 buf = skb_peek(&sk->sk_receive_queue); in tipc_recv_stream()
1478 (!skb_queue_empty(&sk->sk_receive_queue) || in tipc_recv_stream()
1524 __skb_queue_purge(&sk->sk_receive_queue); in tipc_sock_destruct()
1696 __skb_queue_tail(&sk->sk_receive_queue, skb); in filter_rcv()
1968 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_accept()
1974 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_accept()
2018 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2058 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
2059 __skb_queue_head(&new_sk->sk_receive_queue, buf); in tipc_accept()
2102 skb = __skb_dequeue(&sk->sk_receive_queue); in tipc_shutdown()
2124 __skb_queue_purge(&sk->sk_receive_queue); in tipc_shutdown()
2447 value = skb_queue_len(&sk->sk_receive_queue); in tipc_getsockopt()