/fs/btrfs/ |
D | async-thread.c | 96 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 …]
|
D | async-thread.h | 47 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);
|
D | disk-io.c | 43 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/ |
D | cmservice.c | 141 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 …]
|
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() 363 static void afs_callback_updater(struct work_struct *work) 371 server = container_of(work, struct afs_server, updater);
|
D | rxrpc.c | 601 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
|
D | mntpt.c | 29 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/ |
D | xfs_sync.c | 403 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 …]
|
D | xfs_aops.c | 248 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/ |
D | xfs_mru_cache.c | 211 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()
|
D | xfs_mru_cache.h | 36 struct delayed_work work; /* Workqueue data for reaping. */ member
|
/fs/ocfs2/cluster/ |
D | tcp.c | 136 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/ |
D | AUTHORS | 10 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)
|
D | cifs_dfs_ref.c | 28 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/ |
D | dir.c | 355 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/ |
D | nfs4renewd.c | 60 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()
|
D | namespace.c | 21 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/ |
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/sysfs/ |
D | file.c | 666 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/ |
D | sock.c | 380 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/ |
D | dcache.h | 55 void ocfs2_drop_dl_inodes(struct work_struct *work);
|
D | localalloc.h | 57 void ocfs2_la_enable_worker(struct work_struct *work);
|
D | dcache.c | 305 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/ |
D | lowcomms.c | 146 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/ |
D | Changes | 9 - 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.
|