Commit 60f31a60 authored by Brian Foster's avatar Brian Foster Committed by Darrick J. Wong

xfs: clean out superfluous dfops dop params/vars

The dfops code still passes around the xfs_defer_ops pointer
superfluously in a few places. Clean this up wherever the
transaction will suffice.
Signed-off-by: default avatarBrian Foster <bfoster@redhat.com>
Reviewed-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
Reviewed-by: default avatarChristoph Hellwig <hch@lst.de>
Signed-off-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
parent 7dbddbac
...@@ -181,9 +181,9 @@ static const struct xfs_defer_op_type *defer_op_types[XFS_DEFER_OPS_TYPE_MAX]; ...@@ -181,9 +181,9 @@ static const struct xfs_defer_op_type *defer_op_types[XFS_DEFER_OPS_TYPE_MAX];
*/ */
STATIC void STATIC void
xfs_defer_intake_work( xfs_defer_intake_work(
struct xfs_trans *tp, struct xfs_trans *tp)
struct xfs_defer_ops *dop)
{ {
struct xfs_defer_ops *dop = tp->t_dfops;
struct list_head *li; struct list_head *li;
struct xfs_defer_pending *dfp; struct xfs_defer_pending *dfp;
...@@ -204,9 +204,9 @@ xfs_defer_intake_work( ...@@ -204,9 +204,9 @@ xfs_defer_intake_work(
STATIC void STATIC void
xfs_defer_trans_abort( xfs_defer_trans_abort(
struct xfs_trans *tp, struct xfs_trans *tp,
struct xfs_defer_ops *dop,
int error) int error)
{ {
struct xfs_defer_ops *dop = tp->t_dfops;
struct xfs_defer_pending *dfp; struct xfs_defer_pending *dfp;
trace_xfs_defer_trans_abort(tp->t_mountp, dop, _RET_IP_); trace_xfs_defer_trans_abort(tp->t_mountp, dop, _RET_IP_);
...@@ -230,7 +230,6 @@ STATIC int ...@@ -230,7 +230,6 @@ STATIC int
xfs_defer_trans_roll( xfs_defer_trans_roll(
struct xfs_trans **tp) struct xfs_trans **tp)
{ {
struct xfs_defer_ops *dop = (*tp)->t_dfops;
struct xfs_buf_log_item *bli; struct xfs_buf_log_item *bli;
struct xfs_inode_log_item *ili; struct xfs_inode_log_item *ili;
struct xfs_log_item *lip; struct xfs_log_item *lip;
...@@ -272,14 +271,14 @@ xfs_defer_trans_roll( ...@@ -272,14 +271,14 @@ xfs_defer_trans_roll(
} }
} }
trace_xfs_defer_trans_roll((*tp)->t_mountp, dop, _RET_IP_); trace_xfs_defer_trans_roll((*tp)->t_mountp, (*tp)->t_dfops, _RET_IP_);
/* Roll the transaction. */ /* Roll the transaction. */
error = xfs_trans_roll(tp); error = xfs_trans_roll(tp);
dop = (*tp)->t_dfops;
if (error) { if (error) {
trace_xfs_defer_trans_roll_error((*tp)->t_mountp, dop, error); trace_xfs_defer_trans_roll_error((*tp)->t_mountp,
xfs_defer_trans_abort(*tp, dop, error); (*tp)->t_dfops, error);
xfs_defer_trans_abort(*tp, error);
return error; return error;
} }
...@@ -299,9 +298,10 @@ xfs_defer_trans_roll( ...@@ -299,9 +298,10 @@ xfs_defer_trans_roll(
/* Do we have any work items to finish? */ /* Do we have any work items to finish? */
bool bool
xfs_defer_has_unfinished_work( xfs_defer_has_unfinished_work(
struct xfs_defer_ops *dop) struct xfs_trans *tp)
{ {
return !list_empty(&dop->dop_pending) || !list_empty(&dop->dop_intake); return !list_empty(&tp->t_dfops->dop_pending) ||
!list_empty(&tp->t_dfops->dop_intake);
} }
/* /*
...@@ -311,7 +311,7 @@ static void ...@@ -311,7 +311,7 @@ static void
xfs_defer_reset( xfs_defer_reset(
struct xfs_trans *tp) struct xfs_trans *tp)
{ {
ASSERT(!xfs_defer_has_unfinished_work(tp->t_dfops)); ASSERT(!xfs_defer_has_unfinished_work(tp));
/* /*
* Low mode state transfers across transaction rolls to mirror dfops * Low mode state transfers across transaction rolls to mirror dfops
...@@ -332,7 +332,6 @@ int ...@@ -332,7 +332,6 @@ int
xfs_defer_finish_noroll( xfs_defer_finish_noroll(
struct xfs_trans **tp) struct xfs_trans **tp)
{ {
struct xfs_defer_ops *dop = (*tp)->t_dfops;
struct xfs_defer_pending *dfp; struct xfs_defer_pending *dfp;
struct list_head *li; struct list_head *li;
struct list_head *n; struct list_head *n;
...@@ -342,24 +341,22 @@ xfs_defer_finish_noroll( ...@@ -342,24 +341,22 @@ xfs_defer_finish_noroll(
ASSERT((*tp)->t_flags & XFS_TRANS_PERM_LOG_RES); ASSERT((*tp)->t_flags & XFS_TRANS_PERM_LOG_RES);
trace_xfs_defer_finish((*tp)->t_mountp, dop, _RET_IP_); trace_xfs_defer_finish((*tp)->t_mountp, (*tp)->t_dfops, _RET_IP_);
/* Until we run out of pending work to finish... */ /* Until we run out of pending work to finish... */
while (xfs_defer_has_unfinished_work(dop)) { while (xfs_defer_has_unfinished_work(*tp)) {
/* Log intents for work items sitting in the intake. */ /* Log intents for work items sitting in the intake. */
xfs_defer_intake_work(*tp, dop); xfs_defer_intake_work(*tp);
/* /*
* Roll the transaction and update dop in case dfops was * Roll the transaction.
* embedded in the transaction.
*/ */
error = xfs_defer_trans_roll(tp); error = xfs_defer_trans_roll(tp);
if (error) if (error)
goto out; goto out;
dop = (*tp)->t_dfops;
/* Log an intent-done item for the first pending item. */ /* Log an intent-done item for the first pending item. */
dfp = list_first_entry(&dop->dop_pending, dfp = list_first_entry(&(*tp)->t_dfops->dop_pending,
struct xfs_defer_pending, dfp_list); struct xfs_defer_pending, dfp_list);
trace_xfs_defer_pending_finish((*tp)->t_mountp, dfp); trace_xfs_defer_pending_finish((*tp)->t_mountp, dfp);
dfp->dfp_done = dfp->dfp_type->create_done(*tp, dfp->dfp_intent, dfp->dfp_done = dfp->dfp_type->create_done(*tp, dfp->dfp_intent,
...@@ -390,7 +387,7 @@ xfs_defer_finish_noroll( ...@@ -390,7 +387,7 @@ xfs_defer_finish_noroll(
*/ */
if (cleanup_fn) if (cleanup_fn)
cleanup_fn(*tp, state, error); cleanup_fn(*tp, state, error);
xfs_defer_trans_abort(*tp, dop, error); xfs_defer_trans_abort(*tp, error);
goto out; goto out;
} }
} }
...@@ -420,9 +417,11 @@ xfs_defer_finish_noroll( ...@@ -420,9 +417,11 @@ xfs_defer_finish_noroll(
out: out:
if (error) if (error)
trace_xfs_defer_finish_error((*tp)->t_mountp, dop, error); trace_xfs_defer_finish_error((*tp)->t_mountp, (*tp)->t_dfops,
error);
else else
trace_xfs_defer_finish_done((*tp)->t_mountp, dop, _RET_IP_); trace_xfs_defer_finish_done((*tp)->t_mountp, (*tp)->t_dfops,
_RET_IP_);
return error; return error;
} }
......
...@@ -41,7 +41,7 @@ int xfs_defer_finish_noroll(struct xfs_trans **tp); ...@@ -41,7 +41,7 @@ int xfs_defer_finish_noroll(struct xfs_trans **tp);
int xfs_defer_finish(struct xfs_trans **tp); int xfs_defer_finish(struct xfs_trans **tp);
void xfs_defer_cancel(struct xfs_trans *); void xfs_defer_cancel(struct xfs_trans *);
void xfs_defer_init(struct xfs_trans *tp, struct xfs_defer_ops *dop); void xfs_defer_init(struct xfs_trans *tp, struct xfs_defer_ops *dop);
bool xfs_defer_has_unfinished_work(struct xfs_defer_ops *dop); bool xfs_defer_has_unfinished_work(struct xfs_trans *tp);
void xfs_defer_move(struct xfs_trans *dtp, struct xfs_trans *stp); void xfs_defer_move(struct xfs_trans *dtp, struct xfs_trans *stp);
/* Description of a deferred type. */ /* Description of a deferred type. */
......
...@@ -929,7 +929,7 @@ __xfs_trans_commit( ...@@ -929,7 +929,7 @@ __xfs_trans_commit(
* Finish deferred items on final commit. Only permanent transactions * Finish deferred items on final commit. Only permanent transactions
* should ever have deferred ops. * should ever have deferred ops.
*/ */
WARN_ON_ONCE(xfs_defer_has_unfinished_work(tp->t_dfops) && WARN_ON_ONCE(xfs_defer_has_unfinished_work(tp) &&
!(tp->t_flags & XFS_TRANS_PERM_LOG_RES)); !(tp->t_flags & XFS_TRANS_PERM_LOG_RES));
if (!regrant && (tp->t_flags & XFS_TRANS_PERM_LOG_RES)) { if (!regrant && (tp->t_flags & XFS_TRANS_PERM_LOG_RES)) {
error = xfs_defer_finish_noroll(&tp); error = xfs_defer_finish_noroll(&tp);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment