xfs_inode_item.c 23.8 KB
Newer Older
L
Linus Torvalds 已提交
1
/*
2 3
 * Copyright (c) 2000-2002,2005 Silicon Graphics, Inc.
 * All Rights Reserved.
L
Linus Torvalds 已提交
4
 *
5 6
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License as
L
Linus Torvalds 已提交
7 8
 * published by the Free Software Foundation.
 *
9 10 11 12
 * 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.
L
Linus Torvalds 已提交
13
 *
14 15 16
 * 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
L
Linus Torvalds 已提交
17 18
 */
#include "xfs.h"
19
#include "xfs_fs.h"
L
Linus Torvalds 已提交
20
#include "xfs_types.h"
21
#include "xfs_bit.h"
L
Linus Torvalds 已提交
22
#include "xfs_log.h"
23
#include "xfs_inum.h"
L
Linus Torvalds 已提交
24 25
#include "xfs_trans.h"
#include "xfs_sb.h"
26
#include "xfs_ag.h"
L
Linus Torvalds 已提交
27 28 29 30 31
#include "xfs_mount.h"
#include "xfs_trans_priv.h"
#include "xfs_bmap_btree.h"
#include "xfs_dinode.h"
#include "xfs_inode.h"
32
#include "xfs_inode_item.h"
33
#include "xfs_error.h"
C
Christoph Hellwig 已提交
34
#include "xfs_trace.h"
L
Linus Torvalds 已提交
35 36 37 38


kmem_zone_t	*xfs_ili_zone;		/* inode log item zone */

39 40 41 42 43 44
static inline struct xfs_inode_log_item *INODE_ITEM(struct xfs_log_item *lip)
{
	return container_of(lip, struct xfs_inode_log_item, ili_item);
}


L
Linus Torvalds 已提交
45 46 47 48 49 50 51 52 53
/*
 * This returns the number of iovecs needed to log the given inode item.
 *
 * We need one iovec for the inode log format structure, one for the
 * inode core, and possibly one for the inode data/extents/b-tree root
 * and one for the inode attribute data/extents/b-tree root.
 */
STATIC uint
xfs_inode_item_size(
54
	struct xfs_log_item	*lip)
L
Linus Torvalds 已提交
55
{
56 57 58
	struct xfs_inode_log_item *iip = INODE_ITEM(lip);
	struct xfs_inode	*ip = iip->ili_inode;
	uint			nvecs = 2;
L
Linus Torvalds 已提交
59 60 61

	switch (ip->i_d.di_format) {
	case XFS_DINODE_FMT_EXTENTS:
62
		if ((iip->ili_fields & XFS_ILOG_DEXT) &&
63 64
		    ip->i_d.di_nextents > 0 &&
		    ip->i_df.if_bytes > 0)
L
Linus Torvalds 已提交
65 66 67 68
			nvecs++;
		break;

	case XFS_DINODE_FMT_BTREE:
69
		if ((iip->ili_fields & XFS_ILOG_DBROOT) &&
70
		    ip->i_df.if_broot_bytes > 0)
L
Linus Torvalds 已提交
71 72 73 74
			nvecs++;
		break;

	case XFS_DINODE_FMT_LOCAL:
75
		if ((iip->ili_fields & XFS_ILOG_DDATA) &&
76
		    ip->i_df.if_bytes > 0)
L
Linus Torvalds 已提交
77 78 79 80 81 82 83 84 85 86 87 88
			nvecs++;
		break;

	case XFS_DINODE_FMT_DEV:
	case XFS_DINODE_FMT_UUID:
		break;

	default:
		ASSERT(0);
		break;
	}

89
	if (!XFS_IFORK_Q(ip))
L
Linus Torvalds 已提交
90
		return nvecs;
91

L
Linus Torvalds 已提交
92 93 94 95 96 97

	/*
	 * Log any necessary attribute data.
	 */
	switch (ip->i_d.di_aformat) {
	case XFS_DINODE_FMT_EXTENTS:
98
		if ((iip->ili_fields & XFS_ILOG_AEXT) &&
99 100
		    ip->i_d.di_anextents > 0 &&
		    ip->i_afp->if_bytes > 0)
L
Linus Torvalds 已提交
101 102 103 104
			nvecs++;
		break;

	case XFS_DINODE_FMT_BTREE:
105
		if ((iip->ili_fields & XFS_ILOG_ABROOT) &&
106
		    ip->i_afp->if_broot_bytes > 0)
L
Linus Torvalds 已提交
107 108 109 110
			nvecs++;
		break;

	case XFS_DINODE_FMT_LOCAL:
111
		if ((iip->ili_fields & XFS_ILOG_ADATA) &&
112
		    ip->i_afp->if_bytes > 0)
L
Linus Torvalds 已提交
113 114 115 116 117 118 119 120 121 122 123
			nvecs++;
		break;

	default:
		ASSERT(0);
		break;
	}

	return nvecs;
}

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 157 158
/*
 * xfs_inode_item_format_extents - convert in-core extents to on-disk form
 *
 * For either the data or attr fork in extent format, we need to endian convert
 * the in-core extent as we place them into the on-disk inode. In this case, we
 * need to do this conversion before we write the extents into the log. Because
 * we don't have the disk inode to write into here, we allocate a buffer and
 * format the extents into it via xfs_iextents_copy(). We free the buffer in
 * the unlock routine after the copy for the log has been made.
 *
 * In the case of the data fork, the in-core and on-disk fork sizes can be
 * different due to delayed allocation extents. We only log on-disk extents
 * here, so always use the physical fork size to determine the size of the
 * buffer we need to allocate.
 */
