Home
last modified time | relevance | path

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

/linux/fs/smb/server/
H A Dtransport_rdma.c157 spin_lock_irqsave(&sc->recv_io.free.lock, flags); in get_free_recvmsg()
158 if (!list_empty(&sc->recv_io.free.list)) { in get_free_recvmsg()
159 recvmsg = list_first_entry(&sc->recv_io.free.list, in get_free_recvmsg()
164 spin_unlock_irqrestore(&sc->recv_io.free.lock, flags); in get_free_recvmsg()
181 spin_lock_irqsave(&sc->recv_io.free.lock, flags); in put_recvmsg()
182 list_add(&recvmsg->list, &sc->recv_io.free.list); in put_recvmsg()
183 spin_unlock_irqrestore(&sc->recv_io.free.lock, flags); in put_recvmsg()
185 queue_work(sc->workqueue, &sc->recv_io.posted.refill_work); in put_recvmsg()
194 spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags); in enqueue_reassembly()
195 list_add_tail(&recvmsg->list, &sc->recv_io.reassembly.list); in enqueue_reassembly()
[all …]
/linux/fs/smb/client/
H A Dsmbdirect.c180 wake_up_all(&sc->recv_io.reassembly.wait_queue); in smbd_disconnect_wake_up_all()
199 disable_work(&sc->recv_io.posted.refill_work); in smbd_disconnect_rdma_work()
254 disable_work(&sc->recv_io.posted.refill_work); in smbd_disconnect_rdma_connection()
571 sc->recv_io.credits.target = le16_to_cpu(packet->credits_requested); in process_negotiation_response()
572 sc->recv_io.credits.target = min_t(u16, sc->recv_io.credits.target, sp->recv_credit_max); in process_negotiation_response()
611 sc->recv_io.expected = SMBDIRECT_EXPECT_DATA_TRANSFER; in process_negotiation_response()
620 container_of(work, struct smbdirect_socket, recv_io.posted.refill_work); in smbd_post_send_credits()
626 if (sc->recv_io.credits.target > in smbd_post_send_credits()
627 atomic_read(&sc->recv_io.credits.count)) { in smbd_post_send_credits()
642 atomic_inc(&sc->recv_io.posted.count); in smbd_post_send_credits()
[all …]
H A Dcifs_debug.c532 sc->recv_io.reassembly.data_length, in cifs_debug_data_proc_show()
533 sc->recv_io.reassembly.queue_length); in cifs_debug_data_proc_show()
537 atomic_read(&sc->recv_io.credits.count), in cifs_debug_data_proc_show()
538 sc->recv_io.credits.target); in cifs_debug_data_proc_show()
/linux/fs/smb/common/smbdirect/
H A Dsmbdirect_socket.h270 } recv_io; member
383 INIT_LIST_HEAD(&sc->recv_io.free.list); in smbdirect_socket_init()
384 spin_lock_init(&sc->recv_io.free.lock); in smbdirect_socket_init()
386 atomic_set(&sc->recv_io.posted.count, 0); in smbdirect_socket_init()
387 INIT_WORK(&sc->recv_io.posted.refill_work, __smbdirect_socket_disabled_work); in smbdirect_socket_init()
388 disable_work_sync(&sc->recv_io.posted.refill_work); in smbdirect_socket_init()
390 atomic_set(&sc->recv_io.credits.count, 0); in smbdirect_socket_init()
392 INIT_LIST_HEAD(&sc->recv_io.reassembly.list); in smbdirect_socket_init()
393 spin_lock_init(&sc->recv_io.reassembly.lock); in smbdirect_socket_init()
394 init_waitqueue_head(&sc->recv_io.reassembly.wait_queue); in smbdirect_socket_init()
/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()