1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156
|
/*
* Copyright (c) 2000-2001,2005 Silicon Graphics, Inc.
* All Rights Reserved.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License as
* published by the Free Software Foundation.
*
* This program is distributed in the hope that it would be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#include "libxfs.h"
#include "avl.h"
#include "globals.h"
#include "agheader.h"
#include "incore.h"
#include "protos.h"
#include "err_protos.h"
#include "dinode.h"
#include "versions.h"
#include "progress.h"
#include "threads.h"
static void
update_inode_nlinks(
xfs_mount_t *mp,
xfs_ino_t ino,
__uint32_t nlinks)
{
xfs_trans_t *tp;
xfs_inode_t *ip;
int error;
int dirty;
int nres;
nres = no_modify ? 0 : 10;
error = -libxfs_trans_alloc(mp, &M_RES(mp)->tr_remove, nres, 0, 0, &tp);
ASSERT(error == 0);
error = -libxfs_trans_iget(mp, tp, ino, 0, 0, &ip);
if (error) {
if (!no_modify)
do_error(
_("couldn't map inode %" PRIu64 ", err = %d\n"),
ino, error);
else {
do_warn(
_("couldn't map inode %" PRIu64 ", err = %d, can't compare link counts\n"),
ino, error);
return;
}
}
dirty = 0;
/* compare and set links if they differ. */
if (VFS_I(ip)->i_nlink != nlinks) {
if (!no_modify) {
do_warn(
_("resetting inode %" PRIu64 " nlinks from %u to %u\n"),
ino, VFS_I(ip)->i_nlink, nlinks);
set_nlink(VFS_I(ip), nlinks);
dirty = 1;
} else {
do_warn(
_("would have reset inode %" PRIu64 " nlinks from %u to %u\n"),
ino, VFS_I(ip)->i_nlink, nlinks);
}
}
if (!dirty) {
libxfs_trans_cancel(tp);
} else {
libxfs_trans_log_inode(tp, ip, XFS_ILOG_CORE);
/*
* no need to do a bmap finish since
* we're not allocating anything
*/
ASSERT(error == 0);
error = -libxfs_trans_commit(tp);
ASSERT(error == 0);
}
IRELE(ip);
}
/*
* for each ag, look at each inode 1 at a time. If the number of
* links is bad, reset it, log the inode core, commit the transaction
*/
static void
do_link_updates(
struct work_queue *wq,
xfs_agnumber_t agno,
void *arg)
{
ino_tree_node_t *irec;
int j;
__uint32_t nrefs;
for (irec = findfirst_inode_rec(agno); irec;
irec = next_ino_rec(irec)) {
for (j = 0; j < XFS_INODES_PER_CHUNK; j++) {
ASSERT(is_inode_confirmed(irec, j));
if (is_inode_free(irec, j))
continue;
ASSERT(no_modify || is_inode_reached(irec, j));
nrefs = num_inode_references(irec, j);
ASSERT(no_modify || nrefs > 0);
if (get_inode_disk_nlinks(irec, j) != nrefs)
update_inode_nlinks(wq->mp,
XFS_AGINO_TO_INO(wq->mp, agno,
irec->ino_startnum + j),
nrefs);
}
}
PROG_RPT_INC(prog_rpt_done[agno], 1);
}
void
phase7(
struct xfs_mount *mp,
int scan_threads)
{
struct work_queue wq;
int agno;
if (!no_modify)
do_log(_("Phase 7 - verify and correct link counts...\n"));
else
do_log(_("Phase 7 - verify link counts...\n"));
set_progress_msg(PROGRESS_FMT_CORR_LINK, (__uint64_t) glob_agcount);
create_work_queue(&wq, mp, scan_threads);
for (agno = 0; agno < mp->m_sb.sb_agcount; agno++)
queue_work(&wq, do_link_updates, agno, NULL);
destroy_work_queue(&wq);
print_final_rpt();
}
|