STATIC void
xfs_inode_item_format_extents(
	struct xfs_inode	*ip,
	struct xfs_log_iovec	*vecp,
	int			whichfork,
	int			type)
{
	xfs_bmbt_rec_t		*ext_buffer;

	ext_buffer = kmem_alloc(XFS_IFORK_SIZE(ip, whichfork), KM_SLEEP);
	if (whichfork == XFS_DATA_FORK)
		ip->i_itemp->ili_extents_buf = ext_buffer;
	else
		ip->i_itemp->ili_aextents_buf = ext_buffer;

	vecp->i_addr = ext_buffer;
	vecp->i_len = xfs_iextents_copy(ip, ext_buffer, whichfork);
	vecp->i_type = type;
}

L
Linus Torvalds 已提交
159 160 161 162 163 164 165 166 167
/*
 * This is called to fill in the vector of log iovecs for the
 * given inode log item.  It fills the first item with an inode
 * log format structure, the second with the on-disk inode structure,
 * and a possible third and/or fourth with the inode data/extents/b-tree
 * root and inode attributes data/extents/b-tree root.
 */
STATIC void
xfs_inode_item_format(
168 169
	struct xfs_log_item	*lip,
	struct xfs_log_iovec	*vecp)
L
Linus Torvalds 已提交
170
{
171 172
	struct xfs_inode_log_item *iip = INODE_ITEM(lip);
	struct xfs_inode	*ip = iip->ili_inode;
L
Linus Torvalds 已提交
173 174 175 176
	uint			nvecs;
	size_t			data_bytes;
	xfs_mount_t		*mp;

177
	vecp->i_addr = &iip->ili_format;
L
Linus Torvalds 已提交
178
	vecp->i_len  = sizeof(xfs_inode_log_format_t);
C
Christoph Hellwig 已提交
179
	vecp->i_type = XLOG_REG_TYPE_IFORMAT;
L
Linus Torvalds 已提交
180 181 182
	vecp++;
	nvecs	     = 1;

183
	vecp->i_addr = &ip->i_d;
C
Christoph Hellwig 已提交
184
	vecp->i_len  = sizeof(struct xfs_icdinode);
C
Christoph Hellwig 已提交
185
	vecp->i_type = XLOG_REG_TYPE_ICORE;
L
Linus Torvalds 已提交
186 187 188 189 190 191 192 193 194 195 196 197
	vecp++;
	nvecs++;

	/*
	 * If this is really an old format inode, then we need to
	 * log it as such.  This means that we have to copy the link
	 * count from the new field to the old.  We don't have to worry
	 * about the new fields, because nothing trusts them as long as
	 * the old inode version number is there.  If the superblock already
	 * has a new version number, then we don't bother converting back.
	 */
	mp = ip->i_mount;
198 199
	ASSERT(ip->i_d.di_version == 1 || xfs_sb_version_hasnlink(&mp->m_sb));
	if (ip->i_d.di_version == 1) {
200
		if (!xfs_sb_version_hasnlink(&mp->m_sb)) {
L
Linus Torvalds 已提交
201 202 203 204 205 206 207 208 209 210 211
			/*
			 * Convert it back.
			 */
			ASSERT(ip->i_d.di_nlink <= XFS_MAXLINK_1);
			ip->i_d.di_onlink = ip->i_d.di_nlink;
		} else {
			/*
			 * The superblock version has already been bumped,
			 * so just make the conversion to the new inode
			 * format permanent.
			 */
212
			ip->i_d.di_version = 2;
L
Linus Torvalds 已提交
213 214 215 216 217 218 219
			ip->i_d.di_onlink = 0;
			memset(&(ip->i_d.di_pad[0]), 0, sizeof(ip->i_d.di_pad));
		}
	}

	switch (ip->i_d.di_format) {
	case XFS_DINODE_FMT_EXTENTS:
220
		iip->ili_fields &=
221 222 223
			~(XFS_ILOG_DDATA | XFS_ILOG_DBROOT |
			  XFS_ILOG_DEV | XFS_ILOG_UUID);

224
		if ((iip->ili_fields & XFS_ILOG_DEXT) &&
225 226
		    ip->i_d.di_nextents > 0 &&
		    ip->i_df.if_bytes > 0) {
L
Linus Torvalds 已提交
227
			ASSERT(ip->i_df.if_u1.if_extents != NULL);
228
			ASSERT(ip->i_df.if_bytes / sizeof(xfs_bmbt_rec_t) > 0);
L
Linus Torvalds 已提交
229
			ASSERT(iip->ili_extents_buf == NULL);
230

231
#ifdef XFS_NATIVE_HOST
D
Dave Chinner 已提交
232 233
                       if (ip->i_d.di_nextents == ip->i_df.if_bytes /
                                               (uint)sizeof(xfs_bmbt_rec_t)) {
L
Linus Torvalds 已提交
234 235 236 237 238
				/*
				 * There are no delayed allocation
				 * extents, so just point to the
				 * real extents array.
				 */
239
				vecp->i_addr = ip->i_df.if_u1.if_extents;
L
Linus Torvalds 已提交
240
				vecp->i_len = ip->i_df.if_bytes;
C
Christoph Hellwig 已提交
241
				vecp->i_type = XLOG_REG_TYPE_IEXT;
L
Linus Torvalds 已提交
242 243 244
			} else
#endif
			{
245 246
				xfs_inode_item_format_extents(ip, vecp,
					XFS_DATA_FORK, XLOG_REG_TYPE_IEXT);
L
Linus Torvalds 已提交
247 248 249 250 251
			}
			ASSERT(vecp->i_len <= ip->i_df.if_bytes);
			iip->ili_format.ilf_dsize = vecp->i_len;
			vecp++;
			nvecs++;
252
		} else {
253
			iip->ili_fields &= ~XFS_ILOG_DEXT;
L
Linus Torvalds 已提交
254 255 256 257
		}
		break;

	case XFS_DINODE_FMT_BTREE:
258
		iip->ili_fields &=
259 260 261
			~(XFS_ILOG_DDATA | XFS_ILOG_DEXT |
			  XFS_ILOG_DEV | XFS_ILOG_UUID);

262
		if ((iip->ili_fields & XFS_ILOG_DBROOT) &&
263
		    ip->i_df.if_broot_bytes > 0) {
L
Linus Torvalds 已提交
264
			ASSERT(ip->i_df.if_broot != NULL);
265
			vecp->i_addr = ip->i_df.if_broot;
L
Linus Torvalds 已提交
266
			vecp->i_len = ip->i_df.if_broot_bytes;
C
Christoph Hellwig 已提交
267
			vecp->i_type = XLOG_REG_TYPE_IBROOT;
L
Linus Torvalds 已提交
268 269 270
			vecp++;
			nvecs++;
			iip->ili_format.ilf_dsize = ip->i_df.if_broot_bytes;
271
		} else {
272
			ASSERT(!(iip->ili_fields &
273 274 275 276 277 278 279 280 281 282 283 284
				 XFS_ILOG_DBROOT));
#ifdef XFS_TRANS_DEBUG
			if (iip->ili_root_size > 0) {
				ASSERT(iip->ili_root_size ==
				       ip->i_df.if_broot_bytes);
				ASSERT(memcmp(iip->ili_orig_root,
					    ip->i_df.if_broot,
					    iip->ili_root_size) == 0);
			} else {
				ASSERT(ip->i_df.if_broot_bytes == 0);
			}
#endif
285
			iip->ili_fields &= ~XFS_ILOG_DBROOT;
L
Linus Torvalds 已提交
286 287 288 289
		}
		break;

	case XFS_DINODE_FMT_LOCAL:
290
		iip->ili_fields &=
291 292
			~(XFS_ILOG_DEXT | XFS_ILOG_DBROOT |
			  XFS_ILOG_DEV | XFS_ILOG_UUID);
293
		if ((iip->ili_fields & XFS_ILOG_DDATA) &&
294
		    ip->i_df.if_bytes > 0) {
L
Linus Torvalds 已提交
295 296 297
			ASSERT(ip->i_df.if_u1.if_data != NULL);
			ASSERT(ip->i_d.di_size > 0);

298
			vecp->i_addr = ip->i_df.if_u1.if_data;
L
Linus Torvalds 已提交
299 300 301 302 303 304 305 306 307
			/*
			 * Round i_bytes up to a word boundary.
			 * The underlying memory is guaranteed to
			 * to be there by xfs_idata_realloc().
			 */
			data_bytes = roundup(ip->i_df.if_bytes, 4);
			ASSERT((ip->i_df.if_real_bytes == 0) ||
			       (ip->i_df.if_real_bytes == data_bytes));
			vecp->i_len = (int)data_bytes;
C
Christoph Hellwig 已提交
308
			vecp->i_type = XLOG_REG_TYPE_ILOCAL;
L
Linus Torvalds 已提交
309 310 311
			vecp++;
			nvecs++;
			iip->ili_format.ilf_dsize = (unsigned)data_bytes;
312
		} else {
313
			iip->ili_fields &= ~XFS_ILOG_DDATA;
L
Linus Torvalds 已提交
314 315 316 317
		}
		break;

	case XFS_DINODE_FMT_DEV:
318
		iip->ili_fields &=
319 320
			~(XFS_ILOG_DDATA | XFS_ILOG_DBROOT |
			  XFS_ILOG_DEXT | XFS_ILOG_UUID);
321
		if (iip->ili_fields & XFS_ILOG_DEV) {
L
Linus Torvalds 已提交
322 323 324 325 326 327
			iip->ili_format.ilf_u.ilfu_rdev =
				ip->i_df.if_u2.if_rdev;
		}
		break;

	case XFS_DINODE_FMT_UUID:
328
		iip->ili_fields &=
329 330
			~(XFS_ILOG_DDATA | XFS_ILOG_DBROOT |
			  XFS_ILOG_DEXT | XFS_ILOG_DEV);
331
		if (iip->ili_fields & XFS_ILOG_UUID) {
L
Linus Torvalds 已提交
332 333 334 335 336 337 338 339 340 341 342
			iip->ili_format.ilf_u.ilfu_uuid =
				ip->i_df.if_u2.if_uuid;
		}
		break;

	default:
		ASSERT(0);
		break;
	}

	/*
343
	 * If there are no attributes associated with the file, then we're done.
L
Linus Torvalds 已提交
344 345
	 */
	if (!XFS_IFORK_Q(ip)) {
346
		iip->ili_fields &=
347
			~(XFS_ILOG_ADATA | XFS_ILOG_ABROOT | XFS_ILOG_AEXT);
348
		goto out;
L
Linus Torvalds 已提交
349 350 351 352
	}

	switch (ip->i_d.di_aformat) {
	case XFS_DINODE_FMT_EXTENTS:
353
		iip->ili_fields &=
354 355
			~(XFS_ILOG_ADATA | XFS_ILOG_ABROOT);

356
		if ((iip->ili_fields & XFS_ILOG_AEXT) &&
357 358 359 360
		    ip->i_d.di_anextents > 0 &&
		    ip->i_afp->if_bytes > 0) {
			ASSERT(ip->i_afp->if_bytes / sizeof(xfs_bmbt_rec_t) ==
				ip->i_d.di_anextents);
361
			ASSERT(ip->i_afp->if_u1.if_extents != NULL);
362
#ifdef XFS_NATIVE_HOST
L
Linus Torvalds 已提交
363 364 365 366
			/*
			 * There are not delayed allocation extents
			 * for attributes, so just point at the array.
			 */
367
			vecp->i_addr = ip->i_afp->if_u1.if_extents;
L
Linus Torvalds 已提交
368
			vecp->i_len = ip->i_afp->if_bytes;
369
			vecp->i_type = XLOG_REG_TYPE_IATTR_EXT;
L
Linus Torvalds 已提交
370 371
#else
			ASSERT(iip->ili_aextents_buf == NULL);
372 373
			xfs_inode_item_format_extents(ip, vecp,
					XFS_ATTR_FORK, XLOG_REG_TYPE_IATTR_EXT);
L
Linus Torvalds 已提交
374 375 376 377
#endif
			iip->ili_format.ilf_asize = vecp->i_len;
			vecp++;
			nvecs++;
378
		} else {
379
			iip->ili_fields &= ~XFS_ILOG_AEXT;
L
Linus Torvalds 已提交
380 381 382 383
		}
		break;

	case XFS_DINODE_FMT_BTREE:
384
		iip->ili_fields &=
385 386
			~(XFS_ILOG_ADATA | XFS_ILOG_AEXT);

387
		if ((iip->ili_fields & XFS_ILOG_ABROOT) &&
388
		    ip->i_afp->if_broot_bytes > 0) {
L
Linus Torvalds 已提交
389
			ASSERT(ip->i_afp->if_broot != NULL);
390

391
			vecp->i_addr = ip->i_afp->if_broot;
L
Linus Torvalds 已提交
392
			vecp->i_len = ip->i_afp->if_broot_bytes;
C
Christoph Hellwig 已提交
393
			vecp->i_type = XLOG_REG_TYPE_IATTR_BROOT;
L
Linus Torvalds 已提交
394 395 396
			vecp++;
			nvecs++;
			iip->ili_format.ilf_asize = ip->i_afp->if_broot_bytes;
397
		} else {
398
			iip->ili_fields &= ~XFS_ILOG_ABROOT;
L
Linus Torvalds 已提交
399 400 401 402
		}
		break;

	case XFS_DINODE_FMT_LOCAL:
403
		iip->ili_fields &=
404 405
			~(XFS_ILOG_AEXT | XFS_ILOG_ABROOT);

406
		if ((iip->ili_fields & XFS_ILOG_ADATA) &&
407
		    ip->i_afp->if_bytes > 0) {
L
Linus Torvalds 已提交
408 409
			ASSERT(ip->i_afp->if_u1.if_data != NULL);

410
			vecp->i_addr = ip->i_afp->if_u1.if_data;
L
Linus Torvalds 已提交
411 412 413 414 415 416 417 418 419
			/*
			 * Round i_bytes up to a word boundary.
			 * The underlying memory is guaranteed to
			 * to be there by xfs_idata_realloc().
			 */
			data_bytes = roundup(ip->i_afp->if_bytes, 4);
			ASSERT((ip->i_afp->if_real_bytes == 0) ||
			       (ip->i_afp->if_real_bytes == data_bytes));
			vecp->i_len = (int)data_bytes;
C
Christoph Hellwig 已提交
420
			vecp->i_type = XLOG_REG_TYPE_IATTR_LOCAL;
L
Linus Torvalds 已提交
421 422 423
			vecp++;
			nvecs++;
			iip->ili_format.ilf_asize = (unsigned)data_bytes;
424
		} else {
425
			iip->ili_fields &= ~XFS_ILOG_ADATA;
L
Linus Torvalds 已提交
426 427 428 429 430 431 432 433
		}
		break;

	default:
		ASSERT(0);
		break;
	}

434 435 436 437 438 439 440
out:
	/*
	 * Now update the log format that goes out to disk from the in-core
	 * values.  We always write the inode core to make the arithmetic
	 * games in recovery easier, which isn't a big deal as just about any
	 * transaction would dirty it anyway.
	 */
441 442
	iip->ili_format.ilf_fields = XFS_ILOG_CORE |
		(iip->ili_fields & ~XFS_ILOG_TIMESTAMP);
L
Linus Torvalds 已提交
443 444 445 446 447 448
	iip->ili_format.ilf_size = nvecs;
}


/*
 * This is called to pin the inode associated with the inode log
449
 * item in memory so it cannot be written out.
L
Linus Torvalds 已提交
450 451 452
 */
STATIC void
xfs_inode_item_pin(
453
	struct xfs_log_item	*lip)
L
Linus Torvalds 已提交
454
{
455
	struct xfs_inode	*ip = INODE_ITEM(lip)->ili_inode;
456

457 458 459 460
	ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));

	trace_xfs_inode_pin(ip, _RET_IP_);
	atomic_inc(&ip->i_pincount);
L
Linus Torvalds 已提交
461 462 463 464 465 466
}


/*
 * This is called to unpin the inode associated with the inode log
 * item which was previously pinned with a call to xfs_inode_item_pin().
467 468
 *
 * Also wake up anyone in xfs_iunpin_wait() if the count goes to 0.
L
Linus Torvalds 已提交
469 470 471
 */
STATIC void
xfs_inode_item_unpin(
472
	struct xfs_log_item	*lip,
473
	int			remove)
L
Linus Torvalds 已提交
474
{
475
	struct xfs_inode	*ip = INODE_ITEM(lip)->ili_inode;
476

477
	trace_xfs_inode_unpin(ip, _RET_IP_);
478 479
	ASSERT(atomic_read(&ip->i_pincount) > 0);
	if (atomic_dec_and_test(&ip->i_pincount))
480
		wake_up_bit(&ip->i_flags, __XFS_IPINNED_BIT);
L
Linus Torvalds 已提交
481 482 483
}

STATIC uint
484 485 486
xfs_inode_item_push(
	struct xfs_log_item	*lip,
	struct list_head	*buffer_list)
L
Linus Torvalds 已提交
487
{
488 489
	struct xfs_inode_log_item *iip = INODE_ITEM(lip);
	struct xfs_inode	*ip = iip->ili_inode;
490 491 492
	struct xfs_buf		*bp = NULL;
	uint			rval = XFS_ITEM_SUCCESS;
	int			error;
L
Linus Torvalds 已提交
493

494
	if (xfs_ipincount(ip) > 0)
L
Linus Torvalds 已提交
495 496
		return XFS_ITEM_PINNED;

497
	if (!xfs_ilock_nowait(ip, XFS_ILOCK_SHARED))
L
Linus Torvalds 已提交
498 499
		return XFS_ITEM_LOCKED;

500 501 502 503 504
	/*
	 * Re-check the pincount now that we stabilized the value by
	 * taking the ilock.
	 */
	if (xfs_ipincount(ip) > 0) {
505 506
		rval = XFS_ITEM_PINNED;
		goto out_unlock;
507 508
	}

509 510 511 512 513
	/*
	 * Someone else is already flushing the inode.  Nothing we can do
	 * here but wait for the flush to finish and remove the item from
	 * the AIL.
	 */
L
Linus Torvalds 已提交
514
	if (!xfs_iflock_nowait(ip)) {
515 516
		rval = XFS_ITEM_FLUSHING;
		goto out_unlock;
L
Linus Torvalds 已提交
517 518
	}

519 520 521
	/*
	 * Stale inode items should force out the iclog.
	 */
L
Linus Torvalds 已提交
522 523
	if (ip->i_flags & XFS_ISTALE) {
		xfs_ifunlock(ip);
524
		xfs_iunlock(ip, XFS_ILOCK_SHARED);
L
Linus Torvalds 已提交
525 526 527
		return XFS_ITEM_PINNED;
	}

528 529 530 531 532 533 534 535 536 537
	ASSERT(iip->ili_fields != 0 || XFS_FORCED_SHUTDOWN(ip->i_mount));
	ASSERT(iip->ili_logged == 0 || XFS_FORCED_SHUTDOWN(ip->i_mount));

	spin_unlock(&lip->li_ailp->xa_lock);

	error = xfs_iflush(ip, &bp);
	if (!error) {
		if (!xfs_buf_delwri_queue(bp, buffer_list))
			rval = XFS_ITEM_FLUSHING;
		xfs_buf_relse(bp);
L
Linus Torvalds 已提交
538
	}
539 540 541 542 543

	spin_lock(&lip->li_ailp->xa_lock);
out_unlock:
	xfs_iunlock(ip, XFS_ILOCK_SHARED);
	return rval;
L
Linus Torvalds 已提交
544 545 546 547 548 549 550 551 552 553
}

