diff options
Diffstat (limited to 'fs/reiserfs')
-rw-r--r-- | fs/reiserfs/journal.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/fs/reiserfs/journal.c b/fs/reiserfs/journal.c index 0f7b1e807e60..3cb4a562030e 100644 --- a/fs/reiserfs/journal.c +++ b/fs/reiserfs/journal.c | |||
@@ -1411,8 +1411,8 @@ static int flush_journal_list(struct super_block *s, | |||
1411 | 1411 | ||
1412 | /* if flushall == 0, the lock is already held */ | 1412 | /* if flushall == 0, the lock is already held */ |
1413 | if (flushall) { | 1413 | if (flushall) { |
1414 | down(&journal->j_flush_sem); | 1414 | mutex_lock(&journal->j_flush_mutex); |
1415 | } else if (!down_trylock(&journal->j_flush_sem)) { | 1415 | } else if (mutex_trylock(&journal->j_flush_mutex)) { |
1416 | BUG(); | 1416 | BUG(); |
1417 | } | 1417 | } |
1418 | 1418 | ||
@@ -1642,7 +1642,7 @@ static int flush_journal_list(struct super_block *s, | |||
1642 | jl->j_state = 0; | 1642 | jl->j_state = 0; |
1643 | put_journal_list(s, jl); | 1643 | put_journal_list(s, jl); |
1644 | if (flushall) | 1644 | if (flushall) |
1645 | up(&journal->j_flush_sem); | 1645 | mutex_unlock(&journal->j_flush_mutex); |
1646 | put_fs_excl(); | 1646 | put_fs_excl(); |
1647 | return err; | 1647 | return err; |
1648 | } | 1648 | } |
@@ -1772,12 +1772,12 @@ static int kupdate_transactions(struct super_block *s, | |||
1772 | struct reiserfs_journal *journal = SB_JOURNAL(s); | 1772 | struct reiserfs_journal *journal = SB_JOURNAL(s); |
1773 | chunk.nr = 0; | 1773 | chunk.nr = 0; |
1774 | 1774 | ||
1775 | down(&journal->j_flush_sem); | 1775 | mutex_lock(&journal->j_flush_mutex); |
1776 | if (!journal_list_still_alive(s, orig_trans_id)) { | 1776 | if (!journal_list_still_alive(s, orig_trans_id)) { |
1777 | goto done; | 1777 | goto done; |
1778 | } | 1778 | } |
1779 | 1779 | ||
1780 | /* we've got j_flush_sem held, nobody is going to delete any | 1780 | /* we've got j_flush_mutex held, nobody is going to delete any |
1781 | * of these lists out from underneath us | 1781 | * of these lists out from underneath us |
1782 | */ | 1782 | */ |
1783 | while ((num_trans && transactions_flushed < num_trans) || | 1783 | while ((num_trans && transactions_flushed < num_trans) || |
@@ -1812,7 +1812,7 @@ static int kupdate_transactions(struct super_block *s, | |||
1812 | } | 1812 | } |
1813 | 1813 | ||
1814 | done: | 1814 | done: |
1815 | up(&journal->j_flush_sem); | 1815 | mutex_unlock(&journal->j_flush_mutex); |
1816 | return ret; | 1816 | return ret; |
1817 | } | 1817 | } |
1818 | 1818 | ||
@@ -2838,7 +2838,7 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
2838 | journal->j_first = NULL; | 2838 | journal->j_first = NULL; |
2839 | init_waitqueue_head(&(journal->j_join_wait)); | 2839 | init_waitqueue_head(&(journal->j_join_wait)); |
2840 | mutex_init(&journal->j_mutex); | 2840 | mutex_init(&journal->j_mutex); |
2841 | sema_init(&journal->j_flush_sem, 1); | 2841 | mutex_init(&journal->j_flush_mutex); |
2842 | 2842 | ||
2843 | journal->j_trans_id = 10; | 2843 | journal->j_trans_id = 10; |
2844 | journal->j_mount_id = 10; | 2844 | journal->j_mount_id = 10; |