Home
last modified time | relevance | path

Searched refs:work (Results 1 – 25 of 61) sorted by relevance

123

/fs/btrfs/
Dasync-thread.c96 struct btrfs_work *work) in run_ordered_completions() argument
103 set_bit(WORK_DONE_BIT, &work->flags); in run_ordered_completions()
108 work = list_entry(workers->order_list.next, in run_ordered_completions()
111 if (!test_bit(WORK_DONE_BIT, &work->flags)) in run_ordered_completions()
119 if (test_and_set_bit(WORK_ORDER_DONE_BIT, &work->flags)) in run_ordered_completions()
124 work->ordered_func(work); in run_ordered_completions()
128 list_del(&work->order_list); in run_ordered_completions()
129 work->ordered_free(work); in run_ordered_completions()
143 struct btrfs_work *work; in worker_loop() local
149 work = list_entry(cur, struct btrfs_work, list); in worker_loop()
[all …]
Dasync-thread.h47 void (*func)(struct btrfs_work *work);
48 void (*ordered_func)(struct btrfs_work *work);
49 void (*ordered_free)(struct btrfs_work *work);
96 int btrfs_queue_worker(struct btrfs_workers *workers, struct btrfs_work *work);
100 int btrfs_requeue_work(struct btrfs_work *work);
Ddisk-io.c43 static void end_workqueue_fn(struct btrfs_work *work);
58 struct btrfs_work work; member
75 struct btrfs_work work; member
459 end_io_wq->work.func = end_workqueue_fn; in end_workqueue_bio()
460 end_io_wq->work.flags = 0; in end_workqueue_bio()
465 &end_io_wq->work); in end_workqueue_bio()
468 &end_io_wq->work); in end_workqueue_bio()
472 &end_io_wq->work); in end_workqueue_bio()
475 &end_io_wq->work); in end_workqueue_bio()
513 static void run_one_async_start(struct btrfs_work *work) in run_one_async_start() argument
[all …]
/fs/afs/
Dcmservice.c141 static void SRXAFSCB_CallBack(struct work_struct *work) in SRXAFSCB_CallBack() argument
143 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_CallBack()
290 INIT_WORK(&call->work, SRXAFSCB_CallBack); in afs_deliver_cb_callback()
291 schedule_work(&call->work); in afs_deliver_cb_callback()
298 static void SRXAFSCB_InitCallBackState(struct work_struct *work) in SRXAFSCB_InitCallBackState() argument
300 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_InitCallBackState()
337 INIT_WORK(&call->work, SRXAFSCB_InitCallBackState); in afs_deliver_cb_init_call_back_state()
338 schedule_work(&call->work); in afs_deliver_cb_init_call_back_state()
368 INIT_WORK(&call->work, SRXAFSCB_InitCallBackState); in afs_deliver_cb_init_call_back_state3()
369 schedule_work(&call->work); in afs_deliver_cb_init_call_back_state3()
[all …]
Dcallback.c63 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()
363 static void afs_callback_updater(struct work_struct *work)
371 server = container_of(work, struct afs_server, updater);
Drxrpc.c601 static void afs_delete_async_call(struct work_struct *work) in afs_delete_async_call() argument
604 container_of(work, struct afs_call, async_work); in afs_delete_async_call()
618 static void afs_process_async_call(struct work_struct *work) in afs_process_async_call() argument
621 container_of(work, struct afs_call, async_work); in afs_process_async_call()
664 static void afs_collect_incoming_call(struct work_struct *work) in afs_collect_incoming_call() argument
Dmntpt.c29 static void afs_mntpt_expiry_timed_out(struct work_struct *work);
262 static void afs_mntpt_expiry_timed_out(struct work_struct *work) in afs_mntpt_expiry_timed_out() argument
/fs/xfs/linux-2.6/
Dxfs_sync.c403 struct bhv_vfs_sync_work *work; in xfs_syncd_queue_work() local
405 work = kmem_alloc(sizeof(struct bhv_vfs_sync_work), KM_SLEEP); in xfs_syncd_queue_work()
406 INIT_LIST_HEAD(&work->w_list); in xfs_syncd_queue_work()
407 work->w_syncer = syncer; in xfs_syncd_queue_work()
408 work->w_data = data; in xfs_syncd_queue_work()
409 work->w_mount = mp; in xfs_syncd_queue_work()
411 list_add_tail(&work->w_list, &mp->m_sync_list); in xfs_syncd_queue_work()
500 bhv_vfs_sync_work_t *work, *n; in xfssyncd() local
526 list_for_each_entry_safe(work, n, &mp->m_sync_list, w_list) in xfssyncd()
527 list_move(&work->w_list, &tmp); in xfssyncd()
[all …]
Dxfs_aops.c248 struct work_struct *work) in xfs_end_bio_delalloc() argument
251 container_of(work, xfs_ioend_t, io_work); in xfs_end_bio_delalloc()
262 struct work_struct *work) in xfs_end_bio_written() argument
265 container_of(work, xfs_ioend_t, io_work); in xfs_end_bio_written()
279 struct work_struct *work) in xfs_end_bio_unwritten() argument
282 container_of(work, xfs_ioend_t, io_work); in xfs_end_bio_unwritten()
304 struct work_struct *work) in xfs_end_bio_read() argument
307 container_of(work, xfs_ioend_t, io_work); in xfs_end_bio_read()
/fs/xfs/
Dxfs_mru_cache.c211 queue_delayed_work(xfs_mru_reap_wq, &mru->work, in _xfs_mru_cache_list_insert()
278 struct work_struct *work) in _xfs_mru_cache_reap() argument
280 xfs_mru_cache_t *mru = container_of(work, xfs_mru_cache_t, work.work); in _xfs_mru_cache_reap()
298 queue_delayed_work(xfs_mru_reap_wq, &mru->work, next); in _xfs_mru_cache_reap()
379 INIT_DELAYED_WORK(&mru->work, _xfs_mru_cache_reap); in xfs_mru_cache_create()
411 cancel_rearming_delayed_workqueue(xfs_mru_reap_wq, &mru->work); in xfs_mru_cache_flush()
Dxfs_mru_cache.h36 struct delayed_work work; /* Workqueue data for reaping. */ member
/fs/ocfs2/cluster/
Dtcp.c136 static void o2net_sc_connect_completed(struct work_struct *work);
137 static void o2net_rx_until_empty(struct work_struct *work);
138 static void o2net_shutdown_sc(struct work_struct *work);
140 static void o2net_sc_send_keep_req(struct work_struct *work);
417 struct work_struct *work) in o2net_sc_queue_work() argument
420 if (!queue_work(o2net_wq, work)) in o2net_sc_queue_work()
424 struct delayed_work *work, in o2net_sc_queue_delayed_work() argument
428 if (!queue_delayed_work(o2net_wq, work, delay)) in o2net_sc_queue_delayed_work()
432 struct delayed_work *work) in o2net_sc_cancel_delayed_work() argument
434 if (cancel_delayed_work(work)) in o2net_sc_cancel_delayed_work()
[all …]
/fs/cifs/
DAUTHORS10 Jeremy Allison of the Samba team has done invaluable work in adding the server
16 Newbigin and others for their work on the Linux smbfs module. Thanks to
18 Workgroup for their work specifying this highly complex protocol and finally
30 Mark Hamzy (for some of the early cifs IPv6 work)
41 Jeff Layton (many, many fixes, as well as great work on the cifs Kerberos code)
Dcifs_dfs_ref.c28 static void cifs_dfs_expire_automounts(struct work_struct *work);
33 static void cifs_dfs_expire_automounts(struct work_struct *work) in cifs_dfs_expire_automounts() argument
/fs/fat/
Ddir.c355 unsigned char work[MSDOS_NAME]; in fat_search_long() local
387 memcpy(work, de->name, sizeof(de->name)); in fat_search_long()
389 if (work[0] == 0x05) in fat_search_long()
390 work[0] = 0xE5; in fat_search_long()
392 if (!work[i]) in fat_search_long()
394 chl = fat_shortname2uni(nls_disk, &work[i], 8 - i, in fat_search_long()
398 if (work[i] != ' ') in fat_search_long()
408 if (!work[i]) in fat_search_long()
410 chl = fat_shortname2uni(nls_disk, &work[i], in fat_search_long()
415 if (work[i] != ' ') in fat_search_long()
[all …]
/fs/nfs/
Dnfs4renewd.c60 nfs4_renew_state(struct work_struct *work) in nfs4_renew_state() argument
63 container_of(work, struct nfs_client, cl_renewd.work); in nfs4_renew_state()
Dnamespace.c21 static void nfs_expire_automounts(struct work_struct *work);
172 static void nfs_expire_automounts(struct work_struct *work) in nfs_expire_automounts() argument
/fs/jffs2/
DLICENCE22 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/sysfs/
Dfile.c666 struct work_struct work; member
669 static void sysfs_schedule_callback_work(struct work_struct *work) in sysfs_schedule_callback_work() argument
671 struct sysfs_schedule_callback_struct *ss = container_of(work, in sysfs_schedule_callback_work()
672 struct sysfs_schedule_callback_struct, work); in sysfs_schedule_callback_work()
717 INIT_WORK(&ss->work, sysfs_schedule_callback_work); in sysfs_schedule_callback()
718 schedule_work(&ss->work); in sysfs_schedule_callback()
/fs/ncpfs/
Dsock.c380 void ncpdgram_rcv_proc(struct work_struct *work) in ncpdgram_rcv_proc() argument
383 container_of(work, struct ncp_server, rcv.tq); in ncpdgram_rcv_proc()
499 void ncpdgram_timeout_proc(struct work_struct *work) in ncpdgram_timeout_proc() argument
502 container_of(work, struct ncp_server, timeout_tq); in ncpdgram_timeout_proc()
678 void ncp_tcp_rcv_proc(struct work_struct *work) in ncp_tcp_rcv_proc() argument
681 container_of(work, struct ncp_server, rcv.tq); in ncp_tcp_rcv_proc()
688 void ncp_tcp_tx_proc(struct work_struct *work) in ncp_tcp_tx_proc() argument
691 container_of(work, struct ncp_server, tx.tq); in ncp_tcp_tx_proc()
/fs/ocfs2/
Ddcache.h55 void ocfs2_drop_dl_inodes(struct work_struct *work);
Dlocalalloc.h57 void ocfs2_la_enable_worker(struct work_struct *work);
Ddcache.c305 void ocfs2_drop_dl_inodes(struct work_struct *work) in ocfs2_drop_dl_inodes() argument
307 struct ocfs2_super *osb = container_of(work, struct ocfs2_super, in ocfs2_drop_dl_inodes()
/fs/dlm/
Dlowcomms.c146 static void process_recv_sockets(struct work_struct *work);
147 static void process_send_sockets(struct work_struct *work);
1345 static void process_recv_sockets(struct work_struct *work) in process_recv_sockets() argument
1347 struct connection *con = container_of(work, struct connection, rwork); in process_recv_sockets()
1357 static void process_send_sockets(struct work_struct *work) in process_send_sockets() argument
1359 struct connection *con = container_of(work, struct connection, swork); in process_send_sockets()
/fs/affs/
DChanges9 - Doesn't work on the alpha. The only 64/32-bit
13 reads basically work (but all files are of size 0).
17 doesn't work with devices which have 256 byte
214 invalid filenames didn't work correctly.

123