Lines Matching refs:sk_receive_queue
194 return skb_queue_len(&sk->sk_receive_queue) > sk->sk_max_ack_backlog; in unix_recvq_full()
473 if (!skb_queue_empty(&sk->sk_receive_queue)) { in unix_dgram_disconnected()
474 skb_queue_purge(&sk->sk_receive_queue); in unix_dgram_disconnected()
492 skb_queue_purge(&sk->sk_receive_queue); in unix_sock_destructor()
545 if (!skb_queue_empty(&sk->sk_receive_queue) || embrion) in unix_release_sock()
559 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) { in unix_release_sock()
1368 spin_lock(&other->sk_receive_queue.lock); in unix_stream_connect()
1369 __skb_queue_tail(&other->sk_receive_queue, skb); in unix_stream_connect()
1370 spin_unlock(&other->sk_receive_queue.lock); in unix_stream_connect()
1750 skb_queue_tail(&other->sk_receive_queue, skb); in unix_dgram_sendmsg()
1852 skb_queue_tail(&other->sk_receive_queue, skb); in unix_stream_sendmsg()
1932 skb = skb_peek_tail(&other->sk_receive_queue); in unix_stream_sendpage()
1965 spin_lock(&other->sk_receive_queue.lock); in unix_stream_sendpage()
1966 __skb_queue_tail(&other->sk_receive_queue, newskb); in unix_stream_sendpage()
1967 spin_unlock(&other->sk_receive_queue.lock); in unix_stream_sendpage()
2148 tail = skb_peek_tail(&sk->sk_receive_queue); in unix_stream_data_wait()
2243 last = skb = skb_peek(&sk->sk_receive_queue); in unix_stream_read_generic()
2288 skb = skb_peek_next(skb, &sk->sk_receive_queue); in unix_stream_read_generic()
2352 skb_unlink(skb, &sk->sk_receive_queue); in unix_stream_read_generic()
2372 skb = skb_peek_next(skb, &sk->sk_receive_queue); in unix_stream_read_generic()
2499 spin_lock(&sk->sk_receive_queue.lock); in unix_inq_len()
2502 skb_queue_walk(&sk->sk_receive_queue, skb) in unix_inq_len()
2505 skb = skb_peek(&sk->sk_receive_queue); in unix_inq_len()
2509 spin_unlock(&sk->sk_receive_queue.lock); in unix_inq_len()
2602 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in unix_poll()
2641 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in unix_dgram_poll()