xfs_trans_ail.c 20.5 KB
Newer Older
L
Linus Torvalds 已提交
1
/*
2
 * Copyright (c) 2000-2002,2005 Silicon Graphics, Inc.
3
 * Copyright (c) 2008 Dave Chinner
4
 * All Rights Reserved.
L
Linus Torvalds 已提交
5
 *
6 7
 * 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 已提交
8 9
 * published by the Free Software Foundation.
 *
10 11 12 13
 * 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 已提交
14
 *
15 16 17
 * 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 已提交
18 19
 */
#include "xfs.h"
20
#include "xfs_fs.h"
L
Linus Torvalds 已提交
21 22
#include "xfs_types.h"
#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
#include "xfs_mount.h"
#include "xfs_trans_priv.h"
#include "xfs_error.h"

31
STATIC void xfs_ail_splice(struct xfs_ail *, struct list_head *, xfs_lsn_t);
D
Dave Chinner 已提交
32
STATIC void xfs_ail_delete(struct xfs_ail *, xfs_log_item_t *);
D
David Chinner 已提交
33 34
STATIC xfs_log_item_t * xfs_ail_min(struct xfs_ail *);
STATIC xfs_log_item_t * xfs_ail_next(struct xfs_ail *, xfs_log_item_t *);
L
Linus Torvalds 已提交
35 36

#ifdef DEBUG
D
David Chinner 已提交
37
STATIC void xfs_ail_check(struct xfs_ail *, xfs_log_item_t *);
L
Linus Torvalds 已提交
38
#else
39
#define	xfs_ail_check(a,l)
L
Linus Torvalds 已提交
40 41 42 43 44 45 46 47 48 49 50 51 52
#endif /* DEBUG */


/*
 * This is called by the log manager code to determine the LSN
 * of the tail of the log.  This is exactly the LSN of the first
 * item in the AIL.  If the AIL is empty, then this function
 * returns 0.
 *
 * We need the AIL lock in order to get a coherent read of the
 * lsn of the last item in the AIL.
 */
xfs_lsn_t
53 54
xfs_trans_ail_tail(
	struct xfs_ail	*ailp)
L
Linus Torvalds 已提交
55 56 57 58
{
	xfs_lsn_t	lsn;
	xfs_log_item_t	*lip;

59
	spin_lock(&ailp->xa_lock);
60
	lip = xfs_ail_min(ailp);
L
Linus Torvalds 已提交
61 62 63 64 65
	if (lip == NULL) {
		lsn = (xfs_lsn_t)0;
	} else {
		lsn = lip->li_lsn;
	}
66
	spin_unlock(&ailp->xa_lock);
L
Linus Torvalds 已提交
67 68 69 70 71 72 73

	return lsn;
}

/*
 * xfs_trans_push_ail
 *
74 75 76
 * This routine is called to move the tail of the AIL forward.  It does this by
 * trying to flush items in the AIL whose lsns are below the given
 * threshold_lsn.
L
Linus Torvalds 已提交
77
 *
78 79 80
 * the push is run asynchronously in a separate thread, so we return the tail
 * of the log right now instead of the tail after the push. This means we will
 * either continue right away, or we will sleep waiting on the async thread to
M
Malcolm Parsons 已提交
81
 * do its work.
82 83 84 85
 *
 * We do this unlocked - we only need to know whether there is anything in the
 * AIL at the time we are called. We don't need to access the contents of
 * any of the objects, so the lock is not needed.
L
Linus Torvalds 已提交
86
 */
87
void
88 89 90
xfs_trans_ail_push(
	struct xfs_ail	*ailp,
	xfs_lsn_t	threshold_lsn)
