On Tue, Aug 13, 2019 at 07:17:33PM +0800, kaixuxia wrote:
> In this patch we make the unlinked list removal a deferred operation,
> i.e. log an iunlink remove intent and then do it after the RENAME_WHITEOUT
> transaction has committed, and the iunlink remove intention and done
> log items are provided.
I really like the idea of doing this, not just for the inode unlink
list removal, but for all the high level complex metadata
modifications such as create, unlink, etc.
The reason I like this is that it moves use closer to being able to
do operations almost completely asynchronously once the first intent
has been logged.
Once we have committed the intent, we can treat the rest of the
operation like recovery - all the information needed to perform the
operation is in the intenti and all the objects that need to be
locked across the entire operation are locked and joined to the
defer structure. If the intent hits the log the we guarantee that it
will be completed atomically and in the correct sequence order.
Hence it doesn't matter once the intent is built and committed what
context actually completes the rest of the transaction.
If we have to do a sync transaction, because XFS_MOUNT_SYNC,
XFS_MOUNT_DIRSYNC, or there's a sync flag on the inode(s), we can
add a waitqueue_head to the struct xfs_defer and have the context
issuing the transaction attach itself and wait for the defer ops to
complete and wake it....
.....
> @@ -3752,6 +3755,96 @@ struct xfs_buf_cancel {
> }
>
> /*
> + * This routine is called to create an in-core iunlink remove intent
> + * item from the iri format structure which was logged on disk.
> + * It allocates an in-core iri, copies the inode from the format
> + * structure into it, and adds the iri to the AIL with the given
> + * LSN.
> + */
> +STATIC int
> +xlog_recover_iri_pass2(
> + struct xlog *log,
> + struct xlog_recover_item *item,
> + xfs_lsn_t lsn)
> +{
> + xfs_mount_t *mp = log->l_mp;
> + xfs_iri_log_item_t *irip;
> + xfs_iri_log_format_t *iri_formatp;
> +
> + iri_formatp = item->ri_buf[0].i_addr;
> +
> + irip = xfs_iri_init(mp, 1);
> + irip->iri_format = *iri_formatp;
> + if (item->ri_buf[0].i_len != sizeof(xfs_iri_log_format_t)) {
> + xfs_iri_item_free(irip);
> + return EFSCORRUPTED;
> + }
> +
> + spin_lock(&log->l_ailp->ail_lock);
> + /*
> + * The IRI has two references. One for the IRD and one for IRI to ensure
> + * it makes it into the AIL. Insert the IRI into the AIL directly and
> + * drop the IRI reference. Note that xfs_trans_ail_update() drops the
> + * AIL lock.
> + */
> + xfs_trans_ail_update(log->l_ailp, &irip->iri_item, lsn);
> + xfs_iri_release(irip);
> + return 0;
> +}
These intent recovery functions all do very, very similar things.
We already have 4 copies of this almost identical code - I think
there needs to be some factoring/abstrcting done here rather than
continuing to copy/paste this code...
> @@ -3981,6 +4074,8 @@ struct xfs_buf_cancel {
> case XFS_LI_CUD:
> case XFS_LI_BUI:
> case XFS_LI_BUD:
> + case XFS_LI_IRI:
> + case XFS_LI_IRD:
> default:
> break;
> }
> @@ -4010,6 +4105,8 @@ struct xfs_buf_cancel {
> case XFS_LI_CUD:
> case XFS_LI_BUI:
> case XFS_LI_BUD:
> + case XFS_LI_IRI:
> + case XFS_LI_IRD:
> /* nothing to do in pass 1 */
> return 0;
> default:
> @@ -4052,6 +4149,10 @@ struct xfs_buf_cancel {
> return xlog_recover_bui_pass2(log, item, trans->r_lsn);
> case XFS_LI_BUD:
> return xlog_recover_bud_pass2(log, item);
> + case XFS_LI_IRI:
> + return xlog_recover_iri_pass2(log, item, trans->r_lsn);
> + case XFS_LI_IRD:
> + return xlog_recover_ird_pass2(log, item);
> case XFS_LI_DQUOT:
> return xlog_recover_dquot_pass2(log, buffer_list, item,
> trans->r_lsn);
As can be seen by the increasing size of this table....
> @@ -4721,6 +4822,46 @@ struct xfs_buf_cancel {
> spin_lock(&ailp->ail_lock);
> }
>
> +/* Recover the IRI if necessary. */
> +STATIC int
> +xlog_recover_process_iri(
> + struct xfs_trans *parent_tp,
> + struct xfs_ail *ailp,
> + struct xfs_log_item *lip)
> +{
> + struct xfs_iri_log_item *irip;
> + int error;
> +
> + /*
> + * Skip IRIs that we've already processed.
> + */
> + irip = container_of(lip, struct xfs_iri_log_item, iri_item);
> + if (test_bit(XFS_IRI_RECOVERED, &irip->iri_flags))
> + return 0;
> +
> + spin_unlock(&ailp->ail_lock);
> + error = xfs_iri_recover(parent_tp, irip);
> + spin_lock(&ailp->ail_lock);
> +
> + return error;
> +}
> +
> +/* Release the IRI since we're cancelling everything. */
> +STATIC void
> +xlog_recover_cancel_iri(
> + struct xfs_mount *mp,
> + struct xfs_ail *ailp,
> + struct xfs_log_item *lip)
> +{
> + struct xfs_iri_log_item *irip;
> +
> + irip = container_of(lip, struct xfs_iri_log_item, iri_item);
> +
> + spin_unlock(&ailp->ail_lock);
> + xfs_iri_release(irip);
> + spin_lock(&ailp->ail_lock);
> +}
More cookie cutter code.
> @@ -4856,6 +4998,9 @@ static inline bool xlog_item_is_intent(struct xfs_log_item *lip)
> case XFS_LI_BUI:
> error = xlog_recover_process_bui(parent_tp, ailp, lip);
> break;
> + case XFS_LI_IRI:
> + error = xlog_recover_process_iri(parent_tp, ailp, lip);
> + break;
> }
> if (error)
> goto out;
> @@ -4912,6 +5057,9 @@ static inline bool xlog_item_is_intent(struct xfs_log_item *lip)
> case XFS_LI_BUI:
> xlog_recover_cancel_bui(log->l_mp, ailp, lip);
> break;
> + case XFS_LI_IRI:
> + xlog_recover_cancel_iri(log->l_mp, ailp, lip);
> + break;
> }
And the table that drives it....
I guess what I'm saying is that I'd really like to see an abstract
type specifically for intent log items and generic infrastructure to
manipulate them before we go adding more of them...
Cheers,
Dave.
--
Dave Chinner
david@xxxxxxxxxxxxx
