Home
last modified time | relevance | path

Searched refs:recvmsg_queue (Results 1 – 6 of 6) sorted by relevance

/linux-6.3-rc2/net/rxrpc/
A Drecvmsg.c117 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()
A Dinput.c355 __skb_queue_tail(&call->recvmsg_queue, skb); in rxrpc_input_queue_data()
434 spin_lock(&call->recvmsg_queue.lock); in rxrpc_input_data_one()
456 spin_unlock(&call->recvmsg_queue.lock); in rxrpc_input_data_one()
A Dcall_object.c162 skb_queue_head_init(&call->recvmsg_queue); in rxrpc_alloc_call()
543 skb_queue_purge(&call->recvmsg_queue); in rxrpc_cleanup_ring()
A Daf_rxrpc.c386 return !skb_queue_empty(&call->recvmsg_queue); in rxrpc_kernel_check_life()
A Dar-internal.h669 struct sk_buff_head recvmsg_queue; /* Queue of packets ready for recvmsg() */ member
/linux-6.3-rc2/fs/ksmbd/
A Dtransport_rdma.c129 struct list_head recvmsg_queue; member
256 if (!list_empty(&t->recvmsg_queue)) { in get_free_recvmsg()
257 recvmsg = list_first_entry(&t->recvmsg_queue, in get_free_recvmsg()
273 list_add(&recvmsg->list, &t->recvmsg_queue); in put_recvmsg()
385 INIT_LIST_HEAD(&t->recvmsg_queue); in alloc_transport()
1843 INIT_LIST_HEAD(&t->recvmsg_queue); in smb_direct_create_pools()
1850 list_add(&recvmsg->list, &t->recvmsg_queue); in smb_direct_create_pools()

Completed in 19 milliseconds