aboutsummaryrefslogtreecommitdiffstats
path: root/fs
diff options
context:
space:
mode:
Diffstat (limited to 'fs')
-rw-r--r--fs/jbd/commit.c2
-rw-r--r--fs/jbd/revoke.c20
2 files changed, 12 insertions, 10 deletions
diff --git a/fs/jbd/commit.c b/fs/jbd/commit.c
index a8e8513a78a9..06560c520f49 100644
--- a/fs/jbd/commit.c
+++ b/fs/jbd/commit.c
@@ -502,7 +502,7 @@ void journal_commit_transaction(journal_t *journal)
502 err = 0; 502 err = 0;
503 } 503 }
504 504
505 journal_write_revoke_records(journal, commit_transaction); 505 journal_write_revoke_records(journal, commit_transaction, write_op);
506 506
507 /* 507 /*
508 * If we found any dirty or locked buffers, then we should have 508 * If we found any dirty or locked buffers, then we should have
diff --git a/fs/jbd/revoke.c b/fs/jbd/revoke.c
index c7bd649bbbdc..1b1a06e1c836 100644
--- a/fs/jbd/revoke.c
+++ b/fs/jbd/revoke.c
@@ -67,6 +67,7 @@
67#include <linux/slab.h> 67#include <linux/slab.h>
68#include <linux/list.h> 68#include <linux/list.h>
69#include <linux/init.h> 69#include <linux/init.h>
70#include <linux/bio.h>
70#endif 71#endif
71#include <linux/log2.h> 72#include <linux/log2.h>
72 73
@@ -99,8 +100,8 @@ struct jbd_revoke_table_s
99#ifdef __KERNEL__ 100#ifdef __KERNEL__
100static void write_one_revoke_record(journal_t *, transaction_t *, 101static void write_one_revoke_record(journal_t *, transaction_t *,
101 struct journal_head **, int *, 102 struct journal_head **, int *,
102 struct jbd_revoke_record_s *); 103 struct jbd_revoke_record_s *, int);
103static void flush_descriptor(journal_t *, struct journal_head *, int); 104static void flush_descriptor(journal_t *, struct journal_head *, int, int);
104#endif 105#endif
105 106
106/* Utility functions to maintain the revoke table */ 107/* Utility functions to maintain the revoke table */
@@ -486,7 +487,7 @@ void journal_switch_revoke_table(journal_t *journal)
486 */ 487 */
487 488
488void journal_write_revoke_records(journal_t *journal, 489void journal_write_revoke_records(journal_t *journal,
489 transaction_t *transaction) 490 transaction_t *transaction, int write_op)
490{ 491{
491 struct journal_head *descriptor; 492 struct journal_head *descriptor;
492 struct jbd_revoke_record_s *record; 493 struct jbd_revoke_record_s *record;
@@ -510,14 +511,14 @@ void journal_write_revoke_records(journal_t *journal,
510 hash_list->next; 511 hash_list->next;
511 write_one_revoke_record(journal, transaction, 512 write_one_revoke_record(journal, transaction,
512 &descriptor, &offset, 513 &descriptor, &offset,
513 record); 514 record, write_op);
514 count++; 515 count++;
515 list_del(&record->hash); 516 list_del(&record->hash);
516 kmem_cache_free(revoke_record_cache, record); 517 kmem_cache_free(revoke_record_cache, record);
517 } 518 }
518 } 519 }
519 if (descriptor) 520 if (descriptor)
520 flush_descriptor(journal, descriptor, offset); 521 flush_descriptor(journal, descriptor, offset, write_op);
521 jbd_debug(1, "Wrote %d revoke records\n", count); 522 jbd_debug(1, "Wrote %d revoke records\n", count);
522} 523}
523 524
@@ -530,7 +531,8 @@ static void write_one_revoke_record(journal_t *journal,
530 transaction_t *transaction, 531 transaction_t *transaction,
531 struct journal_head **descriptorp, 532 struct journal_head **descriptorp,
532 int *offsetp, 533 int *offsetp,
533 struct jbd_revoke_record_s *record) 534 struct jbd_revoke_record_s *record,
535 int write_op)
534{ 536{
535 struct journal_head *descriptor; 537 struct journal_head *descriptor;
536 int offset; 538 int offset;
@@ -549,7 +551,7 @@ static void write_one_revoke_record(journal_t *journal,
549 /* Make sure we have a descriptor with space left for the record */ 551 /* Make sure we have a descriptor with space left for the record */
550 if (descriptor) { 552 if (descriptor) {
551 if (offset == journal->j_blocksize) { 553 if (offset == journal->j_blocksize) {
552 flush_descriptor(journal, descriptor, offset); 554 flush_descriptor(journal, descriptor, offset, write_op);
553 descriptor = NULL; 555 descriptor = NULL;
554 } 556 }
555 } 557 }
@@ -586,7 +588,7 @@ static void write_one_revoke_record(journal_t *journal,
586 588
587static void flush_descriptor(journal_t *journal, 589static void flush_descriptor(journal_t *journal,
588 struct journal_head *descriptor, 590 struct journal_head *descriptor,
589 int offset) 591 int offset, int write_op)
590{ 592{
591 journal_revoke_header_t *header; 593 journal_revoke_header_t *header;
592 struct buffer_head *bh = jh2bh(descriptor); 594 struct buffer_head *bh = jh2bh(descriptor);
@@ -601,7 +603,7 @@ static void flush_descriptor(journal_t *journal,
601 set_buffer_jwrite(bh); 603 set_buffer_jwrite(bh);
602 BUFFER_TRACE(bh, "write"); 604 BUFFER_TRACE(bh, "write");
603 set_buffer_dirty(bh); 605 set_buffer_dirty(bh);
604 ll_rw_block(SWRITE, 1, &bh); 606 ll_rw_block((write_op == WRITE) ? SWRITE : SWRITE_SYNC_PLUG, 1, &bh);
605} 607}
606#endif 608#endif
607 609