/*
 * Unlock the inode associated with the inode log item.
 * Clear the fields of the inode and inode log item that
 * are specific to the current transaction.  If the
 * hold flags is set, do not unlock the inode.
 */
STATIC void
xfs_inode_item_unlock(
554
	struct xfs_log_item	*lip)
L
Linus Torvalds 已提交
555
{
556 557
	struct xfs_inode_log_item *iip = INODE_ITEM(lip);
	struct xfs_inode	*ip = iip->ili_inode;
558
	unsigned short		lock_flags;
L
Linus Torvalds 已提交
559

C
Christoph Hellwig 已提交
560 561
	ASSERT(ip->i_itemp != NULL);
	ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
L
Linus Torvalds 已提交
562 563 564 565 566 567 568 569

	/*
	 * If the inode needed a separate buffer with which to log
	 * its extents, then free it now.
	 */
	if (iip->ili_extents_buf != NULL) {
		ASSERT(ip->i_d.di_format == XFS_DINODE_FMT_EXTENTS);
		ASSERT(ip->i_d.di_nextents > 0);
570
		ASSERT(iip->ili_fields & XFS_ILOG_DEXT);
L
Linus Torvalds 已提交
571
		ASSERT(ip->i_df.if_bytes > 0);
572
		kmem_free(iip->ili_extents_buf);
L
Linus Torvalds 已提交
573 574 575 576 577
		iip->ili_extents_buf = NULL;
	}
	if (iip->ili_aextents_buf != NULL) {
		ASSERT(ip->i_d.di_aformat == XFS_DINODE_FMT_EXTENTS);
		ASSERT(ip->i_d.di_anextents > 0);
578
		ASSERT(iip->ili_fields & XFS_ILOG_AEXT);
L
Linus Torvalds 已提交
579
		ASSERT(ip->i_afp->if_bytes > 0);
580
		kmem_free(iip->ili_aextents_buf);
L
Linus Torvalds 已提交
581 582 583
		iip->ili_aextents_buf = NULL;
	}

584 585
	lock_flags = iip->ili_lock_flags;
	iip->ili_lock_flags = 0;
586
	if (lock_flags)
C
Christoph Hellwig 已提交
587
		xfs_iunlock(ip, lock_flags);
L
Linus Torvalds 已提交
588 589 590
}

