Lines Matching refs:sk_receive_queue

228 	return skb_queue_len(&sk->sk_receive_queue) > sk->sk_max_ack_backlog;  in unix_recvq_full()
233 return skb_queue_len_lockless(&sk->sk_receive_queue) > in unix_recvq_full_lockless()
550 if (!skb_queue_empty(&sk->sk_receive_queue)) { in unix_dgram_disconnected()
551 skb_queue_purge(&sk->sk_receive_queue); in unix_dgram_disconnected()
570 skb_queue_purge(&sk->sk_receive_queue); in unix_sock_destructor()
631 if (!skb_queue_empty(&sk->sk_receive_queue) || embrion) in unix_release_sock()
644 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) { in unix_release_sock()
795 spin_lock(&sk->sk_receive_queue.lock); in unix_count_nr_fds()
796 skb = skb_peek(&sk->sk_receive_queue); in unix_count_nr_fds()
800 skb = skb_peek_next(skb, &sk->sk_receive_queue); in unix_count_nr_fds()
802 spin_unlock(&sk->sk_receive_queue.lock); in unix_count_nr_fds()
1627 spin_lock(&other->sk_receive_queue.lock); in unix_stream_connect()
1628 __skb_queue_tail(&other->sk_receive_queue, skb); in unix_stream_connect()
1629 spin_unlock(&other->sk_receive_queue.lock); in unix_stream_connect()
2074 skb_queue_tail(&other->sk_receive_queue, skb); in unix_dgram_sendmsg()
2137 skb_queue_tail(&other->sk_receive_queue, skb); in queue_oob()
2230 skb_queue_tail(&other->sk_receive_queue, skb); in unix_stream_sendmsg()
2319 skb = skb_peek_tail(&other->sk_receive_queue); in unix_stream_sendpage()
2352 spin_lock(&other->sk_receive_queue.lock); in unix_stream_sendpage()
2353 __skb_queue_tail(&other->sk_receive_queue, newskb); in unix_stream_sendpage()
2354 spin_unlock(&other->sk_receive_queue.lock); in unix_stream_sendpage()
2438 skb = __skb_try_recv_datagram(sk, &sk->sk_receive_queue, flags, in __unix_dgram_recvmsg()
2451 !__skb_wait_for_more_packets(sk, &sk->sk_receive_queue, in __unix_dgram_recvmsg()
2572 tail = skb_peek_tail(&sk->sk_receive_queue); in unix_stream_data_wait()
2660 skb_unlink(skb, &sk->sk_receive_queue); in manage_oob()
2673 skb_unlink(skb, &sk->sk_receive_queue); in manage_oob()
2675 skb = skb_peek(&sk->sk_receive_queue); in manage_oob()
2745 last = skb = skb_peek(&sk->sk_receive_queue); in unix_stream_read_generic()
2802 skb = skb_peek_next(skb, &sk->sk_receive_queue); in unix_stream_read_generic()
2868 skb_unlink(skb, &sk->sk_receive_queue); in unix_stream_read_generic()
2888 skb = skb_peek_next(skb, &sk->sk_receive_queue); in unix_stream_read_generic()
3039 spin_lock(&sk->sk_receive_queue.lock); in unix_inq_len()
3042 skb_queue_walk(&sk->sk_receive_queue, skb) in unix_inq_len()
3045 skb = skb_peek(&sk->sk_receive_queue); in unix_inq_len()
3049 spin_unlock(&sk->sk_receive_queue.lock); in unix_inq_len()
3124 skb = skb_peek(&sk->sk_receive_queue); in unix_ioctl()
3162 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in unix_poll()
3207 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in unix_dgram_poll()