Commit c1b99198 authored by Christoph Hellwig's avatar Christoph Hellwig Committed by NeilBrown

raid5-cache: new helper: r5_reserve_log_entry

Factor out code to reserve log space.
Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarShaohua Li <shli@fb.com>
Signed-off-by: default avatarNeilBrown <neilb@suse.com>
parent 51039cd0
...@@ -271,6 +271,23 @@ static struct bio *r5l_bio_alloc(struct r5l_log *log, struct r5l_io_unit *io) ...@@ -271,6 +271,23 @@ static struct bio *r5l_bio_alloc(struct r5l_log *log, struct r5l_io_unit *io)
return bio; return bio;
} }
static void r5_reserve_log_entry(struct r5l_log *log, struct r5l_io_unit *io)
{
log->log_start = r5l_ring_add(log, log->log_start, BLOCK_SECTORS);
/*
* If we filled up the log device start from the beginning again,
* which will require a new bio.
*
* Note: for this to work properly the log size needs to me a multiple
* of BLOCK_SECTORS.
*/
if (log->log_start == 0)
io->current_bio = NULL;
io->log_end = log->log_start;
}
static struct r5l_io_unit *r5l_new_meta(struct r5l_log *log) static struct r5l_io_unit *r5l_new_meta(struct r5l_log *log)
{ {
struct r5l_io_unit *io; struct r5l_io_unit *io;
...@@ -299,11 +316,7 @@ static struct r5l_io_unit *r5l_new_meta(struct r5l_log *log) ...@@ -299,11 +316,7 @@ static struct r5l_io_unit *r5l_new_meta(struct r5l_log *log)
bio_add_page(io->current_bio, io->meta_page, PAGE_SIZE, 0); bio_add_page(io->current_bio, io->meta_page, PAGE_SIZE, 0);
log->seq++; log->seq++;
log->log_start = r5l_ring_add(log, log->log_start, BLOCK_SECTORS); r5_reserve_log_entry(log, io);
io->log_end = log->log_start;
/* current bio hit disk end */
if (log->log_start == 0)
io->current_bio = NULL;
spin_lock_irq(&log->io_list_lock); spin_lock_irq(&log->io_list_lock);
list_add_tail(&io->log_sibling, &log->running_ios); list_add_tail(&io->log_sibling, &log->running_ios);
...@@ -357,13 +370,8 @@ static void r5l_append_payload_page(struct r5l_log *log, struct page *page) ...@@ -357,13 +370,8 @@ static void r5l_append_payload_page(struct r5l_log *log, struct page *page)
io->current_bio = NULL; io->current_bio = NULL;
goto alloc_bio; goto alloc_bio;
} }
log->log_start = r5l_ring_add(log, log->log_start,
BLOCK_SECTORS);
/* current bio hit disk end */
if (log->log_start == 0)
io->current_bio = NULL;
io->log_end = log->log_start; r5_reserve_log_entry(log, io);
} }
static void r5l_log_stripe(struct r5l_log *log, struct stripe_head *sh, static void r5l_log_stripe(struct r5l_log *log, struct stripe_head *sh,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment