Home
last modified time | relevance | path

Searched refs:recv_io (Results 1 – 3 of 3) sorted by relevance

/linux/fs/smb/server/
H A Dtransport_rdma.c170 spin_lock_irqsave(&sc->recv_io.free.lock, flags); in get_free_recvmsg()
171 if (!list_empty(&sc->recv_io.free.list)) { in get_free_recvmsg()
172 recvmsg = list_first_entry(&sc->recv_io.free.list, in get_free_recvmsg()
177 spin_unlock_irqrestore(&sc->recv_io.free.lock, flags); in get_free_recvmsg()
194 spin_lock_irqsave(&sc->recv_io.free.lock, flags); in put_recvmsg()
195 list_add(&recvmsg->list, &sc->recv_io.free.list); in put_recvmsg()
196 spin_unlock_irqrestore(&sc->recv_io.free.lock, flags); in put_recvmsg()
198 queue_work(sc->workqueue, &sc->recv_io.posted.refill_work); in put_recvmsg()
207 spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags); in enqueue_reassembly()
208 list_add_tail(&recvmsg->list, &sc->recv_io.reassembly.list); in enqueue_reassembly()
[all …]
/linux/fs/smb/client/
H A Dsmbdirect.c199 wake_up_all(&sc->recv_io.reassembly.wait_queue); in smbd_disconnect_wake_up_all()
218 disable_work(&sc->recv_io.posted.refill_work); in smbd_disconnect_rdma_work()
273 disable_work(&sc->recv_io.posted.refill_work); in smbd_disconnect_rdma_connection()
666 sc->recv_io.credits.target = le16_to_cpu(packet->credits_requested); in process_negotiation_response()
667 sc->recv_io.credits.target = min_t(u16, sc->recv_io.credits.target, sp->recv_credit_max); in process_negotiation_response()
707 sc->recv_io.expected = SMBDIRECT_EXPECT_DATA_TRANSFER; in process_negotiation_response()
716 container_of(work, struct smbdirect_socket, recv_io.posted.refill_work); in smbd_post_send_credits()
723 if (sc->recv_io.credits.target > in smbd_post_send_credits()
724 atomic_read(&sc->recv_io.credits.count)) { in smbd_post_send_credits()
739 atomic_inc(&sc->recv_io.posted.count); in smbd_post_send_credits()
[all …]
/linux/tools/testing/selftests/net/
H A Dreuseport_bpf.c215 struct iovec recv_io = { recv_buf, 8 }; in test_recv_order() local
231 msg.msg_iov = &recv_io; in test_recv_order()