1 /* SPDX-License-Identifier: GPL-2.0-or-later */
3 * Copyright (C) 2019 Oracle. All Rights Reserved.
4 * Author: Darrick J. Wong <darrick.wong@oracle.com>
6 #ifndef __XFS_PWORK_H__
7 #define __XFS_PWORK_H__
12 typedef int (*xfs_pwork_work_fn)(struct xfs_mount *mp, struct xfs_pwork *pwork);
15 * Parallel work coordination structure.
17 struct xfs_pwork_ctl {
18 struct workqueue_struct *wq;
20 xfs_pwork_work_fn work_fn;
21 struct wait_queue_head poll_wait;
27 * Embed this parallel work control item inside your own work structure,
28 * then queue work with it.
31 struct work_struct work;
32 struct xfs_pwork_ctl *pctl;
35 #define XFS_PWORK_SINGLE_THREADED { .pctl = NULL }
37 /* Have we been told to abort? */
39 xfs_pwork_ctl_want_abort(
40 struct xfs_pwork_ctl *pctl)
42 return pctl && pctl->error;
45 /* Have we been told to abort? */
48 struct xfs_pwork *pwork)
50 return xfs_pwork_ctl_want_abort(pwork->pctl);
53 int xfs_pwork_init(struct xfs_mount *mp, struct xfs_pwork_ctl *pctl,
54 xfs_pwork_work_fn work_fn, const char *tag);
55 void xfs_pwork_queue(struct xfs_pwork_ctl *pctl, struct xfs_pwork *pwork);
56 int xfs_pwork_destroy(struct xfs_pwork_ctl *pctl);
57 void xfs_pwork_poll(struct xfs_pwork_ctl *pctl);
59 #endif /* __XFS_PWORK_H__ */