L
Linus Torvalds 已提交
91
{
92
	xfs_log_item_t	*lip;
L
Linus Torvalds 已提交
93

94 95 96 97
	lip = xfs_ail_min(ailp);
	if (lip && !XFS_FORCED_SHUTDOWN(ailp->xa_mount)) {
		if (XFS_LSN_CMP(threshold_lsn, ailp->xa_target) > 0)
			xfsaild_wakeup(ailp, threshold_lsn);
98 99 100
	}
}

101 102 103 104 105 106 107 108 109 110 111 112 113
/*
 * AIL traversal cursor initialisation.
 *
 * The cursor keeps track of where our current traversal is up
 * to by tracking the next ƣtem in the list for us. However, for
 * this to be safe, removing an object from the AIL needs to invalidate
 * any cursor that points to it. hence the traversal cursor needs to
 * be linked to the struct xfs_ail so that deletion can search all the
 * active cursors for invalidation.
 *
 * We don't link the push cursor because it is embedded in the struct
 * xfs_ail and hence easily findable.
 */
114
STATIC void
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
xfs_trans_ail_cursor_init(
	struct xfs_ail		*ailp,
	struct xfs_ail_cursor	*cur)
{
	cur->item = NULL;
	if (cur == &ailp->xa_cursors)
		return;

	cur->next = ailp->xa_cursors.next;
	ailp->xa_cursors.next = cur;
}

/*
 * Set the cursor to the next item, because when we look
 * up the cursor the current item may have been freed.
 */
STATIC void
xfs_trans_ail_cursor_set(
	struct xfs_ail		*ailp,
	struct xfs_ail_cursor	*cur,
	struct xfs_log_item	*lip)
{
	if (lip)
		cur->item = xfs_ail_next(ailp, lip);
}

/*
 * Get the next item in the traversal and advance the cursor.
 * If the cursor was invalidated (inidicated by a lip of 1),
 * restart the traversal.
 */
146
struct xfs_log_item *
147 148 149 150 151 152 153 154 155 156 157 158 159 160 161
xfs_trans_ail_cursor_next(
	struct xfs_ail		*ailp,
	struct xfs_ail_cursor	*cur)
{
	struct xfs_log_item	*lip = cur->item;

	if ((__psint_t)lip & 1)
		lip = xfs_ail_min(ailp);
	xfs_trans_ail_cursor_set(ailp, cur, lip);
	return lip;
}

/*
 * Now that the traversal is complete, we need to remove the cursor
 * from the list of traversing cursors. Avoid removing the embedded
M
Malcolm Parsons 已提交
162
 * push cursor, but use the fact it is always present to make the
163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185
 * list deletion simple.
 */
void
xfs_trans_ail_cursor_done(
	struct xfs_ail		*ailp,
	struct xfs_ail_cursor	*done)
{
	struct xfs_ail_cursor	*prev = NULL;
	struct xfs_ail_cursor	*cur;

	done->item = NULL;
	if (done == &ailp->xa_cursors)
		return;
	prev = &ailp->xa_cursors;
	for (cur = prev->next; cur; prev = cur, cur = prev->next) {
		if (cur == done) {
			prev->next = cur->next;
			break;
		}
	}
	ASSERT(cur);
}

186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209
/*
 * Invalidate any cursor that is pointing to this item. This is
 * called when an item is removed from the AIL. Any cursor pointing
 * to this object is now invalid and the traversal needs to be
 * terminated so it doesn't reference a freed object. We set the
 * cursor item to a value of 1 so we can distinguish between an
 * invalidation and the end of the list when getting the next item
 * from the cursor.
 */
STATIC void
xfs_trans_ail_cursor_clear(
	struct xfs_ail		*ailp,
	struct xfs_log_item	*lip)
{
	struct xfs_ail_cursor	*cur;

	/* need to search all cursors */
	for (cur = &ailp->xa_cursors; cur; cur = cur->next) {
		if (cur->item == lip)
			cur->item = (struct xfs_log_item *)
					((__psint_t)cur->item | 1);
	}
}

210 211 212 213 214
/*
 * Return the item in the AIL with the current lsn.
 * Return the current tree generation number for use
 * in calls to xfs_trans_next_ail().
 */
215 216
xfs_log_item_t *
xfs_trans_ail_cursor_first(
217 218 219
	struct xfs_ail		*ailp,
	struct xfs_ail_cursor	*cur,
	xfs_lsn_t		lsn)
220
{
221
	xfs_log_item_t		*lip;
222

223
	xfs_trans_ail_cursor_init(ailp, cur);
224
	lip = xfs_ail_min(ailp);
225
	if (lsn == 0)
226
		goto out;
227

228
	list_for_each_entry(lip, &ailp->xa_ail, li_ail) {
229
		if (XFS_LSN_CMP(lip->li_lsn, lsn) >= 0)
230
			goto out;
231
	}
232 233 234 235
	lip = NULL;
out:
	xfs_trans_ail_cursor_set(ailp, cur, lip);
	return lip;
236 237 238
}

/*
239 240
 * xfsaild_push does the work of pushing on the AIL.  Returning a timeout of
 * zero indicates that the caller should sleep until woken.
241 242 243
 */
long
xfsaild_push(
D
David Chinner 已提交
244
	struct xfs_ail	*ailp,
245 246
	xfs_lsn_t	*last_lsn)
{
247
	long		tout = 0;
248
	xfs_lsn_t	last_pushed_lsn = *last_lsn;
D
David Chinner 已提交
249
	xfs_lsn_t	target =  ailp->xa_target;
250 251 252
	xfs_lsn_t	lsn;
	xfs_log_item_t	*lip;
	int		flush_log, count, stuck;
D
David Chinner 已提交
253
	xfs_mount_t	*mp = ailp->xa_mount;
254
	struct xfs_ail_cursor	*cur = &ailp->xa_cursors;
255
	int		push_xfsbufd = 0;
L
Linus Torvalds 已提交
256

257
	spin_lock(&ailp->xa_lock);
258
	xfs_trans_ail_cursor_init(ailp, cur);
259
	lip = xfs_trans_ail_cursor_first(ailp, cur, *last_lsn);
260
	if (!lip || XFS_FORCED_SHUTDOWN(mp)) {
L
Linus Torvalds 已提交
261
		/*
262
		 * AIL is empty or our push has reached the end.
L
Linus Torvalds 已提交
263
		 */
264
		xfs_trans_ail_cursor_done(ailp, cur);
265
		spin_unlock(&ailp->xa_lock);
266
		*last_lsn = 0;
267
		return tout;
L
Linus Torvalds 已提交
268 269 270 271 272 273
	}

	XFS_STATS_INC(xs_push_ail);

	/*
	 * While the item we are looking at is below the given threshold
274
	 * try to flush it out. We'd like not to stop until we've at least
L
Linus Torvalds 已提交
275
	 * tried to push on everything in the AIL with an LSN less than
276 277 278 279 280 281
	 * the given threshold.
	 *
	 * However, we will stop after a certain number of pushes and wait
	 * for a reduced timeout to fire before pushing further. This
	 * prevents use from spinning when we can't do anything or there is
	 * lots of contention on the AIL lists.
L
Linus Torvalds 已提交
282
	 */
283
	lsn = lip->li_lsn;
284
	flush_log = stuck = count = 0;
285 286
	while ((XFS_LSN_CMP(lip->li_lsn, target) < 0)) {
		int	lock_result;
L
Linus Torvalds 已提交
287
		/*
288 289 290 291
		 * If we can lock the item without sleeping, unlock the AIL
		 * lock and flush the item.  Then re-grab the AIL lock so we
		 * can look for the next item on the AIL. List changes are
		 * handled by the AIL lookup functions internally
L
Linus Torvalds 已提交
292
		 *
293 294 295 296
		 * If we can't lock the item, either its holder will flush it
		 * or it is already being flushed or it is being relogged.  In
		 * any of these case it is being taken care of and we can just
		 * skip to the next item in the list.
L
Linus Torvalds 已提交
297 298
		 */
		lock_result = IOP_TRYLOCK(lip);
299
		spin_unlock(&ailp->xa_lock);
L
Linus Torvalds 已提交
300
		switch (lock_result) {
301
		case XFS_ITEM_SUCCESS:
L
Linus Torvalds 已提交
302 303
			XFS_STATS_INC(xs_push_ail_success);
			IOP_PUSH(lip);
304
			last_pushed_lsn = lsn;
L
Linus Torvalds 已提交
305 306
			break;

307
		case XFS_ITEM_PUSHBUF:
L
Linus Torvalds 已提交
308 309
			XFS_STATS_INC(xs_push_ail_pushbuf);
			IOP_PUSHBUF(lip);
310
			last_pushed_lsn = lsn;
311
			push_xfsbufd = 1;
L
Linus Torvalds 已提交
312 313
			break;

314
		case XFS_ITEM_PINNED:
L
Linus Torvalds 已提交
315
			XFS_STATS_INC(xs_push_ail_pinned);
316
			stuck++;
L
Linus Torvalds 已提交
317 318 319
			flush_log = 1;
			break;

320
		case XFS_ITEM_LOCKED:
L
Linus Torvalds 已提交
321
			XFS_STATS_INC(xs_push_ail_locked);
322 323
			last_pushed_lsn = lsn;
			stuck++;
L
Linus Torvalds 已提交
324 325
			break;

326
		default:
L
Linus Torvalds 已提交
327 328 329 330
			ASSERT(0);
			break;
		}

331
		spin_lock(&ailp->xa_lock);
332 333
		/* should we bother continuing? */
		if (XFS_FORCED_SHUTDOWN(mp))
L
Linus Torvalds 已提交
334
			break;
335 336 337
		ASSERT(mp->m_log);

		count++;
L
Linus Torvalds 已提交
338

339 340 341 342 343 344 345 346 347 348 349 350 351 352 353
		/*
		 * Are there too many items we can't do anything with?
		 * If we we are skipping too many items because we can't flush
		 * them or they are already being flushed, we back off and
		 * given them time to complete whatever operation is being
		 * done. i.e. remove pressure from the AIL while we can't make
		 * progress so traversals don't slow down further inserts and
		 * removals to/from the AIL.
		 *
		 * The value of 100 is an arbitrary magic number based on
		 * observation.
		 */
		if (stuck > 100)
			break;

354
		lip = xfs_trans_ail_cursor_next(ailp, cur);
355 356 357
		if (lip == NULL)
			break;
		lsn = lip->li_lsn;
L
Linus Torvalds 已提交
358
	}
359
	xfs_trans_ail_cursor_done(ailp, cur);
360
	spin_unlock(&ailp->xa_lock);
L
Linus Torvalds 已提交
361 362 363 364 365 366 367 368

	if (flush_log) {
		/*
		 * If something we need to push out was pinned, then
		 * push out the log so it will become unpinned and
		 * move forward in the AIL.
		 */
		XFS_STATS_INC(xs_push_ail_flush);
369
		xfs_log_force(mp, 0);
L
Linus Torvalds 已提交
370 371
	}

372 373 374 375 376
	if (push_xfsbufd) {
		/* we've got delayed write buffers to flush */
		wake_up_process(mp->m_ddev_targp->bt_task);
	}

377 378
	if (!count) {
		/* We're past our target or empty, so idle */
379
		last_pushed_lsn = 0;
380 381 382 383 384 385
	} else if (XFS_LSN_CMP(lsn, target) >= 0) {
		/*
		 * We reached the target so wait a bit longer for I/O to
		 * complete and remove pushed items from the AIL before we
		 * start the next scan from the start of the AIL.
		 */
386
		tout = 50;
387
		last_pushed_lsn = 0;
388
	} else if ((stuck * 100) / count > 90) {
389 390 391 392 393 394 395 396 397
		/*
		 * Either there is a lot of contention on the AIL or we
		 * are stuck due to operations in progress. "Stuck" in this
		 * case is defined as >90% of the items we tried to push
		 * were stuck.
		 *
		 * Backoff a bit more to allow some I/O to complete before
		 * continuing from where we were.
		 */
398 399 400 401
		tout = 20;
	} else {
		/* more to do, but wait a short while before continuing */
		tout = 10;
L
Linus Torvalds 已提交
402
	}
403 404
	*last_lsn = last_pushed_lsn;
	return tout;
405
}
L
Linus Torvalds 已提交
406 407 408 409 410 411 412 413 414 415 416 417


