Home
last modified time | relevance | path

Searched refs:async_work (Results 1 – 11 of 11) sorted by relevance

/kernel/linux/linux-5.10/fs/hmdfs/comm/
Dsocket_adapter.c619 struct hmdfs_async_work *async_work = in hmdfs_recv_page_work_fn() local
622 hmdfs_client_resp_statis(async_work->head.peer->sbi, in hmdfs_recv_page_work_fn()
625 async_work->head.msg_id); in hmdfs_recv_page_work_fn()
626 asw_done(async_work); in hmdfs_recv_page_work_fn()
634 struct hmdfs_async_work *async_work = NULL; in hmdfs_sendpage_request() local
671 async_work = kzalloc(sizeof(*async_work), GFP_KERNEL); in hmdfs_sendpage_request()
672 if (!async_work) { in hmdfs_sendpage_request()
676 async_work->start = start; in hmdfs_sendpage_request()
677 ret = hmdfs_alloc_msg_idr(con, MSG_IDR_PAGE, async_work); in hmdfs_sendpage_request()
682 head.msg_id = cpu_to_le32(async_work->head.msg_id); in hmdfs_sendpage_request()
[all …]
Dtransport.c222 struct hmdfs_async_work *async_work = NULL; in tcp_recvpage_tls() local
237 async_work = (struct hmdfs_async_work *)hmdfs_find_msg_head(node, in tcp_recvpage_tls()
239 if (!async_work || !cancel_delayed_work(&async_work->d_work)) in tcp_recvpage_tls()
242 page = async_work->page; in tcp_recvpage_tls()
253 hmdfs_client_recv_readpage(recv, rd_err, async_work); in tcp_recvpage_tls()
254 asw_put(async_work); in tcp_recvpage_tls()
259 if (async_work) in tcp_recvpage_tls()
260 asw_put(async_work); in tcp_recvpage_tls()
Dsocket_adapter.h162 void hmdfs_wakeup_async_work(struct hmdfs_async_work *async_work);
/kernel/linux/linux-5.10/drivers/char/tpm/
Dtpm-dev-common.c59 container_of(work, struct file_priv, async_work); in tpm_dev_async_work()
121 INIT_WORK(&priv->async_work, tpm_dev_async_work); in tpm_common_open()
210 queue_work(tpm_dev_wq, &priv->async_work); in tpm_common_write()
265 flush_work(&priv->async_work); in tpm_common_release()
Dtpm-dev.h15 struct work_struct async_work; member
/kernel/linux/linux-5.10/fs/btrfs/
Ddelayed-inode.c1318 struct btrfs_async_delayed_work *async_work; in btrfs_async_run_delayed_root() local
1327 async_work = container_of(work, struct btrfs_async_delayed_work, work); in btrfs_async_run_delayed_root()
1328 delayed_root = async_work->delayed_root; in btrfs_async_run_delayed_root()
1367 } while ((async_work->nr == 0 && total_done < BTRFS_DELAYED_WRITEBACK) in btrfs_async_run_delayed_root()
1368 || total_done < async_work->nr); in btrfs_async_run_delayed_root()
1373 kfree(async_work); in btrfs_async_run_delayed_root()
1380 struct btrfs_async_delayed_work *async_work; in btrfs_wq_run_delayed_node() local
1382 async_work = kmalloc(sizeof(*async_work), GFP_NOFS); in btrfs_wq_run_delayed_node()
1383 if (!async_work) in btrfs_wq_run_delayed_node()
1386 async_work->delayed_root = delayed_root; in btrfs_wq_run_delayed_node()
[all …]
Dspace-info.c1316 struct work_struct *async_work; in __reserve_bytes() local
1326 async_work = &fs_info->async_data_reclaim_work; in __reserve_bytes()
1328 async_work = &fs_info->async_reclaim_work; in __reserve_bytes()
1380 queue_work(system_unbound_wq, async_work); in __reserve_bytes()
/kernel/linux/linux-5.10/fs/afs/
Drxrpc.c149 INIT_WORK(&call->async_work, afs_process_async_call); in afs_alloc_call()
174 ASSERT(!work_pending(&call->async_work)); in afs_put_call()
492 if (cancel_work_sync(&call->async_work)) in afs_make_call()
712 if (!queue_work(afs_async_calls, &call->async_work)) in afs_wake_up_async_call()
723 struct afs_call *call = container_of(work, struct afs_call, async_work); in afs_process_async_call()
Dinternal.h99 struct work_struct async_work; /* async I/O processor */ member
/kernel/linux/linux-5.10/fs/hmdfs/
Dhmdfs_client.c390 struct hmdfs_async_work *async_work) in hmdfs_client_recv_readpage() argument
392 struct page *page = async_work->page; in hmdfs_client_recv_readpage()
403 hmdfs_client_resp_statis(async_work->head.peer->sbi, F_READPAGE, in hmdfs_client_recv_readpage()
404 HMDFS_RESP_NORMAL, async_work->start, jiffies); in hmdfs_client_recv_readpage()
406 trace_hmdfs_client_recv_readpage(async_work->head.peer, in hmdfs_client_recv_readpage()
409 asw_done(async_work); in hmdfs_client_recv_readpage()
Dhmdfs_client.h108 struct hmdfs_async_work *async_work);