commit.c
上传用户:jlfgdled
上传日期:2013-04-10
资源大小:33168k
文件大小:22k
源码类别:

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*
  2.  * linux/fs/commit.c
  3.  *
  4.  * Written by Stephen C. Tweedie <sct@redhat.com>, 1998
  5.  *
  6.  * Copyright 1998 Red Hat corp --- All Rights Reserved
  7.  *
  8.  * This file is part of the Linux kernel and is made available under
  9.  * the terms of the GNU General Public License, version 2, or at your
  10.  * option, any later version, incorporated herein by reference.
  11.  *
  12.  * Journal commit routines for the generic filesystem journaling code;
  13.  * part of the ext2fs journaling system.
  14.  */
  15. #include <linux/sched.h>
  16. #include <linux/fs.h>
  17. #include <linux/jbd.h>
  18. #include <linux/errno.h>
  19. #include <linux/slab.h>
  20. #include <linux/locks.h>
  21. #include <linux/smp_lock.h>
  22. extern spinlock_t journal_datalist_lock;
  23. /*
  24.  * Default IO end handler for temporary BJ_IO buffer_heads.
  25.  */
  26. void journal_end_buffer_io_sync(struct buffer_head *bh, int uptodate)
  27. {
  28. BUFFER_TRACE(bh, "");
  29. mark_buffer_uptodate(bh, uptodate);
  30. unlock_buffer(bh);
  31. }
  32. /*
  33.  * journal_commit_transaction
  34.  *
  35.  * The primary function for committing a transaction to the log.  This
  36.  * function is called by the journal thread to begin a complete commit.
  37.  */
  38. void journal_commit_transaction(journal_t *journal)
  39. {
  40. transaction_t *commit_transaction;
  41. struct journal_head *jh, *new_jh, *descriptor;
  42. struct journal_head *next_jh, *last_jh;
  43. struct buffer_head *wbuf[64];
  44. int bufs;
  45. int flags;
  46. int err;
  47. unsigned long blocknr;
  48. char *tagp = NULL;
  49. journal_header_t *header;
  50. journal_block_tag_t *tag = NULL;
  51. int space_left = 0;
  52. int first_tag = 0;
  53. int tag_flag;
  54. int i;
  55. /*
  56.  * First job: lock down the current transaction and wait for
  57.  * all outstanding updates to complete.
  58.  */
  59. lock_journal(journal); /* Protect journal->j_running_transaction */
  60. #ifdef COMMIT_STATS
  61. spin_lock(&journal_datalist_lock);
  62. summarise_journal_usage(journal);
  63. spin_unlock(&journal_datalist_lock);
  64. #endif
  65. lock_kernel();
  66. J_ASSERT (journal->j_running_transaction != NULL);
  67. J_ASSERT (journal->j_committing_transaction == NULL);
  68. commit_transaction = journal->j_running_transaction;
  69. J_ASSERT (commit_transaction->t_state == T_RUNNING);
  70. jbd_debug (1, "JBD: starting commit of transaction %dn",
  71.    commit_transaction->t_tid);
  72. commit_transaction->t_state = T_LOCKED;
  73. while (commit_transaction->t_updates != 0) {
  74. unlock_journal(journal);
  75. sleep_on(&journal->j_wait_updates);
  76. lock_journal(journal);
  77. }
  78. J_ASSERT (commit_transaction->t_outstanding_credits <=
  79. journal->j_max_transaction_buffers);
  80. /* Do we need to erase the effects of a prior journal_flush? */
  81. if (journal->j_flags & JFS_FLUSHED) {
  82. jbd_debug(3, "super block updatedn");
  83. journal_update_superblock(journal, 1);
  84. } else {
  85. jbd_debug(3, "superblock not updatedn");
  86. }
  87. /*
  88.  * First thing we are allowed to do is to discard any remaining
  89.  * BJ_Reserved buffers.  Note, it is _not_ permissible to assume
  90.  * that there are no such buffers: if a large filesystem
  91.  * operation like a truncate needs to split itself over multiple
  92.  * transactions, then it may try to do a journal_restart() while
  93.  * there are still BJ_Reserved buffers outstanding.  These must
  94.  * be released cleanly from the current transaction.
  95.  *
  96.  * In this case, the filesystem must still reserve write access
  97.  * again before modifying the buffer in the new transaction, but
  98.  * we do not require it to remember exactly which old buffers it
  99.  * has reserved.  This is consistent with the existing behaviour
  100.  * that multiple journal_get_write_access() calls to the same
  101.  * buffer are perfectly permissable.
  102.  */
  103. while (commit_transaction->t_reserved_list) {
  104. jh = commit_transaction->t_reserved_list;
  105. JBUFFER_TRACE(jh, "reserved, unused: refile");
  106. journal_refile_buffer(jh);
  107. }
  108. /*
  109.  * Now try to drop any written-back buffers from the journal's
  110.  * checkpoint lists.  We do this *before* commit because it potentially
  111.  * frees some memory
  112.  */
  113. spin_lock(&journal_datalist_lock);
  114. __journal_clean_checkpoint_list(journal);
  115. spin_unlock(&journal_datalist_lock);
  116. /* First part of the commit: force the revoke list out to disk.
  117.  * The revoke code generates its own metadata blocks on disk for this.
  118.  *
  119.  * It is important that we do this while the transaction is
  120.  * still locked.  Generating the revoke records should not
  121.  * generate any IO stalls, so this should be quick; and doing
  122.  * the work while we have the transaction locked means that we
  123.  * only ever have to maintain the revoke list for one
  124.  * transaction at a time.
  125.  */
  126. jbd_debug (3, "JBD: commit phase 1n");
  127. journal_write_revoke_records(journal, commit_transaction);
  128. /*
  129.  * Now that we have built the revoke records, we can start
  130.  * reusing the revoke list for a new running transaction.  We
  131.  * can now safely start committing the old transaction: time to
  132.  * get a new running transaction for incoming filesystem updates
  133.  */
  134. commit_transaction->t_state = T_FLUSH;
  135. wake_up(&journal->j_wait_transaction_locked);
  136. journal->j_committing_transaction = commit_transaction;
  137. journal->j_running_transaction = NULL;
  138. commit_transaction->t_log_start = journal->j_head;
  139. unlock_kernel();
  140. jbd_debug (3, "JBD: commit phase 2n");
  141. /*
  142.  * Now start flushing things to disk, in the order they appear
  143.  * on the transaction lists.  Data blocks go first.
  144.  */
  145. /*
  146.  * Whenever we unlock the journal and sleep, things can get added
  147.  * onto ->t_datalist, so we have to keep looping back to write_out_data
  148.  * until we *know* that the list is empty.
  149.  */
  150. write_out_data:
  151. /*
  152.  * Cleanup any flushed data buffers from the data list.  Even in
  153.  * abort mode, we want to flush this out as soon as possible.
  154.  *
  155.  * We take journal_datalist_lock to protect the lists from
  156.  * journal_try_to_free_buffers().
  157.  */
  158. spin_lock(&journal_datalist_lock);
  159. write_out_data_locked:
  160. bufs = 0;
  161. next_jh = commit_transaction->t_sync_datalist;
  162. if (next_jh == NULL)
  163. goto sync_datalist_empty;
  164. last_jh = next_jh->b_tprev;
  165. do {
  166. struct buffer_head *bh;
  167. jh = next_jh;
  168. next_jh = jh->b_tnext;
  169. bh = jh2bh(jh);
  170. if (!buffer_locked(bh)) {
  171. if (buffer_dirty(bh)) {
  172. BUFFER_TRACE(bh, "start journal writeout");
  173. atomic_inc(&bh->b_count);
  174. wbuf[bufs++] = bh;
  175. } else {
  176. BUFFER_TRACE(bh, "writeout complete: unfile");
  177. __journal_unfile_buffer(jh);
  178. jh->b_transaction = NULL;
  179. __journal_remove_journal_head(bh);
  180. refile_buffer(bh);
  181. __brelse(bh);
  182. }
  183. }
  184. if (bufs == ARRAY_SIZE(wbuf)) {
  185. /*
  186.  * Major speedup: start here on the next scan
  187.  */
  188. J_ASSERT(commit_transaction->t_sync_datalist != 0);
  189. commit_transaction->t_sync_datalist = jh;
  190. break;
  191. }
  192. } while (jh != last_jh);
  193. if (bufs || current->need_resched) {
  194. jbd_debug(2, "submit %d writesn", bufs);
  195. spin_unlock(&journal_datalist_lock);
  196. unlock_journal(journal);
  197. if (bufs)
  198. ll_rw_block(WRITE, bufs, wbuf);
  199. if (current->need_resched)
  200. schedule();
  201. journal_brelse_array(wbuf, bufs);
  202. lock_journal(journal);
  203. spin_lock(&journal_datalist_lock);
  204. if (bufs)
  205. goto write_out_data_locked;
  206. }
  207. /*
  208.  * Wait for all previously submitted IO on the data list to complete.
  209.  */
  210. jh = commit_transaction->t_sync_datalist;
  211. if (jh == NULL)
  212. goto sync_datalist_empty;
  213. do {
  214. struct buffer_head *bh;
  215. jh = jh->b_tprev; /* Wait on the last written */
  216. bh = jh2bh(jh);
  217. if (buffer_locked(bh)) {
  218. spin_unlock(&journal_datalist_lock);
  219. unlock_journal(journal);
  220. wait_on_buffer(bh);
  221. /* the journal_head may have been removed now */
  222. lock_journal(journal);
  223. goto write_out_data;
  224. } else if (buffer_dirty(bh)) {
  225. goto write_out_data_locked;
  226. }
  227. } while (jh != commit_transaction->t_sync_datalist);
  228. goto write_out_data_locked;
  229. sync_datalist_empty:
  230. /*
  231.  * Wait for all the async writepage data.  As they become unlocked
  232.  * in end_buffer_io_async(), the only place where they can be
  233.  * reaped is in try_to_free_buffers(), and we're locked against
  234.  * that.
  235.  */
  236. while ((jh = commit_transaction->t_async_datalist)) {
  237. struct buffer_head *bh = jh2bh(jh);
  238. if (buffer_locked(bh)) {
  239. spin_unlock(&journal_datalist_lock);
  240. unlock_journal(journal);
  241. wait_on_buffer(bh);
  242. lock_journal(journal);
  243. spin_lock(&journal_datalist_lock);
  244. continue; /* List may have changed */
  245. }
  246. if (jh->b_next_transaction) {
  247. /*
  248.  * For writepage() buffers in journalled data mode: a
  249.  * later transaction may want the buffer for "metadata"
  250.  */
  251. __journal_refile_buffer(jh);
  252. } else {
  253. BUFFER_TRACE(bh, "finished async writeout: unfile");
  254. __journal_unfile_buffer(jh);
  255. jh->b_transaction = NULL;
  256. __journal_remove_journal_head(bh);
  257. BUFFER_TRACE(bh, "finished async writeout: refile");
  258. /* It can sometimes be on BUF_LOCKED due to migration
  259.  * from syncdata to asyncdata */
  260. if (bh->b_list != BUF_CLEAN)
  261. refile_buffer(bh);
  262. __brelse(bh);
  263. }
  264. }
  265. spin_unlock(&journal_datalist_lock);
  266. /*
  267.  * If we found any dirty or locked buffers, then we should have
  268.  * looped back up to the write_out_data label.  If there weren't
  269.  * any then journal_clean_data_list should have wiped the list
  270.  * clean by now, so check that it is in fact empty.
  271.  */
  272. J_ASSERT (commit_transaction->t_sync_datalist == NULL);
  273. J_ASSERT (commit_transaction->t_async_datalist == NULL);
  274. jbd_debug (3, "JBD: commit phase 3n");
  275. /*
  276.  * Way to go: we have now written out all of the data for a
  277.  * transaction!  Now comes the tricky part: we need to write out
  278.  * metadata.  Loop over the transaction's entire buffer list:
  279.  */
  280. commit_transaction->t_state = T_COMMIT;
  281. descriptor = 0;
  282. bufs = 0;
  283. while (commit_transaction->t_buffers) {
  284. /* Find the next buffer to be journaled... */
  285. jh = commit_transaction->t_buffers;
  286. /* If we're in abort mode, we just un-journal the buffer and
  287.    release it for background writing. */
  288. if (is_journal_aborted(journal)) {
  289. JBUFFER_TRACE(jh, "journal is aborting: refile");
  290. journal_refile_buffer(jh);
  291. /* If that was the last one, we need to clean up
  292.  * any descriptor buffers which may have been
  293.  * already allocated, even if we are now
  294.  * aborting. */
  295. if (!commit_transaction->t_buffers)
  296. goto start_journal_io;
  297. continue;
  298. }
  299. /* Make sure we have a descriptor block in which to
  300.    record the metadata buffer. */
  301. if (!descriptor) {
  302. struct buffer_head *bh;
  303. J_ASSERT (bufs == 0);
  304. jbd_debug(4, "JBD: get descriptorn");
  305. descriptor = journal_get_descriptor_buffer(journal);
  306. if (!descriptor) {
  307. __journal_abort_hard(journal);
  308. continue;
  309. }
  310. bh = jh2bh(descriptor);
  311. jbd_debug(4, "JBD: got buffer %ld (%p)n",
  312. bh->b_blocknr, bh->b_data);
  313. header = (journal_header_t *)&bh->b_data[0];
  314. header->h_magic     = htonl(JFS_MAGIC_NUMBER);
  315. header->h_blocktype = htonl(JFS_DESCRIPTOR_BLOCK);
  316. header->h_sequence  = htonl(commit_transaction->t_tid);
  317. tagp = &bh->b_data[sizeof(journal_header_t)];
  318. space_left = bh->b_size - sizeof(journal_header_t);
  319. first_tag = 1;
  320. set_bit(BH_JWrite, &bh->b_state);
  321. wbuf[bufs++] = bh;
  322. /* Record it so that we can wait for IO
  323.                            completion later */
  324. BUFFER_TRACE(bh, "ph3: file as descriptor");
  325. journal_file_buffer(descriptor, commit_transaction,
  326. BJ_LogCtl);
  327. }
  328. /* Where is the buffer to be written? */
  329. err = journal_next_log_block(journal, &blocknr);
  330. /* If the block mapping failed, just abandon the buffer
  331.    and repeat this loop: we'll fall into the
  332.    refile-on-abort condition above. */
  333. if (err) {
  334. __journal_abort_hard(journal);
  335. continue;
  336. }
  337. /* Bump b_count to prevent truncate from stumbling over
  338.                    the shadowed buffer!  @@@ This can go if we ever get
  339.                    rid of the BJ_IO/BJ_Shadow pairing of buffers. */
  340. atomic_inc(&jh2bh(jh)->b_count);
  341. /* Make a temporary IO buffer with which to write it out
  342.                    (this will requeue both the metadata buffer and the
  343.                    temporary IO buffer). new_bh goes on BJ_IO*/
  344. set_bit(BH_JWrite, &jh2bh(jh)->b_state);
  345. /*
  346.  * akpm: journal_write_metadata_buffer() sets
  347.  * new_bh->b_transaction to commit_transaction.
  348.  * We need to clean this up before we release new_bh
  349.  * (which is of type BJ_IO)
  350.  */
  351. JBUFFER_TRACE(jh, "ph3: write metadata");
  352. flags = journal_write_metadata_buffer(commit_transaction,
  353.       jh, &new_jh, blocknr);
  354. set_bit(BH_JWrite, &jh2bh(new_jh)->b_state);
  355. set_bit(BH_Lock, &jh2bh(new_jh)->b_state);
  356. wbuf[bufs++] = jh2bh(new_jh);
  357. /* Record the new block's tag in the current descriptor
  358.                    buffer */
  359. tag_flag = 0;
  360. if (flags & 1)
  361. tag_flag |= JFS_FLAG_ESCAPE;
  362. if (!first_tag)
  363. tag_flag |= JFS_FLAG_SAME_UUID;
  364. tag = (journal_block_tag_t *) tagp;
  365. tag->t_blocknr = htonl(jh2bh(jh)->b_blocknr);
  366. tag->t_flags = htonl(tag_flag);
  367. tagp += sizeof(journal_block_tag_t);
  368. space_left -= sizeof(journal_block_tag_t);
  369. if (first_tag) {
  370. memcpy (tagp, journal->j_uuid, 16);
  371. tagp += 16;
  372. space_left -= 16;
  373. first_tag = 0;
  374. }
  375. /* If there's no more to do, or if the descriptor is full,
  376.    let the IO rip! */
  377. if (bufs == ARRAY_SIZE(wbuf) ||
  378.     commit_transaction->t_buffers == NULL ||
  379.     space_left < sizeof(journal_block_tag_t) + 16) {
  380. jbd_debug(4, "JBD: Submit %d IOsn", bufs);
  381. /* Write an end-of-descriptor marker before
  382.                            submitting the IOs.  "tag" still points to
  383.                            the last tag we set up. */
  384. tag->t_flags |= htonl(JFS_FLAG_LAST_TAG);
  385. start_journal_io:
  386. unlock_journal(journal);
  387. for (i=0; i<bufs; i++) {
  388. struct buffer_head *bh = wbuf[i];
  389. clear_bit(BH_Dirty, &bh->b_state);
  390. bh->b_end_io = journal_end_buffer_io_sync;
  391. submit_bh(WRITE, bh);
  392. }
  393. if (current->need_resched)
  394. schedule();
  395. lock_journal(journal);
  396. /* Force a new descriptor to be generated next
  397.                            time round the loop. */
  398. descriptor = NULL;
  399. bufs = 0;
  400. }
  401. }
  402. /* Lo and behold: we have just managed to send a transaction to
  403.            the log.  Before we can commit it, wait for the IO so far to
  404.            complete.  Control buffers being written are on the
  405.            transaction's t_log_list queue, and metadata buffers are on
  406.            the t_iobuf_list queue.
  407.    Wait for the buffers in reverse order.  That way we are
  408.    less likely to be woken up until all IOs have completed, and
  409.    so we incur less scheduling load.
  410. */
  411. jbd_debug(3, "JBD: commit phase 4n");
  412. /* akpm: these are BJ_IO, and journal_datalist_lock is not needed */
  413.  wait_for_iobuf:
  414. while (commit_transaction->t_iobuf_list != NULL) {
  415. struct buffer_head *bh;
  416. jh = commit_transaction->t_iobuf_list->b_tprev;
  417. bh = jh2bh(jh);
  418. if (buffer_locked(bh)) {
  419. unlock_journal(journal);
  420. wait_on_buffer(bh);
  421. lock_journal(journal);
  422. goto wait_for_iobuf;
  423. }
  424. clear_bit(BH_JWrite, &jh2bh(jh)->b_state);
  425. JBUFFER_TRACE(jh, "ph4: unfile after journal write");
  426. journal_unfile_buffer(jh);
  427. /*
  428.  * akpm: don't put back a buffer_head with stale pointers
  429.  * dangling around.
  430.  */
  431. J_ASSERT_JH(jh, jh->b_transaction != NULL);
  432. jh->b_transaction = NULL;
  433. /*
  434.  * ->t_iobuf_list should contain only dummy buffer_heads
  435.  * which were created by journal_write_metadata_buffer().
  436.  */
  437. bh = jh2bh(jh);
  438. BUFFER_TRACE(bh, "dumping temporary bh");
  439. journal_unlock_journal_head(jh);
  440. __brelse(bh);
  441. J_ASSERT_BH(bh, atomic_read(&bh->b_count) == 0);
  442. put_unused_buffer_head(bh);
  443. /* We also have to unlock and free the corresponding
  444.                    shadowed buffer */
  445. jh = commit_transaction->t_shadow_list->b_tprev;
  446. bh = jh2bh(jh);
  447. clear_bit(BH_JWrite, &bh->b_state);
  448. J_ASSERT_BH(bh, buffer_jdirty(bh));
  449. /* The metadata is now released for reuse, but we need
  450.                    to remember it against this transaction so that when
  451.                    we finally commit, we can do any checkpointing
  452.                    required. */
  453. JBUFFER_TRACE(jh, "file as BJ_Forget");
  454. journal_file_buffer(jh, commit_transaction, BJ_Forget);
  455. /* Wake up any transactions which were waiting for this
  456.    IO to complete */
  457. wake_up(&bh->b_wait);
  458. JBUFFER_TRACE(jh, "brelse shadowed buffer");
  459. __brelse(bh);
  460. }
  461. J_ASSERT (commit_transaction->t_shadow_list == NULL);
  462. jbd_debug(3, "JBD: commit phase 5n");
  463. /* Here we wait for the revoke record and descriptor record buffers */
  464.  wait_for_ctlbuf:
  465. while (commit_transaction->t_log_list != NULL) {
  466. struct buffer_head *bh;
  467. jh = commit_transaction->t_log_list->b_tprev;
  468. bh = jh2bh(jh);
  469. if (buffer_locked(bh)) {
  470. unlock_journal(journal);
  471. wait_on_buffer(bh);
  472. lock_journal(journal);
  473. goto wait_for_ctlbuf;
  474. }
  475. BUFFER_TRACE(bh, "ph5: control buffer writeout done: unfile");
  476. clear_bit(BH_JWrite, &bh->b_state);
  477. journal_unfile_buffer(jh);
  478. jh->b_transaction = NULL;
  479. journal_unlock_journal_head(jh);
  480. put_bh(bh); /* One for getblk */
  481. }
  482. jbd_debug(3, "JBD: commit phase 6n");
  483. if (is_journal_aborted(journal)) {
  484. unlock_journal(journal);
  485. goto skip_commit;
  486. }
  487. /* Done it all: now write the commit record.  We should have
  488.  * cleaned up our previous buffers by now, so if we are in abort
  489.  * mode we can now just skip the rest of the journal write
  490.  * entirely. */
  491. descriptor = journal_get_descriptor_buffer(journal);
  492. if (!descriptor) {
  493. __journal_abort_hard(journal);
  494. unlock_journal(journal);
  495. goto skip_commit;
  496. }
  497. /* AKPM: buglet - add `i' to tmp! */
  498. for (i = 0; i < jh2bh(descriptor)->b_size; i += 512) {
  499. journal_header_t *tmp =
  500. (journal_header_t*)jh2bh(descriptor)->b_data;
  501. tmp->h_magic = htonl(JFS_MAGIC_NUMBER);
  502. tmp->h_blocktype = htonl(JFS_COMMIT_BLOCK);
  503. tmp->h_sequence = htonl(commit_transaction->t_tid);
  504. }
  505. unlock_journal(journal);
  506. JBUFFER_TRACE(descriptor, "write commit block");
  507. {
  508. struct buffer_head *bh = jh2bh(descriptor);
  509. clear_bit(BH_Dirty, &bh->b_state);
  510. bh->b_end_io = journal_end_buffer_io_sync;
  511. submit_bh(WRITE, bh);
  512. wait_on_buffer(bh);
  513. put_bh(bh); /* One for getblk() */
  514. journal_unlock_journal_head(descriptor);
  515. }
  516. /* End of a transaction!  Finally, we can do checkpoint
  517.            processing: any buffers committed as a result of this
  518.            transaction can be removed from any checkpoint list it was on
  519.            before. */
  520. skip_commit: /* The journal should be unlocked by now. */
  521. /* Call any callbacks that had been registered for handles in this
  522.  * transaction.  It is up to the callback to free any allocated
  523.  * memory.
  524.  */
  525. if (!list_empty(&commit_transaction->t_jcb)) {
  526. struct list_head *p, *n;
  527. int error = is_journal_aborted(journal);
  528. list_for_each_safe(p, n, &commit_transaction->t_jcb) {
  529. struct journal_callback *jcb;
  530. jcb = list_entry(p, struct journal_callback, jcb_list);
  531. list_del(p);
  532. jcb->jcb_func(jcb, error);
  533. }
  534. }
  535. lock_journal(journal);
  536. jbd_debug(3, "JBD: commit phase 7n");
  537. J_ASSERT(commit_transaction->t_sync_datalist == NULL);
  538. J_ASSERT(commit_transaction->t_async_datalist == NULL);
  539. J_ASSERT(commit_transaction->t_buffers == NULL);
  540. J_ASSERT(commit_transaction->t_checkpoint_list == NULL);
  541. J_ASSERT(commit_transaction->t_iobuf_list == NULL);
  542. J_ASSERT(commit_transaction->t_shadow_list == NULL);
  543. J_ASSERT(commit_transaction->t_log_list == NULL);
  544. while (commit_transaction->t_forget) {
  545. transaction_t *cp_transaction;
  546. struct buffer_head *bh;
  547. jh = commit_transaction->t_forget;
  548. J_ASSERT_JH(jh, jh->b_transaction == commit_transaction ||
  549. jh->b_transaction == journal->j_running_transaction);
  550. /*
  551.  * If there is undo-protected committed data against
  552.  * this buffer, then we can remove it now.  If it is a
  553.  * buffer needing such protection, the old frozen_data
  554.  * field now points to a committed version of the
  555.  * buffer, so rotate that field to the new committed
  556.  * data.
  557.  *
  558.  * Otherwise, we can just throw away the frozen data now.
  559.  */
  560. if (jh->b_committed_data) {
  561. kfree(jh->b_committed_data);
  562. jh->b_committed_data = NULL;
  563. if (jh->b_frozen_data) {
  564. jh->b_committed_data = jh->b_frozen_data;
  565. jh->b_frozen_data = NULL;
  566. }
  567. } else if (jh->b_frozen_data) {
  568. kfree(jh->b_frozen_data);
  569. jh->b_frozen_data = NULL;
  570. }
  571. spin_lock(&journal_datalist_lock);
  572. cp_transaction = jh->b_cp_transaction;
  573. if (cp_transaction) {
  574. JBUFFER_TRACE(jh, "remove from old cp transaction");
  575. J_ASSERT_JH(jh, commit_transaction != cp_transaction);
  576. __journal_remove_checkpoint(jh);
  577. }
  578. /* Only re-checkpoint the buffer_head if it is marked
  579.  * dirty.  If the buffer was added to the BJ_Forget list
  580.  * by journal_forget, it may no longer be dirty and
  581.  * there's no point in keeping a checkpoint record for
  582.  * it. */
  583. bh = jh2bh(jh);
  584. /* A buffer which has been freed while still being
  585.  * journaled by a previous transaction may end up still
  586.  * being dirty here, but we want to avoid writing back
  587.  * that buffer in the future now that the last use has
  588.  * been committed.  That's not only a performance gain,
  589.  * it also stops aliasing problems if the buffer is left
  590.  * behind for writeback and gets reallocated for another
  591.  * use in a different page. */
  592. if (__buffer_state(bh, Freed)) {
  593. clear_bit(BH_Freed, &bh->b_state);
  594. clear_bit(BH_JBDDirty, &bh->b_state);
  595. }
  596. if (buffer_jdirty(bh)) {
  597. JBUFFER_TRACE(jh, "add to new checkpointing trans");
  598. __journal_insert_checkpoint(jh, commit_transaction);
  599. JBUFFER_TRACE(jh, "refile for checkpoint writeback");
  600. __journal_refile_buffer(jh);
  601. } else {
  602. J_ASSERT_BH(bh, !buffer_dirty(bh));
  603. J_ASSERT_JH(jh, jh->b_next_transaction == NULL);
  604. __journal_unfile_buffer(jh);
  605. jh->b_transaction = 0;
  606. __journal_remove_journal_head(bh);
  607. __brelse(bh);
  608. }
  609. spin_unlock(&journal_datalist_lock);
  610. }
  611. /* Done with this transaction! */
  612. jbd_debug(3, "JBD: commit phase 8n");
  613. J_ASSERT (commit_transaction->t_state == T_COMMIT);
  614. commit_transaction->t_state = T_FINISHED;
  615. J_ASSERT (commit_transaction == journal->j_committing_transaction);
  616. journal->j_commit_sequence = commit_transaction->t_tid;
  617. journal->j_committing_transaction = NULL;
  618. spin_lock(&journal_datalist_lock);
  619. if (commit_transaction->t_checkpoint_list == NULL) {
  620. __journal_drop_transaction(journal, commit_transaction);
  621. } else {
  622. if (journal->j_checkpoint_transactions == NULL) {
  623. journal->j_checkpoint_transactions = commit_transaction;
  624. commit_transaction->t_cpnext = commit_transaction;
  625. commit_transaction->t_cpprev = commit_transaction;
  626. } else {
  627. commit_transaction->t_cpnext =
  628. journal->j_checkpoint_transactions;
  629. commit_transaction->t_cpprev =
  630. commit_transaction->t_cpnext->t_cpprev;
  631. commit_transaction->t_cpnext->t_cpprev =
  632. commit_transaction;
  633. commit_transaction->t_cpprev->t_cpnext =
  634. commit_transaction;
  635. }
  636. }
  637. spin_unlock(&journal_datalist_lock);
  638. jbd_debug(1, "JBD: commit %d complete, head %dn",
  639.   journal->j_commit_sequence, journal->j_tail_sequence);
  640. unlock_journal(journal);
  641. wake_up(&journal->j_wait_done_commit);
  642. }