/*
 * This is to be called when an item is unlocked that may have
 * been in the AIL.  It will wake up the first member of the AIL
 * wait list if this item's unlocking might allow it to progress.
 * If the item is in the AIL, then we need to get the AIL lock
 * while doing our checking so we don't race with someone going
 * to sleep waiting for this event in xfs_trans_push_ail().
 */
void
xfs_trans_unlocked_item(
418
	struct xfs_ail	*ailp,
L
Linus Torvalds 已提交
419 420 421 422 423 424 425 426 427 428 429
	xfs_log_item_t	*lip)
{
	xfs_log_item_t	*min_lip;

	/*
	 * If we're forcibly shutting down, we may have
	 * unlocked log items arbitrarily. The last thing
	 * we want to do is to move the tail of the log
	 * over some potentially valid data.
	 */
	if (!(lip->li_flags & XFS_LI_IN_AIL) ||
430
	    XFS_FORCED_SHUTDOWN(ailp->xa_mount)) {
L
Linus Torvalds 已提交
431 432 433 434 435 436 437 438 439 440 441 442 443 444 445
		return;
	}

	/*
	 * This is the one case where we can call into xfs_ail_min()
	 * without holding the AIL lock because we only care about the
	 * case where we are at the tail of the AIL.  If the object isn't
	 * at the tail, it doesn't matter what result we get back.  This
	 * is slightly racy because since we were just unlocked, we could
	 * go to sleep between the call to xfs_ail_min and the call to
	 * xfs_log_move_tail, have someone else lock us, commit to us disk,
	 * move us out of the tail of the AIL, and then we wake up.  However,
	 * the call to xfs_log_move_tail() doesn't do anything if there's
	 * not enough free space to wake people up so we're safe calling it.
	 */
446
	min_lip = xfs_ail_min(ailp);
L
Linus Torvalds 已提交
447 448

	if (min_lip == lip)
449
		xfs_log_move_tail(ailp->xa_mount, 1);
L
Linus Torvalds 已提交
450 451
}	/* xfs_trans_unlocked_item */

