libfrog: fix missing error checking in workqueue code

[thirdparty/xfsprogs-dev.git] / scrub / phase4.c

// SPDX-License-Identifier: GPL-2.0+
/*
 * Copyright (C) 2018 Oracle.  All Rights Reserved.
 * Author: Darrick J. Wong <darrick.wong@oracle.com>
 */
#include "xfs.h"
#include <stdint.h>
#include <dirent.h>
#include <sys/types.h>
#include <sys/statvfs.h>
#include "list.h"
#include "libfrog/paths.h"
#include "libfrog/workqueue.h"
#include "xfs_scrub.h"
#include "common.h"
#include "progress.h"
#include "scrub.h"
#include "repair.h"
#include "vfs.h"

/* Phase 4: Repair filesystem. */

/* Fix all the problems in our per-AG list. */
static void
xfs_repair_ag(
	struct workqueue		*wq,
	xfs_agnumber_t			agno,
	void				*priv)
{
	struct scrub_ctx		*ctx = (struct scrub_ctx *)wq->wq_ctx;
	bool				*pmoveon = priv;
	struct xfs_action_list		*alist;
	size_t				unfixed;
	size_t				new_unfixed;
	unsigned int			flags = 0;
	bool				moveon;

	alist = &ctx->action_lists[agno];
	unfixed = xfs_action_list_length(alist);

	/* Repair anything broken until we fail to make progress. */
	do {
		moveon = xfs_action_list_process(ctx, ctx->mnt.fd, alist, flags);
		if (!moveon) {
			*pmoveon = false;
			return;
		}
		new_unfixed = xfs_action_list_length(alist);
		if (new_unfixed == unfixed)
			break;
		unfixed = new_unfixed;
	} while (unfixed > 0 && *pmoveon);

	if (!*pmoveon)
		return;

	/* Try once more, but this time complain if we can't fix things. */
	flags |= ALP_COMPLAIN_IF_UNFIXED;
	moveon = xfs_action_list_process(ctx, ctx->mnt.fd, alist, flags);
	if (!moveon)
		*pmoveon = false;
}

/* Process all the action items. */
static bool
xfs_process_action_items(
	struct scrub_ctx		*ctx)
{
	struct workqueue		wq;
	xfs_agnumber_t			agno;
	bool				moveon = true;
	int				ret;

	ret = workqueue_create(&wq, (struct xfs_mount *)ctx,
			scrub_nproc_workqueue(ctx));
	if (ret) {
		str_liberror(ctx, ret, _("creating repair workqueue"));
		return false;
	}
	for (agno = 0; agno < ctx->mnt.fsgeom.agcount; agno++) {
		if (xfs_action_list_length(&ctx->action_lists[agno]) > 0) {
			ret = workqueue_add(&wq, xfs_repair_ag, agno, &moveon);
			if (ret) {
				moveon = false;
				str_liberror(ctx, ret,
						_("queueing repair work"));
				break;
			}
		}
		if (!moveon)
			break;
	}
	workqueue_destroy(&wq);

	pthread_mutex_lock(&ctx->lock);
	if (moveon && ctx->errors_found == 0 && want_fstrim) {
		fstrim(ctx);
		progress_add(1);
	}
	pthread_mutex_unlock(&ctx->lock);

	return moveon;
}

/* Fix everything that needs fixing. */
bool
xfs_repair_fs(
	struct scrub_ctx		*ctx)
{
	bool				moveon;

	/*
	 * Check the summary counters early.  Normally we do this during phase
	 * seven, but some of the cross-referencing requires fairly-accurate
	 * counters, so counter repairs have to be put on the list now so that
	 * they get fixed before we stop retrying unfixed metadata repairs.
	 */
	moveon = xfs_scrub_fs_summary(ctx, &ctx->action_lists[0]);
	if (!moveon)
		return false;

	return xfs_process_action_items(ctx);
}

/* Estimate how much work we're going to do. */
bool
xfs_estimate_repair_work(
	struct scrub_ctx	*ctx,
	uint64_t		*items,
	unsigned int		*nr_threads,
	int			*rshift)
{
	xfs_agnumber_t		agno;
	size_t			need_fixing = 0;

	for (agno = 0; agno < ctx->mnt.fsgeom.agcount; agno++)
		need_fixing += xfs_action_list_length(&ctx->action_lists[agno]);
	need_fixing++;
	*items = need_fixing;
	*nr_threads = scrub_nproc(ctx) + 1;
	*rshift = 0;
	return true;
}