Lines Matching refs:sk_receive_queue
247 kfree_skb(__skb_dequeue(&sk->sk_receive_queue)); in tsk_advance_rx_queue()
261 while ((skb = __skb_dequeue(&sk->sk_receive_queue))) { in tsk_rej_rx_queue()
431 skb = __skb_dequeue(&sk->sk_receive_queue); in tipc_release()
466 __skb_queue_purge(&sk->sk_receive_queue); in tipc_release()
640 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_poll()
1238 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_rcvmsg()
1248 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_rcvmsg()
1305 buf = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
1402 buf = skb_peek(&sk->sk_receive_queue); in tipc_recv_stream()
1463 (!skb_queue_empty(&sk->sk_receive_queue) || in tipc_recv_stream()
1671 __skb_queue_tail(&sk->sk_receive_queue, *skb); in filter_rcv()
1957 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_accept()
1963 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_accept()
2007 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2047 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
2048 __skb_queue_head(&new_sk->sk_receive_queue, buf); in tipc_accept()
2086 skb = __skb_dequeue(&sk->sk_receive_queue); in tipc_shutdown()
2114 __skb_queue_purge(&sk->sk_receive_queue); in tipc_shutdown()
2437 value = skb_queue_len(&sk->sk_receive_queue); in tipc_getsockopt()