452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524
/*
 * xfs_trans_ail_update - bulk AIL insertion operation.
 *
 * @xfs_trans_ail_update takes an array of log items that all need to be
 * positioned at the same LSN in the AIL. If an item is not in the AIL, it will
 * be added.  Otherwise, it will be repositioned  by removing it and re-adding
 * it to the AIL. If we move the first item in the AIL, update the log tail to
 * match the new minimum LSN in the AIL.
 *
 * This function takes the AIL lock once to execute the update operations on
 * all the items in the array, and as such should not be called with the AIL
 * lock held. As a result, once we have the AIL lock, we need to check each log
 * item LSN to confirm it needs to be moved forward in the AIL.
 *
 * To optimise the insert operation, we delete all the items from the AIL in
 * the first pass, moving them into a temporary list, then splice the temporary
 * list into the correct position in the AIL. This avoids needing to do an
 * insert operation on every item.
 *
 * This function must be called with the AIL lock held.  The lock is dropped
 * before returning.
 */
void
xfs_trans_ail_update_bulk(
	struct xfs_ail		*ailp,
	struct xfs_log_item	**log_items,
	int			nr_items,
	xfs_lsn_t		lsn) __releases(ailp->xa_lock)
{
	xfs_log_item_t		*mlip;
	xfs_lsn_t		tail_lsn;
	int			mlip_changed = 0;
	int			i;
	LIST_HEAD(tmp);

	mlip = xfs_ail_min(ailp);

	for (i = 0; i < nr_items; i++) {
		struct xfs_log_item *lip = log_items[i];
		if (lip->li_flags & XFS_LI_IN_AIL) {
			/* check if we really need to move the item */
			if (XFS_LSN_CMP(lsn, lip->li_lsn) <= 0)
				continue;

			xfs_ail_delete(ailp, lip);
			if (mlip == lip)
				mlip_changed = 1;
		} else {
			lip->li_flags |= XFS_LI_IN_AIL;
		}
		lip->li_lsn = lsn;
		list_add(&lip->li_ail, &tmp);
	}

	xfs_ail_splice(ailp, &tmp, lsn);

	if (!mlip_changed) {
		spin_unlock(&ailp->xa_lock);
		return;
	}

	/*
	 * It is not safe to access mlip after the AIL lock is dropped, so we
	 * must get a copy of li_lsn before we do so.  This is especially
	 * important on 32-bit platforms where accessing and updating 64-bit
	 * values like li_lsn is not atomic.
	 */
	mlip = xfs_ail_min(ailp);
	tail_lsn = mlip->li_lsn;
	spin_unlock(&ailp->xa_lock);
	xfs_log_move_tail(ailp->xa_mount, tail_lsn);
}