/*
591 592 593 594 595 596 597 598 599 600 601
 * This is called to find out where the oldest active copy of the inode log
 * item in the on disk log resides now that the last log write of it completed
 * at the given lsn.  Since we always re-log all dirty data in an inode, the
 * latest copy in the on disk log is the only one that matters.  Therefore,
 * simply return the given lsn.
 *
 * If the inode has been marked stale because the cluster is being freed, we
 * don't want to (re-)insert this inode into the AIL. There is a race condition
 * where the cluster buffer may be unpinned before the inode is inserted into
 * the AIL during transaction committed processing. If the buffer is unpinned
 * before the inode item has been committed and inserted, then it is possible
602
 * for the buffer to be written and IO completes before the inode is inserted
603 604 605 606 607
 * into the AIL. In that case, we'd be inserting a clean, stale inode into the
 * AIL which will never get removed. It will, however, get reclaimed which
 * triggers an assert in xfs_inode_free() complaining about freein an inode
 * still in the AIL.
 *
608 609 610
 * To avoid this, just unpin the inode directly and return a LSN of -1 so the
 * transaction committed code knows that it does not need to do any further
 * processing on the item.
L
Linus Torvalds 已提交
611 612 613
 */
STATIC xfs_lsn_t
xfs_inode_item_committed(
614
	struct xfs_log_item	*lip,
L
Linus Torvalds 已提交
615 616
	xfs_lsn_t		lsn)
{
617 618 619
	struct xfs_inode_log_item *iip = INODE_ITEM(lip);
	struct xfs_inode	*ip = iip->ili_inode;

620 621 622 623
	if (xfs_iflags_test(ip, XFS_ISTALE)) {
		xfs_inode_item_unpin(lip, 0);
		return -1;
	}
624
	return lsn;
L
Linus Torvalds 已提交
625 626 627 628 629 630 631 632
}

/*
 * XXX rcc - this one really has to do something.  Probably needs
 * to stamp in a new field in the incore inode.
 */
STATIC void
xfs_inode_item_committing(
633
	struct xfs_log_item	*lip,
L
Linus Torvalds 已提交
634 635
	xfs_lsn_t		lsn)
{
636
	INODE_ITEM(lip)->ili_last_lsn = lsn;
L
Linus Torvalds 已提交
637 638 639 640 641
}

/*
 * This is the ops vector shared by all buf log items.
 */
C
Christoph Hellwig 已提交
642
static const struct xfs_item_ops xfs_inode_item_ops = {
643 644 645 646 647 648 649 650
	.iop_size	= xfs_inode_item_size,
	.iop_format	= xfs_inode_item_format,
	.iop_pin	= xfs_inode_item_pin,
	.iop_unpin	= xfs_inode_item_unpin,
	.iop_unlock	= xfs_inode_item_unlock,
	.iop_committed	= xfs_inode_item_committed,
	.iop_push	= xfs_inode_item_push,
	.iop_committing = xfs_inode_item_committing
L
Linus Torvalds 已提交
651 652 653 654 655 656 657 658
};


