Searched refs:msg_wq (Results 1 – 4 of 4) sorted by relevance
| /kernel/linux/linux-5.10/fs/hmdfs/comm/ |
| D | socket_adapter.c | 70 struct sendmsg_wait_queue *msg_wq; in msg_release() local
73 msg_wq = (struct sendmsg_wait_queue *)container_of(kref, in msg_release()
75 con = msg_wq->head.peer; in msg_release()
76 idr_remove(&con->msg_idr, msg_wq->head.msg_id); in msg_release()
79 kfree(msg_wq->buf); in msg_release()
80 if (msg_wq->recv_info.local_filp) in msg_release()
81 fput(msg_wq->recv_info.local_filp); in msg_release()
82 kfree(msg_wq); in msg_release()
86 void msg_put(struct sendmsg_wait_queue *msg_wq) in msg_put() argument
88 kref_put_lock(&msg_wq->head.ref, msg_release, in msg_put()
[all …]
|
| D | socket_adapter.h | 164 void msg_put(struct sendmsg_wait_queue *msg_wq);
|
| /kernel/linux/linux-5.10/drivers/ntb/test/ |
| D | ntb_tool.c | 260 wait_queue_head_t msg_wq; member
327 wake_up(&tc->msg_wq); in tool_msg_event()
1391 if (wait_event_interruptible(tc->msg_wq, in tool_msg_event_write()
1454 init_waitqueue_head(&tc->msg_wq); in tool_create_data()
1469 wake_up(&tc->msg_wq); in tool_clear_data()
|
| /kernel/linux/linux-5.10/fs/hmdfs/ |
| D | main.c | 995 struct sendmsg_wait_queue *msg_wq = NULL; in hmdfs_cancel_async_readdir() local
1019 list_for_each_entry(msg_wq, &sbi->async_readdir_msg_list, async_msg) in hmdfs_cancel_async_readdir()
1020 hmdfs_response_wakeup(msg_wq, -EINTR, 0, NULL); in hmdfs_cancel_async_readdir()
|