| /fs/btrfs/ |
| D | async-thread.c | 63 btrfs_work_owner(const struct btrfs_work *work) in btrfs_work_owner() argument
65 return work->wq->fs_info; in btrfs_work_owner()
226 struct btrfs_work *work; in run_ordered_work() local
236 work = list_entry(list->next, struct btrfs_work, in run_ordered_work()
238 if (!test_bit(WORK_DONE_BIT, &work->flags)) in run_ordered_work()
247 if (test_and_set_bit(WORK_ORDER_DONE_BIT, &work->flags)) in run_ordered_work()
249 trace_btrfs_ordered_sched(work); in run_ordered_work()
251 work->ordered_func(work); in run_ordered_work()
255 list_del(&work->ordered_list); in run_ordered_work()
258 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 *btrfs_work_owner(const struct btrfs_work *work);
|
| 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()
1666 struct btrfs_work work; member
1733 static void unplug_work(struct btrfs_work *work) in unplug_work() argument
1736 plug = container_of(work, struct btrfs_plug_cb, work); in unplug_work()
1746 btrfs_init_work(&plug->work, unplug_work, NULL, NULL); in btrfs_raid_unplug()
[all …]
|
| D | scrub.c | 98 struct btrfs_work work; member
118 struct btrfs_work work; member
140 struct btrfs_work work; member
242 static void scrub_bio_end_io_worker(struct btrfs_work *work);
253 static void scrub_wr_bio_end_io_worker(struct btrfs_work *work);
601 btrfs_init_work(&sbio->work, scrub_bio_end_io_worker, NULL, in scrub_setup_ctx()
1723 btrfs_init_work(&sbio->work, scrub_wr_bio_end_io_worker, NULL, NULL); in scrub_wr_bio_end_io()
1724 btrfs_queue_work(fs_info->scrub_wr_completion_workers, &sbio->work); in scrub_wr_bio_end_io()
1727 static void scrub_wr_bio_end_io_worker(struct btrfs_work *work) in scrub_wr_bio_end_io_worker() argument
1729 struct scrub_bio *sbio = container_of(work, struct scrub_bio, work); in scrub_wr_bio_end_io_worker()
[all …]
|
| /fs/ |
| D | fs-writeback.c | 161 struct wb_writeback_work *work) in finish_writeback_work() argument
163 struct wb_completion *done = work->done; in finish_writeback_work()
165 if (work->auto_free) in finish_writeback_work()
166 kfree(work); in finish_writeback_work()
177 struct wb_writeback_work *work) in wb_queue_work() argument
179 trace_writeback_queue(wb, work); in wb_queue_work()
181 if (work->done) in wb_queue_work()
182 atomic_inc(&work->done->cnt); in wb_queue_work()
187 list_add_tail(&work->list, &wb->work_list); in wb_queue_work()
190 finish_writeback_work(wb, work); in wb_queue_work()
[all …]
|
| D | sync.c | 128 static void do_sync_work(struct work_struct *work) in do_sync_work() argument
143 kfree(work); in do_sync_work()
148 struct work_struct *work; in emergency_sync() local
150 work = kmalloc(sizeof(*work), GFP_ATOMIC); in emergency_sync()
151 if (work) { in emergency_sync()
152 INIT_WORK(work, do_sync_work); in emergency_sync()
153 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()
1008 static void do_emergency_remount(struct work_struct *work) in do_emergency_remount() argument
1011 kfree(work); in do_emergency_remount()
1017 struct work_struct *work; in emergency_remount() local
1019 work = kmalloc(sizeof(*work), GFP_ATOMIC); in emergency_remount()
1020 if (work) { in emergency_remount()
1021 INIT_WORK(work, do_emergency_remount); in emergency_remount()
1022 schedule_work(work); in emergency_remount()
1037 static void do_thaw_all(struct work_struct *work) in do_thaw_all() argument
[all …]
|
| D | aio.c | 177 struct work_struct work; member
188 struct work_struct work; member
582 static void free_ioctx(struct work_struct *work) in free_ioctx() argument
584 struct kioctx *ctx = container_of(to_rcu_work(work), struct kioctx, in free_ioctx()
1589 static void aio_fsync_work(struct work_struct *work) in aio_fsync_work() argument
1591 struct aio_kiocb *iocb = container_of(work, struct aio_kiocb, fsync.work); in aio_fsync_work()
1608 INIT_WORK(&req->work, aio_fsync_work); in aio_fsync()
1609 schedule_work(&req->work); in aio_fsync()
1613 static void aio_poll_complete_work(struct work_struct *work) in aio_poll_complete_work() argument
1615 struct poll_iocb *req = container_of(work, struct poll_iocb, work); in aio_poll_complete_work()
[all …]
|
| /fs/afs/ |
| D | cmservice.c | 44 .work = SRXAFSCB_CallBack,
55 .work = SRXAFSCB_InitCallBackState,
66 .work = SRXAFSCB_InitCallBackState,
77 .work = SRXAFSCB_Probe,
88 .work = SRXAFSCB_ProbeUuid,
99 .work = SRXAFSCB_TellMeAboutYourself,
110 .work = SRXAFSCB_CallBack,
249 static void SRXAFSCB_CallBack(struct work_struct *work) in SRXAFSCB_CallBack() argument
251 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_CallBack()
374 static void SRXAFSCB_InitCallBackState(struct work_struct *work) in SRXAFSCB_InitCallBackState() argument
[all …]
|
| D | rxrpc.c | 218 if (call->type->work) { in afs_queue_call_work()
219 INIT_WORK(&call->work, call->type->work); in afs_queue_call_work()
222 if (!queue_work(afs_wq, &call->work)) in afs_queue_call_work()
751 static void afs_delete_async_call(struct work_struct *work) in afs_delete_async_call() argument
753 struct afs_call *call = container_of(work, struct afs_call, async_work); in afs_delete_async_call()
766 static void afs_process_async_call(struct work_struct *work) in afs_process_async_call() argument
768 struct afs_call *call = container_of(work, struct afs_call, async_work); in afs_process_async_call()
801 void afs_charge_preallocation(struct work_struct *work) in afs_charge_preallocation() argument
804 container_of(work, struct afs_net, charge_preallocation_work); in afs_charge_preallocation()
|
| /fs/ext4/ |
| D | readpage.c | 65 struct work_struct work; member
96 static void decrypt_work(struct work_struct *work) in decrypt_work() argument
99 container_of(work, struct bio_post_read_ctx, work); in decrypt_work()
106 static void verity_work(struct work_struct *work) in verity_work() argument
109 container_of(work, struct bio_post_read_ctx, work); in verity_work()
126 INIT_WORK(&ctx->work, decrypt_work); in bio_post_read_processing()
127 fscrypt_enqueue_decrypt_work(&ctx->work); in bio_post_read_processing()
134 INIT_WORK(&ctx->work, verity_work); in bio_post_read_processing()
135 fsverity_enqueue_verify_work(&ctx->work); in bio_post_read_processing()
|
| /fs/xfs/ |
| 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()
|
| 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()
|
| /fs/xfs/libxfs/ |
| D | xfs_ag.c | 341 aghdr_init_work_f work, in xfs_ag_init_hdr() argument
351 (*work)(mp, bp, id); in xfs_ag_init_hdr()
362 aghdr_init_work_f work; member
388 .work = &xfs_sbblock_init, in xfs_ag_init_headers()
395 .work = &xfs_agfblock_init, in xfs_ag_init_headers()
402 .work = &xfs_agflblock_init, in xfs_ag_init_headers()
409 .work = &xfs_agiblock_init, in xfs_ag_init_headers()
416 .work = &xfs_bnoroot_init, in xfs_ag_init_headers()
423 .work = &xfs_cntroot_init, in xfs_ag_init_headers()
430 .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/overlayfs/ |
| D | super.c | 640 struct dentry *work; in ovl_workdir_create() local
649 work = lookup_one_len(name, ofs->workbasedir, strlen(name)); in ovl_workdir_create()
651 if (!IS_ERR(work)) { in ovl_workdir_create()
657 if (work->d_inode) { in ovl_workdir_create()
666 ovl_workdir_cleanup(dir, mnt, work, 0); in ovl_workdir_create()
667 dput(work); in ovl_workdir_create()
671 work = ovl_create_real(dir, work, OVL_CATTR(attr.ia_mode)); in ovl_workdir_create()
672 err = PTR_ERR(work); in ovl_workdir_create()
673 if (IS_ERR(work)) in ovl_workdir_create()
689 err = vfs_removexattr(work, XATTR_NAME_POSIX_ACL_DEFAULT); in ovl_workdir_create()
[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()
|
| D | direct.c | 90 struct work_struct work; member
103 static void nfs_direct_write_schedule_work(struct work_struct *work);
309 INIT_WORK(&dreq->work, nfs_direct_write_schedule_work); in nfs_direct_req_alloc()
731 static void nfs_direct_write_schedule_work(struct work_struct *work) in nfs_direct_write_schedule_work() argument
733 struct nfs_direct_req *dreq = container_of(work, struct nfs_direct_req, work); in nfs_direct_write_schedule_work()
752 queue_work(nfsiod_workqueue, &dreq->work); /* Calls nfs_direct_write_schedule_work */ in nfs_direct_write_complete()
|
| /fs/iomap/ |
| D | direct-io.c | 47 struct work_struct work; member
129 static void iomap_dio_complete_work(struct work_struct *work) in iomap_dio_complete_work() argument
131 struct iomap_dio *dio = container_of(work, struct iomap_dio, aio.work); in iomap_dio_complete_work()
163 INIT_WORK(&dio->aio.work, iomap_dio_complete_work); in iomap_dio_bio_end_io()
164 queue_work(inode->i_sb->s_dio_done_wq, &dio->aio.work); in iomap_dio_bio_end_io()
166 iomap_dio_complete_work(&dio->aio.work); in iomap_dio_bio_end_io()
|
| /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 | 498 cifs_ses_oplock_break(struct work_struct *work) in cifs_ses_oplock_break() argument
500 struct smb2_lease_break_work *lw = container_of(work, in cifs_ses_oplock_break()
733 smb2_cancelled_close_fid(struct work_struct *work) in smb2_cancelled_close_fid() argument
735 struct close_cancelled_open *cancelled = container_of(work, in smb2_cancelled_close_fid()
736 struct close_cancelled_open, work); in smb2_cancelled_close_fid()
760 INIT_WORK(&cancelled->work, smb2_cancelled_close_fid); in __smb2_handle_cancelled_close()
761 WARN_ON(queue_work(cifsiod_wq, &cancelled->work) == false); in __smb2_handle_cancelled_close()
|
| /fs/fuse/ |
| D | virtio_fs.c | 238 static void virtio_fs_hiprio_done_work(struct work_struct *work) in virtio_fs_hiprio_done_work() argument
240 struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq, in virtio_fs_hiprio_done_work()
260 static void virtio_fs_request_dispatch_work(struct work_struct *work) in virtio_fs_request_dispatch_work() argument
263 struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq, in virtio_fs_request_dispatch_work()
264 dispatch_work.work); in virtio_fs_request_dispatch_work()
316 static void virtio_fs_hiprio_dispatch_work(struct work_struct *work) in virtio_fs_hiprio_dispatch_work() argument
319 struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq, in virtio_fs_hiprio_dispatch_work()
320 dispatch_work.work); in virtio_fs_hiprio_dispatch_work()
446 static void virtio_fs_requests_done_work(struct work_struct *work) in virtio_fs_requests_done_work() argument
448 struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq, in virtio_fs_requests_done_work()
|
| /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()
|