| /fs/btrfs/ |
| D | async-thread.c | 63 static void normal_work_helper(struct btrfs_work *work);
68 struct btrfs_work *work = container_of(arg, struct btrfs_work, \
70 normal_work_helper(work); \
252 struct btrfs_work *work; in run_ordered_work() local
260 work = list_entry(list->next, struct btrfs_work, in run_ordered_work()
262 if (!test_bit(WORK_DONE_BIT, &work->flags)) in run_ordered_work()
278 if (test_and_set_bit(WORK_ORDER_DONE_BIT, &work->flags)) in run_ordered_work()
280 trace_btrfs_ordered_sched(work); in run_ordered_work()
282 work->ordered_func(work); in run_ordered_work()
286 list_del(&work->ordered_list); in run_ordered_work()
[all …]
|
| D | raid56.c | 89 struct btrfs_work work; member
182 static void rmw_work(struct btrfs_work *work);
183 static void read_rebuild_work(struct btrfs_work *work);
1486 btrfs_init_work(&rbio->work, btrfs_rmw_helper, in async_rmw_stripe()
1490 &rbio->work); in async_rmw_stripe()
1495 btrfs_init_work(&rbio->work, btrfs_rmw_helper, in async_read_rebuild()
1499 &rbio->work); in async_read_rebuild()
1658 struct btrfs_work work; member
1722 static void unplug_work(struct btrfs_work *work) in unplug_work() argument
1725 plug = container_of(work, struct btrfs_plug_cb, work); in unplug_work()
[all …]
|
| D | async-thread.h | 74 void btrfs_init_work(struct btrfs_work *work, btrfs_work_func_t helper,
79 struct btrfs_work *work);
82 void btrfs_set_work_high_priority(struct btrfs_work *work);
|
| D | scrub.c | 108 struct btrfs_work work; member
128 struct btrfs_work work; member
150 struct btrfs_work work; member
213 struct btrfs_work work; member
231 struct btrfs_work work; member
278 static void scrub_bio_end_io_worker(struct btrfs_work *work);
295 static void scrub_wr_bio_end_io_worker(struct btrfs_work *work);
302 static void copy_nocow_pages_worker(struct btrfs_work *work);
483 btrfs_init_work(&sbio->work, btrfs_scrub_helper, in scrub_setup_ctx()
789 static void scrub_fixup_nodatasum(struct btrfs_work *work) in scrub_fixup_nodatasum() argument
[all …]
|
| D | reada.c | 93 struct btrfs_work work; member
739 static void reada_start_machine_worker(struct btrfs_work *work) in reada_start_machine_worker() argument
745 rmw = container_of(work, struct reada_machine_work, work); in reada_start_machine_worker()
806 btrfs_init_work(&rmw->work, btrfs_readahead_helper, in reada_start_machine()
810 btrfs_queue_work(fs_info->readahead_workers, &rmw->work); in reada_start_machine()
|
| /fs/ |
| D | fs-writeback.c | 178 struct wb_writeback_work *work) in finish_writeback_work() argument
180 struct wb_completion *done = work->done; in finish_writeback_work()
182 if (work->auto_free) in finish_writeback_work()
183 kfree(work); in finish_writeback_work()
189 struct wb_writeback_work *work) in wb_queue_work() argument
191 trace_writeback_queue(wb, work); in wb_queue_work()
193 if (work->done) in wb_queue_work()
194 atomic_inc(&work->done->cnt); in wb_queue_work()
199 list_add_tail(&work->list, &wb->work_list); in wb_queue_work()
202 finish_writeback_work(wb, work); in wb_queue_work()
[all …]
|
| D | sync.c | 122 static void do_sync_work(struct work_struct *work) in do_sync_work() argument
137 kfree(work); in do_sync_work()
142 struct work_struct *work; in emergency_sync() local
144 work = kmalloc(sizeof(*work), GFP_ATOMIC); in emergency_sync()
145 if (work) { in emergency_sync()
146 INIT_WORK(work, do_sync_work); in emergency_sync()
147 schedule_work(work); in emergency_sync()
|
| D | super.c | 148 static void destroy_super_work(struct work_struct *work) in destroy_super_work() argument
150 struct super_block *s = container_of(work, struct super_block, in destroy_super_work()
817 static void do_emergency_remount(struct work_struct *work) in do_emergency_remount() argument
844 kfree(work); in do_emergency_remount()
850 struct work_struct *work; in emergency_remount() local
852 work = kmalloc(sizeof(*work), GFP_ATOMIC); in emergency_remount()
853 if (work) { in emergency_remount()
854 INIT_WORK(work, do_emergency_remount); in emergency_remount()
855 schedule_work(work); in emergency_remount()
|
| /fs/afs/ |
| D | cmservice.c | 154 static void SRXAFSCB_CallBack(struct work_struct *work) in SRXAFSCB_CallBack() argument
156 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_CallBack()
313 INIT_WORK(&call->work, SRXAFSCB_CallBack); in afs_deliver_cb_callback()
314 queue_work(afs_wq, &call->work); in afs_deliver_cb_callback()
321 static void SRXAFSCB_InitCallBackState(struct work_struct *work) in SRXAFSCB_InitCallBackState() argument
323 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_InitCallBackState()
360 INIT_WORK(&call->work, SRXAFSCB_InitCallBackState); in afs_deliver_cb_init_call_back_state()
361 queue_work(afs_wq, &call->work); in afs_deliver_cb_init_call_back_state()
391 INIT_WORK(&call->work, SRXAFSCB_InitCallBackState); in afs_deliver_cb_init_call_back_state3()
392 queue_work(afs_wq, &call->work); in afs_deliver_cb_init_call_back_state3()
[all …]
|
| D | callback.c | 63 void afs_broken_callback_work(struct work_struct *work) in afs_broken_callback_work() argument
66 container_of(work, struct afs_vnode, cb_broken_work); in afs_broken_callback_work()
334 void afs_dispatch_give_up_callbacks(struct work_struct *work) in afs_dispatch_give_up_callbacks() argument
337 container_of(work, struct afs_server, cb_break_work.work); in afs_dispatch_give_up_callbacks()
361 static void afs_callback_updater(struct work_struct *work)
369 server = container_of(work, struct afs_server, updater);
|
| /fs/xfs/ |
| D | xfs_mru_cache.c | 113 struct delayed_work work; /* Workqueue data for reaping. */ member
217 queue_delayed_work(xfs_mru_reap_wq, &mru->work, in _xfs_mru_cache_list_insert()
277 struct work_struct *work) in _xfs_mru_cache_reap() argument
280 container_of(work, struct xfs_mru_cache, work.work); in _xfs_mru_cache_reap()
298 queue_delayed_work(xfs_mru_reap_wq, &mru->work, next); in _xfs_mru_cache_reap()
368 INIT_DELAYED_WORK(&mru->work, _xfs_mru_cache_reap); in xfs_mru_cache_create()
400 cancel_delayed_work_sync(&mru->work); in xfs_mru_cache_flush()
|
| /fs/crypto/ |
| D | bio.c | 55 static void completion_pages(struct work_struct *work) in completion_pages() argument
58 container_of(work, struct fscrypt_ctx, r.work); in completion_pages()
68 INIT_WORK(&ctx->r.work, completion_pages); in fscrypt_enqueue_decrypt_bio()
70 fscrypt_enqueue_decrypt_work(&ctx->r.work); in fscrypt_enqueue_decrypt_bio()
|
| /fs/ocfs2/cluster/ |
| D | tcp.c | 137 static void o2net_sc_connect_completed(struct work_struct *work);
138 static void o2net_rx_until_empty(struct work_struct *work);
139 static void o2net_shutdown_sc(struct work_struct *work);
141 static void o2net_sc_send_keep_req(struct work_struct *work);
475 struct work_struct *work) in o2net_sc_queue_work() argument
478 if (!queue_work(o2net_wq, work)) in o2net_sc_queue_work()
482 struct delayed_work *work, in o2net_sc_queue_delayed_work() argument
486 if (!queue_delayed_work(o2net_wq, work, delay)) in o2net_sc_queue_delayed_work()
490 struct delayed_work *work) in o2net_sc_cancel_delayed_work() argument
492 if (cancel_delayed_work(work)) in o2net_sc_cancel_delayed_work()
[all …]
|
| /fs/ncpfs/ |
| D | ncp_fs_sb.h | 149 extern void ncp_tcp_rcv_proc(struct work_struct *work);
150 extern void ncp_tcp_tx_proc(struct work_struct *work);
151 extern void ncpdgram_rcv_proc(struct work_struct *work);
152 extern void ncpdgram_timeout_proc(struct work_struct *work);
|
| D | sock.c | 382 void ncpdgram_rcv_proc(struct work_struct *work) in ncpdgram_rcv_proc() argument
385 container_of(work, struct ncp_server, rcv.tq); in ncpdgram_rcv_proc()
501 void ncpdgram_timeout_proc(struct work_struct *work) in ncpdgram_timeout_proc() argument
504 container_of(work, struct ncp_server, timeout_tq); in ncpdgram_timeout_proc()
680 void ncp_tcp_rcv_proc(struct work_struct *work) in ncp_tcp_rcv_proc() argument
683 container_of(work, struct ncp_server, rcv.tq); in ncp_tcp_rcv_proc()
690 void ncp_tcp_tx_proc(struct work_struct *work) in ncp_tcp_tx_proc() argument
693 container_of(work, struct ncp_server, tx.tq); in ncp_tcp_tx_proc()
|
| /fs/overlayfs/ |
| D | super.c | 759 struct dentry *work; in ovl_workdir_create() local
769 work = lookup_one_len(OVL_WORKDIR_NAME, dentry, in ovl_workdir_create()
772 if (!IS_ERR(work)) { in ovl_workdir_create()
781 if (work->d_inode) { in ovl_workdir_create()
787 ovl_workdir_cleanup(dir, mnt, work, 0); in ovl_workdir_create()
788 dput(work); in ovl_workdir_create()
792 err = ovl_create_real(dir, work, &stat, NULL, NULL, true); in ovl_workdir_create()
796 err = vfs_removexattr(work, XATTR_NAME_POSIX_ACL_DEFAULT); in ovl_workdir_create()
800 err = vfs_removexattr(work, XATTR_NAME_POSIX_ACL_ACCESS); in ovl_workdir_create()
805 inode_lock(work->d_inode); in ovl_workdir_create()
[all …]
|
| /fs/fscache/ |
| D | object.c | 49 .work = f \
55 #define transit_to(state) ({ prefetch(&STATE(state)->work); STATE(state); })
70 .work = NULL, \
194 ASSERT(state->work != NULL); in fscache_object_sm_dispatcher()
204 if (!state->work) { in fscache_object_sm_dispatcher()
229 new_state = state->work(object, event); in fscache_object_sm_dispatcher()
246 if (state->work) { in fscache_object_sm_dispatcher()
271 static void fscache_object_work_func(struct work_struct *work) in fscache_object_work_func() argument
274 container_of(work, struct fscache_object, work); in fscache_object_work_func()
310 INIT_WORK(&object->work, fscache_object_work_func); in fscache_object_init()
[all …]
|
| D | operation.c | 40 INIT_WORK(&op->work, fscache_op_work_func); in fscache_operation_init()
77 if (!queue_work(fscache_op_wq, &op->work)) in fscache_enqueue_operation()
545 void fscache_operation_gc(struct work_struct *work) in fscache_operation_gc() argument
550 container_of(work, struct fscache_cache, op_gc); in fscache_operation_gc()
597 void fscache_op_work_func(struct work_struct *work) in fscache_op_work_func() argument
600 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 | 98 struct work_struct work; member
108 static void nfs_direct_write_schedule_work(struct work_struct *work);
316 INIT_WORK(&dreq->work, nfs_direct_write_schedule_work); in nfs_direct_req_alloc()
762 static void nfs_direct_write_schedule_work(struct work_struct *work) in nfs_direct_write_schedule_work() argument
764 struct nfs_direct_req *dreq = container_of(work, struct nfs_direct_req, work); in nfs_direct_write_schedule_work()
782 schedule_work(&dreq->work); /* Calls nfs_direct_write_schedule_work */ in nfs_direct_write_complete()
|
| /fs/ext4/ |
| D | readpage.c | 54 static void completion_pages(struct work_struct *work) in completion_pages() argument
58 container_of(work, struct ext4_crypto_ctx, r.work); in completion_pages()
127 INIT_WORK(&ctx->r.work, completion_pages); in mpage_end_io()
129 queue_work(ext4_read_workqueue, &ctx->r.work); in mpage_end_io()
|
| /fs/cifs/ |
| D | smb2misc.c | 432 cifs_ses_oplock_break(struct work_struct *work) in cifs_ses_oplock_break() argument
434 struct smb2_lease_break_work *lw = container_of(work, in cifs_ses_oplock_break()
641 smb2_cancelled_close_fid(struct work_struct *work) in smb2_cancelled_close_fid() argument
643 struct close_cancelled_open *cancelled = container_of(work, in smb2_cancelled_close_fid()
644 struct close_cancelled_open, work); in smb2_cancelled_close_fid()
678 INIT_WORK(&cancelled->work, smb2_cancelled_close_fid); in smb2_handle_cancelled_mid()
679 queue_work(cifsiod_wq, &cancelled->work); in smb2_handle_cancelled_mid()
|
| D | smb2proto.h | 58 extern void smb2_echo_request(struct work_struct *work);
102 extern void smb2_reconnect_server(struct work_struct *work);
166 void smb2_cancelled_close_fid(struct work_struct *work);
|
| /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/fat/ |
| D | dir.c | 360 unsigned char c, work[MSDOS_NAME]; in fat_parse_short() local
371 memcpy(work, de->name, sizeof(work)); in fat_parse_short()
373 if (work[0] == 0x05) in fat_parse_short()
374 work[0] = 0xE5; in fat_parse_short()
378 c = work[i]; in fat_parse_short()
381 chl = fat_shortname2uni(nls_disk, &work[i], 8 - i, in fat_parse_short()
398 ptname[i] = work[i]; in fat_parse_short()
414 c = work[k]; in fat_parse_short()
417 chl = fat_shortname2uni(nls_disk, &work[k], MSDOS_NAME - k, in fat_parse_short()
438 ptname[i] = work[k]; in fat_parse_short()
|