525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597
/*
 * xfs_trans_ail_delete_bulk - remove multiple log items from the AIL
 *
 * @xfs_trans_ail_delete_bulk takes an array of log items that all need to
 * removed from the AIL. The caller is already holding the AIL lock, and done
 * all the checks necessary to ensure the items passed in via @log_items are
 * ready for deletion. This includes checking that the items are in the AIL.
 *
 * For each log item to be removed, unlink it  from the AIL, clear the IN_AIL
 * flag from the item and reset the item's lsn to 0. If we remove the first
 * item in the AIL, update the log tail to match the new minimum LSN in the
 * AIL.
 *
 * This function will not drop the AIL lock until all items are removed from
 * the AIL to minimise the amount of lock traffic on the AIL. This does not
 * greatly increase the AIL hold time, but does significantly reduce the amount
 * of traffic on the lock, especially during IO completion.
 *
 * This function must be called with the AIL lock held.  The lock is dropped
 * before returning.
 */
void
xfs_trans_ail_delete_bulk(
	struct xfs_ail		*ailp,
	struct xfs_log_item	**log_items,
	int			nr_items) __releases(ailp->xa_lock)
{
	xfs_log_item_t		*mlip;
	xfs_lsn_t		tail_lsn;
	int			mlip_changed = 0;
	int			i;

	mlip = xfs_ail_min(ailp);

	for (i = 0; i < nr_items; i++) {
		struct xfs_log_item *lip = log_items[i];
		if (!(lip->li_flags & XFS_LI_IN_AIL)) {
			struct xfs_mount	*mp = ailp->xa_mount;

			spin_unlock(&ailp->xa_lock);
			if (!XFS_FORCED_SHUTDOWN(mp)) {
				xfs_cmn_err(XFS_PTAG_AILDELETE, CE_ALERT, mp,
		"%s: attempting to delete a log item that is not in the AIL",
						__func__);
				xfs_force_shutdown(mp, SHUTDOWN_CORRUPT_INCORE);
			}
			return;
		}

		xfs_ail_delete(ailp, lip);
		lip->li_flags &= ~XFS_LI_IN_AIL;
		lip->li_lsn = 0;
		if (mlip == lip)
			mlip_changed = 1;
	}

	if (!mlip_changed) {
		spin_unlock(&ailp->xa_lock);
		return;
	}

	/*
	 * It is not safe to access mlip after the AIL lock is dropped, so we
	 * must get a copy of li_lsn before we do so.  This is especially
	 * important on 32-bit platforms where accessing and updating 64-bit
	 * values like li_lsn is not atomic. It is possible we've emptied the
	 * AIL here, so if that is the case, pass an LSN of 0 to the tail move.
	 */
	mlip = xfs_ail_min(ailp);
	tail_lsn = mlip ? mlip->li_lsn : 0;
	spin_unlock(&ailp->xa_lock);
	xfs_log_move_tail(ailp->xa_mount, tail_lsn);
}
L
Linus Torvalds 已提交
598 599 600 601 602 603 604 605 606 607 608 609 610 611 612

