Lines Matching refs:sk_receive_queue
186 return skb_queue_len(&sk->sk_receive_queue) > sk->sk_max_ack_backlog; in unix_recvq_full()
457 if (!skb_queue_empty(&sk->sk_receive_queue)) { in unix_dgram_disconnected()
458 skb_queue_purge(&sk->sk_receive_queue); in unix_dgram_disconnected()
476 skb_queue_purge(&sk->sk_receive_queue); in unix_sock_destructor()
529 if (!skb_queue_empty(&sk->sk_receive_queue) || embrion) in unix_release_sock()
543 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) { in unix_release_sock()
751 lockdep_set_class(&sk->sk_receive_queue.lock, in unix_create1()
1328 spin_lock(&other->sk_receive_queue.lock); in unix_stream_connect()
1329 __skb_queue_tail(&other->sk_receive_queue, skb); in unix_stream_connect()
1330 spin_unlock(&other->sk_receive_queue.lock); in unix_stream_connect()
1757 skb_queue_tail(&other->sk_receive_queue, skb); in unix_dgram_sendmsg()
1863 skb_queue_tail(&other->sk_receive_queue, skb); in unix_stream_sendmsg()
2036 if (skb_peek_tail(&sk->sk_receive_queue) != last || in unix_stream_data_wait()
2112 last = skb = skb_peek(&sk->sk_receive_queue); in unix_stream_recvmsg()
2153 skb = skb_peek_next(skb, &sk->sk_receive_queue); in unix_stream_recvmsg()
2200 skb_unlink(skb, &sk->sk_receive_queue); in unix_stream_recvmsg()
2219 skb = skb_peek_next(skb, &sk->sk_receive_queue); in unix_stream_recvmsg()
2287 spin_lock(&sk->sk_receive_queue.lock); in unix_inq_len()
2290 skb_queue_walk(&sk->sk_receive_queue, skb) in unix_inq_len()
2293 skb = skb_peek(&sk->sk_receive_queue); in unix_inq_len()
2297 spin_unlock(&sk->sk_receive_queue.lock); in unix_inq_len()
2351 if (!skb_queue_empty(&sk->sk_receive_queue)) in unix_poll()
2389 if (!skb_queue_empty(&sk->sk_receive_queue)) in unix_dgram_poll()