| /fs/btrfs/ |
| D | async-thread.c | 61 struct btrfs_fs_info * __pure btrfs_work_owner(const struct btrfs_work *work) in btrfs_work_owner() argument
63 return work->wq->fs_info; in btrfs_work_owner()
224 struct btrfs_work *work; in run_ordered_work() local
233 work = list_entry(list->next, struct btrfs_work, in run_ordered_work()
235 if (!test_bit(WORK_DONE_BIT, &work->flags)) in run_ordered_work()
251 if (test_and_set_bit(WORK_ORDER_DONE_BIT, &work->flags)) in run_ordered_work()
253 trace_btrfs_ordered_sched(work); in run_ordered_work()
255 work->ordered_func(work); in run_ordered_work()
259 list_del(&work->ordered_list); in run_ordered_work()
262 if (work == self) { in run_ordered_work()
[all …]
|
| D | async-thread.h | 37 void btrfs_init_work(struct btrfs_work *work, btrfs_func_t func,
40 struct btrfs_work *work);
43 void btrfs_set_work_high_priority(struct btrfs_work *work);
44 struct btrfs_fs_info * __pure btrfs_work_owner(const struct btrfs_work *work);
|
| D | discard.c | 304 cancel_delayed_work_sync(&discard_ctl->work); in btrfs_discard_cancel_work()
327 if (!delayed_work_pending(&discard_ctl->work)) in btrfs_discard_queue_work()
338 if (!override && delayed_work_pending(&discard_ctl->work)) in __btrfs_discard_schedule_work()
370 &discard_ctl->work, delay); in __btrfs_discard_schedule_work()
426 static void btrfs_discard_workfn(struct work_struct *work) in btrfs_discard_workfn() argument
436 discard_ctl = container_of(work, struct btrfs_discard_ctl, work.work); in btrfs_discard_workfn()
687 INIT_DELAYED_WORK(&discard_ctl->work, btrfs_discard_workfn); in btrfs_discard_init()
707 cancel_delayed_work_sync(&fs_info->discard_ctl.work); in btrfs_discard_cleanup()
|
| D | raid56.c | 80 struct btrfs_work work; member
179 static void rmw_work(struct btrfs_work *work);
180 static void read_rebuild_work(struct btrfs_work *work);
189 static void scrub_parity_work(struct btrfs_work *work);
193 btrfs_init_work(&rbio->work, work_func, NULL, NULL); in start_async_work()
194 btrfs_queue_work(rbio->fs_info->rmw_workers, &rbio->work); in start_async_work()
1665 struct btrfs_work work; member
1732 static void unplug_work(struct btrfs_work *work) in unplug_work() argument
1735 plug = container_of(work, struct btrfs_plug_cb, work); in unplug_work()
1745 btrfs_init_work(&plug->work, unplug_work, NULL, NULL); in btrfs_raid_unplug()
[all …]
|
| /fs/ |
| D | fs-writeback.c | 162 struct wb_writeback_work *work) in finish_writeback_work() argument
164 struct wb_completion *done = work->done; in finish_writeback_work()
166 if (work->auto_free) in finish_writeback_work()
167 kfree(work); in finish_writeback_work()
178 struct wb_writeback_work *work) in wb_queue_work() argument
180 trace_writeback_queue(wb, work); in wb_queue_work()
182 if (work->done) in wb_queue_work()
183 atomic_inc(&work->done->cnt); in wb_queue_work()
188 list_add_tail(&work->list, &wb->work_list); in wb_queue_work()
191 finish_writeback_work(wb, work); in wb_queue_work()
[all …]
|
| D | sync.c | 131 static void do_sync_work(struct work_struct *work) in do_sync_work() argument
146 kfree(work); in do_sync_work()
151 struct work_struct *work; in emergency_sync() local
153 work = kmalloc(sizeof(*work), GFP_ATOMIC); in emergency_sync()
154 if (work) { in emergency_sync()
155 INIT_WORK(work, do_sync_work); in emergency_sync()
156 schedule_work(work); in emergency_sync()
|
| D | super.c | 157 static void destroy_super_work(struct work_struct *work) in destroy_super_work() argument
159 struct super_block *s = container_of(work, struct super_block, in destroy_super_work()
1018 static void do_emergency_remount(struct work_struct *work) in do_emergency_remount() argument
1021 kfree(work); in do_emergency_remount()
1027 struct work_struct *work; in emergency_remount() local
1029 work = kmalloc(sizeof(*work), GFP_ATOMIC); in emergency_remount()
1030 if (work) { in emergency_remount()
1031 INIT_WORK(work, do_emergency_remount); in emergency_remount()
1032 schedule_work(work); in emergency_remount()
1047 static void do_thaw_all(struct work_struct *work) in do_thaw_all() argument
[all …]
|
| D | aio.c | 176 struct work_struct work; member
189 struct work_struct work; member
594 static void free_ioctx(struct work_struct *work) in free_ioctx() argument
596 struct kioctx *ctx = container_of(to_rcu_work(work), struct kioctx, in free_ioctx()
1597 static void aio_fsync_work(struct work_struct *work) in aio_fsync_work() argument
1599 struct aio_kiocb *iocb = container_of(work, struct aio_kiocb, fsync.work); in aio_fsync_work()
1623 INIT_WORK(&req->work, aio_fsync_work); in aio_fsync()
1624 schedule_work(&req->work); in aio_fsync()
1628 static void aio_poll_put_work(struct work_struct *work) in aio_poll_put_work() argument
1630 struct poll_iocb *req = container_of(work, struct poll_iocb, work); in aio_poll_put_work()
[all …]
|
| /fs/afs/ |
| D | cmservice.c | 39 .work = SRXAFSCB_CallBack,
49 .work = SRXAFSCB_InitCallBackState,
59 .work = SRXAFSCB_InitCallBackState,
69 .work = SRXAFSCB_Probe,
79 .work = SRXAFSCB_ProbeUuid,
89 .work = SRXAFSCB_TellMeAboutYourself,
99 .work = SRXAFSCB_CallBack,
204 static void SRXAFSCB_CallBack(struct work_struct *work) in SRXAFSCB_CallBack() argument
206 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_CallBack()
329 static void SRXAFSCB_InitCallBackState(struct work_struct *work) in SRXAFSCB_InitCallBackState() argument
[all …]
|
| D | rxrpc.c | 214 if (call->type->work) { in afs_queue_call_work()
215 INIT_WORK(&call->work, call->type->work); in afs_queue_call_work()
218 if (!queue_work(afs_wq, &call->work)) in afs_queue_call_work()
721 static void afs_process_async_call(struct work_struct *work) in afs_process_async_call() argument
723 struct afs_call *call = container_of(work, struct afs_call, async_work); in afs_process_async_call()
746 void afs_charge_preallocation(struct work_struct *work) in afs_charge_preallocation() argument
749 container_of(work, struct afs_net, charge_preallocation_work); in afs_charge_preallocation()
|
| /fs/ext4/ |
| D | readpage.c | 66 struct work_struct work; member
97 static void decrypt_work(struct work_struct *work) in decrypt_work() argument
100 container_of(work, struct bio_post_read_ctx, work); in decrypt_work()
107 static void verity_work(struct work_struct *work) in verity_work() argument
110 container_of(work, struct bio_post_read_ctx, work); in verity_work()
139 INIT_WORK(&ctx->work, decrypt_work); in bio_post_read_processing()
140 fscrypt_enqueue_decrypt_work(&ctx->work); in bio_post_read_processing()
147 INIT_WORK(&ctx->work, verity_work); in bio_post_read_processing()
148 fsverity_enqueue_verify_work(&ctx->work); in bio_post_read_processing()
|
| /fs/xfs/ |
| D | xfs_mru_cache.c | 101 struct delayed_work work; /* Workqueue data for reaping. */ member
206 queue_delayed_work(xfs_mru_reap_wq, &mru->work, in _xfs_mru_cache_list_insert()
266 struct work_struct *work) in _xfs_mru_cache_reap() argument
269 container_of(work, struct xfs_mru_cache, work.work); in _xfs_mru_cache_reap()
287 queue_delayed_work(xfs_mru_reap_wq, &mru->work, next); in _xfs_mru_cache_reap()
358 INIT_DELAYED_WORK(&mru->work, _xfs_mru_cache_reap); in xfs_mru_cache_create()
390 cancel_delayed_work_sync(&mru->work); in xfs_mru_cache_flush()
|
| D | xfs_pwork.c | 39 struct work_struct *work) in xfs_pwork_work() argument
45 pwork = container_of(work, struct xfs_pwork, work); in xfs_pwork_work()
92 INIT_WORK(&pwork->work, xfs_pwork_work); in xfs_pwork_queue()
95 queue_work(pctl->wq, &pwork->work); in xfs_pwork_queue()
|
| /fs/xfs/libxfs/ |
| D | xfs_ag.c | 349 aghdr_init_work_f work, in xfs_ag_init_hdr() argument
359 (*work)(mp, bp, id); in xfs_ag_init_hdr()
370 aghdr_init_work_f work; member
396 .work = &xfs_sbblock_init, in xfs_ag_init_headers()
403 .work = &xfs_agfblock_init, in xfs_ag_init_headers()
410 .work = &xfs_agflblock_init, in xfs_ag_init_headers()
417 .work = &xfs_agiblock_init, in xfs_ag_init_headers()
424 .work = &xfs_bnoroot_init, in xfs_ag_init_headers()
431 .work = &xfs_cntroot_init, in xfs_ag_init_headers()
438 .work = &xfs_btroot_init, in xfs_ag_init_headers()
[all …]
|
| /fs/ocfs2/cluster/ |
| D | tcp.c | 124 static void o2net_sc_connect_completed(struct work_struct *work);
125 static void o2net_rx_until_empty(struct work_struct *work);
126 static void o2net_shutdown_sc(struct work_struct *work);
128 static void o2net_sc_send_keep_req(struct work_struct *work);
460 struct work_struct *work) in o2net_sc_queue_work() argument
463 if (!queue_work(o2net_wq, work)) in o2net_sc_queue_work()
467 struct delayed_work *work, in o2net_sc_queue_delayed_work() argument
471 if (!queue_delayed_work(o2net_wq, work, delay)) in o2net_sc_queue_delayed_work()
475 struct delayed_work *work) in o2net_sc_cancel_delayed_work() argument
477 if (cancel_delayed_work(work)) in o2net_sc_cancel_delayed_work()
[all …]
|
| /fs/fscache/ |
| D | object.c | 45 .work = f \
51 #define transit_to(state) ({ prefetch(&STATE(state)->work); STATE(state); })
66 .work = NULL, \
195 ASSERT(state->work != NULL); in fscache_object_sm_dispatcher()
206 if (!state->work) { in fscache_object_sm_dispatcher()
234 new_state = state->work(object, event); in fscache_object_sm_dispatcher()
251 if (state->work) { in fscache_object_sm_dispatcher()
276 static void fscache_object_work_func(struct work_struct *work) in fscache_object_work_func() argument
279 container_of(work, struct fscache_object, work); in fscache_object_work_func()
315 INIT_WORK(&object->work, fscache_object_work_func); in fscache_object_init()
[all …]
|
| D | operation.c | 37 INIT_WORK(&op->work, fscache_op_work_func); in fscache_operation_init()
78 if (!queue_work(fscache_op_wq, &op->work)) in fscache_enqueue_operation()
561 void fscache_operation_gc(struct work_struct *work) in fscache_operation_gc() argument
566 container_of(work, struct fscache_cache, op_gc); in fscache_operation_gc()
615 void fscache_op_work_func(struct work_struct *work) in fscache_op_work_func() argument
618 container_of(work, struct fscache_operation, work); in fscache_op_work_func()
|
| /fs/nfs/ |
| D | nfs4renewd.c | 55 nfs4_renew_state(struct work_struct *work) in nfs4_renew_state() argument
59 container_of(work, struct nfs_client, cl_renewd.work); in nfs4_renew_state()
|
| /fs/iomap/ |
| D | direct-io.c | 48 struct work_struct work; member
136 static void iomap_dio_complete_work(struct work_struct *work) in iomap_dio_complete_work() argument
138 struct iomap_dio *dio = container_of(work, struct iomap_dio, aio.work); in iomap_dio_complete_work()
170 INIT_WORK(&dio->aio.work, iomap_dio_complete_work); in iomap_dio_bio_end_io()
171 queue_work(inode->i_sb->s_dio_done_wq, &dio->aio.work); in iomap_dio_bio_end_io()
173 iomap_dio_complete_work(&dio->aio.work); in iomap_dio_bio_end_io()
|
| /fs/overlayfs/ |
| D | super.c | 741 struct dentry *work; in ovl_workdir_create() local
747 work = lookup_one_len(name, ofs->workbasedir, strlen(name)); in ovl_workdir_create()
749 if (!IS_ERR(work)) { in ovl_workdir_create()
755 if (work->d_inode) { in ovl_workdir_create()
764 err = ovl_workdir_cleanup(dir, mnt, work, 0); in ovl_workdir_create()
765 dput(work); in ovl_workdir_create()
767 work = ERR_PTR(err); in ovl_workdir_create()
773 err = ovl_mkdir_real(dir, &work, attr.ia_mode); in ovl_workdir_create()
779 if (d_really_is_negative(work)) in ovl_workdir_create()
795 err = vfs_removexattr(work, XATTR_NAME_POSIX_ACL_DEFAULT); in ovl_workdir_create()
[all …]
|
| /fs/jffs2/ |
| D | LICENCE | 22 files and link them with other works to produce a work based on these
23 files, these files do not by themselves cause the resulting work to be
28 This exception does not invalidate any other reasons why a work based on
|
| /fs/cifs/ |
| D | smb2misc.c | 499 cifs_ses_oplock_break(struct work_struct *work) in cifs_ses_oplock_break() argument
501 struct smb2_lease_break_work *lw = container_of(work, in cifs_ses_oplock_break()
747 smb2_cancelled_close_fid(struct work_struct *work) in smb2_cancelled_close_fid() argument
749 struct close_cancelled_open *cancelled = container_of(work, in smb2_cancelled_close_fid()
750 struct close_cancelled_open, work); in smb2_cancelled_close_fid()
792 INIT_WORK(&cancelled->work, smb2_cancelled_close_fid); in __smb2_handle_cancelled_cmd()
793 WARN_ON(queue_work(cifsiod_wq, &cancelled->work) == false); in __smb2_handle_cancelled_cmd()
|
| /fs/nfsd/ |
| D | filecache.c | 48 struct work_struct work; member
377 queue_work(nfsd_filecache_wq, &l->work); in nfsd_file_list_add_disposal()
483 nfsd_file_gc_worker(struct work_struct *work) in nfsd_file_gc_worker() argument
573 nfsd_file_delayed_close(struct work_struct *work) in nfsd_file_delayed_close() argument
576 struct nfsd_fcache_disposal *l = container_of(work, in nfsd_file_delayed_close()
577 struct nfsd_fcache_disposal, work); in nfsd_file_delayed_close()
760 INIT_WORK(&l->work, nfsd_file_delayed_close); in nfsd_alloc_fcache_disposal()
771 cancel_work_sync(&l->work); in nfsd_free_fcache_disposal()
|
| /fs/fuse/ |
| D | virtio_fs.c | 322 static void virtio_fs_hiprio_done_work(struct work_struct *work) in virtio_fs_hiprio_done_work() argument
324 struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq, in virtio_fs_hiprio_done_work()
344 static void virtio_fs_request_dispatch_work(struct work_struct *work) in virtio_fs_request_dispatch_work() argument
347 struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq, in virtio_fs_request_dispatch_work()
348 dispatch_work.work); in virtio_fs_request_dispatch_work()
460 static void virtio_fs_hiprio_dispatch_work(struct work_struct *work) in virtio_fs_hiprio_dispatch_work() argument
463 struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq, in virtio_fs_hiprio_dispatch_work()
464 dispatch_work.work); in virtio_fs_hiprio_dispatch_work()
592 static void virtio_fs_complete_req_work(struct work_struct *work) in virtio_fs_complete_req_work() argument
595 container_of(work, typeof(*w), done_work); in virtio_fs_complete_req_work()
[all …]
|
| /fs/fat/ |
| D | dir.c | 359 unsigned char c, work[MSDOS_NAME]; in fat_parse_short() local
370 memcpy(work, de->name, sizeof(work)); in fat_parse_short()
374 if (work[0] == 0x05) in fat_parse_short()
375 work[0] = 0xE5; in fat_parse_short()
379 c = work[i]; in fat_parse_short()
382 chl = fat_shortname2uni(nls_disk, &work[i], 8 - i, in fat_parse_short()
399 ptname[i] = work[i]; in fat_parse_short()
415 c = work[k]; in fat_parse_short()
418 chl = fat_shortname2uni(nls_disk, &work[k], MSDOS_NAME - k, in fat_parse_short()
439 ptname[i] = work[k]; in fat_parse_short()
|