Searched refs:recvmsg_queue (Results 1 – 5 of 5) sorted by relevance
117 skb = skb_dequeue(&call->recvmsg_queue); in rxrpc_rotate_rx_window()192 skb = skb_peek(&call->recvmsg_queue); in rxrpc_recvmsg_data()254 skb = skb_peek_next(skb, &call->recvmsg_queue); in rxrpc_recvmsg_data()345 skb_queue_empty(&call->recvmsg_queue)) { in rxrpc_recvmsg()413 skb_queue_empty(&call->recvmsg_queue)) in rxrpc_recvmsg()418 if (!skb_queue_empty(&call->recvmsg_queue)) in rxrpc_recvmsg()423 rxrpc_purge_queue(&call->recvmsg_queue); in rxrpc_recvmsg()
369 __skb_queue_tail(&call->recvmsg_queue, skb); in rxrpc_input_queue_data()446 spin_lock(&call->recvmsg_queue.lock); in rxrpc_input_data_one()468 spin_unlock(&call->recvmsg_queue.lock); in rxrpc_input_data_one()
160 skb_queue_head_init(&call->recvmsg_queue); in rxrpc_alloc_call()543 rxrpc_purge_queue(&call->recvmsg_queue); in rxrpc_cleanup_ring()
402 return !skb_queue_empty(&call->recvmsg_queue); in rxrpc_kernel_check_life()
678 struct sk_buff_head recvmsg_queue; /* Queue of packets ready for recvmsg() */ member