/*
 * The active item list (AIL) is a doubly linked list of log
 * items sorted by ascending lsn.  The base of the list is
 * a forw/back pointer pair embedded in the xfs mount structure.
 * The base is initialized with both pointers pointing to the
 * base.  This case always needs to be distinguished, because
 * the base has no lsn to look at.  We almost always insert
 * at the end of the list, so on inserts we search from the
 * end of the list to find where the new item belongs.
 */

/*
 * Initialize the doubly linked list to point only to itself.
 */
613
int
L
Linus Torvalds 已提交
614 615 616
xfs_trans_ail_init(
	xfs_mount_t	*mp)
{
D
David Chinner 已提交
617
	struct xfs_ail	*ailp;
618
	int		error;
D
David Chinner 已提交
619 620 621 622 623 624 625

	ailp = kmem_zalloc(sizeof(struct xfs_ail), KM_MAYFAIL);
	if (!ailp)
		return ENOMEM;

	ailp->xa_mount = mp;
	INIT_LIST_HEAD(&ailp->xa_ail);
626
	spin_lock_init(&ailp->xa_lock);
627 628 629 630 631 632 633 634 635
	error = xfsaild_start(ailp);
	if (error)
		goto out_free_ailp;
	mp->m_ail = ailp;
	return 0;

out_free_ailp:
	kmem_free(ailp);
	return error;
636 637 638 639 640 641
}

void
xfs_trans_ail_destroy(
	xfs_mount_t	*mp)
{
D
David Chinner 已提交
642 643 644 645
	struct xfs_ail	*ailp = mp->m_ail;

	xfsaild_stop(ailp);
	kmem_free(ailp);
L
Linus Torvalds 已提交
646 647
}

648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678
/*
 * splice the log item list into the AIL at the given LSN.
 */
STATIC void
xfs_ail_splice(
	struct xfs_ail	*ailp,
	struct list_head *list,
	xfs_lsn_t	lsn)
{
	xfs_log_item_t	*next_lip;

	/*
	 * If the list is empty, just insert the item.
	 */
	if (list_empty(&ailp->xa_ail)) {
		list_splice(list, &ailp->xa_ail);
		return;
	}

	list_for_each_entry_reverse(next_lip, &ailp->xa_ail, li_ail) {
		if (XFS_LSN_CMP(next_lip->li_lsn, lsn) <= 0)
			break;
	}

	ASSERT((&next_lip->li_ail == &ailp->xa_ail) ||
	       (XFS_LSN_CMP(next_lip->li_lsn, lsn) <= 0));

	list_splice_init(list, &next_lip->li_ail);
	return;
}

L
Linus Torvalds 已提交
679 680 681
/*
 * Delete the given item from the AIL.  Return a pointer to the item.
 */