/*
 * Initialize the inode log item for a newly allocated (in-core) inode.
 */
void
xfs_inode_item_init(
659 660
	struct xfs_inode	*ip,
	struct xfs_mount	*mp)
L
Linus Torvalds 已提交
661
{
662
	struct xfs_inode_log_item *iip;
L
Linus Torvalds 已提交
663 664 665 666 667

	ASSERT(ip->i_itemp == NULL);
	iip = ip->i_itemp = kmem_zone_zalloc(xfs_ili_zone, KM_SLEEP);

	iip->ili_inode = ip;
668 669
	xfs_log_item_init(mp, &iip->ili_item, XFS_LI_INODE,
						&xfs_inode_item_ops);
L
Linus Torvalds 已提交
670 671
	iip->ili_format.ilf_type = XFS_LI_INODE;
	iip->ili_format.ilf_ino = ip->i_ino;
672 673 674
	iip->ili_format.ilf_blkno = ip->i_imap.im_blkno;
	iip->ili_format.ilf_len = ip->i_imap.im_len;
	iip->ili_format.ilf_boffset = ip->i_imap.im_boffset;
L
Linus Torvalds 已提交
675 676 677 678 679 680 681 682 683 684 685
}

/*
 * Free the inode log item and any memory hanging off of it.
 */
void
xfs_inode_item_destroy(
	xfs_inode_t	*ip)
{
#ifdef XFS_TRANS_DEBUG
	if (ip->i_itemp->ili_root_size != 0) {
686
		kmem_free(ip->i_itemp->ili_orig_root);
L
Linus Torvalds 已提交
687 688 689 690 691 692 693 694 695 696 697 698
	}
#endif
	kmem_zone_free(xfs_ili_zone, ip->i_itemp);
}


/*
 * This is the inode flushing I/O completion routine.  It is called
 * from interrupt level when the buffer containing the inode is
 * flushed to disk.  It is responsible for removing the inode item
 * from the AIL if it has not been re-logged, and unlocking the inode's
 * flush lock.
699 700 701 702 703
 *
 * To reduce AIL lock traffic as much as possible, we scan the buffer log item
 * list for other inodes that will run this function. We remove them from the
 * buffer list so we can process all the inode IO completions in one AIL lock
 * traversal.
L
Linus Torvalds 已提交
704 705 706
 */
void
xfs_iflush_done(
707 708
	struct xfs_buf		*bp,
	struct xfs_log_item	*lip)
L
Linus Torvalds 已提交
709
{
710 711 712 713
	struct xfs_inode_log_item *iip;
	struct xfs_log_item	*blip;
	struct xfs_log_item	*next;
	struct xfs_log_item	*prev;
714
	struct xfs_ail		*ailp = lip->li_ailp;
715 716 717 718 719 720
	int			need_ail = 0;

	/*
	 * Scan the buffer IO completions for other inodes being completed and
	 * attach them to the current inode log item.
	 */
721
	blip = bp->b_fspriv;
722 723 724 725 726 727 728 729 730 731 732
	prev = NULL;
	while (blip != NULL) {
		if (lip->li_cb != xfs_iflush_done) {
			prev = blip;
			blip = blip->li_bio_list;
			continue;
		}

		/* remove from list */
		next = blip->li_bio_list;
		if (!prev) {
733
			bp->b_fspriv = next;
734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756
		} else {
			prev->li_bio_list = next;
		}

		/* add to current list */
		blip->li_bio_list = lip->li_bio_list;
		lip->li_bio_list = blip;

		/*
		 * while we have the item, do the unlocked check for needing
		 * the AIL lock.
		 */
		iip = INODE_ITEM(blip);
		if (iip->ili_logged && blip->li_lsn == iip->ili_flush_lsn)
			need_ail++;

		blip = next;
	}

	/* make sure we capture the state of the initial inode. */
	iip = INODE_ITEM(lip);
	if (iip->ili_logged && lip->li_lsn == iip->ili_flush_lsn)
		need_ail++;
L
Linus Torvalds 已提交
757 758 759 760 761 762 763 764 765 766

	/*
	 * We only want to pull the item from the AIL if it is
	 * actually there and its location in the log has not
	 * changed since we started the flush.  Thus, we only bother
	 * if the ili_logged flag is set and the inode's lsn has not
	 * changed.  First we check the lsn outside
	 * the lock since it's cheaper, and then we recheck while
	 * holding the lock before removing the inode from the AIL.
	 */
767 768 769
	if (need_ail) {
		struct xfs_log_item *log_items[need_ail];
		int i = 0;
770
		spin_lock(&ailp->xa_lock);
771 772 773 774 775 776 777
		for (blip = lip; blip; blip = blip->li_bio_list) {
			iip = INODE_ITEM(blip);
			if (iip->ili_logged &&
			    blip->li_lsn == iip->ili_flush_lsn) {
				log_items[i++] = blip;
			}
			ASSERT(i <= need_ail);
L
Linus Torvalds 已提交
778
		}
779 780
		/* xfs_trans_ail_delete_bulk() drops the AIL lock. */
		xfs_trans_ail_delete_bulk(ailp, log_items, i);
L
Linus Torvalds 已提交
781 782 783 784
	}


	/*
785 786 787
	 * clean up and unlock the flush lock now we are done. We can clear the
	 * ili_last_fields bits now that we know that the data corresponding to
	 * them is safely on disk.
L
Linus Torvalds 已提交
788
	 */
789 790 791 792 793 794 795 796 797
	for (blip = lip; blip; blip = next) {
		next = blip->li_bio_list;
		blip->li_bio_list = NULL;

		iip = INODE_ITEM(blip);
		iip->ili_logged = 0;
		iip->ili_last_fields = 0;
		xfs_ifunlock(iip->ili_inode);
	}
L
Linus Torvalds 已提交
798 799 800 801 802 803 804 805 806 807 808 809 810 811
}

