]>
git.proxmox.com Git - mirror_ubuntu-artful-kernel.git/blob - fs/aufs/wkq.h
2 * Copyright (C) 2005-2017 Junjiro R. Okajima
4 * This program, aufs is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation; either version 2 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program. If not, see <http://www.gnu.org/licenses/>.
19 * workqueue for asynchronous/super-io operations
20 * todo: try new credentials management scheme
23 #ifndef __AUFS_WKQ_H__
24 #define __AUFS_WKQ_H__
28 #include <linux/percpu_counter.h>
32 /* ---------------------------------------------------------------------- */
35 * in the next operation, wait for the 'nowait' tasks in system-wide workqueue
37 struct au_nowait_tasks
{
39 wait_queue_head_t nw_wq
;
42 /* ---------------------------------------------------------------------- */
44 typedef void (*au_wkq_func_t
)(void *args
);
48 #define AuWkq_NEST (1 << 1)
49 #define au_ftest_wkq(flags, name) ((flags) & AuWkq_##name)
50 #define au_fset_wkq(flags, name) \
51 do { (flags) |= AuWkq_##name; } while (0)
52 #define au_fclr_wkq(flags, name) \
53 do { (flags) &= ~AuWkq_##name; } while (0)
55 #ifndef CONFIG_AUFS_HNOTIFY
61 int au_wkq_do_wait(unsigned int flags
, au_wkq_func_t func
, void *args
);
62 int au_wkq_nowait(au_wkq_func_t func
, void *args
, struct super_block
*sb
,
64 void au_nwt_init(struct au_nowait_tasks
*nwt
);
65 int __init
au_wkq_init(void);
66 void au_wkq_fin(void);
68 /* ---------------------------------------------------------------------- */
70 static inline int au_wkq_test(void)
72 return current
->flags
& PF_WQ_WORKER
;
75 static inline int au_wkq_wait(au_wkq_func_t func
, void *args
)
77 return au_wkq_do_wait(AuWkq_WAIT
, func
, args
);
80 static inline void au_nwt_done(struct au_nowait_tasks
*nwt
)
82 if (atomic_dec_and_test(&nwt
->nw_len
))
83 wake_up_all(&nwt
->nw_wq
);
86 static inline int au_nwt_flush(struct au_nowait_tasks
*nwt
)
88 wait_event(nwt
->nw_wq
, !atomic_read(&nwt
->nw_len
));
92 #endif /* __KERNEL__ */
93 #endif /* __AUFS_WKQ_H__ */