Home
last modified time | relevance | path

Searched refs:receive_queue (Results 1 - 18 of 18) sorted by relevance

/kernel/linux/linux-6.6/drivers/net/
H A Dvirtio_net.c165 struct receive_queue { struct
166 /* Virtqueue associated with this receive_queue */
242 struct receive_queue *rq;
387 static void give_pages(struct receive_queue *rq, struct page *page) in give_pages()
397 static struct page *get_a_page(struct receive_queue *rq, gfp_t gfp_mask) in get_a_page()
411 struct receive_queue *rq, void *buf) in virtnet_rq_free_buf()
508 struct receive_queue *rq, in page_to_skb()
607 static void virtnet_rq_unmap(struct receive_queue *rq, void *buf, u32 len) in virtnet_rq_unmap()
636 static void *virtnet_rq_get_buf(struct receive_queue *rq, u32 *len, void **ctx) in virtnet_rq_get_buf()
647 static void virtnet_rq_init_one_sg(struct receive_queue *r
[all...]
/kernel/linux/linux-5.10/drivers/net/
H A Dvirtio_net.c139 struct receive_queue { struct
140 /* Virtqueue associated with this receive_queue */
186 struct receive_queue *rq;
305 static void give_pages(struct receive_queue *rq, struct page *page) in give_pages()
315 static struct page *get_a_page(struct receive_queue *rq, gfp_t gfp_mask) in get_a_page()
399 struct receive_queue *rq, in page_to_skb()
552 struct receive_queue *rq = vi->rq; in virtnet_xdp_xmit()
642 static struct page *xdp_linearize_page(struct receive_queue *rq, in xdp_linearize_page()
698 struct receive_queue *rq, in receive_small()
838 struct receive_queue *r in receive_big()
[all...]
/kernel/linux/linux-5.10/fs/cifs/
H A Dsmbdirect.h120 struct list_head receive_queue; member
H A Dsmbdirect.c1200 if (!list_empty(&info->receive_queue)) { in get_receive_buffer()
1202 &info->receive_queue, in get_receive_buffer()
1228 list_add_tail(&response->list, &info->receive_queue); in put_receive_buffer()
1247 INIT_LIST_HEAD(&info->receive_queue); in allocate_receive_buffers()
1263 list_add_tail(&response->list, &info->receive_queue); in allocate_receive_buffers()
1270 while (!list_empty(&info->receive_queue)) { in allocate_receive_buffers()
1272 &info->receive_queue, in allocate_receive_buffers()
/kernel/linux/linux-6.6/fs/smb/client/
H A Dsmbdirect.h120 struct list_head receive_queue; member
H A Dsmbdirect.c1167 if (!list_empty(&info->receive_queue)) { in get_receive_buffer()
1169 &info->receive_queue, in get_receive_buffer()
1195 list_add_tail(&response->list, &info->receive_queue); in put_receive_buffer()
1214 INIT_LIST_HEAD(&info->receive_queue); in allocate_receive_buffers()
1230 list_add_tail(&response->list, &info->receive_queue); in allocate_receive_buffers()
1237 while (!list_empty(&info->receive_queue)) { in allocate_receive_buffers()
1239 &info->receive_queue, in allocate_receive_buffers()
/kernel/linux/linux-6.6/net/mptcp/
H A Dprotocol.c1909 skb_queue_walk_safe(&msk->receive_queue, skb, tmp) { in __mptcp_recvmsg_mskq()
1943 __skb_unlink(skb, &msk->receive_queue); in __mptcp_recvmsg_mskq()
2069 skb_queue_splice_tail_init(&sk->sk_receive_queue, &msk->receive_queue); in __mptcp_splice_receive_queue()
2112 return !skb_queue_empty(&msk->receive_queue); in __mptcp_move_skbs()
2120 skb = skb_peek(&msk->receive_queue); in mptcp_inq_hint()
2178 if (skb_queue_empty(&msk->receive_queue) && __mptcp_move_skbs(msk)) in mptcp_recvmsg()
2243 skb_queue_empty(&msk->receive_queue), copied); in mptcp_recvmsg()
2763 __skb_queue_head_init(&msk->receive_queue); in __mptcp_init_sock()
2998 /* Concurrent splices from sk_receive_queue into receive_queue will in mptcp_check_readable()
3002 skb_queue_empty_lockless(&msk->receive_queue)) in mptcp_check_readable()
[all...]
H A Dprotocol.h309 struct sk_buff_head receive_queue; member
/kernel/linux/linux-5.10/drivers/scsi/cxgbi/cxgb4i/
H A Dcxgb4i.c1337 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_hdr()
1400 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_data()
1559 data_skb = skb_peek(&csk->receive_queue); in do_rx_iscsi_cmp()
1567 __skb_unlink(data_skb, &csk->receive_queue); in do_rx_iscsi_cmp()
1571 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_cmp()
1572 __skb_queue_tail(&csk->receive_queue, data_skb); in do_rx_iscsi_cmp()
1574 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_cmp()
/kernel/linux/linux-6.6/drivers/scsi/cxgbi/cxgb4i/
H A Dcxgb4i.c1338 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_hdr()
1401 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_data()
1560 data_skb = skb_peek(&csk->receive_queue); in do_rx_iscsi_cmp()
1568 __skb_unlink(data_skb, &csk->receive_queue); in do_rx_iscsi_cmp()
1572 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_cmp()
1573 __skb_queue_tail(&csk->receive_queue, data_skb); in do_rx_iscsi_cmp()
1575 __skb_queue_tail(&csk->receive_queue, skb); in do_rx_iscsi_cmp()
/kernel/linux/linux-5.10/drivers/scsi/cxgbi/
H A Dlibcxgbi.c574 skb_queue_head_init(&csk->receive_queue); in cxgbi_sock_create()
883 data_lost = skb_queue_len(&csk->receive_queue); in need_active_close()
884 __skb_queue_purge(&csk->receive_queue); in need_active_close()
1646 skb = skb_peek(&csk->receive_queue); in cxgbi_conn_pdu_ready()
1655 __skb_unlink(skb, &csk->receive_queue); in cxgbi_conn_pdu_ready()
1695 dskb = skb_peek(&csk->receive_queue); in cxgbi_conn_pdu_ready()
1705 __skb_unlink(dskb, &csk->receive_queue); in cxgbi_conn_pdu_ready()
H A Dlibcxgbi.h157 struct sk_buff_head receive_queue; member
/kernel/linux/linux-6.6/drivers/scsi/cxgbi/
H A Dlibcxgbi.c574 skb_queue_head_init(&csk->receive_queue); in cxgbi_sock_create()
883 data_lost = skb_queue_len(&csk->receive_queue); in need_active_close()
884 __skb_queue_purge(&csk->receive_queue); in need_active_close()
1646 skb = skb_peek(&csk->receive_queue); in cxgbi_conn_pdu_ready()
1655 __skb_unlink(skb, &csk->receive_queue); in cxgbi_conn_pdu_ready()
1695 dskb = skb_peek(&csk->receive_queue); in cxgbi_conn_pdu_ready()
1705 __skb_unlink(dskb, &csk->receive_queue); in cxgbi_conn_pdu_ready()
H A Dlibcxgbi.h156 struct sk_buff_head receive_queue; member
/kernel/linux/linux-5.10/drivers/infiniband/hw/mlx5/
H A Dodp.c1059 u32 *total_wqe_bytes, bool receive_queue) in pagefault_data_segments()
1091 if (receive_queue && bcnt == 0 && key == MLX5_INVALID_LKEY && in pagefault_data_segments()
1055 pagefault_data_segments(struct mlx5_ib_dev *dev, struct mlx5_pagefault *pfault, void *wqe, void *wqe_end, u32 *bytes_mapped, u32 *total_wqe_bytes, bool receive_queue) pagefault_data_segments() argument
/kernel/linux/linux-6.6/drivers/infiniband/hw/mlx5/
H A Dodp.c976 * @receive_queue: receive WQE end of sg list
985 u32 *total_wqe_bytes, bool receive_queue) in pagefault_data_segments()
1017 if (receive_queue && bcnt == 0 && in pagefault_data_segments()
981 pagefault_data_segments(struct mlx5_ib_dev *dev, struct mlx5_pagefault *pfault, void *wqe, void *wqe_end, u32 *bytes_mapped, u32 *total_wqe_bytes, bool receive_queue) pagefault_data_segments() argument
/kernel/linux/linux-5.10/drivers/scsi/cxgbi/cxgb3i/
H A Dcxgb3i.c828 __skb_queue_tail(&csk->receive_queue, skb); in do_iscsi_hdr()
/kernel/linux/linux-6.6/drivers/scsi/cxgbi/cxgb3i/
H A Dcxgb3i.c829 __skb_queue_tail(&csk->receive_queue, skb); in do_iscsi_hdr()

Completed in 48 milliseconds