/*
 * This is the inode flushing abort routine.  It is called
 * from xfs_iflush when the filesystem is shutting down to clean
 * up the inode state.
 * It is responsible for removing the inode item
 * from the AIL if it has not been re-logged, and unlocking the inode's
 * flush lock.
 */
void
xfs_iflush_abort(
	xfs_inode_t		*ip)
{
812
	xfs_inode_log_item_t	*iip = ip->i_itemp;
L
Linus Torvalds 已提交
813 814

	if (iip) {
815
		struct xfs_ail	*ailp = iip->ili_item.li_ailp;
L
Linus Torvalds 已提交
816
		if (iip->ili_item.li_flags & XFS_LI_IN_AIL) {
817
			spin_lock(&ailp->xa_lock);
L
Linus Torvalds 已提交
818
			if (iip->ili_item.li_flags & XFS_LI_IN_AIL) {
819 820
				/* xfs_trans_ail_delete() drops the AIL lock. */
				xfs_trans_ail_delete(ailp, (xfs_log_item_t *)iip);
L
Linus Torvalds 已提交
821
			} else
822
				spin_unlock(&ailp->xa_lock);
L
Linus Torvalds 已提交
823 824 825 826 827 828 829 830 831 832 833
		}
		iip->ili_logged = 0;
		/*
		 * Clear the ili_last_fields bits now that we know that the
		 * data corresponding to them is safely on disk.
		 */
		iip->ili_last_fields = 0;
		/*
		 * Clear the inode logging fields so no more flushes are
		 * attempted.
		 */
834
		iip->ili_fields = 0;
L
Linus Torvalds 已提交
835 836 837 838 839 840 841 842 843
	}
	/*
	 * Release the inode's flush lock since we're done with it.
	 */
	xfs_ifunlock(ip);
}

void
xfs_istale_done(
844 845
	struct xfs_buf		*bp,
	struct xfs_log_item	*lip)
L
Linus Torvalds 已提交
846
{
847
	xfs_iflush_abort(INODE_ITEM(lip)->ili_inode);
L
Linus Torvalds 已提交
848
}
849 850 851 852 853 854 855 856 857 858 859

/*
 * convert an xfs_inode_log_format struct from either 32 or 64 bit versions
 * (which can have different field alignments) to the native version
 */
int
xfs_inode_item_format_convert(
	xfs_log_iovec_t		*buf,
	xfs_inode_log_format_t	*in_f)
{
	if (buf->i_len == sizeof(xfs_inode_log_format_32_t)) {
860
		xfs_inode_log_format_32_t *in_f32 = buf->i_addr;
861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876

		in_f->ilf_type = in_f32->ilf_type;
		in_f->ilf_size = in_f32->ilf_size;
		in_f->ilf_fields = in_f32->ilf_fields;
		in_f->ilf_asize = in_f32->ilf_asize;
		in_f->ilf_dsize = in_f32->ilf_dsize;
		in_f->ilf_ino = in_f32->ilf_ino;
		/* copy biggest field of ilf_u */
		memcpy(in_f->ilf_u.ilfu_uuid.__u_bits,
		       in_f32->ilf_u.ilfu_uuid.__u_bits,
		       sizeof(uuid_t));
		in_f->ilf_blkno = in_f32->ilf_blkno;
		in_f->ilf_len = in_f32->ilf_len;
		in_f->ilf_boffset = in_f32->ilf_boffset;
		return 0;
	} else if (buf->i_len == sizeof(xfs_inode_log_format_64_t)){
877
		xfs_inode_log_format_64_t *in_f64 = buf->i_addr;
878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895

		in_f->ilf_type = in_f64->ilf_type;
		in_f->ilf_size = in_f64->ilf_size;
		in_f->ilf_fields = in_f64->ilf_fields;
		in_f->ilf_asize = in_f64->ilf_asize;
		in_f->ilf_dsize = in_f64->ilf_dsize;
		in_f->ilf_ino = in_f64->ilf_ino;
		/* copy biggest field of ilf_u */
		memcpy(in_f->ilf_u.ilfu_uuid.__u_bits,
		       in_f64->ilf_u.ilfu_uuid.__u_bits,
		       sizeof(uuid_t));
		in_f->ilf_blkno = in_f64->ilf_blkno;
		in_f->ilf_len = in_f64->ilf_len;
		in_f->ilf_boffset = in_f64->ilf_boffset;
		return 0;
	}
	return EFSCORRUPTED;
}