|
@@ -257,9 +257,12 @@ static void
|
|
__flush_batch(journal_t *journal, int *batch_count)
|
|
__flush_batch(journal_t *journal, int *batch_count)
|
|
{
|
|
{
|
|
int i;
|
|
int i;
|
|
|
|
+ struct blk_plug plug;
|
|
|
|
|
|
|
|
+ blk_start_plug(&plug);
|
|
for (i = 0; i < *batch_count; i++)
|
|
for (i = 0; i < *batch_count; i++)
|
|
- write_dirty_buffer(journal->j_chkpt_bhs[i], WRITE);
|
|
|
|
|
|
+ write_dirty_buffer(journal->j_chkpt_bhs[i], WRITE_SYNC);
|
|
|
|
+ blk_finish_plug(&plug);
|
|
|
|
|
|
for (i = 0; i < *batch_count; i++) {
|
|
for (i = 0; i < *batch_count; i++) {
|
|
struct buffer_head *bh = journal->j_chkpt_bhs[i];
|
|
struct buffer_head *bh = journal->j_chkpt_bhs[i];
|