xfs_trans_ail.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777
  1. /*
  2. * Copyright (c) 2000-2002,2005 Silicon Graphics, Inc.
  3. * Copyright (c) 2008 Dave Chinner
  4. * All Rights Reserved.
  5. *
  6. * This program is free software; you can redistribute it and/or
  7. * modify it under the terms of the GNU General Public License as
  8. * published by the Free Software Foundation.
  9. *
  10. * This program is distributed in the hope that it would be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program; if not, write the Free Software Foundation,
  17. * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  18. */
  19. #include "xfs.h"
  20. #include "xfs_fs.h"
  21. #include "xfs_types.h"
  22. #include "xfs_log.h"
  23. #include "xfs_inum.h"
  24. #include "xfs_trans.h"
  25. #include "xfs_sb.h"
  26. #include "xfs_ag.h"
  27. #include "xfs_mount.h"
  28. #include "xfs_trans_priv.h"
  29. #include "xfs_error.h"
  30. struct workqueue_struct *xfs_ail_wq; /* AIL workqueue */
  31. STATIC void xfs_ail_splice(struct xfs_ail *, struct list_head *, xfs_lsn_t);
  32. STATIC void xfs_ail_delete(struct xfs_ail *, xfs_log_item_t *);
  33. STATIC xfs_log_item_t * xfs_ail_min(struct xfs_ail *);
  34. STATIC xfs_log_item_t * xfs_ail_next(struct xfs_ail *, xfs_log_item_t *);
  35. #ifdef DEBUG
  36. STATIC void xfs_ail_check(struct xfs_ail *, xfs_log_item_t *);
  37. #else
  38. #define xfs_ail_check(a,l)
  39. #endif /* DEBUG */
  40. /*
  41. * This is called by the log manager code to determine the LSN
  42. * of the tail of the log. This is exactly the LSN of the first
  43. * item in the AIL. If the AIL is empty, then this function
  44. * returns 0.
  45. *
  46. * We need the AIL lock in order to get a coherent read of the
  47. * lsn of the last item in the AIL.
  48. */
  49. xfs_lsn_t
  50. xfs_trans_ail_tail(
  51. struct xfs_ail *ailp)
  52. {
  53. xfs_lsn_t lsn;
  54. xfs_log_item_t *lip;
  55. spin_lock(&ailp->xa_lock);
  56. lip = xfs_ail_min(ailp);
  57. if (lip == NULL) {
  58. lsn = (xfs_lsn_t)0;
  59. } else {
  60. lsn = lip->li_lsn;
  61. }
  62. spin_unlock(&ailp->xa_lock);
  63. return lsn;
  64. }
  65. /*
  66. * AIL traversal cursor initialisation.
  67. *
  68. * The cursor keeps track of where our current traversal is up
  69. * to by tracking the next ƣtem in the list for us. However, for
  70. * this to be safe, removing an object from the AIL needs to invalidate
  71. * any cursor that points to it. hence the traversal cursor needs to
  72. * be linked to the struct xfs_ail so that deletion can search all the
  73. * active cursors for invalidation.
  74. *
  75. * We don't link the push cursor because it is embedded in the struct
  76. * xfs_ail and hence easily findable.
  77. */
  78. STATIC void
  79. xfs_trans_ail_cursor_init(
  80. struct xfs_ail *ailp,
  81. struct xfs_ail_cursor *cur)
  82. {
  83. cur->item = NULL;
  84. if (cur == &ailp->xa_cursors)
  85. return;
  86. cur->next = ailp->xa_cursors.next;
  87. ailp->xa_cursors.next = cur;
  88. }
  89. /*
  90. * Set the cursor to the next item, because when we look
  91. * up the cursor the current item may have been freed.
  92. */
  93. STATIC void
  94. xfs_trans_ail_cursor_set(
  95. struct xfs_ail *ailp,
  96. struct xfs_ail_cursor *cur,
  97. struct xfs_log_item *lip)
  98. {
  99. if (lip)
  100. cur->item = xfs_ail_next(ailp, lip);
  101. }
  102. /*
  103. * Get the next item in the traversal and advance the cursor.
  104. * If the cursor was invalidated (inidicated by a lip of 1),
  105. * restart the traversal.
  106. */
  107. struct xfs_log_item *
  108. xfs_trans_ail_cursor_next(
  109. struct xfs_ail *ailp,
  110. struct xfs_ail_cursor *cur)
  111. {
  112. struct xfs_log_item *lip = cur->item;
  113. if ((__psint_t)lip & 1)
  114. lip = xfs_ail_min(ailp);
  115. xfs_trans_ail_cursor_set(ailp, cur, lip);
  116. return lip;
  117. }
  118. /*
  119. * Now that the traversal is complete, we need to remove the cursor
  120. * from the list of traversing cursors. Avoid removing the embedded
  121. * push cursor, but use the fact it is always present to make the
  122. * list deletion simple.
  123. */
  124. void
  125. xfs_trans_ail_cursor_done(
  126. struct xfs_ail *ailp,
  127. struct xfs_ail_cursor *done)
  128. {
  129. struct xfs_ail_cursor *prev = NULL;
  130. struct xfs_ail_cursor *cur;
  131. done->item = NULL;
  132. if (done == &ailp->xa_cursors)
  133. return;
  134. prev = &ailp->xa_cursors;
  135. for (cur = prev->next; cur; prev = cur, cur = prev->next) {
  136. if (cur == done) {
  137. prev->next = cur->next;
  138. break;
  139. }
  140. }
  141. ASSERT(cur);
  142. }
  143. /*
  144. * Invalidate any cursor that is pointing to this item. This is
  145. * called when an item is removed from the AIL. Any cursor pointing
  146. * to this object is now invalid and the traversal needs to be
  147. * terminated so it doesn't reference a freed object. We set the
  148. * cursor item to a value of 1 so we can distinguish between an
  149. * invalidation and the end of the list when getting the next item
  150. * from the cursor.
  151. */
  152. STATIC void
  153. xfs_trans_ail_cursor_clear(
  154. struct xfs_ail *ailp,
  155. struct xfs_log_item *lip)
  156. {
  157. struct xfs_ail_cursor *cur;
  158. /* need to search all cursors */
  159. for (cur = &ailp->xa_cursors; cur; cur = cur->next) {
  160. if (cur->item == lip)
  161. cur->item = (struct xfs_log_item *)
  162. ((__psint_t)cur->item | 1);
  163. }
  164. }
  165. /*
  166. * Return the item in the AIL with the current lsn.
  167. * Return the current tree generation number for use
  168. * in calls to xfs_trans_next_ail().
  169. */
  170. xfs_log_item_t *
  171. xfs_trans_ail_cursor_first(
  172. struct xfs_ail *ailp,
  173. struct xfs_ail_cursor *cur,
  174. xfs_lsn_t lsn)
  175. {
  176. xfs_log_item_t *lip;
  177. xfs_trans_ail_cursor_init(ailp, cur);
  178. lip = xfs_ail_min(ailp);
  179. if (lsn == 0)
  180. goto out;
  181. list_for_each_entry(lip, &ailp->xa_ail, li_ail) {
  182. if (XFS_LSN_CMP(lip->li_lsn, lsn) >= 0)
  183. goto out;
  184. }
  185. lip = NULL;
  186. out:
  187. xfs_trans_ail_cursor_set(ailp, cur, lip);
  188. return lip;
  189. }
  190. /*
  191. * xfs_ail_worker does the work of pushing on the AIL. It will requeue itself
  192. * to run at a later time if there is more work to do to complete the push.
  193. */
  194. STATIC void
  195. xfs_ail_worker(
  196. struct work_struct *work)
  197. {
  198. struct xfs_ail *ailp = container_of(to_delayed_work(work),
  199. struct xfs_ail, xa_work);
  200. long tout;
  201. xfs_lsn_t target = ailp->xa_target;
  202. xfs_lsn_t lsn;
  203. xfs_log_item_t *lip;
  204. int flush_log, count, stuck;
  205. xfs_mount_t *mp = ailp->xa_mount;
  206. struct xfs_ail_cursor *cur = &ailp->xa_cursors;
  207. int push_xfsbufd = 0;
  208. spin_lock(&ailp->xa_lock);
  209. xfs_trans_ail_cursor_init(ailp, cur);
  210. lip = xfs_trans_ail_cursor_first(ailp, cur, ailp->xa_last_pushed_lsn);
  211. if (!lip || XFS_FORCED_SHUTDOWN(mp)) {
  212. /*
  213. * AIL is empty or our push has reached the end.
  214. */
  215. xfs_trans_ail_cursor_done(ailp, cur);
  216. spin_unlock(&ailp->xa_lock);
  217. ailp->xa_last_pushed_lsn = 0;
  218. return;
  219. }
  220. XFS_STATS_INC(xs_push_ail);
  221. /*
  222. * While the item we are looking at is below the given threshold
  223. * try to flush it out. We'd like not to stop until we've at least
  224. * tried to push on everything in the AIL with an LSN less than
  225. * the given threshold.
  226. *
  227. * However, we will stop after a certain number of pushes and wait
  228. * for a reduced timeout to fire before pushing further. This
  229. * prevents use from spinning when we can't do anything or there is
  230. * lots of contention on the AIL lists.
  231. */
  232. lsn = lip->li_lsn;
  233. flush_log = stuck = count = 0;
  234. while ((XFS_LSN_CMP(lip->li_lsn, target) < 0)) {
  235. int lock_result;
  236. /*
  237. * If we can lock the item without sleeping, unlock the AIL
  238. * lock and flush the item. Then re-grab the AIL lock so we
  239. * can look for the next item on the AIL. List changes are
  240. * handled by the AIL lookup functions internally
  241. *
  242. * If we can't lock the item, either its holder will flush it
  243. * or it is already being flushed or it is being relogged. In
  244. * any of these case it is being taken care of and we can just
  245. * skip to the next item in the list.
  246. */
  247. lock_result = IOP_TRYLOCK(lip);
  248. spin_unlock(&ailp->xa_lock);
  249. switch (lock_result) {
  250. case XFS_ITEM_SUCCESS:
  251. XFS_STATS_INC(xs_push_ail_success);
  252. IOP_PUSH(lip);
  253. ailp->xa_last_pushed_lsn = lsn;
  254. break;
  255. case XFS_ITEM_PUSHBUF:
  256. XFS_STATS_INC(xs_push_ail_pushbuf);
  257. IOP_PUSHBUF(lip);
  258. ailp->xa_last_pushed_lsn = lsn;
  259. push_xfsbufd = 1;
  260. break;
  261. case XFS_ITEM_PINNED:
  262. XFS_STATS_INC(xs_push_ail_pinned);
  263. stuck++;
  264. flush_log = 1;
  265. break;
  266. case XFS_ITEM_LOCKED:
  267. XFS_STATS_INC(xs_push_ail_locked);
  268. ailp->xa_last_pushed_lsn = lsn;
  269. stuck++;
  270. break;
  271. default:
  272. ASSERT(0);
  273. break;
  274. }
  275. spin_lock(&ailp->xa_lock);
  276. /* should we bother continuing? */
  277. if (XFS_FORCED_SHUTDOWN(mp))
  278. break;
  279. ASSERT(mp->m_log);
  280. count++;
  281. /*
  282. * Are there too many items we can't do anything with?
  283. * If we we are skipping too many items because we can't flush
  284. * them or they are already being flushed, we back off and
  285. * given them time to complete whatever operation is being
  286. * done. i.e. remove pressure from the AIL while we can't make
  287. * progress so traversals don't slow down further inserts and
  288. * removals to/from the AIL.
  289. *
  290. * The value of 100 is an arbitrary magic number based on
  291. * observation.
  292. */
  293. if (stuck > 100)
  294. break;
  295. lip = xfs_trans_ail_cursor_next(ailp, cur);
  296. if (lip == NULL)
  297. break;
  298. lsn = lip->li_lsn;
  299. }
  300. xfs_trans_ail_cursor_done(ailp, cur);
  301. spin_unlock(&ailp->xa_lock);
  302. if (flush_log) {
  303. /*
  304. * If something we need to push out was pinned, then
  305. * push out the log so it will become unpinned and
  306. * move forward in the AIL.
  307. */
  308. XFS_STATS_INC(xs_push_ail_flush);
  309. xfs_log_force(mp, 0);
  310. }
  311. if (push_xfsbufd) {
  312. /* we've got delayed write buffers to flush */
  313. wake_up_process(mp->m_ddev_targp->bt_task);
  314. }
  315. /* assume we have more work to do in a short while */
  316. tout = 10;
  317. if (!count) {
  318. /* We're past our target or empty, so idle */
  319. ailp->xa_last_pushed_lsn = 0;
  320. /*
  321. * Check for an updated push target before clearing the
  322. * XFS_AIL_PUSHING_BIT. If the target changed, we've got more
  323. * work to do. Wait a bit longer before starting that work.
  324. */
  325. smp_rmb();
  326. if (ailp->xa_target == target) {
  327. clear_bit(XFS_AIL_PUSHING_BIT, &ailp->xa_flags);
  328. return;
  329. }
  330. tout = 50;
  331. } else if (XFS_LSN_CMP(lsn, target) >= 0) {
  332. /*
  333. * We reached the target so wait a bit longer for I/O to
  334. * complete and remove pushed items from the AIL before we
  335. * start the next scan from the start of the AIL.
  336. */
  337. tout = 50;
  338. ailp->xa_last_pushed_lsn = 0;
  339. } else if ((stuck * 100) / count > 90) {
  340. /*
  341. * Either there is a lot of contention on the AIL or we
  342. * are stuck due to operations in progress. "Stuck" in this
  343. * case is defined as >90% of the items we tried to push
  344. * were stuck.
  345. *
  346. * Backoff a bit more to allow some I/O to complete before
  347. * continuing from where we were.
  348. */
  349. tout = 20;
  350. }
  351. /* There is more to do, requeue us. */
  352. queue_delayed_work(xfs_syncd_wq, &ailp->xa_work,
  353. msecs_to_jiffies(tout));
  354. }
  355. /*
  356. * This routine is called to move the tail of the AIL forward. It does this by
  357. * trying to flush items in the AIL whose lsns are below the given
  358. * threshold_lsn.
  359. *
  360. * The push is run asynchronously in a workqueue, which means the caller needs
  361. * to handle waiting on the async flush for space to become available.
  362. * We don't want to interrupt any push that is in progress, hence we only queue
  363. * work if we set the pushing bit approriately.
  364. *
  365. * We do this unlocked - we only need to know whether there is anything in the
  366. * AIL at the time we are called. We don't need to access the contents of
  367. * any of the objects, so the lock is not needed.
  368. */
  369. void
  370. xfs_trans_ail_push(
  371. struct xfs_ail *ailp,
  372. xfs_lsn_t threshold_lsn)
  373. {
  374. xfs_log_item_t *lip;
  375. lip = xfs_ail_min(ailp);
  376. if (!lip || XFS_FORCED_SHUTDOWN(ailp->xa_mount) ||
  377. XFS_LSN_CMP(threshold_lsn, ailp->xa_target) <= 0)
  378. return;
  379. /*
  380. * Ensure that the new target is noticed in push code before it clears
  381. * the XFS_AIL_PUSHING_BIT.
  382. */
  383. smp_wmb();
  384. ailp->xa_target = threshold_lsn;
  385. if (!test_and_set_bit(XFS_AIL_PUSHING_BIT, &ailp->xa_flags))
  386. queue_delayed_work(xfs_syncd_wq, &ailp->xa_work, 0);
  387. }
  388. /*
  389. * This is to be called when an item is unlocked that may have
  390. * been in the AIL. It will wake up the first member of the AIL
  391. * wait list if this item's unlocking might allow it to progress.
  392. * If the item is in the AIL, then we need to get the AIL lock
  393. * while doing our checking so we don't race with someone going
  394. * to sleep waiting for this event in xfs_trans_push_ail().
  395. */
  396. void
  397. xfs_trans_unlocked_item(
  398. struct xfs_ail *ailp,
  399. xfs_log_item_t *lip)
  400. {
  401. xfs_log_item_t *min_lip;
  402. /*
  403. * If we're forcibly shutting down, we may have
  404. * unlocked log items arbitrarily. The last thing
  405. * we want to do is to move the tail of the log
  406. * over some potentially valid data.
  407. */
  408. if (!(lip->li_flags & XFS_LI_IN_AIL) ||
  409. XFS_FORCED_SHUTDOWN(ailp->xa_mount)) {
  410. return;
  411. }
  412. /*
  413. * This is the one case where we can call into xfs_ail_min()
  414. * without holding the AIL lock because we only care about the
  415. * case where we are at the tail of the AIL. If the object isn't
  416. * at the tail, it doesn't matter what result we get back. This
  417. * is slightly racy because since we were just unlocked, we could
  418. * go to sleep between the call to xfs_ail_min and the call to
  419. * xfs_log_move_tail, have someone else lock us, commit to us disk,
  420. * move us out of the tail of the AIL, and then we wake up. However,
  421. * the call to xfs_log_move_tail() doesn't do anything if there's
  422. * not enough free space to wake people up so we're safe calling it.
  423. */
  424. min_lip = xfs_ail_min(ailp);
  425. if (min_lip == lip)
  426. xfs_log_move_tail(ailp->xa_mount, 1);
  427. } /* xfs_trans_unlocked_item */
  428. /*
  429. * xfs_trans_ail_update - bulk AIL insertion operation.
  430. *
  431. * @xfs_trans_ail_update takes an array of log items that all need to be
  432. * positioned at the same LSN in the AIL. If an item is not in the AIL, it will
  433. * be added. Otherwise, it will be repositioned by removing it and re-adding
  434. * it to the AIL. If we move the first item in the AIL, update the log tail to
  435. * match the new minimum LSN in the AIL.
  436. *
  437. * This function takes the AIL lock once to execute the update operations on
  438. * all the items in the array, and as such should not be called with the AIL
  439. * lock held. As a result, once we have the AIL lock, we need to check each log
  440. * item LSN to confirm it needs to be moved forward in the AIL.
  441. *
  442. * To optimise the insert operation, we delete all the items from the AIL in
  443. * the first pass, moving them into a temporary list, then splice the temporary
  444. * list into the correct position in the AIL. This avoids needing to do an
  445. * insert operation on every item.
  446. *
  447. * This function must be called with the AIL lock held. The lock is dropped
  448. * before returning.
  449. */
  450. void
  451. xfs_trans_ail_update_bulk(
  452. struct xfs_ail *ailp,
  453. struct xfs_log_item **log_items,
  454. int nr_items,
  455. xfs_lsn_t lsn) __releases(ailp->xa_lock)
  456. {
  457. xfs_log_item_t *mlip;
  458. xfs_lsn_t tail_lsn;
  459. int mlip_changed = 0;
  460. int i;
  461. LIST_HEAD(tmp);
  462. mlip = xfs_ail_min(ailp);
  463. for (i = 0; i < nr_items; i++) {
  464. struct xfs_log_item *lip = log_items[i];
  465. if (lip->li_flags & XFS_LI_IN_AIL) {
  466. /* check if we really need to move the item */
  467. if (XFS_LSN_CMP(lsn, lip->li_lsn) <= 0)
  468. continue;
  469. xfs_ail_delete(ailp, lip);
  470. if (mlip == lip)
  471. mlip_changed = 1;
  472. } else {
  473. lip->li_flags |= XFS_LI_IN_AIL;
  474. }
  475. lip->li_lsn = lsn;
  476. list_add(&lip->li_ail, &tmp);
  477. }
  478. xfs_ail_splice(ailp, &tmp, lsn);
  479. if (!mlip_changed) {
  480. spin_unlock(&ailp->xa_lock);
  481. return;
  482. }
  483. /*
  484. * It is not safe to access mlip after the AIL lock is dropped, so we
  485. * must get a copy of li_lsn before we do so. This is especially
  486. * important on 32-bit platforms where accessing and updating 64-bit
  487. * values like li_lsn is not atomic.
  488. */
  489. mlip = xfs_ail_min(ailp);
  490. tail_lsn = mlip->li_lsn;
  491. spin_unlock(&ailp->xa_lock);
  492. xfs_log_move_tail(ailp->xa_mount, tail_lsn);
  493. }
  494. /*
  495. * xfs_trans_ail_delete_bulk - remove multiple log items from the AIL
  496. *
  497. * @xfs_trans_ail_delete_bulk takes an array of log items that all need to
  498. * removed from the AIL. The caller is already holding the AIL lock, and done
  499. * all the checks necessary to ensure the items passed in via @log_items are
  500. * ready for deletion. This includes checking that the items are in the AIL.
  501. *
  502. * For each log item to be removed, unlink it from the AIL, clear the IN_AIL
  503. * flag from the item and reset the item's lsn to 0. If we remove the first
  504. * item in the AIL, update the log tail to match the new minimum LSN in the
  505. * AIL.
  506. *
  507. * This function will not drop the AIL lock until all items are removed from
  508. * the AIL to minimise the amount of lock traffic on the AIL. This does not
  509. * greatly increase the AIL hold time, but does significantly reduce the amount
  510. * of traffic on the lock, especially during IO completion.
  511. *
  512. * This function must be called with the AIL lock held. The lock is dropped
  513. * before returning.
  514. */
  515. void
  516. xfs_trans_ail_delete_bulk(
  517. struct xfs_ail *ailp,
  518. struct xfs_log_item **log_items,
  519. int nr_items) __releases(ailp->xa_lock)
  520. {
  521. xfs_log_item_t *mlip;
  522. xfs_lsn_t tail_lsn;
  523. int mlip_changed = 0;
  524. int i;
  525. mlip = xfs_ail_min(ailp);
  526. for (i = 0; i < nr_items; i++) {
  527. struct xfs_log_item *lip = log_items[i];
  528. if (!(lip->li_flags & XFS_LI_IN_AIL)) {
  529. struct xfs_mount *mp = ailp->xa_mount;
  530. spin_unlock(&ailp->xa_lock);
  531. if (!XFS_FORCED_SHUTDOWN(mp)) {
  532. xfs_alert_tag(mp, XFS_PTAG_AILDELETE,
  533. "%s: attempting to delete a log item that is not in the AIL",
  534. __func__);
  535. xfs_force_shutdown(mp, SHUTDOWN_CORRUPT_INCORE);
  536. }
  537. return;
  538. }
  539. xfs_ail_delete(ailp, lip);
  540. lip->li_flags &= ~XFS_LI_IN_AIL;
  541. lip->li_lsn = 0;
  542. if (mlip == lip)
  543. mlip_changed = 1;
  544. }
  545. if (!mlip_changed) {
  546. spin_unlock(&ailp->xa_lock);
  547. return;
  548. }
  549. /*
  550. * It is not safe to access mlip after the AIL lock is dropped, so we
  551. * must get a copy of li_lsn before we do so. This is especially
  552. * important on 32-bit platforms where accessing and updating 64-bit
  553. * values like li_lsn is not atomic. It is possible we've emptied the
  554. * AIL here, so if that is the case, pass an LSN of 0 to the tail move.
  555. */
  556. mlip = xfs_ail_min(ailp);
  557. tail_lsn = mlip ? mlip->li_lsn : 0;
  558. spin_unlock(&ailp->xa_lock);
  559. xfs_log_move_tail(ailp->xa_mount, tail_lsn);
  560. }
  561. /*
  562. * The active item list (AIL) is a doubly linked list of log
  563. * items sorted by ascending lsn. The base of the list is
  564. * a forw/back pointer pair embedded in the xfs mount structure.
  565. * The base is initialized with both pointers pointing to the
  566. * base. This case always needs to be distinguished, because
  567. * the base has no lsn to look at. We almost always insert
  568. * at the end of the list, so on inserts we search from the
  569. * end of the list to find where the new item belongs.
  570. */
  571. /*
  572. * Initialize the doubly linked list to point only to itself.
  573. */
  574. int
  575. xfs_trans_ail_init(
  576. xfs_mount_t *mp)
  577. {
  578. struct xfs_ail *ailp;
  579. ailp = kmem_zalloc(sizeof(struct xfs_ail), KM_MAYFAIL);
  580. if (!ailp)
  581. return ENOMEM;
  582. ailp->xa_mount = mp;
  583. INIT_LIST_HEAD(&ailp->xa_ail);
  584. spin_lock_init(&ailp->xa_lock);
  585. INIT_DELAYED_WORK(&ailp->xa_work, xfs_ail_worker);
  586. mp->m_ail = ailp;
  587. return 0;
  588. }
  589. void
  590. xfs_trans_ail_destroy(
  591. xfs_mount_t *mp)
  592. {
  593. struct xfs_ail *ailp = mp->m_ail;
  594. cancel_delayed_work_sync(&ailp->xa_work);
  595. kmem_free(ailp);
  596. }
  597. /*
  598. * splice the log item list into the AIL at the given LSN.
  599. */
  600. STATIC void
  601. xfs_ail_splice(
  602. struct xfs_ail *ailp,
  603. struct list_head *list,
  604. xfs_lsn_t lsn)
  605. {
  606. xfs_log_item_t *next_lip;
  607. /*
  608. * If the list is empty, just insert the item.
  609. */
  610. if (list_empty(&ailp->xa_ail)) {
  611. list_splice(list, &ailp->xa_ail);
  612. return;
  613. }
  614. list_for_each_entry_reverse(next_lip, &ailp->xa_ail, li_ail) {
  615. if (XFS_LSN_CMP(next_lip->li_lsn, lsn) <= 0)
  616. break;
  617. }
  618. ASSERT((&next_lip->li_ail == &ailp->xa_ail) ||
  619. (XFS_LSN_CMP(next_lip->li_lsn, lsn) <= 0));
  620. list_splice_init(list, &next_lip->li_ail);
  621. return;
  622. }
  623. /*
  624. * Delete the given item from the AIL. Return a pointer to the item.
  625. */
  626. STATIC void
  627. xfs_ail_delete(
  628. struct xfs_ail *ailp,
  629. xfs_log_item_t *lip)
  630. {
  631. xfs_ail_check(ailp, lip);
  632. list_del(&lip->li_ail);
  633. xfs_trans_ail_cursor_clear(ailp, lip);
  634. }
  635. /*
  636. * Return a pointer to the first item in the AIL.
  637. * If the AIL is empty, then return NULL.
  638. */
  639. STATIC xfs_log_item_t *
  640. xfs_ail_min(
  641. struct xfs_ail *ailp)
  642. {
  643. if (list_empty(&ailp->xa_ail))
  644. return NULL;
  645. return list_first_entry(&ailp->xa_ail, xfs_log_item_t, li_ail);
  646. }
  647. /*
  648. * Return a pointer to the item which follows
  649. * the given item in the AIL. If the given item
  650. * is the last item in the list, then return NULL.
  651. */
  652. STATIC xfs_log_item_t *
  653. xfs_ail_next(
  654. struct xfs_ail *ailp,
  655. xfs_log_item_t *lip)
  656. {
  657. if (lip->li_ail.next == &ailp->xa_ail)
  658. return NULL;
  659. return list_first_entry(&lip->li_ail, xfs_log_item_t, li_ail);
  660. }
  661. #ifdef DEBUG
  662. /*
  663. * Check that the list is sorted as it should be.
  664. */
  665. STATIC void
  666. xfs_ail_check(
  667. struct xfs_ail *ailp,
  668. xfs_log_item_t *lip)
  669. {
  670. xfs_log_item_t *prev_lip;
  671. if (list_empty(&ailp->xa_ail))
  672. return;
  673. /*
  674. * Check the next and previous entries are valid.
  675. */
  676. ASSERT((lip->li_flags & XFS_LI_IN_AIL) != 0);
  677. prev_lip = list_entry(lip->li_ail.prev, xfs_log_item_t, li_ail);
  678. if (&prev_lip->li_ail != &ailp->xa_ail)
  679. ASSERT(XFS_LSN_CMP(prev_lip->li_lsn, lip->li_lsn) <= 0);
  680. prev_lip = list_entry(lip->li_ail.next, xfs_log_item_t, li_ail);
  681. if (&prev_lip->li_ail != &ailp->xa_ail)
  682. ASSERT(XFS_LSN_CMP(prev_lip->li_lsn, lip->li_lsn) >= 0);
  683. #ifdef XFS_TRANS_DEBUG
  684. /*
  685. * Walk the list checking lsn ordering, and that every entry has the
  686. * XFS_LI_IN_AIL flag set. This is really expensive, so only do it
  687. * when specifically debugging the transaction subsystem.
  688. */
  689. prev_lip = list_entry(&ailp->xa_ail, xfs_log_item_t, li_ail);
  690. list_for_each_entry(lip, &ailp->xa_ail, li_ail) {
  691. if (&prev_lip->li_ail != &ailp->xa_ail)
  692. ASSERT(XFS_LSN_CMP(prev_lip->li_lsn, lip->li_lsn) <= 0);
  693. ASSERT((lip->li_flags & XFS_LI_IN_AIL) != 0);
  694. prev_lip = lip;
  695. }
  696. #endif /* XFS_TRANS_DEBUG */
  697. }
  698. #endif /* DEBUG */