* [PATCH] md/raid10: introduce handle_badblocks
@ 2017-04-13 9:28 Guoqing Jiang
2017-04-13 20:50 ` Shaohua Li
0 siblings, 1 reply; 2+ messages in thread
From: Guoqing Jiang @ 2017-04-13 9:28 UTC (permalink / raw)
To: linux-raid; +Cc: shli, neilb, Guoqing Jiang
If the state of r10bio is either R10BIO_IsSync or
R10BIO_IsRecover, then handle_write_completed calls
the same logic to clear or set badblock for bio and
repl_bio, so refactor these codes to a new function
named handle_badblocks.
Signed-off-by: Guoqing Jiang <gqjiang@suse.com>
---
drivers/md/raid10.c | 42 +++++++++++++++++-------------------------
1 file changed, 17 insertions(+), 25 deletions(-)
diff --git a/drivers/md/raid10.c b/drivers/md/raid10.c
index 4167091..a707772 100644
--- a/drivers/md/raid10.c
+++ b/drivers/md/raid10.c
@@ -2620,6 +2620,20 @@ static void handle_read_error(struct mddev *mddev, struct r10bio *r10_bio)
raid10_read_request(mddev, r10_bio->master_bio, r10_bio);
}
+static void handle_badblocks(struct r10bio *r10_bio, struct md_rdev *rdev,
+ struct r10conf *conf, int slot, bool repl)
+{
+ struct bio *bio = repl ? r10_bio->devs[slot].repl_bio :
+ r10_bio->devs[slot].bio;
+ sector_t addr = r10_bio->devs[slot].addr;
+
+ if (!bio->bi_error)
+ rdev_clear_badblocks(rdev, addr, r10_bio->sectors, 0);
+ else
+ if (!rdev_set_badblocks(rdev, addr, r10_bio->sectors, 0))
+ md_error(conf->mddev, rdev);
+}
+
static void handle_write_completed(struct r10conf *conf, struct r10bio *r10_bio)
{
/* Some sort of write request has finished and it
@@ -2638,34 +2652,12 @@ static void handle_write_completed(struct r10conf *conf, struct r10bio *r10_bio)
rdev = conf->mirrors[dev].rdev;
if (r10_bio->devs[m].bio == NULL)
continue;
- if (!r10_bio->devs[m].bio->bi_error) {
- rdev_clear_badblocks(
- rdev,
- r10_bio->devs[m].addr,
- r10_bio->sectors, 0);
- } else {
- if (!rdev_set_badblocks(
- rdev,
- r10_bio->devs[m].addr,
- r10_bio->sectors, 0))
- md_error(conf->mddev, rdev);
- }
+ handle_badblocks(r10_bio, rdev, conf, m, false);
+
rdev = conf->mirrors[dev].replacement;
if (r10_bio->devs[m].repl_bio == NULL)
continue;
-
- if (!r10_bio->devs[m].repl_bio->bi_error) {
- rdev_clear_badblocks(
- rdev,
- r10_bio->devs[m].addr,
- r10_bio->sectors, 0);
- } else {
- if (!rdev_set_badblocks(
- rdev,
- r10_bio->devs[m].addr,
- r10_bio->sectors, 0))
- md_error(conf->mddev, rdev);
- }
+ handle_badblocks(r10_bio, rdev, conf, m, true);
}
put_buf(r10_bio);
} else {
--
2.6.6
^ permalink raw reply related [flat|nested] 2+ messages in thread
* Re: [PATCH] md/raid10: introduce handle_badblocks
2017-04-13 9:28 [PATCH] md/raid10: introduce handle_badblocks Guoqing Jiang
@ 2017-04-13 20:50 ` Shaohua Li
0 siblings, 0 replies; 2+ messages in thread
From: Shaohua Li @ 2017-04-13 20:50 UTC (permalink / raw)
To: Guoqing Jiang; +Cc: linux-raid, neilb
On Thu, Apr 13, 2017 at 05:28:28PM +0800, Guoqing Jiang wrote:
> If the state of r10bio is either R10BIO_IsSync or
> R10BIO_IsRecover, then handle_write_completed calls
> the same logic to clear or set badblock for bio and
> repl_bio, so refactor these codes to a new function
> named handle_badblocks.
>
> Signed-off-by: Guoqing Jiang <gqjiang@suse.com>
> ---
> drivers/md/raid10.c | 42 +++++++++++++++++-------------------------
> 1 file changed, 17 insertions(+), 25 deletions(-)
I'm reluctant to accept this one. Don't get me wrong, this does reduce the code
lines a little bit, but not much. The problem, I think, is the name.
handle_badblocks describes a big scope, it actually makes coding reading
harder. So if you can find a better name, I'll merge this.
Thanks,
Shaohua
> diff --git a/drivers/md/raid10.c b/drivers/md/raid10.c
> index 4167091..a707772 100644
> --- a/drivers/md/raid10.c
> +++ b/drivers/md/raid10.c
> @@ -2620,6 +2620,20 @@ static void handle_read_error(struct mddev *mddev, struct r10bio *r10_bio)
> raid10_read_request(mddev, r10_bio->master_bio, r10_bio);
> }
>
> +static void handle_badblocks(struct r10bio *r10_bio, struct md_rdev *rdev,
> + struct r10conf *conf, int slot, bool repl)
> +{
> + struct bio *bio = repl ? r10_bio->devs[slot].repl_bio :
> + r10_bio->devs[slot].bio;
> + sector_t addr = r10_bio->devs[slot].addr;
> +
> + if (!bio->bi_error)
> + rdev_clear_badblocks(rdev, addr, r10_bio->sectors, 0);
> + else
> + if (!rdev_set_badblocks(rdev, addr, r10_bio->sectors, 0))
> + md_error(conf->mddev, rdev);
> +}
> +
> static void handle_write_completed(struct r10conf *conf, struct r10bio *r10_bio)
> {
> /* Some sort of write request has finished and it
> @@ -2638,34 +2652,12 @@ static void handle_write_completed(struct r10conf *conf, struct r10bio *r10_bio)
> rdev = conf->mirrors[dev].rdev;
> if (r10_bio->devs[m].bio == NULL)
> continue;
> - if (!r10_bio->devs[m].bio->bi_error) {
> - rdev_clear_badblocks(
> - rdev,
> - r10_bio->devs[m].addr,
> - r10_bio->sectors, 0);
> - } else {
> - if (!rdev_set_badblocks(
> - rdev,
> - r10_bio->devs[m].addr,
> - r10_bio->sectors, 0))
> - md_error(conf->mddev, rdev);
> - }
> + handle_badblocks(r10_bio, rdev, conf, m, false);
> +
> rdev = conf->mirrors[dev].replacement;
> if (r10_bio->devs[m].repl_bio == NULL)
> continue;
> -
> - if (!r10_bio->devs[m].repl_bio->bi_error) {
> - rdev_clear_badblocks(
> - rdev,
> - r10_bio->devs[m].addr,
> - r10_bio->sectors, 0);
> - } else {
> - if (!rdev_set_badblocks(
> - rdev,
> - r10_bio->devs[m].addr,
> - r10_bio->sectors, 0))
> - md_error(conf->mddev, rdev);
> - }
> + handle_badblocks(r10_bio, rdev, conf, m, true);
> }
> put_buf(r10_bio);
> } else {
> --
> 2.6.6
>
> --
> To unsubscribe from this list: send the line "unsubscribe linux-raid" in
> the body of a message to majordomo@vger.kernel.org
> More majordomo info at http://vger.kernel.org/majordomo-info.html
^ permalink raw reply [flat|nested] 2+ messages in thread
end of thread, other threads:[~2017-04-13 20:50 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2017-04-13 9:28 [PATCH] md/raid10: introduce handle_badblocks Guoqing Jiang
2017-04-13 20:50 ` Shaohua Li
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).