D
Dave Chinner 已提交
682
STATIC void
L
Linus Torvalds 已提交
683
xfs_ail_delete(
D
David Chinner 已提交
684
	struct xfs_ail	*ailp,
L
Linus Torvalds 已提交
685 686
	xfs_log_item_t	*lip)
{
687 688
	xfs_ail_check(ailp, lip);
	list_del(&lip->li_ail);
D
Dave Chinner 已提交
689
	xfs_trans_ail_cursor_clear(ailp, lip);
L
Linus Torvalds 已提交
690 691 692 693 694 695 696 697
}

/*
 * Return a pointer to the first item in the AIL.
 * If the AIL is empty, then return NULL.
 */
STATIC xfs_log_item_t *
xfs_ail_min(
D
David Chinner 已提交
698
	struct xfs_ail	*ailp)
L
Linus Torvalds 已提交
699
{
700
	if (list_empty(&ailp->xa_ail))
L
Linus Torvalds 已提交
701
		return NULL;
702 703

	return list_first_entry(&ailp->xa_ail, xfs_log_item_t, li_ail);
L
Linus Torvalds 已提交
704 705 706 707 708 709 710 711 712
}

/*
 * Return a pointer to the item which follows
 * the given item in the AIL.  If the given item
 * is the last item in the list, then return NULL.
 */
STATIC xfs_log_item_t *
xfs_ail_next(
D
David Chinner 已提交
713
	struct xfs_ail	*ailp,
L
Linus Torvalds 已提交
714 715
	xfs_log_item_t	*lip)
{
716
	if (lip->li_ail.next == &ailp->xa_ail)
L
Linus Torvalds 已提交
717 718
		return NULL;

719
	return list_first_entry(&lip->li_ail, xfs_log_item_t, li_ail);
L
Linus Torvalds 已提交
720 721 722 723 724 725 726 727
}

#ifdef DEBUG
/*
 * Check that the list is sorted as it should be.
 */
STATIC void
xfs_ail_check(
D
David Chinner 已提交
728
	struct xfs_ail	*ailp,
729
	xfs_log_item_t	*lip)
L
Linus Torvalds 已提交
730 731 732
{
	xfs_log_item_t	*prev_lip;

733
	if (list_empty(&ailp->xa_ail))
L
Linus Torvalds 已提交
734 735
		return;

736 737 738 739
	/*
	 * Check the next and previous entries are valid.
	 */
	ASSERT((lip->li_flags & XFS_LI_IN_AIL) != 0);
740 741
	prev_lip = list_entry(lip->li_ail.prev, xfs_log_item_t, li_ail);
	if (&prev_lip->li_ail != &ailp->xa_ail)
742
		ASSERT(XFS_LSN_CMP(prev_lip->li_lsn, lip->li_lsn) <= 0);
743 744 745

	prev_lip = list_entry(lip->li_ail.next, xfs_log_item_t, li_ail);
	if (&prev_lip->li_ail != &ailp->xa_ail)
746 747 748 749
		ASSERT(XFS_LSN_CMP(prev_lip->li_lsn, lip->li_lsn) >= 0);


#ifdef XFS_TRANS_DEBUG
L
Linus Torvalds 已提交
750
	/*
751 752 753
	 * Walk the list checking lsn ordering, and that every entry has the
	 * XFS_LI_IN_AIL flag set. This is really expensive, so only do it
	 * when specifically debugging the transaction subsystem.
L
Linus Torvalds 已提交
754
	 */
755 756 757
	prev_lip = list_entry(&ailp->xa_ail, xfs_log_item_t, li_ail);
	list_for_each_entry(lip, &ailp->xa_ail, li_ail) {
		if (&prev_lip->li_ail != &ailp->xa_ail)
L
Linus Torvalds 已提交
758 759 760 761
			ASSERT(XFS_LSN_CMP(prev_lip->li_lsn, lip->li_lsn) <= 0);
		ASSERT((lip->li_flags & XFS_LI_IN_AIL) != 0);
		prev_lip = lip;
	}
762
#endif /* XFS_TRANS_DEBUG */
L
Linus Torvalds 已提交
763 764
}
#endif /* DEBUG */