|
@@ -26,7 +26,9 @@
|
|
#include <linux/backing-dev.h>
|
|
#include <linux/backing-dev.h>
|
|
#include <linux/bio.h>
|
|
#include <linux/bio.h>
|
|
#include <linux/blkdev.h>
|
|
#include <linux/blkdev.h>
|
|
|
|
+#include <linux/bitops.h>
|
|
#include <trace/events/jbd2.h>
|
|
#include <trace/events/jbd2.h>
|
|
|
|
+#include <asm/system.h>
|
|
|
|
|
|
/*
|
|
/*
|
|
* Default IO end handler for temporary BJ_IO buffer_heads.
|
|
* Default IO end handler for temporary BJ_IO buffer_heads.
|
|
@@ -236,7 +238,7 @@ static int journal_submit_data_buffers(journal_t *journal,
|
|
spin_lock(&journal->j_list_lock);
|
|
spin_lock(&journal->j_list_lock);
|
|
list_for_each_entry(jinode, &commit_transaction->t_inode_list, i_list) {
|
|
list_for_each_entry(jinode, &commit_transaction->t_inode_list, i_list) {
|
|
mapping = jinode->i_vfs_inode->i_mapping;
|
|
mapping = jinode->i_vfs_inode->i_mapping;
|
|
- jinode->i_flags |= JI_COMMIT_RUNNING;
|
|
|
|
|
|
+ set_bit(__JI_COMMIT_RUNNING, &jinode->i_flags);
|
|
spin_unlock(&journal->j_list_lock);
|
|
spin_unlock(&journal->j_list_lock);
|
|
/*
|
|
/*
|
|
* submit the inode data buffers. We use writepage
|
|
* submit the inode data buffers. We use writepage
|
|
@@ -251,7 +253,8 @@ static int journal_submit_data_buffers(journal_t *journal,
|
|
spin_lock(&journal->j_list_lock);
|
|
spin_lock(&journal->j_list_lock);
|
|
J_ASSERT(jinode->i_transaction == commit_transaction);
|
|
J_ASSERT(jinode->i_transaction == commit_transaction);
|
|
commit_transaction->t_flushed_data_blocks = 1;
|
|
commit_transaction->t_flushed_data_blocks = 1;
|
|
- jinode->i_flags &= ~JI_COMMIT_RUNNING;
|
|
|
|
|
|
+ clear_bit(__JI_COMMIT_RUNNING, &jinode->i_flags);
|
|
|
|
+ smp_mb__after_clear_bit();
|
|
wake_up_bit(&jinode->i_flags, __JI_COMMIT_RUNNING);
|
|
wake_up_bit(&jinode->i_flags, __JI_COMMIT_RUNNING);
|
|
}
|
|
}
|
|
spin_unlock(&journal->j_list_lock);
|
|
spin_unlock(&journal->j_list_lock);
|
|
@@ -272,7 +275,7 @@ static int journal_finish_inode_data_buffers(journal_t *journal,
|
|
/* For locking, see the comment in journal_submit_data_buffers() */
|
|
/* For locking, see the comment in journal_submit_data_buffers() */
|
|
spin_lock(&journal->j_list_lock);
|
|
spin_lock(&journal->j_list_lock);
|
|
list_for_each_entry(jinode, &commit_transaction->t_inode_list, i_list) {
|
|
list_for_each_entry(jinode, &commit_transaction->t_inode_list, i_list) {
|
|
- jinode->i_flags |= JI_COMMIT_RUNNING;
|
|
|
|
|
|
+ set_bit(__JI_COMMIT_RUNNING, &jinode->i_flags);
|
|
spin_unlock(&journal->j_list_lock);
|
|
spin_unlock(&journal->j_list_lock);
|
|
err = filemap_fdatawait(jinode->i_vfs_inode->i_mapping);
|
|
err = filemap_fdatawait(jinode->i_vfs_inode->i_mapping);
|
|
if (err) {
|
|
if (err) {
|
|
@@ -288,7 +291,8 @@ static int journal_finish_inode_data_buffers(journal_t *journal,
|
|
ret = err;
|
|
ret = err;
|
|
}
|
|
}
|
|
spin_lock(&journal->j_list_lock);
|
|
spin_lock(&journal->j_list_lock);
|
|
- jinode->i_flags &= ~JI_COMMIT_RUNNING;
|
|
|
|
|
|
+ clear_bit(__JI_COMMIT_RUNNING, &jinode->i_flags);
|
|
|
|
+ smp_mb__after_clear_bit();
|
|
wake_up_bit(&jinode->i_flags, __JI_COMMIT_RUNNING);
|
|
wake_up_bit(&jinode->i_flags, __JI_COMMIT_RUNNING);
|
|
}
|
|
}
|
|
|
|
|