Lines Matching refs:sk_receive_queue
237 kfree_skb(__skb_dequeue(&sk->sk_receive_queue)); in tsk_advance_rx_queue()
265 while ((skb = __skb_dequeue(&sk->sk_receive_queue))) in tsk_rej_rx_queue()
513 while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) { in __tipc_shutdown()
732 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_poll()
740 if (skb_queue_empty(&sk->sk_receive_queue)) in tipc_poll()
1659 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_rcvmsg()
1669 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_rcvmsg()
1727 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
1836 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
1893 } while (!skb_queue_empty(&sk->sk_receive_queue) || copied < required); in tipc_recvstream()
1934 __skb_queue_purge(&sk->sk_receive_queue); in tipc_sock_destruct()
2146 __skb_queue_tail(&sk->sk_receive_queue, skb); in tipc_sk_filter_rcv()
2426 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_accept()
2432 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_accept()
2474 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2513 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
2514 __skb_queue_head(&new_sk->sk_receive_queue, buf); in tipc_accept()
2547 __skb_queue_purge(&sk->sk_receive_queue); in tipc_shutdown()
2961 value = skb_queue_len(&sk->sk_receive_queue); in tipc_getsockopt()
3348 skb_queue_len(&sk->sk_receive_queue)) || in tipc_sk_fill_sock_diag()