Lines Matching refs:sk_receive_queue

238 	kfree_skb(__skb_dequeue(&sk->sk_receive_queue));  in tsk_advance_rx_queue()
267 while ((skb = __skb_dequeue(&sk->sk_receive_queue))) in tsk_rej_rx_queue()
521 while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) { in __tipc_shutdown()
743 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
751 if (skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
1691 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_rcvmsg()
1704 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_rcvmsg()
1761 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
1871 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
1929 } while (!skb_queue_empty(&sk->sk_receive_queue) || copied < required); in tipc_recvstream()
1970 __skb_queue_purge(&sk->sk_receive_queue); in tipc_sock_destruct()
2194 __skb_queue_tail(&sk->sk_receive_queue, skb); in tipc_sk_filter_rcv()
2495 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_accept()
2501 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_accept()
2543 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2582 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
2583 __skb_queue_head(&new_sk->sk_receive_queue, buf); in tipc_accept()
2617 __skb_queue_purge(&sk->sk_receive_queue); in tipc_shutdown()
3070 value = skb_queue_len(&sk->sk_receive_queue); in tipc_getsockopt()
3462 skb_queue_len(&sk->sk_receive_queue)) || in tipc_sk_fill_sock_diag()
3802 i += tipc_list_dump(&sk->sk_receive_queue, false, buf + i); in tipc_sk_dump()