OMAPDSS: VENC: fix NULL pointer dereference in DSS2 VENC sysfs debug attr on OMAP4
[zen-stable.git] / drivers / md / raid10.c
blob189838956aa992dab25079bf453ad80ef03ea399
1 /*
2 * raid10.c : Multiple Devices driver for Linux
4 * Copyright (C) 2000-2004 Neil Brown
6 * RAID-10 support for md.
8 * Base on code in raid1.c. See raid1.c for further copyright information.
11 * This program is free software; you can redistribute it and/or modify
12 * it under the terms of the GNU General Public License as published by
13 * the Free Software Foundation; either version 2, or (at your option)
14 * any later version.
16 * You should have received a copy of the GNU General Public License
17 * (for example /usr/src/linux/COPYING); if not, write to the Free
18 * Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
21 #include <linux/slab.h>
22 #include <linux/delay.h>
23 #include <linux/blkdev.h>
24 #include <linux/module.h>
25 #include <linux/seq_file.h>
26 #include <linux/ratelimit.h>
27 #include "md.h"
28 #include "raid10.h"
29 #include "raid0.h"
30 #include "bitmap.h"
33 * RAID10 provides a combination of RAID0 and RAID1 functionality.
34 * The layout of data is defined by
35 * chunk_size
36 * raid_disks
37 * near_copies (stored in low byte of layout)
38 * far_copies (stored in second byte of layout)
39 * far_offset (stored in bit 16 of layout )
41 * The data to be stored is divided into chunks using chunksize.
42 * Each device is divided into far_copies sections.
43 * In each section, chunks are laid out in a style similar to raid0, but
44 * near_copies copies of each chunk is stored (each on a different drive).
45 * The starting device for each section is offset near_copies from the starting
46 * device of the previous section.
47 * Thus they are (near_copies*far_copies) of each chunk, and each is on a different
48 * drive.
49 * near_copies and far_copies must be at least one, and their product is at most
50 * raid_disks.
52 * If far_offset is true, then the far_copies are handled a bit differently.
53 * The copies are still in different stripes, but instead of be very far apart
54 * on disk, there are adjacent stripes.
58 * Number of guaranteed r10bios in case of extreme VM load:
60 #define NR_RAID10_BIOS 256
62 /* When there are this many requests queue to be written by
63 * the raid10 thread, we become 'congested' to provide back-pressure
64 * for writeback.
66 static int max_queued_requests = 1024;
68 static void allow_barrier(struct r10conf *conf);
69 static void lower_barrier(struct r10conf *conf);
70 static int enough(struct r10conf *conf, int ignore);
72 static void * r10bio_pool_alloc(gfp_t gfp_flags, void *data)
74 struct r10conf *conf = data;
75 int size = offsetof(struct r10bio, devs[conf->copies]);
77 /* allocate a r10bio with room for raid_disks entries in the
78 * bios array */
79 return kzalloc(size, gfp_flags);
82 static void r10bio_pool_free(void *r10_bio, void *data)
84 kfree(r10_bio);
87 /* Maximum size of each resync request */
88 #define RESYNC_BLOCK_SIZE (64*1024)
89 #define RESYNC_PAGES ((RESYNC_BLOCK_SIZE + PAGE_SIZE-1) / PAGE_SIZE)
90 /* amount of memory to reserve for resync requests */
91 #define RESYNC_WINDOW (1024*1024)
92 /* maximum number of concurrent requests, memory permitting */
93 #define RESYNC_DEPTH (32*1024*1024/RESYNC_BLOCK_SIZE)
96 * When performing a resync, we need to read and compare, so
97 * we need as many pages are there are copies.
98 * When performing a recovery, we need 2 bios, one for read,
99 * one for write (we recover only one drive per r10buf)
102 static void * r10buf_pool_alloc(gfp_t gfp_flags, void *data)
104 struct r10conf *conf = data;
105 struct page *page;
106 struct r10bio *r10_bio;
107 struct bio *bio;
108 int i, j;
109 int nalloc;
111 r10_bio = r10bio_pool_alloc(gfp_flags, conf);
112 if (!r10_bio)
113 return NULL;
115 if (test_bit(MD_RECOVERY_SYNC, &conf->mddev->recovery))
116 nalloc = conf->copies; /* resync */
117 else
118 nalloc = 2; /* recovery */
121 * Allocate bios.
123 for (j = nalloc ; j-- ; ) {
124 bio = bio_kmalloc(gfp_flags, RESYNC_PAGES);
125 if (!bio)
126 goto out_free_bio;
127 r10_bio->devs[j].bio = bio;
128 if (!conf->have_replacement)
129 continue;
130 bio = bio_kmalloc(gfp_flags, RESYNC_PAGES);
131 if (!bio)
132 goto out_free_bio;
133 r10_bio->devs[j].repl_bio = bio;
136 * Allocate RESYNC_PAGES data pages and attach them
137 * where needed.
139 for (j = 0 ; j < nalloc; j++) {
140 struct bio *rbio = r10_bio->devs[j].repl_bio;
141 bio = r10_bio->devs[j].bio;
142 for (i = 0; i < RESYNC_PAGES; i++) {
143 if (j == 1 && !test_bit(MD_RECOVERY_SYNC,
144 &conf->mddev->recovery)) {
145 /* we can share bv_page's during recovery */
146 struct bio *rbio = r10_bio->devs[0].bio;
147 page = rbio->bi_io_vec[i].bv_page;
148 get_page(page);
149 } else
150 page = alloc_page(gfp_flags);
151 if (unlikely(!page))
152 goto out_free_pages;
154 bio->bi_io_vec[i].bv_page = page;
155 if (rbio)
156 rbio->bi_io_vec[i].bv_page = page;
160 return r10_bio;
162 out_free_pages:
163 for ( ; i > 0 ; i--)
164 safe_put_page(bio->bi_io_vec[i-1].bv_page);
165 while (j--)
166 for (i = 0; i < RESYNC_PAGES ; i++)
167 safe_put_page(r10_bio->devs[j].bio->bi_io_vec[i].bv_page);
168 j = -1;
169 out_free_bio:
170 while (++j < nalloc) {
171 bio_put(r10_bio->devs[j].bio);
172 if (r10_bio->devs[j].repl_bio)
173 bio_put(r10_bio->devs[j].repl_bio);
175 r10bio_pool_free(r10_bio, conf);
176 return NULL;
179 static void r10buf_pool_free(void *__r10_bio, void *data)
181 int i;
182 struct r10conf *conf = data;
183 struct r10bio *r10bio = __r10_bio;
184 int j;
186 for (j=0; j < conf->copies; j++) {
187 struct bio *bio = r10bio->devs[j].bio;
188 if (bio) {
189 for (i = 0; i < RESYNC_PAGES; i++) {
190 safe_put_page(bio->bi_io_vec[i].bv_page);
191 bio->bi_io_vec[i].bv_page = NULL;
193 bio_put(bio);
195 bio = r10bio->devs[j].repl_bio;
196 if (bio)
197 bio_put(bio);
199 r10bio_pool_free(r10bio, conf);
202 static void put_all_bios(struct r10conf *conf, struct r10bio *r10_bio)
204 int i;
206 for (i = 0; i < conf->copies; i++) {
207 struct bio **bio = & r10_bio->devs[i].bio;
208 if (!BIO_SPECIAL(*bio))
209 bio_put(*bio);
210 *bio = NULL;
211 bio = &r10_bio->devs[i].repl_bio;
212 if (r10_bio->read_slot < 0 && !BIO_SPECIAL(*bio))
213 bio_put(*bio);
214 *bio = NULL;
218 static void free_r10bio(struct r10bio *r10_bio)
220 struct r10conf *conf = r10_bio->mddev->private;
222 put_all_bios(conf, r10_bio);
223 mempool_free(r10_bio, conf->r10bio_pool);
226 static void put_buf(struct r10bio *r10_bio)
228 struct r10conf *conf = r10_bio->mddev->private;
230 mempool_free(r10_bio, conf->r10buf_pool);
232 lower_barrier(conf);
235 static void reschedule_retry(struct r10bio *r10_bio)
237 unsigned long flags;
238 struct mddev *mddev = r10_bio->mddev;
239 struct r10conf *conf = mddev->private;
241 spin_lock_irqsave(&conf->device_lock, flags);
242 list_add(&r10_bio->retry_list, &conf->retry_list);
243 conf->nr_queued ++;
244 spin_unlock_irqrestore(&conf->device_lock, flags);
246 /* wake up frozen array... */
247 wake_up(&conf->wait_barrier);
249 md_wakeup_thread(mddev->thread);
253 * raid_end_bio_io() is called when we have finished servicing a mirrored
254 * operation and are ready to return a success/failure code to the buffer
255 * cache layer.
257 static void raid_end_bio_io(struct r10bio *r10_bio)
259 struct bio *bio = r10_bio->master_bio;
260 int done;
261 struct r10conf *conf = r10_bio->mddev->private;
263 if (bio->bi_phys_segments) {
264 unsigned long flags;
265 spin_lock_irqsave(&conf->device_lock, flags);
266 bio->bi_phys_segments--;
267 done = (bio->bi_phys_segments == 0);
268 spin_unlock_irqrestore(&conf->device_lock, flags);
269 } else
270 done = 1;
271 if (!test_bit(R10BIO_Uptodate, &r10_bio->state))
272 clear_bit(BIO_UPTODATE, &bio->bi_flags);
273 if (done) {
274 bio_endio(bio, 0);
276 * Wake up any possible resync thread that waits for the device
277 * to go idle.
279 allow_barrier(conf);
281 free_r10bio(r10_bio);
285 * Update disk head position estimator based on IRQ completion info.
287 static inline void update_head_pos(int slot, struct r10bio *r10_bio)
289 struct r10conf *conf = r10_bio->mddev->private;
291 conf->mirrors[r10_bio->devs[slot].devnum].head_position =
292 r10_bio->devs[slot].addr + (r10_bio->sectors);
296 * Find the disk number which triggered given bio
298 static int find_bio_disk(struct r10conf *conf, struct r10bio *r10_bio,
299 struct bio *bio, int *slotp, int *replp)
301 int slot;
302 int repl = 0;
304 for (slot = 0; slot < conf->copies; slot++) {
305 if (r10_bio->devs[slot].bio == bio)
306 break;
307 if (r10_bio->devs[slot].repl_bio == bio) {
308 repl = 1;
309 break;
313 BUG_ON(slot == conf->copies);
314 update_head_pos(slot, r10_bio);
316 if (slotp)
317 *slotp = slot;
318 if (replp)
319 *replp = repl;
320 return r10_bio->devs[slot].devnum;
323 static void raid10_end_read_request(struct bio *bio, int error)
325 int uptodate = test_bit(BIO_UPTODATE, &bio->bi_flags);
326 struct r10bio *r10_bio = bio->bi_private;
327 int slot, dev;
328 struct md_rdev *rdev;
329 struct r10conf *conf = r10_bio->mddev->private;
332 slot = r10_bio->read_slot;
333 dev = r10_bio->devs[slot].devnum;
334 rdev = r10_bio->devs[slot].rdev;
336 * this branch is our 'one mirror IO has finished' event handler:
338 update_head_pos(slot, r10_bio);
340 if (uptodate) {
342 * Set R10BIO_Uptodate in our master bio, so that
343 * we will return a good error code to the higher
344 * levels even if IO on some other mirrored buffer fails.
346 * The 'master' represents the composite IO operation to
347 * user-side. So if something waits for IO, then it will
348 * wait for the 'master' bio.
350 set_bit(R10BIO_Uptodate, &r10_bio->state);
351 } else {
352 /* If all other devices that store this block have
353 * failed, we want to return the error upwards rather
354 * than fail the last device. Here we redefine
355 * "uptodate" to mean "Don't want to retry"
357 unsigned long flags;
358 spin_lock_irqsave(&conf->device_lock, flags);
359 if (!enough(conf, rdev->raid_disk))
360 uptodate = 1;
361 spin_unlock_irqrestore(&conf->device_lock, flags);
363 if (uptodate) {
364 raid_end_bio_io(r10_bio);
365 rdev_dec_pending(rdev, conf->mddev);
366 } else {
368 * oops, read error - keep the refcount on the rdev
370 char b[BDEVNAME_SIZE];
371 printk_ratelimited(KERN_ERR
372 "md/raid10:%s: %s: rescheduling sector %llu\n",
373 mdname(conf->mddev),
374 bdevname(rdev->bdev, b),
375 (unsigned long long)r10_bio->sector);
376 set_bit(R10BIO_ReadError, &r10_bio->state);
377 reschedule_retry(r10_bio);
381 static void close_write(struct r10bio *r10_bio)
383 /* clear the bitmap if all writes complete successfully */
384 bitmap_endwrite(r10_bio->mddev->bitmap, r10_bio->sector,
385 r10_bio->sectors,
386 !test_bit(R10BIO_Degraded, &r10_bio->state),
388 md_write_end(r10_bio->mddev);
391 static void one_write_done(struct r10bio *r10_bio)
393 if (atomic_dec_and_test(&r10_bio->remaining)) {
394 if (test_bit(R10BIO_WriteError, &r10_bio->state))
395 reschedule_retry(r10_bio);
396 else {
397 close_write(r10_bio);
398 if (test_bit(R10BIO_MadeGood, &r10_bio->state))
399 reschedule_retry(r10_bio);
400 else
401 raid_end_bio_io(r10_bio);
406 static void raid10_end_write_request(struct bio *bio, int error)
408 int uptodate = test_bit(BIO_UPTODATE, &bio->bi_flags);
409 struct r10bio *r10_bio = bio->bi_private;
410 int dev;
411 int dec_rdev = 1;
412 struct r10conf *conf = r10_bio->mddev->private;
413 int slot, repl;
414 struct md_rdev *rdev = NULL;
416 dev = find_bio_disk(conf, r10_bio, bio, &slot, &repl);
418 if (repl)
419 rdev = conf->mirrors[dev].replacement;
420 if (!rdev) {
421 smp_rmb();
422 repl = 0;
423 rdev = conf->mirrors[dev].rdev;
426 * this branch is our 'one mirror IO has finished' event handler:
428 if (!uptodate) {
429 if (repl)
430 /* Never record new bad blocks to replacement,
431 * just fail it.
433 md_error(rdev->mddev, rdev);
434 else {
435 set_bit(WriteErrorSeen, &rdev->flags);
436 if (!test_and_set_bit(WantReplacement, &rdev->flags))
437 set_bit(MD_RECOVERY_NEEDED,
438 &rdev->mddev->recovery);
439 set_bit(R10BIO_WriteError, &r10_bio->state);
440 dec_rdev = 0;
442 } else {
444 * Set R10BIO_Uptodate in our master bio, so that
445 * we will return a good error code for to the higher
446 * levels even if IO on some other mirrored buffer fails.
448 * The 'master' represents the composite IO operation to
449 * user-side. So if something waits for IO, then it will
450 * wait for the 'master' bio.
452 sector_t first_bad;
453 int bad_sectors;
455 set_bit(R10BIO_Uptodate, &r10_bio->state);
457 /* Maybe we can clear some bad blocks. */
458 if (is_badblock(rdev,
459 r10_bio->devs[slot].addr,
460 r10_bio->sectors,
461 &first_bad, &bad_sectors)) {
462 bio_put(bio);
463 if (repl)
464 r10_bio->devs[slot].repl_bio = IO_MADE_GOOD;
465 else
466 r10_bio->devs[slot].bio = IO_MADE_GOOD;
467 dec_rdev = 0;
468 set_bit(R10BIO_MadeGood, &r10_bio->state);
474 * Let's see if all mirrored write operations have finished
475 * already.
477 one_write_done(r10_bio);
478 if (dec_rdev)
479 rdev_dec_pending(conf->mirrors[dev].rdev, conf->mddev);
483 * RAID10 layout manager
484 * As well as the chunksize and raid_disks count, there are two
485 * parameters: near_copies and far_copies.
486 * near_copies * far_copies must be <= raid_disks.
487 * Normally one of these will be 1.
488 * If both are 1, we get raid0.
489 * If near_copies == raid_disks, we get raid1.
491 * Chunks are laid out in raid0 style with near_copies copies of the
492 * first chunk, followed by near_copies copies of the next chunk and
493 * so on.
494 * If far_copies > 1, then after 1/far_copies of the array has been assigned
495 * as described above, we start again with a device offset of near_copies.
496 * So we effectively have another copy of the whole array further down all
497 * the drives, but with blocks on different drives.
498 * With this layout, and block is never stored twice on the one device.
500 * raid10_find_phys finds the sector offset of a given virtual sector
501 * on each device that it is on.
503 * raid10_find_virt does the reverse mapping, from a device and a
504 * sector offset to a virtual address
507 static void raid10_find_phys(struct r10conf *conf, struct r10bio *r10bio)
509 int n,f;
510 sector_t sector;
511 sector_t chunk;
512 sector_t stripe;
513 int dev;
515 int slot = 0;
517 /* now calculate first sector/dev */
518 chunk = r10bio->sector >> conf->chunk_shift;
519 sector = r10bio->sector & conf->chunk_mask;
521 chunk *= conf->near_copies;
522 stripe = chunk;
523 dev = sector_div(stripe, conf->raid_disks);
524 if (conf->far_offset)
525 stripe *= conf->far_copies;
527 sector += stripe << conf->chunk_shift;
529 /* and calculate all the others */
530 for (n=0; n < conf->near_copies; n++) {
531 int d = dev;
532 sector_t s = sector;
533 r10bio->devs[slot].addr = sector;
534 r10bio->devs[slot].devnum = d;
535 slot++;
537 for (f = 1; f < conf->far_copies; f++) {
538 d += conf->near_copies;
539 if (d >= conf->raid_disks)
540 d -= conf->raid_disks;
541 s += conf->stride;
542 r10bio->devs[slot].devnum = d;
543 r10bio->devs[slot].addr = s;
544 slot++;
546 dev++;
547 if (dev >= conf->raid_disks) {
548 dev = 0;
549 sector += (conf->chunk_mask + 1);
552 BUG_ON(slot != conf->copies);
555 static sector_t raid10_find_virt(struct r10conf *conf, sector_t sector, int dev)
557 sector_t offset, chunk, vchunk;
559 offset = sector & conf->chunk_mask;
560 if (conf->far_offset) {
561 int fc;
562 chunk = sector >> conf->chunk_shift;
563 fc = sector_div(chunk, conf->far_copies);
564 dev -= fc * conf->near_copies;
565 if (dev < 0)
566 dev += conf->raid_disks;
567 } else {
568 while (sector >= conf->stride) {
569 sector -= conf->stride;
570 if (dev < conf->near_copies)
571 dev += conf->raid_disks - conf->near_copies;
572 else
573 dev -= conf->near_copies;
575 chunk = sector >> conf->chunk_shift;
577 vchunk = chunk * conf->raid_disks + dev;
578 sector_div(vchunk, conf->near_copies);
579 return (vchunk << conf->chunk_shift) + offset;
583 * raid10_mergeable_bvec -- tell bio layer if a two requests can be merged
584 * @q: request queue
585 * @bvm: properties of new bio
586 * @biovec: the request that could be merged to it.
588 * Return amount of bytes we can accept at this offset
589 * If near_copies == raid_disk, there are no striping issues,
590 * but in that case, the function isn't called at all.
592 static int raid10_mergeable_bvec(struct request_queue *q,
593 struct bvec_merge_data *bvm,
594 struct bio_vec *biovec)
596 struct mddev *mddev = q->queuedata;
597 sector_t sector = bvm->bi_sector + get_start_sect(bvm->bi_bdev);
598 int max;
599 unsigned int chunk_sectors = mddev->chunk_sectors;
600 unsigned int bio_sectors = bvm->bi_size >> 9;
602 max = (chunk_sectors - ((sector & (chunk_sectors - 1)) + bio_sectors)) << 9;
603 if (max < 0) max = 0; /* bio_add cannot handle a negative return */
604 if (max <= biovec->bv_len && bio_sectors == 0)
605 return biovec->bv_len;
606 else
607 return max;
611 * This routine returns the disk from which the requested read should
612 * be done. There is a per-array 'next expected sequential IO' sector
613 * number - if this matches on the next IO then we use the last disk.
614 * There is also a per-disk 'last know head position' sector that is
615 * maintained from IRQ contexts, both the normal and the resync IO
616 * completion handlers update this position correctly. If there is no
617 * perfect sequential match then we pick the disk whose head is closest.
619 * If there are 2 mirrors in the same 2 devices, performance degrades
620 * because position is mirror, not device based.
622 * The rdev for the device selected will have nr_pending incremented.
626 * FIXME: possibly should rethink readbalancing and do it differently
627 * depending on near_copies / far_copies geometry.
629 static struct md_rdev *read_balance(struct r10conf *conf,
630 struct r10bio *r10_bio,
631 int *max_sectors)
633 const sector_t this_sector = r10_bio->sector;
634 int disk, slot;
635 int sectors = r10_bio->sectors;
636 int best_good_sectors;
637 sector_t new_distance, best_dist;
638 struct md_rdev *rdev, *best_rdev;
639 int do_balance;
640 int best_slot;
642 raid10_find_phys(conf, r10_bio);
643 rcu_read_lock();
644 retry:
645 sectors = r10_bio->sectors;
646 best_slot = -1;
647 best_rdev = NULL;
648 best_dist = MaxSector;
649 best_good_sectors = 0;
650 do_balance = 1;
652 * Check if we can balance. We can balance on the whole
653 * device if no resync is going on (recovery is ok), or below
654 * the resync window. We take the first readable disk when
655 * above the resync window.
657 if (conf->mddev->recovery_cp < MaxSector
658 && (this_sector + sectors >= conf->next_resync))
659 do_balance = 0;
661 for (slot = 0; slot < conf->copies ; slot++) {
662 sector_t first_bad;
663 int bad_sectors;
664 sector_t dev_sector;
666 if (r10_bio->devs[slot].bio == IO_BLOCKED)
667 continue;
668 disk = r10_bio->devs[slot].devnum;
669 rdev = rcu_dereference(conf->mirrors[disk].replacement);
670 if (rdev == NULL || test_bit(Faulty, &rdev->flags) ||
671 r10_bio->devs[slot].addr + sectors > rdev->recovery_offset)
672 rdev = rcu_dereference(conf->mirrors[disk].rdev);
673 if (rdev == NULL)
674 continue;
675 if (test_bit(Faulty, &rdev->flags))
676 continue;
677 if (!test_bit(In_sync, &rdev->flags) &&
678 r10_bio->devs[slot].addr + sectors > rdev->recovery_offset)
679 continue;
681 dev_sector = r10_bio->devs[slot].addr;
682 if (is_badblock(rdev, dev_sector, sectors,
683 &first_bad, &bad_sectors)) {
684 if (best_dist < MaxSector)
685 /* Already have a better slot */
686 continue;
687 if (first_bad <= dev_sector) {
688 /* Cannot read here. If this is the
689 * 'primary' device, then we must not read
690 * beyond 'bad_sectors' from another device.
692 bad_sectors -= (dev_sector - first_bad);
693 if (!do_balance && sectors > bad_sectors)
694 sectors = bad_sectors;
695 if (best_good_sectors > sectors)
696 best_good_sectors = sectors;
697 } else {
698 sector_t good_sectors =
699 first_bad - dev_sector;
700 if (good_sectors > best_good_sectors) {
701 best_good_sectors = good_sectors;
702 best_slot = slot;
703 best_rdev = rdev;
705 if (!do_balance)
706 /* Must read from here */
707 break;
709 continue;
710 } else
711 best_good_sectors = sectors;
713 if (!do_balance)
714 break;
716 /* This optimisation is debatable, and completely destroys
717 * sequential read speed for 'far copies' arrays. So only
718 * keep it for 'near' arrays, and review those later.
720 if (conf->near_copies > 1 && !atomic_read(&rdev->nr_pending))
721 break;
723 /* for far > 1 always use the lowest address */
724 if (conf->far_copies > 1)
725 new_distance = r10_bio->devs[slot].addr;
726 else
727 new_distance = abs(r10_bio->devs[slot].addr -
728 conf->mirrors[disk].head_position);
729 if (new_distance < best_dist) {
730 best_dist = new_distance;
731 best_slot = slot;
732 best_rdev = rdev;
735 if (slot >= conf->copies) {
736 slot = best_slot;
737 rdev = best_rdev;
740 if (slot >= 0) {
741 atomic_inc(&rdev->nr_pending);
742 if (test_bit(Faulty, &rdev->flags)) {
743 /* Cannot risk returning a device that failed
744 * before we inc'ed nr_pending
746 rdev_dec_pending(rdev, conf->mddev);
747 goto retry;
749 r10_bio->read_slot = slot;
750 } else
751 rdev = NULL;
752 rcu_read_unlock();
753 *max_sectors = best_good_sectors;
755 return rdev;
758 static int raid10_congested(void *data, int bits)
760 struct mddev *mddev = data;
761 struct r10conf *conf = mddev->private;
762 int i, ret = 0;
764 if ((bits & (1 << BDI_async_congested)) &&
765 conf->pending_count >= max_queued_requests)
766 return 1;
768 if (mddev_congested(mddev, bits))
769 return 1;
770 rcu_read_lock();
771 for (i = 0; i < conf->raid_disks && ret == 0; i++) {
772 struct md_rdev *rdev = rcu_dereference(conf->mirrors[i].rdev);
773 if (rdev && !test_bit(Faulty, &rdev->flags)) {
774 struct request_queue *q = bdev_get_queue(rdev->bdev);
776 ret |= bdi_congested(&q->backing_dev_info, bits);
779 rcu_read_unlock();
780 return ret;
783 static void flush_pending_writes(struct r10conf *conf)
785 /* Any writes that have been queued but are awaiting
786 * bitmap updates get flushed here.
788 spin_lock_irq(&conf->device_lock);
790 if (conf->pending_bio_list.head) {
791 struct bio *bio;
792 bio = bio_list_get(&conf->pending_bio_list);
793 conf->pending_count = 0;
794 spin_unlock_irq(&conf->device_lock);
795 /* flush any pending bitmap writes to disk
796 * before proceeding w/ I/O */
797 bitmap_unplug(conf->mddev->bitmap);
798 wake_up(&conf->wait_barrier);
800 while (bio) { /* submit pending writes */
801 struct bio *next = bio->bi_next;
802 bio->bi_next = NULL;
803 generic_make_request(bio);
804 bio = next;
806 } else
807 spin_unlock_irq(&conf->device_lock);
810 /* Barriers....
811 * Sometimes we need to suspend IO while we do something else,
812 * either some resync/recovery, or reconfigure the array.
813 * To do this we raise a 'barrier'.
814 * The 'barrier' is a counter that can be raised multiple times
815 * to count how many activities are happening which preclude
816 * normal IO.
817 * We can only raise the barrier if there is no pending IO.
818 * i.e. if nr_pending == 0.
819 * We choose only to raise the barrier if no-one is waiting for the
820 * barrier to go down. This means that as soon as an IO request
821 * is ready, no other operations which require a barrier will start
822 * until the IO request has had a chance.
824 * So: regular IO calls 'wait_barrier'. When that returns there
825 * is no backgroup IO happening, It must arrange to call
826 * allow_barrier when it has finished its IO.
827 * backgroup IO calls must call raise_barrier. Once that returns
828 * there is no normal IO happeing. It must arrange to call
829 * lower_barrier when the particular background IO completes.
832 static void raise_barrier(struct r10conf *conf, int force)
834 BUG_ON(force && !conf->barrier);
835 spin_lock_irq(&conf->resync_lock);
837 /* Wait until no block IO is waiting (unless 'force') */
838 wait_event_lock_irq(conf->wait_barrier, force || !conf->nr_waiting,
839 conf->resync_lock, );
841 /* block any new IO from starting */
842 conf->barrier++;
844 /* Now wait for all pending IO to complete */
845 wait_event_lock_irq(conf->wait_barrier,
846 !conf->nr_pending && conf->barrier < RESYNC_DEPTH,
847 conf->resync_lock, );
849 spin_unlock_irq(&conf->resync_lock);
852 static void lower_barrier(struct r10conf *conf)
854 unsigned long flags;
855 spin_lock_irqsave(&conf->resync_lock, flags);
856 conf->barrier--;
857 spin_unlock_irqrestore(&conf->resync_lock, flags);
858 wake_up(&conf->wait_barrier);
861 static void wait_barrier(struct r10conf *conf)
863 spin_lock_irq(&conf->resync_lock);
864 if (conf->barrier) {
865 conf->nr_waiting++;
866 /* Wait for the barrier to drop.
867 * However if there are already pending
868 * requests (preventing the barrier from
869 * rising completely), and the
870 * pre-process bio queue isn't empty,
871 * then don't wait, as we need to empty
872 * that queue to get the nr_pending
873 * count down.
875 wait_event_lock_irq(conf->wait_barrier,
876 !conf->barrier ||
877 (conf->nr_pending &&
878 current->bio_list &&
879 !bio_list_empty(current->bio_list)),
880 conf->resync_lock,
882 conf->nr_waiting--;
884 conf->nr_pending++;
885 spin_unlock_irq(&conf->resync_lock);
888 static void allow_barrier(struct r10conf *conf)
890 unsigned long flags;
891 spin_lock_irqsave(&conf->resync_lock, flags);
892 conf->nr_pending--;
893 spin_unlock_irqrestore(&conf->resync_lock, flags);
894 wake_up(&conf->wait_barrier);
897 static void freeze_array(struct r10conf *conf)
899 /* stop syncio and normal IO and wait for everything to
900 * go quiet.
901 * We increment barrier and nr_waiting, and then
902 * wait until nr_pending match nr_queued+1
903 * This is called in the context of one normal IO request
904 * that has failed. Thus any sync request that might be pending
905 * will be blocked by nr_pending, and we need to wait for
906 * pending IO requests to complete or be queued for re-try.
907 * Thus the number queued (nr_queued) plus this request (1)
908 * must match the number of pending IOs (nr_pending) before
909 * we continue.
911 spin_lock_irq(&conf->resync_lock);
912 conf->barrier++;
913 conf->nr_waiting++;
914 wait_event_lock_irq(conf->wait_barrier,
915 conf->nr_pending == conf->nr_queued+1,
916 conf->resync_lock,
917 flush_pending_writes(conf));
919 spin_unlock_irq(&conf->resync_lock);
922 static void unfreeze_array(struct r10conf *conf)
924 /* reverse the effect of the freeze */
925 spin_lock_irq(&conf->resync_lock);
926 conf->barrier--;
927 conf->nr_waiting--;
928 wake_up(&conf->wait_barrier);
929 spin_unlock_irq(&conf->resync_lock);
932 static void make_request(struct mddev *mddev, struct bio * bio)
934 struct r10conf *conf = mddev->private;
935 struct r10bio *r10_bio;
936 struct bio *read_bio;
937 int i;
938 int chunk_sects = conf->chunk_mask + 1;
939 const int rw = bio_data_dir(bio);
940 const unsigned long do_sync = (bio->bi_rw & REQ_SYNC);
941 const unsigned long do_fua = (bio->bi_rw & REQ_FUA);
942 unsigned long flags;
943 struct md_rdev *blocked_rdev;
944 int plugged;
945 int sectors_handled;
946 int max_sectors;
948 if (unlikely(bio->bi_rw & REQ_FLUSH)) {
949 md_flush_request(mddev, bio);
950 return;
953 /* If this request crosses a chunk boundary, we need to
954 * split it. This will only happen for 1 PAGE (or less) requests.
956 if (unlikely( (bio->bi_sector & conf->chunk_mask) + (bio->bi_size >> 9)
957 > chunk_sects &&
958 conf->near_copies < conf->raid_disks)) {
959 struct bio_pair *bp;
960 /* Sanity check -- queue functions should prevent this happening */
961 if (bio->bi_vcnt != 1 ||
962 bio->bi_idx != 0)
963 goto bad_map;
964 /* This is a one page bio that upper layers
965 * refuse to split for us, so we need to split it.
967 bp = bio_split(bio,
968 chunk_sects - (bio->bi_sector & (chunk_sects - 1)) );
970 /* Each of these 'make_request' calls will call 'wait_barrier'.
971 * If the first succeeds but the second blocks due to the resync
972 * thread raising the barrier, we will deadlock because the
973 * IO to the underlying device will be queued in generic_make_request
974 * and will never complete, so will never reduce nr_pending.
975 * So increment nr_waiting here so no new raise_barriers will
976 * succeed, and so the second wait_barrier cannot block.
978 spin_lock_irq(&conf->resync_lock);
979 conf->nr_waiting++;
980 spin_unlock_irq(&conf->resync_lock);
982 make_request(mddev, &bp->bio1);
983 make_request(mddev, &bp->bio2);
985 spin_lock_irq(&conf->resync_lock);
986 conf->nr_waiting--;
987 wake_up(&conf->wait_barrier);
988 spin_unlock_irq(&conf->resync_lock);
990 bio_pair_release(bp);
991 return;
992 bad_map:
993 printk("md/raid10:%s: make_request bug: can't convert block across chunks"
994 " or bigger than %dk %llu %d\n", mdname(mddev), chunk_sects/2,
995 (unsigned long long)bio->bi_sector, bio->bi_size >> 10);
997 bio_io_error(bio);
998 return;
1001 md_write_start(mddev, bio);
1004 * Register the new request and wait if the reconstruction
1005 * thread has put up a bar for new requests.
1006 * Continue immediately if no resync is active currently.
1008 wait_barrier(conf);
1010 r10_bio = mempool_alloc(conf->r10bio_pool, GFP_NOIO);
1012 r10_bio->master_bio = bio;
1013 r10_bio->sectors = bio->bi_size >> 9;
1015 r10_bio->mddev = mddev;
1016 r10_bio->sector = bio->bi_sector;
1017 r10_bio->state = 0;
1019 /* We might need to issue multiple reads to different
1020 * devices if there are bad blocks around, so we keep
1021 * track of the number of reads in bio->bi_phys_segments.
1022 * If this is 0, there is only one r10_bio and no locking
1023 * will be needed when the request completes. If it is
1024 * non-zero, then it is the number of not-completed requests.
1026 bio->bi_phys_segments = 0;
1027 clear_bit(BIO_SEG_VALID, &bio->bi_flags);
1029 if (rw == READ) {
1031 * read balancing logic:
1033 struct md_rdev *rdev;
1034 int slot;
1036 read_again:
1037 rdev = read_balance(conf, r10_bio, &max_sectors);
1038 if (!rdev) {
1039 raid_end_bio_io(r10_bio);
1040 return;
1042 slot = r10_bio->read_slot;
1044 read_bio = bio_clone_mddev(bio, GFP_NOIO, mddev);
1045 md_trim_bio(read_bio, r10_bio->sector - bio->bi_sector,
1046 max_sectors);
1048 r10_bio->devs[slot].bio = read_bio;
1049 r10_bio->devs[slot].rdev = rdev;
1051 read_bio->bi_sector = r10_bio->devs[slot].addr +
1052 rdev->data_offset;
1053 read_bio->bi_bdev = rdev->bdev;
1054 read_bio->bi_end_io = raid10_end_read_request;
1055 read_bio->bi_rw = READ | do_sync;
1056 read_bio->bi_private = r10_bio;
1058 if (max_sectors < r10_bio->sectors) {
1059 /* Could not read all from this device, so we will
1060 * need another r10_bio.
1062 sectors_handled = (r10_bio->sectors + max_sectors
1063 - bio->bi_sector);
1064 r10_bio->sectors = max_sectors;
1065 spin_lock_irq(&conf->device_lock);
1066 if (bio->bi_phys_segments == 0)
1067 bio->bi_phys_segments = 2;
1068 else
1069 bio->bi_phys_segments++;
1070 spin_unlock(&conf->device_lock);
1071 /* Cannot call generic_make_request directly
1072 * as that will be queued in __generic_make_request
1073 * and subsequent mempool_alloc might block
1074 * waiting for it. so hand bio over to raid10d.
1076 reschedule_retry(r10_bio);
1078 r10_bio = mempool_alloc(conf->r10bio_pool, GFP_NOIO);
1080 r10_bio->master_bio = bio;
1081 r10_bio->sectors = ((bio->bi_size >> 9)
1082 - sectors_handled);
1083 r10_bio->state = 0;
1084 r10_bio->mddev = mddev;
1085 r10_bio->sector = bio->bi_sector + sectors_handled;
1086 goto read_again;
1087 } else
1088 generic_make_request(read_bio);
1089 return;
1093 * WRITE:
1095 if (conf->pending_count >= max_queued_requests) {
1096 md_wakeup_thread(mddev->thread);
1097 wait_event(conf->wait_barrier,
1098 conf->pending_count < max_queued_requests);
1100 /* first select target devices under rcu_lock and
1101 * inc refcount on their rdev. Record them by setting
1102 * bios[x] to bio
1103 * If there are known/acknowledged bad blocks on any device
1104 * on which we have seen a write error, we want to avoid
1105 * writing to those blocks. This potentially requires several
1106 * writes to write around the bad blocks. Each set of writes
1107 * gets its own r10_bio with a set of bios attached. The number
1108 * of r10_bios is recored in bio->bi_phys_segments just as with
1109 * the read case.
1111 plugged = mddev_check_plugged(mddev);
1113 r10_bio->read_slot = -1; /* make sure repl_bio gets freed */
1114 raid10_find_phys(conf, r10_bio);
1115 retry_write:
1116 blocked_rdev = NULL;
1117 rcu_read_lock();
1118 max_sectors = r10_bio->sectors;
1120 for (i = 0; i < conf->copies; i++) {
1121 int d = r10_bio->devs[i].devnum;
1122 struct md_rdev *rdev = rcu_dereference(conf->mirrors[d].rdev);
1123 struct md_rdev *rrdev = rcu_dereference(
1124 conf->mirrors[d].replacement);
1125 if (rdev == rrdev)
1126 rrdev = NULL;
1127 if (rdev && unlikely(test_bit(Blocked, &rdev->flags))) {
1128 atomic_inc(&rdev->nr_pending);
1129 blocked_rdev = rdev;
1130 break;
1132 if (rrdev && unlikely(test_bit(Blocked, &rrdev->flags))) {
1133 atomic_inc(&rrdev->nr_pending);
1134 blocked_rdev = rrdev;
1135 break;
1137 if (rrdev && test_bit(Faulty, &rrdev->flags))
1138 rrdev = NULL;
1140 r10_bio->devs[i].bio = NULL;
1141 r10_bio->devs[i].repl_bio = NULL;
1142 if (!rdev || test_bit(Faulty, &rdev->flags)) {
1143 set_bit(R10BIO_Degraded, &r10_bio->state);
1144 continue;
1146 if (test_bit(WriteErrorSeen, &rdev->flags)) {
1147 sector_t first_bad;
1148 sector_t dev_sector = r10_bio->devs[i].addr;
1149 int bad_sectors;
1150 int is_bad;
1152 is_bad = is_badblock(rdev, dev_sector,
1153 max_sectors,
1154 &first_bad, &bad_sectors);
1155 if (is_bad < 0) {
1156 /* Mustn't write here until the bad block
1157 * is acknowledged
1159 atomic_inc(&rdev->nr_pending);
1160 set_bit(BlockedBadBlocks, &rdev->flags);
1161 blocked_rdev = rdev;
1162 break;
1164 if (is_bad && first_bad <= dev_sector) {
1165 /* Cannot write here at all */
1166 bad_sectors -= (dev_sector - first_bad);
1167 if (bad_sectors < max_sectors)
1168 /* Mustn't write more than bad_sectors
1169 * to other devices yet
1171 max_sectors = bad_sectors;
1172 /* We don't set R10BIO_Degraded as that
1173 * only applies if the disk is missing,
1174 * so it might be re-added, and we want to
1175 * know to recover this chunk.
1176 * In this case the device is here, and the
1177 * fact that this chunk is not in-sync is
1178 * recorded in the bad block log.
1180 continue;
1182 if (is_bad) {
1183 int good_sectors = first_bad - dev_sector;
1184 if (good_sectors < max_sectors)
1185 max_sectors = good_sectors;
1188 r10_bio->devs[i].bio = bio;
1189 atomic_inc(&rdev->nr_pending);
1190 if (rrdev) {
1191 r10_bio->devs[i].repl_bio = bio;
1192 atomic_inc(&rrdev->nr_pending);
1195 rcu_read_unlock();
1197 if (unlikely(blocked_rdev)) {
1198 /* Have to wait for this device to get unblocked, then retry */
1199 int j;
1200 int d;
1202 for (j = 0; j < i; j++) {
1203 if (r10_bio->devs[j].bio) {
1204 d = r10_bio->devs[j].devnum;
1205 rdev_dec_pending(conf->mirrors[d].rdev, mddev);
1207 if (r10_bio->devs[j].repl_bio) {
1208 struct md_rdev *rdev;
1209 d = r10_bio->devs[j].devnum;
1210 rdev = conf->mirrors[d].replacement;
1211 if (!rdev) {
1212 /* Race with remove_disk */
1213 smp_mb();
1214 rdev = conf->mirrors[d].rdev;
1216 rdev_dec_pending(rdev, mddev);
1219 allow_barrier(conf);
1220 md_wait_for_blocked_rdev(blocked_rdev, mddev);
1221 wait_barrier(conf);
1222 goto retry_write;
1225 if (max_sectors < r10_bio->sectors) {
1226 /* We are splitting this into multiple parts, so
1227 * we need to prepare for allocating another r10_bio.
1229 r10_bio->sectors = max_sectors;
1230 spin_lock_irq(&conf->device_lock);
1231 if (bio->bi_phys_segments == 0)
1232 bio->bi_phys_segments = 2;
1233 else
1234 bio->bi_phys_segments++;
1235 spin_unlock_irq(&conf->device_lock);
1237 sectors_handled = r10_bio->sector + max_sectors - bio->bi_sector;
1239 atomic_set(&r10_bio->remaining, 1);
1240 bitmap_startwrite(mddev->bitmap, r10_bio->sector, r10_bio->sectors, 0);
1242 for (i = 0; i < conf->copies; i++) {
1243 struct bio *mbio;
1244 int d = r10_bio->devs[i].devnum;
1245 if (!r10_bio->devs[i].bio)
1246 continue;
1248 mbio = bio_clone_mddev(bio, GFP_NOIO, mddev);
1249 md_trim_bio(mbio, r10_bio->sector - bio->bi_sector,
1250 max_sectors);
1251 r10_bio->devs[i].bio = mbio;
1253 mbio->bi_sector = (r10_bio->devs[i].addr+
1254 conf->mirrors[d].rdev->data_offset);
1255 mbio->bi_bdev = conf->mirrors[d].rdev->bdev;
1256 mbio->bi_end_io = raid10_end_write_request;
1257 mbio->bi_rw = WRITE | do_sync | do_fua;
1258 mbio->bi_private = r10_bio;
1260 atomic_inc(&r10_bio->remaining);
1261 spin_lock_irqsave(&conf->device_lock, flags);
1262 bio_list_add(&conf->pending_bio_list, mbio);
1263 conf->pending_count++;
1264 spin_unlock_irqrestore(&conf->device_lock, flags);
1266 if (!r10_bio->devs[i].repl_bio)
1267 continue;
1269 mbio = bio_clone_mddev(bio, GFP_NOIO, mddev);
1270 md_trim_bio(mbio, r10_bio->sector - bio->bi_sector,
1271 max_sectors);
1272 r10_bio->devs[i].repl_bio = mbio;
1274 /* We are actively writing to the original device
1275 * so it cannot disappear, so the replacement cannot
1276 * become NULL here
1278 mbio->bi_sector = (r10_bio->devs[i].addr+
1279 conf->mirrors[d].replacement->data_offset);
1280 mbio->bi_bdev = conf->mirrors[d].replacement->bdev;
1281 mbio->bi_end_io = raid10_end_write_request;
1282 mbio->bi_rw = WRITE | do_sync | do_fua;
1283 mbio->bi_private = r10_bio;
1285 atomic_inc(&r10_bio->remaining);
1286 spin_lock_irqsave(&conf->device_lock, flags);
1287 bio_list_add(&conf->pending_bio_list, mbio);
1288 conf->pending_count++;
1289 spin_unlock_irqrestore(&conf->device_lock, flags);
1292 /* Don't remove the bias on 'remaining' (one_write_done) until
1293 * after checking if we need to go around again.
1296 if (sectors_handled < (bio->bi_size >> 9)) {
1297 one_write_done(r10_bio);
1298 /* We need another r10_bio. It has already been counted
1299 * in bio->bi_phys_segments.
1301 r10_bio = mempool_alloc(conf->r10bio_pool, GFP_NOIO);
1303 r10_bio->master_bio = bio;
1304 r10_bio->sectors = (bio->bi_size >> 9) - sectors_handled;
1306 r10_bio->mddev = mddev;
1307 r10_bio->sector = bio->bi_sector + sectors_handled;
1308 r10_bio->state = 0;
1309 goto retry_write;
1311 one_write_done(r10_bio);
1313 /* In case raid10d snuck in to freeze_array */
1314 wake_up(&conf->wait_barrier);
1316 if (do_sync || !mddev->bitmap || !plugged)
1317 md_wakeup_thread(mddev->thread);
1320 static void status(struct seq_file *seq, struct mddev *mddev)
1322 struct r10conf *conf = mddev->private;
1323 int i;
1325 if (conf->near_copies < conf->raid_disks)
1326 seq_printf(seq, " %dK chunks", mddev->chunk_sectors / 2);
1327 if (conf->near_copies > 1)
1328 seq_printf(seq, " %d near-copies", conf->near_copies);
1329 if (conf->far_copies > 1) {
1330 if (conf->far_offset)
1331 seq_printf(seq, " %d offset-copies", conf->far_copies);
1332 else
1333 seq_printf(seq, " %d far-copies", conf->far_copies);
1335 seq_printf(seq, " [%d/%d] [", conf->raid_disks,
1336 conf->raid_disks - mddev->degraded);
1337 for (i = 0; i < conf->raid_disks; i++)
1338 seq_printf(seq, "%s",
1339 conf->mirrors[i].rdev &&
1340 test_bit(In_sync, &conf->mirrors[i].rdev->flags) ? "U" : "_");
1341 seq_printf(seq, "]");
1344 /* check if there are enough drives for
1345 * every block to appear on atleast one.
1346 * Don't consider the device numbered 'ignore'
1347 * as we might be about to remove it.
1349 static int enough(struct r10conf *conf, int ignore)
1351 int first = 0;
1353 do {
1354 int n = conf->copies;
1355 int cnt = 0;
1356 while (n--) {
1357 if (conf->mirrors[first].rdev &&
1358 first != ignore)
1359 cnt++;
1360 first = (first+1) % conf->raid_disks;
1362 if (cnt == 0)
1363 return 0;
1364 } while (first != 0);
1365 return 1;
1368 static void error(struct mddev *mddev, struct md_rdev *rdev)
1370 char b[BDEVNAME_SIZE];
1371 struct r10conf *conf = mddev->private;
1374 * If it is not operational, then we have already marked it as dead
1375 * else if it is the last working disks, ignore the error, let the
1376 * next level up know.
1377 * else mark the drive as failed
1379 if (test_bit(In_sync, &rdev->flags)
1380 && !enough(conf, rdev->raid_disk))
1382 * Don't fail the drive, just return an IO error.
1384 return;
1385 if (test_and_clear_bit(In_sync, &rdev->flags)) {
1386 unsigned long flags;
1387 spin_lock_irqsave(&conf->device_lock, flags);
1388 mddev->degraded++;
1389 spin_unlock_irqrestore(&conf->device_lock, flags);
1391 * if recovery is running, make sure it aborts.
1393 set_bit(MD_RECOVERY_INTR, &mddev->recovery);
1395 set_bit(Blocked, &rdev->flags);
1396 set_bit(Faulty, &rdev->flags);
1397 set_bit(MD_CHANGE_DEVS, &mddev->flags);
1398 printk(KERN_ALERT
1399 "md/raid10:%s: Disk failure on %s, disabling device.\n"
1400 "md/raid10:%s: Operation continuing on %d devices.\n",
1401 mdname(mddev), bdevname(rdev->bdev, b),
1402 mdname(mddev), conf->raid_disks - mddev->degraded);
1405 static void print_conf(struct r10conf *conf)
1407 int i;
1408 struct mirror_info *tmp;
1410 printk(KERN_DEBUG "RAID10 conf printout:\n");
1411 if (!conf) {
1412 printk(KERN_DEBUG "(!conf)\n");
1413 return;
1415 printk(KERN_DEBUG " --- wd:%d rd:%d\n", conf->raid_disks - conf->mddev->degraded,
1416 conf->raid_disks);
1418 for (i = 0; i < conf->raid_disks; i++) {
1419 char b[BDEVNAME_SIZE];
1420 tmp = conf->mirrors + i;
1421 if (tmp->rdev)
1422 printk(KERN_DEBUG " disk %d, wo:%d, o:%d, dev:%s\n",
1423 i, !test_bit(In_sync, &tmp->rdev->flags),
1424 !test_bit(Faulty, &tmp->rdev->flags),
1425 bdevname(tmp->rdev->bdev,b));
1429 static void close_sync(struct r10conf *conf)
1431 wait_barrier(conf);
1432 allow_barrier(conf);
1434 mempool_destroy(conf->r10buf_pool);
1435 conf->r10buf_pool = NULL;
1438 static int raid10_spare_active(struct mddev *mddev)
1440 int i;
1441 struct r10conf *conf = mddev->private;
1442 struct mirror_info *tmp;
1443 int count = 0;
1444 unsigned long flags;
1447 * Find all non-in_sync disks within the RAID10 configuration
1448 * and mark them in_sync
1450 for (i = 0; i < conf->raid_disks; i++) {
1451 tmp = conf->mirrors + i;
1452 if (tmp->replacement
1453 && tmp->replacement->recovery_offset == MaxSector
1454 && !test_bit(Faulty, &tmp->replacement->flags)
1455 && !test_and_set_bit(In_sync, &tmp->replacement->flags)) {
1456 /* Replacement has just become active */
1457 if (!tmp->rdev
1458 || !test_and_clear_bit(In_sync, &tmp->rdev->flags))
1459 count++;
1460 if (tmp->rdev) {
1461 /* Replaced device not technically faulty,
1462 * but we need to be sure it gets removed
1463 * and never re-added.
1465 set_bit(Faulty, &tmp->rdev->flags);
1466 sysfs_notify_dirent_safe(
1467 tmp->rdev->sysfs_state);
1469 sysfs_notify_dirent_safe(tmp->replacement->sysfs_state);
1470 } else if (tmp->rdev
1471 && !test_bit(Faulty, &tmp->rdev->flags)
1472 && !test_and_set_bit(In_sync, &tmp->rdev->flags)) {
1473 count++;
1474 sysfs_notify_dirent(tmp->rdev->sysfs_state);
1477 spin_lock_irqsave(&conf->device_lock, flags);
1478 mddev->degraded -= count;
1479 spin_unlock_irqrestore(&conf->device_lock, flags);
1481 print_conf(conf);
1482 return count;
1486 static int raid10_add_disk(struct mddev *mddev, struct md_rdev *rdev)
1488 struct r10conf *conf = mddev->private;
1489 int err = -EEXIST;
1490 int mirror;
1491 int first = 0;
1492 int last = conf->raid_disks - 1;
1494 if (mddev->recovery_cp < MaxSector)
1495 /* only hot-add to in-sync arrays, as recovery is
1496 * very different from resync
1498 return -EBUSY;
1499 if (!enough(conf, -1))
1500 return -EINVAL;
1502 if (rdev->raid_disk >= 0)
1503 first = last = rdev->raid_disk;
1505 if (rdev->saved_raid_disk >= first &&
1506 conf->mirrors[rdev->saved_raid_disk].rdev == NULL)
1507 mirror = rdev->saved_raid_disk;
1508 else
1509 mirror = first;
1510 for ( ; mirror <= last ; mirror++) {
1511 struct mirror_info *p = &conf->mirrors[mirror];
1512 if (p->recovery_disabled == mddev->recovery_disabled)
1513 continue;
1514 if (p->rdev) {
1515 if (!test_bit(WantReplacement, &p->rdev->flags) ||
1516 p->replacement != NULL)
1517 continue;
1518 clear_bit(In_sync, &rdev->flags);
1519 set_bit(Replacement, &rdev->flags);
1520 rdev->raid_disk = mirror;
1521 err = 0;
1522 disk_stack_limits(mddev->gendisk, rdev->bdev,
1523 rdev->data_offset << 9);
1524 if (rdev->bdev->bd_disk->queue->merge_bvec_fn) {
1525 blk_queue_max_segments(mddev->queue, 1);
1526 blk_queue_segment_boundary(mddev->queue,
1527 PAGE_CACHE_SIZE - 1);
1529 conf->fullsync = 1;
1530 rcu_assign_pointer(p->replacement, rdev);
1531 break;
1534 disk_stack_limits(mddev->gendisk, rdev->bdev,
1535 rdev->data_offset << 9);
1536 /* as we don't honour merge_bvec_fn, we must
1537 * never risk violating it, so limit
1538 * ->max_segments to one lying with a single
1539 * page, as a one page request is never in
1540 * violation.
1542 if (rdev->bdev->bd_disk->queue->merge_bvec_fn) {
1543 blk_queue_max_segments(mddev->queue, 1);
1544 blk_queue_segment_boundary(mddev->queue,
1545 PAGE_CACHE_SIZE - 1);
1548 p->head_position = 0;
1549 p->recovery_disabled = mddev->recovery_disabled - 1;
1550 rdev->raid_disk = mirror;
1551 err = 0;
1552 if (rdev->saved_raid_disk != mirror)
1553 conf->fullsync = 1;
1554 rcu_assign_pointer(p->rdev, rdev);
1555 break;
1558 md_integrity_add_rdev(rdev, mddev);
1559 print_conf(conf);
1560 return err;
1563 static int raid10_remove_disk(struct mddev *mddev, struct md_rdev *rdev)
1565 struct r10conf *conf = mddev->private;
1566 int err = 0;
1567 int number = rdev->raid_disk;
1568 struct md_rdev **rdevp;
1569 struct mirror_info *p = conf->mirrors + number;
1571 print_conf(conf);
1572 if (rdev == p->rdev)
1573 rdevp = &p->rdev;
1574 else if (rdev == p->replacement)
1575 rdevp = &p->replacement;
1576 else
1577 return 0;
1579 if (test_bit(In_sync, &rdev->flags) ||
1580 atomic_read(&rdev->nr_pending)) {
1581 err = -EBUSY;
1582 goto abort;
1584 /* Only remove faulty devices if recovery
1585 * is not possible.
1587 if (!test_bit(Faulty, &rdev->flags) &&
1588 mddev->recovery_disabled != p->recovery_disabled &&
1589 (!p->replacement || p->replacement == rdev) &&
1590 enough(conf, -1)) {
1591 err = -EBUSY;
1592 goto abort;
1594 *rdevp = NULL;
1595 synchronize_rcu();
1596 if (atomic_read(&rdev->nr_pending)) {
1597 /* lost the race, try later */
1598 err = -EBUSY;
1599 *rdevp = rdev;
1600 goto abort;
1601 } else if (p->replacement) {
1602 /* We must have just cleared 'rdev' */
1603 p->rdev = p->replacement;
1604 clear_bit(Replacement, &p->replacement->flags);
1605 smp_mb(); /* Make sure other CPUs may see both as identical
1606 * but will never see neither -- if they are careful.
1608 p->replacement = NULL;
1609 clear_bit(WantReplacement, &rdev->flags);
1610 } else
1611 /* We might have just remove the Replacement as faulty
1612 * Clear the flag just in case
1614 clear_bit(WantReplacement, &rdev->flags);
1616 err = md_integrity_register(mddev);
1618 abort:
1620 print_conf(conf);
1621 return err;
1625 static void end_sync_read(struct bio *bio, int error)
1627 struct r10bio *r10_bio = bio->bi_private;
1628 struct r10conf *conf = r10_bio->mddev->private;
1629 int d;
1631 d = find_bio_disk(conf, r10_bio, bio, NULL, NULL);
1633 if (test_bit(BIO_UPTODATE, &bio->bi_flags))
1634 set_bit(R10BIO_Uptodate, &r10_bio->state);
1635 else
1636 /* The write handler will notice the lack of
1637 * R10BIO_Uptodate and record any errors etc
1639 atomic_add(r10_bio->sectors,
1640 &conf->mirrors[d].rdev->corrected_errors);
1642 /* for reconstruct, we always reschedule after a read.
1643 * for resync, only after all reads
1645 rdev_dec_pending(conf->mirrors[d].rdev, conf->mddev);
1646 if (test_bit(R10BIO_IsRecover, &r10_bio->state) ||
1647 atomic_dec_and_test(&r10_bio->remaining)) {
1648 /* we have read all the blocks,
1649 * do the comparison in process context in raid10d
1651 reschedule_retry(r10_bio);
1655 static void end_sync_request(struct r10bio *r10_bio)
1657 struct mddev *mddev = r10_bio->mddev;
1659 while (atomic_dec_and_test(&r10_bio->remaining)) {
1660 if (r10_bio->master_bio == NULL) {
1661 /* the primary of several recovery bios */
1662 sector_t s = r10_bio->sectors;
1663 if (test_bit(R10BIO_MadeGood, &r10_bio->state) ||
1664 test_bit(R10BIO_WriteError, &r10_bio->state))
1665 reschedule_retry(r10_bio);
1666 else
1667 put_buf(r10_bio);
1668 md_done_sync(mddev, s, 1);
1669 break;
1670 } else {
1671 struct r10bio *r10_bio2 = (struct r10bio *)r10_bio->master_bio;
1672 if (test_bit(R10BIO_MadeGood, &r10_bio->state) ||
1673 test_bit(R10BIO_WriteError, &r10_bio->state))
1674 reschedule_retry(r10_bio);
1675 else
1676 put_buf(r10_bio);
1677 r10_bio = r10_bio2;
1682 static void end_sync_write(struct bio *bio, int error)
1684 int uptodate = test_bit(BIO_UPTODATE, &bio->bi_flags);
1685 struct r10bio *r10_bio = bio->bi_private;
1686 struct mddev *mddev = r10_bio->mddev;
1687 struct r10conf *conf = mddev->private;
1688 int d;
1689 sector_t first_bad;
1690 int bad_sectors;
1691 int slot;
1692 int repl;
1693 struct md_rdev *rdev = NULL;
1695 d = find_bio_disk(conf, r10_bio, bio, &slot, &repl);
1696 if (repl)
1697 rdev = conf->mirrors[d].replacement;
1698 if (!rdev) {
1699 smp_mb();
1700 rdev = conf->mirrors[d].rdev;
1703 if (!uptodate) {
1704 if (repl)
1705 md_error(mddev, rdev);
1706 else {
1707 set_bit(WriteErrorSeen, &rdev->flags);
1708 if (!test_and_set_bit(WantReplacement, &rdev->flags))
1709 set_bit(MD_RECOVERY_NEEDED,
1710 &rdev->mddev->recovery);
1711 set_bit(R10BIO_WriteError, &r10_bio->state);
1713 } else if (is_badblock(rdev,
1714 r10_bio->devs[slot].addr,
1715 r10_bio->sectors,
1716 &first_bad, &bad_sectors))
1717 set_bit(R10BIO_MadeGood, &r10_bio->state);
1719 rdev_dec_pending(rdev, mddev);
1721 end_sync_request(r10_bio);
1725 * Note: sync and recover and handled very differently for raid10
1726 * This code is for resync.
1727 * For resync, we read through virtual addresses and read all blocks.
1728 * If there is any error, we schedule a write. The lowest numbered
1729 * drive is authoritative.
1730 * However requests come for physical address, so we need to map.
1731 * For every physical address there are raid_disks/copies virtual addresses,
1732 * which is always are least one, but is not necessarly an integer.
1733 * This means that a physical address can span multiple chunks, so we may
1734 * have to submit multiple io requests for a single sync request.
1737 * We check if all blocks are in-sync and only write to blocks that
1738 * aren't in sync
1740 static void sync_request_write(struct mddev *mddev, struct r10bio *r10_bio)
1742 struct r10conf *conf = mddev->private;
1743 int i, first;
1744 struct bio *tbio, *fbio;
1745 int vcnt;
1747 atomic_set(&r10_bio->remaining, 1);
1749 /* find the first device with a block */
1750 for (i=0; i<conf->copies; i++)
1751 if (test_bit(BIO_UPTODATE, &r10_bio->devs[i].bio->bi_flags))
1752 break;
1754 if (i == conf->copies)
1755 goto done;
1757 first = i;
1758 fbio = r10_bio->devs[i].bio;
1760 vcnt = (r10_bio->sectors + (PAGE_SIZE >> 9) - 1) >> (PAGE_SHIFT - 9);
1761 /* now find blocks with errors */
1762 for (i=0 ; i < conf->copies ; i++) {
1763 int j, d;
1765 tbio = r10_bio->devs[i].bio;
1767 if (tbio->bi_end_io != end_sync_read)
1768 continue;
1769 if (i == first)
1770 continue;
1771 if (test_bit(BIO_UPTODATE, &r10_bio->devs[i].bio->bi_flags)) {
1772 /* We know that the bi_io_vec layout is the same for
1773 * both 'first' and 'i', so we just compare them.
1774 * All vec entries are PAGE_SIZE;
1776 for (j = 0; j < vcnt; j++)
1777 if (memcmp(page_address(fbio->bi_io_vec[j].bv_page),
1778 page_address(tbio->bi_io_vec[j].bv_page),
1779 PAGE_SIZE))
1780 break;
1781 if (j == vcnt)
1782 continue;
1783 mddev->resync_mismatches += r10_bio->sectors;
1784 if (test_bit(MD_RECOVERY_CHECK, &mddev->recovery))
1785 /* Don't fix anything. */
1786 continue;
1788 /* Ok, we need to write this bio, either to correct an
1789 * inconsistency or to correct an unreadable block.
1790 * First we need to fixup bv_offset, bv_len and
1791 * bi_vecs, as the read request might have corrupted these
1793 tbio->bi_vcnt = vcnt;
1794 tbio->bi_size = r10_bio->sectors << 9;
1795 tbio->bi_idx = 0;
1796 tbio->bi_phys_segments = 0;
1797 tbio->bi_flags &= ~(BIO_POOL_MASK - 1);
1798 tbio->bi_flags |= 1 << BIO_UPTODATE;
1799 tbio->bi_next = NULL;
1800 tbio->bi_rw = WRITE;
1801 tbio->bi_private = r10_bio;
1802 tbio->bi_sector = r10_bio->devs[i].addr;
1804 for (j=0; j < vcnt ; j++) {
1805 tbio->bi_io_vec[j].bv_offset = 0;
1806 tbio->bi_io_vec[j].bv_len = PAGE_SIZE;
1808 memcpy(page_address(tbio->bi_io_vec[j].bv_page),
1809 page_address(fbio->bi_io_vec[j].bv_page),
1810 PAGE_SIZE);
1812 tbio->bi_end_io = end_sync_write;
1814 d = r10_bio->devs[i].devnum;
1815 atomic_inc(&conf->mirrors[d].rdev->nr_pending);
1816 atomic_inc(&r10_bio->remaining);
1817 md_sync_acct(conf->mirrors[d].rdev->bdev, tbio->bi_size >> 9);
1819 tbio->bi_sector += conf->mirrors[d].rdev->data_offset;
1820 tbio->bi_bdev = conf->mirrors[d].rdev->bdev;
1821 generic_make_request(tbio);
1824 /* Now write out to any replacement devices
1825 * that are active
1827 for (i = 0; i < conf->copies; i++) {
1828 int j, d;
1830 tbio = r10_bio->devs[i].repl_bio;
1831 if (!tbio || !tbio->bi_end_io)
1832 continue;
1833 if (r10_bio->devs[i].bio->bi_end_io != end_sync_write
1834 && r10_bio->devs[i].bio != fbio)
1835 for (j = 0; j < vcnt; j++)
1836 memcpy(page_address(tbio->bi_io_vec[j].bv_page),
1837 page_address(fbio->bi_io_vec[j].bv_page),
1838 PAGE_SIZE);
1839 d = r10_bio->devs[i].devnum;
1840 atomic_inc(&r10_bio->remaining);
1841 md_sync_acct(conf->mirrors[d].replacement->bdev,
1842 tbio->bi_size >> 9);
1843 generic_make_request(tbio);
1846 done:
1847 if (atomic_dec_and_test(&r10_bio->remaining)) {
1848 md_done_sync(mddev, r10_bio->sectors, 1);
1849 put_buf(r10_bio);
1854 * Now for the recovery code.
1855 * Recovery happens across physical sectors.
1856 * We recover all non-is_sync drives by finding the virtual address of
1857 * each, and then choose a working drive that also has that virt address.
1858 * There is a separate r10_bio for each non-in_sync drive.
1859 * Only the first two slots are in use. The first for reading,
1860 * The second for writing.
1863 static void fix_recovery_read_error(struct r10bio *r10_bio)
1865 /* We got a read error during recovery.
1866 * We repeat the read in smaller page-sized sections.
1867 * If a read succeeds, write it to the new device or record
1868 * a bad block if we cannot.
1869 * If a read fails, record a bad block on both old and
1870 * new devices.
1872 struct mddev *mddev = r10_bio->mddev;
1873 struct r10conf *conf = mddev->private;
1874 struct bio *bio = r10_bio->devs[0].bio;
1875 sector_t sect = 0;
1876 int sectors = r10_bio->sectors;
1877 int idx = 0;
1878 int dr = r10_bio->devs[0].devnum;
1879 int dw = r10_bio->devs[1].devnum;
1881 while (sectors) {
1882 int s = sectors;
1883 struct md_rdev *rdev;
1884 sector_t addr;
1885 int ok;
1887 if (s > (PAGE_SIZE>>9))
1888 s = PAGE_SIZE >> 9;
1890 rdev = conf->mirrors[dr].rdev;
1891 addr = r10_bio->devs[0].addr + sect,
1892 ok = sync_page_io(rdev,
1893 addr,
1894 s << 9,
1895 bio->bi_io_vec[idx].bv_page,
1896 READ, false);
1897 if (ok) {
1898 rdev = conf->mirrors[dw].rdev;
1899 addr = r10_bio->devs[1].addr + sect;
1900 ok = sync_page_io(rdev,
1901 addr,
1902 s << 9,
1903 bio->bi_io_vec[idx].bv_page,
1904 WRITE, false);
1905 if (!ok) {
1906 set_bit(WriteErrorSeen, &rdev->flags);
1907 if (!test_and_set_bit(WantReplacement,
1908 &rdev->flags))
1909 set_bit(MD_RECOVERY_NEEDED,
1910 &rdev->mddev->recovery);
1913 if (!ok) {
1914 /* We don't worry if we cannot set a bad block -
1915 * it really is bad so there is no loss in not
1916 * recording it yet
1918 rdev_set_badblocks(rdev, addr, s, 0);
1920 if (rdev != conf->mirrors[dw].rdev) {
1921 /* need bad block on destination too */
1922 struct md_rdev *rdev2 = conf->mirrors[dw].rdev;
1923 addr = r10_bio->devs[1].addr + sect;
1924 ok = rdev_set_badblocks(rdev2, addr, s, 0);
1925 if (!ok) {
1926 /* just abort the recovery */
1927 printk(KERN_NOTICE
1928 "md/raid10:%s: recovery aborted"
1929 " due to read error\n",
1930 mdname(mddev));
1932 conf->mirrors[dw].recovery_disabled
1933 = mddev->recovery_disabled;
1934 set_bit(MD_RECOVERY_INTR,
1935 &mddev->recovery);
1936 break;
1941 sectors -= s;
1942 sect += s;
1943 idx++;
1947 static void recovery_request_write(struct mddev *mddev, struct r10bio *r10_bio)
1949 struct r10conf *conf = mddev->private;
1950 int d;
1951 struct bio *wbio, *wbio2;
1953 if (!test_bit(R10BIO_Uptodate, &r10_bio->state)) {
1954 fix_recovery_read_error(r10_bio);
1955 end_sync_request(r10_bio);
1956 return;
1960 * share the pages with the first bio
1961 * and submit the write request
1963 d = r10_bio->devs[1].devnum;
1964 wbio = r10_bio->devs[1].bio;
1965 wbio2 = r10_bio->devs[1].repl_bio;
1966 if (wbio->bi_end_io) {
1967 atomic_inc(&conf->mirrors[d].rdev->nr_pending);
1968 md_sync_acct(conf->mirrors[d].rdev->bdev, wbio->bi_size >> 9);
1969 generic_make_request(wbio);
1971 if (wbio2 && wbio2->bi_end_io) {
1972 atomic_inc(&conf->mirrors[d].replacement->nr_pending);
1973 md_sync_acct(conf->mirrors[d].replacement->bdev,
1974 wbio2->bi_size >> 9);
1975 generic_make_request(wbio2);
1981 * Used by fix_read_error() to decay the per rdev read_errors.
1982 * We halve the read error count for every hour that has elapsed
1983 * since the last recorded read error.
1986 static void check_decay_read_errors(struct mddev *mddev, struct md_rdev *rdev)
1988 struct timespec cur_time_mon;
1989 unsigned long hours_since_last;
1990 unsigned int read_errors = atomic_read(&rdev->read_errors);
1992 ktime_get_ts(&cur_time_mon);
1994 if (rdev->last_read_error.tv_sec == 0 &&
1995 rdev->last_read_error.tv_nsec == 0) {
1996 /* first time we've seen a read error */
1997 rdev->last_read_error = cur_time_mon;
1998 return;
2001 hours_since_last = (cur_time_mon.tv_sec -
2002 rdev->last_read_error.tv_sec) / 3600;
2004 rdev->last_read_error = cur_time_mon;
2007 * if hours_since_last is > the number of bits in read_errors
2008 * just set read errors to 0. We do this to avoid
2009 * overflowing the shift of read_errors by hours_since_last.
2011 if (hours_since_last >= 8 * sizeof(read_errors))
2012 atomic_set(&rdev->read_errors, 0);
2013 else
2014 atomic_set(&rdev->read_errors, read_errors >> hours_since_last);
2017 static int r10_sync_page_io(struct md_rdev *rdev, sector_t sector,
2018 int sectors, struct page *page, int rw)
2020 sector_t first_bad;
2021 int bad_sectors;
2023 if (is_badblock(rdev, sector, sectors, &first_bad, &bad_sectors)
2024 && (rw == READ || test_bit(WriteErrorSeen, &rdev->flags)))
2025 return -1;
2026 if (sync_page_io(rdev, sector, sectors << 9, page, rw, false))
2027 /* success */
2028 return 1;
2029 if (rw == WRITE) {
2030 set_bit(WriteErrorSeen, &rdev->flags);
2031 if (!test_and_set_bit(WantReplacement, &rdev->flags))
2032 set_bit(MD_RECOVERY_NEEDED,
2033 &rdev->mddev->recovery);
2035 /* need to record an error - either for the block or the device */
2036 if (!rdev_set_badblocks(rdev, sector, sectors, 0))
2037 md_error(rdev->mddev, rdev);
2038 return 0;
2042 * This is a kernel thread which:
2044 * 1. Retries failed read operations on working mirrors.
2045 * 2. Updates the raid superblock when problems encounter.
2046 * 3. Performs writes following reads for array synchronising.
2049 static void fix_read_error(struct r10conf *conf, struct mddev *mddev, struct r10bio *r10_bio)
2051 int sect = 0; /* Offset from r10_bio->sector */
2052 int sectors = r10_bio->sectors;
2053 struct md_rdev*rdev;
2054 int max_read_errors = atomic_read(&mddev->max_corr_read_errors);
2055 int d = r10_bio->devs[r10_bio->read_slot].devnum;
2057 /* still own a reference to this rdev, so it cannot
2058 * have been cleared recently.
2060 rdev = conf->mirrors[d].rdev;
2062 if (test_bit(Faulty, &rdev->flags))
2063 /* drive has already been failed, just ignore any
2064 more fix_read_error() attempts */
2065 return;
2067 check_decay_read_errors(mddev, rdev);
2068 atomic_inc(&rdev->read_errors);
2069 if (atomic_read(&rdev->read_errors) > max_read_errors) {
2070 char b[BDEVNAME_SIZE];
2071 bdevname(rdev->bdev, b);
2073 printk(KERN_NOTICE
2074 "md/raid10:%s: %s: Raid device exceeded "
2075 "read_error threshold [cur %d:max %d]\n",
2076 mdname(mddev), b,
2077 atomic_read(&rdev->read_errors), max_read_errors);
2078 printk(KERN_NOTICE
2079 "md/raid10:%s: %s: Failing raid device\n",
2080 mdname(mddev), b);
2081 md_error(mddev, conf->mirrors[d].rdev);
2082 r10_bio->devs[r10_bio->read_slot].bio = IO_BLOCKED;
2083 return;
2086 while(sectors) {
2087 int s = sectors;
2088 int sl = r10_bio->read_slot;
2089 int success = 0;
2090 int start;
2092 if (s > (PAGE_SIZE>>9))
2093 s = PAGE_SIZE >> 9;
2095 rcu_read_lock();
2096 do {
2097 sector_t first_bad;
2098 int bad_sectors;
2100 d = r10_bio->devs[sl].devnum;
2101 rdev = rcu_dereference(conf->mirrors[d].rdev);
2102 if (rdev &&
2103 test_bit(In_sync, &rdev->flags) &&
2104 is_badblock(rdev, r10_bio->devs[sl].addr + sect, s,
2105 &first_bad, &bad_sectors) == 0) {
2106 atomic_inc(&rdev->nr_pending);
2107 rcu_read_unlock();
2108 success = sync_page_io(rdev,
2109 r10_bio->devs[sl].addr +
2110 sect,
2111 s<<9,
2112 conf->tmppage, READ, false);
2113 rdev_dec_pending(rdev, mddev);
2114 rcu_read_lock();
2115 if (success)
2116 break;
2118 sl++;
2119 if (sl == conf->copies)
2120 sl = 0;
2121 } while (!success && sl != r10_bio->read_slot);
2122 rcu_read_unlock();
2124 if (!success) {
2125 /* Cannot read from anywhere, just mark the block
2126 * as bad on the first device to discourage future
2127 * reads.
2129 int dn = r10_bio->devs[r10_bio->read_slot].devnum;
2130 rdev = conf->mirrors[dn].rdev;
2132 if (!rdev_set_badblocks(
2133 rdev,
2134 r10_bio->devs[r10_bio->read_slot].addr
2135 + sect,
2136 s, 0)) {
2137 md_error(mddev, rdev);
2138 r10_bio->devs[r10_bio->read_slot].bio
2139 = IO_BLOCKED;
2141 break;
2144 start = sl;
2145 /* write it back and re-read */
2146 rcu_read_lock();
2147 while (sl != r10_bio->read_slot) {
2148 char b[BDEVNAME_SIZE];
2150 if (sl==0)
2151 sl = conf->copies;
2152 sl--;
2153 d = r10_bio->devs[sl].devnum;
2154 rdev = rcu_dereference(conf->mirrors[d].rdev);
2155 if (!rdev ||
2156 !test_bit(In_sync, &rdev->flags))
2157 continue;
2159 atomic_inc(&rdev->nr_pending);
2160 rcu_read_unlock();
2161 if (r10_sync_page_io(rdev,
2162 r10_bio->devs[sl].addr +
2163 sect,
2164 s<<9, conf->tmppage, WRITE)
2165 == 0) {
2166 /* Well, this device is dead */
2167 printk(KERN_NOTICE
2168 "md/raid10:%s: read correction "
2169 "write failed"
2170 " (%d sectors at %llu on %s)\n",
2171 mdname(mddev), s,
2172 (unsigned long long)(
2173 sect + rdev->data_offset),
2174 bdevname(rdev->bdev, b));
2175 printk(KERN_NOTICE "md/raid10:%s: %s: failing "
2176 "drive\n",
2177 mdname(mddev),
2178 bdevname(rdev->bdev, b));
2180 rdev_dec_pending(rdev, mddev);
2181 rcu_read_lock();
2183 sl = start;
2184 while (sl != r10_bio->read_slot) {
2185 char b[BDEVNAME_SIZE];
2187 if (sl==0)
2188 sl = conf->copies;
2189 sl--;
2190 d = r10_bio->devs[sl].devnum;
2191 rdev = rcu_dereference(conf->mirrors[d].rdev);
2192 if (!rdev ||
2193 !test_bit(In_sync, &rdev->flags))
2194 continue;
2196 atomic_inc(&rdev->nr_pending);
2197 rcu_read_unlock();
2198 switch (r10_sync_page_io(rdev,
2199 r10_bio->devs[sl].addr +
2200 sect,
2201 s<<9, conf->tmppage,
2202 READ)) {
2203 case 0:
2204 /* Well, this device is dead */
2205 printk(KERN_NOTICE
2206 "md/raid10:%s: unable to read back "
2207 "corrected sectors"
2208 " (%d sectors at %llu on %s)\n",
2209 mdname(mddev), s,
2210 (unsigned long long)(
2211 sect + rdev->data_offset),
2212 bdevname(rdev->bdev, b));
2213 printk(KERN_NOTICE "md/raid10:%s: %s: failing "
2214 "drive\n",
2215 mdname(mddev),
2216 bdevname(rdev->bdev, b));
2217 break;
2218 case 1:
2219 printk(KERN_INFO
2220 "md/raid10:%s: read error corrected"
2221 " (%d sectors at %llu on %s)\n",
2222 mdname(mddev), s,
2223 (unsigned long long)(
2224 sect + rdev->data_offset),
2225 bdevname(rdev->bdev, b));
2226 atomic_add(s, &rdev->corrected_errors);
2229 rdev_dec_pending(rdev, mddev);
2230 rcu_read_lock();
2232 rcu_read_unlock();
2234 sectors -= s;
2235 sect += s;
2239 static void bi_complete(struct bio *bio, int error)
2241 complete((struct completion *)bio->bi_private);
2244 static int submit_bio_wait(int rw, struct bio *bio)
2246 struct completion event;
2247 rw |= REQ_SYNC;
2249 init_completion(&event);
2250 bio->bi_private = &event;
2251 bio->bi_end_io = bi_complete;
2252 submit_bio(rw, bio);
2253 wait_for_completion(&event);
2255 return test_bit(BIO_UPTODATE, &bio->bi_flags);
2258 static int narrow_write_error(struct r10bio *r10_bio, int i)
2260 struct bio *bio = r10_bio->master_bio;
2261 struct mddev *mddev = r10_bio->mddev;
2262 struct r10conf *conf = mddev->private;
2263 struct md_rdev *rdev = conf->mirrors[r10_bio->devs[i].devnum].rdev;
2264 /* bio has the data to be written to slot 'i' where
2265 * we just recently had a write error.
2266 * We repeatedly clone the bio and trim down to one block,
2267 * then try the write. Where the write fails we record
2268 * a bad block.
2269 * It is conceivable that the bio doesn't exactly align with
2270 * blocks. We must handle this.
2272 * We currently own a reference to the rdev.
2275 int block_sectors;
2276 sector_t sector;
2277 int sectors;
2278 int sect_to_write = r10_bio->sectors;
2279 int ok = 1;
2281 if (rdev->badblocks.shift < 0)
2282 return 0;
2284 block_sectors = 1 << rdev->badblocks.shift;
2285 sector = r10_bio->sector;
2286 sectors = ((r10_bio->sector + block_sectors)
2287 & ~(sector_t)(block_sectors - 1))
2288 - sector;
2290 while (sect_to_write) {
2291 struct bio *wbio;
2292 if (sectors > sect_to_write)
2293 sectors = sect_to_write;
2294 /* Write at 'sector' for 'sectors' */
2295 wbio = bio_clone_mddev(bio, GFP_NOIO, mddev);
2296 md_trim_bio(wbio, sector - bio->bi_sector, sectors);
2297 wbio->bi_sector = (r10_bio->devs[i].addr+
2298 rdev->data_offset+
2299 (sector - r10_bio->sector));
2300 wbio->bi_bdev = rdev->bdev;
2301 if (submit_bio_wait(WRITE, wbio) == 0)
2302 /* Failure! */
2303 ok = rdev_set_badblocks(rdev, sector,
2304 sectors, 0)
2305 && ok;
2307 bio_put(wbio);
2308 sect_to_write -= sectors;
2309 sector += sectors;
2310 sectors = block_sectors;
2312 return ok;
2315 static void handle_read_error(struct mddev *mddev, struct r10bio *r10_bio)
2317 int slot = r10_bio->read_slot;
2318 struct bio *bio;
2319 struct r10conf *conf = mddev->private;
2320 struct md_rdev *rdev = r10_bio->devs[slot].rdev;
2321 char b[BDEVNAME_SIZE];
2322 unsigned long do_sync;
2323 int max_sectors;
2325 /* we got a read error. Maybe the drive is bad. Maybe just
2326 * the block and we can fix it.
2327 * We freeze all other IO, and try reading the block from
2328 * other devices. When we find one, we re-write
2329 * and check it that fixes the read error.
2330 * This is all done synchronously while the array is
2331 * frozen.
2333 bio = r10_bio->devs[slot].bio;
2334 bdevname(bio->bi_bdev, b);
2335 bio_put(bio);
2336 r10_bio->devs[slot].bio = NULL;
2338 if (mddev->ro == 0) {
2339 freeze_array(conf);
2340 fix_read_error(conf, mddev, r10_bio);
2341 unfreeze_array(conf);
2342 } else
2343 r10_bio->devs[slot].bio = IO_BLOCKED;
2345 rdev_dec_pending(rdev, mddev);
2347 read_more:
2348 rdev = read_balance(conf, r10_bio, &max_sectors);
2349 if (rdev == NULL) {
2350 printk(KERN_ALERT "md/raid10:%s: %s: unrecoverable I/O"
2351 " read error for block %llu\n",
2352 mdname(mddev), b,
2353 (unsigned long long)r10_bio->sector);
2354 raid_end_bio_io(r10_bio);
2355 return;
2358 do_sync = (r10_bio->master_bio->bi_rw & REQ_SYNC);
2359 slot = r10_bio->read_slot;
2360 printk_ratelimited(
2361 KERN_ERR
2362 "md/raid10:%s: %s: redirecting"
2363 "sector %llu to another mirror\n",
2364 mdname(mddev),
2365 bdevname(rdev->bdev, b),
2366 (unsigned long long)r10_bio->sector);
2367 bio = bio_clone_mddev(r10_bio->master_bio,
2368 GFP_NOIO, mddev);
2369 md_trim_bio(bio,
2370 r10_bio->sector - bio->bi_sector,
2371 max_sectors);
2372 r10_bio->devs[slot].bio = bio;
2373 r10_bio->devs[slot].rdev = rdev;
2374 bio->bi_sector = r10_bio->devs[slot].addr
2375 + rdev->data_offset;
2376 bio->bi_bdev = rdev->bdev;
2377 bio->bi_rw = READ | do_sync;
2378 bio->bi_private = r10_bio;
2379 bio->bi_end_io = raid10_end_read_request;
2380 if (max_sectors < r10_bio->sectors) {
2381 /* Drat - have to split this up more */
2382 struct bio *mbio = r10_bio->master_bio;
2383 int sectors_handled =
2384 r10_bio->sector + max_sectors
2385 - mbio->bi_sector;
2386 r10_bio->sectors = max_sectors;
2387 spin_lock_irq(&conf->device_lock);
2388 if (mbio->bi_phys_segments == 0)
2389 mbio->bi_phys_segments = 2;
2390 else
2391 mbio->bi_phys_segments++;
2392 spin_unlock_irq(&conf->device_lock);
2393 generic_make_request(bio);
2395 r10_bio = mempool_alloc(conf->r10bio_pool,
2396 GFP_NOIO);
2397 r10_bio->master_bio = mbio;
2398 r10_bio->sectors = (mbio->bi_size >> 9)
2399 - sectors_handled;
2400 r10_bio->state = 0;
2401 set_bit(R10BIO_ReadError,
2402 &r10_bio->state);
2403 r10_bio->mddev = mddev;
2404 r10_bio->sector = mbio->bi_sector
2405 + sectors_handled;
2407 goto read_more;
2408 } else
2409 generic_make_request(bio);
2412 static void handle_write_completed(struct r10conf *conf, struct r10bio *r10_bio)
2414 /* Some sort of write request has finished and it
2415 * succeeded in writing where we thought there was a
2416 * bad block. So forget the bad block.
2417 * Or possibly if failed and we need to record
2418 * a bad block.
2420 int m;
2421 struct md_rdev *rdev;
2423 if (test_bit(R10BIO_IsSync, &r10_bio->state) ||
2424 test_bit(R10BIO_IsRecover, &r10_bio->state)) {
2425 for (m = 0; m < conf->copies; m++) {
2426 int dev = r10_bio->devs[m].devnum;
2427 rdev = conf->mirrors[dev].rdev;
2428 if (r10_bio->devs[m].bio == NULL)
2429 continue;
2430 if (test_bit(BIO_UPTODATE,
2431 &r10_bio->devs[m].bio->bi_flags)) {
2432 rdev_clear_badblocks(
2433 rdev,
2434 r10_bio->devs[m].addr,
2435 r10_bio->sectors);
2436 } else {
2437 if (!rdev_set_badblocks(
2438 rdev,
2439 r10_bio->devs[m].addr,
2440 r10_bio->sectors, 0))
2441 md_error(conf->mddev, rdev);
2443 rdev = conf->mirrors[dev].replacement;
2444 if (r10_bio->devs[m].repl_bio == NULL)
2445 continue;
2446 if (test_bit(BIO_UPTODATE,
2447 &r10_bio->devs[m].repl_bio->bi_flags)) {
2448 rdev_clear_badblocks(
2449 rdev,
2450 r10_bio->devs[m].addr,
2451 r10_bio->sectors);
2452 } else {
2453 if (!rdev_set_badblocks(
2454 rdev,
2455 r10_bio->devs[m].addr,
2456 r10_bio->sectors, 0))
2457 md_error(conf->mddev, rdev);
2460 put_buf(r10_bio);
2461 } else {
2462 for (m = 0; m < conf->copies; m++) {
2463 int dev = r10_bio->devs[m].devnum;
2464 struct bio *bio = r10_bio->devs[m].bio;
2465 rdev = conf->mirrors[dev].rdev;
2466 if (bio == IO_MADE_GOOD) {
2467 rdev_clear_badblocks(
2468 rdev,
2469 r10_bio->devs[m].addr,
2470 r10_bio->sectors);
2471 rdev_dec_pending(rdev, conf->mddev);
2472 } else if (bio != NULL &&
2473 !test_bit(BIO_UPTODATE, &bio->bi_flags)) {
2474 if (!narrow_write_error(r10_bio, m)) {
2475 md_error(conf->mddev, rdev);
2476 set_bit(R10BIO_Degraded,
2477 &r10_bio->state);
2479 rdev_dec_pending(rdev, conf->mddev);
2481 bio = r10_bio->devs[m].repl_bio;
2482 rdev = conf->mirrors[dev].replacement;
2483 if (rdev && bio == IO_MADE_GOOD) {
2484 rdev_clear_badblocks(
2485 rdev,
2486 r10_bio->devs[m].addr,
2487 r10_bio->sectors);
2488 rdev_dec_pending(rdev, conf->mddev);
2491 if (test_bit(R10BIO_WriteError,
2492 &r10_bio->state))
2493 close_write(r10_bio);
2494 raid_end_bio_io(r10_bio);
2498 static void raid10d(struct mddev *mddev)
2500 struct r10bio *r10_bio;
2501 unsigned long flags;
2502 struct r10conf *conf = mddev->private;
2503 struct list_head *head = &conf->retry_list;
2504 struct blk_plug plug;
2506 md_check_recovery(mddev);
2508 blk_start_plug(&plug);
2509 for (;;) {
2511 flush_pending_writes(conf);
2513 spin_lock_irqsave(&conf->device_lock, flags);
2514 if (list_empty(head)) {
2515 spin_unlock_irqrestore(&conf->device_lock, flags);
2516 break;
2518 r10_bio = list_entry(head->prev, struct r10bio, retry_list);
2519 list_del(head->prev);
2520 conf->nr_queued--;
2521 spin_unlock_irqrestore(&conf->device_lock, flags);
2523 mddev = r10_bio->mddev;
2524 conf = mddev->private;
2525 if (test_bit(R10BIO_MadeGood, &r10_bio->state) ||
2526 test_bit(R10BIO_WriteError, &r10_bio->state))
2527 handle_write_completed(conf, r10_bio);
2528 else if (test_bit(R10BIO_IsSync, &r10_bio->state))
2529 sync_request_write(mddev, r10_bio);
2530 else if (test_bit(R10BIO_IsRecover, &r10_bio->state))
2531 recovery_request_write(mddev, r10_bio);
2532 else if (test_bit(R10BIO_ReadError, &r10_bio->state))
2533 handle_read_error(mddev, r10_bio);
2534 else {
2535 /* just a partial read to be scheduled from a
2536 * separate context
2538 int slot = r10_bio->read_slot;
2539 generic_make_request(r10_bio->devs[slot].bio);
2542 cond_resched();
2543 if (mddev->flags & ~(1<<MD_CHANGE_PENDING))
2544 md_check_recovery(mddev);
2546 blk_finish_plug(&plug);
2550 static int init_resync(struct r10conf *conf)
2552 int buffs;
2553 int i;
2555 buffs = RESYNC_WINDOW / RESYNC_BLOCK_SIZE;
2556 BUG_ON(conf->r10buf_pool);
2557 conf->have_replacement = 0;
2558 for (i = 0; i < conf->raid_disks; i++)
2559 if (conf->mirrors[i].replacement)
2560 conf->have_replacement = 1;
2561 conf->r10buf_pool = mempool_create(buffs, r10buf_pool_alloc, r10buf_pool_free, conf);
2562 if (!conf->r10buf_pool)
2563 return -ENOMEM;
2564 conf->next_resync = 0;
2565 return 0;
2569 * perform a "sync" on one "block"
2571 * We need to make sure that no normal I/O request - particularly write
2572 * requests - conflict with active sync requests.
2574 * This is achieved by tracking pending requests and a 'barrier' concept
2575 * that can be installed to exclude normal IO requests.
2577 * Resync and recovery are handled very differently.
2578 * We differentiate by looking at MD_RECOVERY_SYNC in mddev->recovery.
2580 * For resync, we iterate over virtual addresses, read all copies,
2581 * and update if there are differences. If only one copy is live,
2582 * skip it.
2583 * For recovery, we iterate over physical addresses, read a good
2584 * value for each non-in_sync drive, and over-write.
2586 * So, for recovery we may have several outstanding complex requests for a
2587 * given address, one for each out-of-sync device. We model this by allocating
2588 * a number of r10_bio structures, one for each out-of-sync device.
2589 * As we setup these structures, we collect all bio's together into a list
2590 * which we then process collectively to add pages, and then process again
2591 * to pass to generic_make_request.
2593 * The r10_bio structures are linked using a borrowed master_bio pointer.
2594 * This link is counted in ->remaining. When the r10_bio that points to NULL
2595 * has its remaining count decremented to 0, the whole complex operation
2596 * is complete.
2600 static sector_t sync_request(struct mddev *mddev, sector_t sector_nr,
2601 int *skipped, int go_faster)
2603 struct r10conf *conf = mddev->private;
2604 struct r10bio *r10_bio;
2605 struct bio *biolist = NULL, *bio;
2606 sector_t max_sector, nr_sectors;
2607 int i;
2608 int max_sync;
2609 sector_t sync_blocks;
2610 sector_t sectors_skipped = 0;
2611 int chunks_skipped = 0;
2613 if (!conf->r10buf_pool)
2614 if (init_resync(conf))
2615 return 0;
2617 skipped:
2618 max_sector = mddev->dev_sectors;
2619 if (test_bit(MD_RECOVERY_SYNC, &mddev->recovery))
2620 max_sector = mddev->resync_max_sectors;
2621 if (sector_nr >= max_sector) {
2622 /* If we aborted, we need to abort the
2623 * sync on the 'current' bitmap chucks (there can
2624 * be several when recovering multiple devices).
2625 * as we may have started syncing it but not finished.
2626 * We can find the current address in
2627 * mddev->curr_resync, but for recovery,
2628 * we need to convert that to several
2629 * virtual addresses.
2631 if (mddev->curr_resync < max_sector) { /* aborted */
2632 if (test_bit(MD_RECOVERY_SYNC, &mddev->recovery))
2633 bitmap_end_sync(mddev->bitmap, mddev->curr_resync,
2634 &sync_blocks, 1);
2635 else for (i=0; i<conf->raid_disks; i++) {
2636 sector_t sect =
2637 raid10_find_virt(conf, mddev->curr_resync, i);
2638 bitmap_end_sync(mddev->bitmap, sect,
2639 &sync_blocks, 1);
2641 } else {
2642 /* completed sync */
2643 if ((!mddev->bitmap || conf->fullsync)
2644 && conf->have_replacement
2645 && test_bit(MD_RECOVERY_SYNC, &mddev->recovery)) {
2646 /* Completed a full sync so the replacements
2647 * are now fully recovered.
2649 for (i = 0; i < conf->raid_disks; i++)
2650 if (conf->mirrors[i].replacement)
2651 conf->mirrors[i].replacement
2652 ->recovery_offset
2653 = MaxSector;
2655 conf->fullsync = 0;
2657 bitmap_close_sync(mddev->bitmap);
2658 close_sync(conf);
2659 *skipped = 1;
2660 return sectors_skipped;
2662 if (chunks_skipped >= conf->raid_disks) {
2663 /* if there has been nothing to do on any drive,
2664 * then there is nothing to do at all..
2666 *skipped = 1;
2667 return (max_sector - sector_nr) + sectors_skipped;
2670 if (max_sector > mddev->resync_max)
2671 max_sector = mddev->resync_max; /* Don't do IO beyond here */
2673 /* make sure whole request will fit in a chunk - if chunks
2674 * are meaningful
2676 if (conf->near_copies < conf->raid_disks &&
2677 max_sector > (sector_nr | conf->chunk_mask))
2678 max_sector = (sector_nr | conf->chunk_mask) + 1;
2680 * If there is non-resync activity waiting for us then
2681 * put in a delay to throttle resync.
2683 if (!go_faster && conf->nr_waiting)
2684 msleep_interruptible(1000);
2686 /* Again, very different code for resync and recovery.
2687 * Both must result in an r10bio with a list of bios that
2688 * have bi_end_io, bi_sector, bi_bdev set,
2689 * and bi_private set to the r10bio.
2690 * For recovery, we may actually create several r10bios
2691 * with 2 bios in each, that correspond to the bios in the main one.
2692 * In this case, the subordinate r10bios link back through a
2693 * borrowed master_bio pointer, and the counter in the master
2694 * includes a ref from each subordinate.
2696 /* First, we decide what to do and set ->bi_end_io
2697 * To end_sync_read if we want to read, and
2698 * end_sync_write if we will want to write.
2701 max_sync = RESYNC_PAGES << (PAGE_SHIFT-9);
2702 if (!test_bit(MD_RECOVERY_SYNC, &mddev->recovery)) {
2703 /* recovery... the complicated one */
2704 int j;
2705 r10_bio = NULL;
2707 for (i=0 ; i<conf->raid_disks; i++) {
2708 int still_degraded;
2709 struct r10bio *rb2;
2710 sector_t sect;
2711 int must_sync;
2712 int any_working;
2713 struct mirror_info *mirror = &conf->mirrors[i];
2715 if ((mirror->rdev == NULL ||
2716 test_bit(In_sync, &mirror->rdev->flags))
2718 (mirror->replacement == NULL ||
2719 test_bit(Faulty,
2720 &mirror->replacement->flags)))
2721 continue;
2723 still_degraded = 0;
2724 /* want to reconstruct this device */
2725 rb2 = r10_bio;
2726 sect = raid10_find_virt(conf, sector_nr, i);
2727 /* Unless we are doing a full sync, or a replacement
2728 * we only need to recover the block if it is set in
2729 * the bitmap
2731 must_sync = bitmap_start_sync(mddev->bitmap, sect,
2732 &sync_blocks, 1);
2733 if (sync_blocks < max_sync)
2734 max_sync = sync_blocks;
2735 if (!must_sync &&
2736 mirror->replacement == NULL &&
2737 !conf->fullsync) {
2738 /* yep, skip the sync_blocks here, but don't assume
2739 * that there will never be anything to do here
2741 chunks_skipped = -1;
2742 continue;
2745 r10_bio = mempool_alloc(conf->r10buf_pool, GFP_NOIO);
2746 raise_barrier(conf, rb2 != NULL);
2747 atomic_set(&r10_bio->remaining, 0);
2749 r10_bio->master_bio = (struct bio*)rb2;
2750 if (rb2)
2751 atomic_inc(&rb2->remaining);
2752 r10_bio->mddev = mddev;
2753 set_bit(R10BIO_IsRecover, &r10_bio->state);
2754 r10_bio->sector = sect;
2756 raid10_find_phys(conf, r10_bio);
2758 /* Need to check if the array will still be
2759 * degraded
2761 for (j=0; j<conf->raid_disks; j++)
2762 if (conf->mirrors[j].rdev == NULL ||
2763 test_bit(Faulty, &conf->mirrors[j].rdev->flags)) {
2764 still_degraded = 1;
2765 break;
2768 must_sync = bitmap_start_sync(mddev->bitmap, sect,
2769 &sync_blocks, still_degraded);
2771 any_working = 0;
2772 for (j=0; j<conf->copies;j++) {
2773 int k;
2774 int d = r10_bio->devs[j].devnum;
2775 sector_t from_addr, to_addr;
2776 struct md_rdev *rdev;
2777 sector_t sector, first_bad;
2778 int bad_sectors;
2779 if (!conf->mirrors[d].rdev ||
2780 !test_bit(In_sync, &conf->mirrors[d].rdev->flags))
2781 continue;
2782 /* This is where we read from */
2783 any_working = 1;
2784 rdev = conf->mirrors[d].rdev;
2785 sector = r10_bio->devs[j].addr;
2787 if (is_badblock(rdev, sector, max_sync,
2788 &first_bad, &bad_sectors)) {
2789 if (first_bad > sector)
2790 max_sync = first_bad - sector;
2791 else {
2792 bad_sectors -= (sector
2793 - first_bad);
2794 if (max_sync > bad_sectors)
2795 max_sync = bad_sectors;
2796 continue;
2799 bio = r10_bio->devs[0].bio;
2800 bio->bi_next = biolist;
2801 biolist = bio;
2802 bio->bi_private = r10_bio;
2803 bio->bi_end_io = end_sync_read;
2804 bio->bi_rw = READ;
2805 from_addr = r10_bio->devs[j].addr;
2806 bio->bi_sector = from_addr + rdev->data_offset;
2807 bio->bi_bdev = rdev->bdev;
2808 atomic_inc(&rdev->nr_pending);
2809 /* and we write to 'i' (if not in_sync) */
2811 for (k=0; k<conf->copies; k++)
2812 if (r10_bio->devs[k].devnum == i)
2813 break;
2814 BUG_ON(k == conf->copies);
2815 to_addr = r10_bio->devs[k].addr;
2816 r10_bio->devs[0].devnum = d;
2817 r10_bio->devs[0].addr = from_addr;
2818 r10_bio->devs[1].devnum = i;
2819 r10_bio->devs[1].addr = to_addr;
2821 rdev = mirror->rdev;
2822 if (!test_bit(In_sync, &rdev->flags)) {
2823 bio = r10_bio->devs[1].bio;
2824 bio->bi_next = biolist;
2825 biolist = bio;
2826 bio->bi_private = r10_bio;
2827 bio->bi_end_io = end_sync_write;
2828 bio->bi_rw = WRITE;
2829 bio->bi_sector = to_addr
2830 + rdev->data_offset;
2831 bio->bi_bdev = rdev->bdev;
2832 atomic_inc(&r10_bio->remaining);
2833 } else
2834 r10_bio->devs[1].bio->bi_end_io = NULL;
2836 /* and maybe write to replacement */
2837 bio = r10_bio->devs[1].repl_bio;
2838 if (bio)
2839 bio->bi_end_io = NULL;
2840 rdev = mirror->replacement;
2841 /* Note: if rdev != NULL, then bio
2842 * cannot be NULL as r10buf_pool_alloc will
2843 * have allocated it.
2844 * So the second test here is pointless.
2845 * But it keeps semantic-checkers happy, and
2846 * this comment keeps human reviewers
2847 * happy.
2849 if (rdev == NULL || bio == NULL ||
2850 test_bit(Faulty, &rdev->flags))
2851 break;
2852 bio->bi_next = biolist;
2853 biolist = bio;
2854 bio->bi_private = r10_bio;
2855 bio->bi_end_io = end_sync_write;
2856 bio->bi_rw = WRITE;
2857 bio->bi_sector = to_addr + rdev->data_offset;
2858 bio->bi_bdev = rdev->bdev;
2859 atomic_inc(&r10_bio->remaining);
2860 break;
2862 if (j == conf->copies) {
2863 /* Cannot recover, so abort the recovery or
2864 * record a bad block */
2865 put_buf(r10_bio);
2866 if (rb2)
2867 atomic_dec(&rb2->remaining);
2868 r10_bio = rb2;
2869 if (any_working) {
2870 /* problem is that there are bad blocks
2871 * on other device(s)
2873 int k;
2874 for (k = 0; k < conf->copies; k++)
2875 if (r10_bio->devs[k].devnum == i)
2876 break;
2877 if (!test_bit(In_sync,
2878 &mirror->rdev->flags)
2879 && !rdev_set_badblocks(
2880 mirror->rdev,
2881 r10_bio->devs[k].addr,
2882 max_sync, 0))
2883 any_working = 0;
2884 if (mirror->replacement &&
2885 !rdev_set_badblocks(
2886 mirror->replacement,
2887 r10_bio->devs[k].addr,
2888 max_sync, 0))
2889 any_working = 0;
2891 if (!any_working) {
2892 if (!test_and_set_bit(MD_RECOVERY_INTR,
2893 &mddev->recovery))
2894 printk(KERN_INFO "md/raid10:%s: insufficient "
2895 "working devices for recovery.\n",
2896 mdname(mddev));
2897 mirror->recovery_disabled
2898 = mddev->recovery_disabled;
2900 break;
2903 if (biolist == NULL) {
2904 while (r10_bio) {
2905 struct r10bio *rb2 = r10_bio;
2906 r10_bio = (struct r10bio*) rb2->master_bio;
2907 rb2->master_bio = NULL;
2908 put_buf(rb2);
2910 goto giveup;
2912 } else {
2913 /* resync. Schedule a read for every block at this virt offset */
2914 int count = 0;
2916 bitmap_cond_end_sync(mddev->bitmap, sector_nr);
2918 if (!bitmap_start_sync(mddev->bitmap, sector_nr,
2919 &sync_blocks, mddev->degraded) &&
2920 !conf->fullsync && !test_bit(MD_RECOVERY_REQUESTED,
2921 &mddev->recovery)) {
2922 /* We can skip this block */
2923 *skipped = 1;
2924 return sync_blocks + sectors_skipped;
2926 if (sync_blocks < max_sync)
2927 max_sync = sync_blocks;
2928 r10_bio = mempool_alloc(conf->r10buf_pool, GFP_NOIO);
2930 r10_bio->mddev = mddev;
2931 atomic_set(&r10_bio->remaining, 0);
2932 raise_barrier(conf, 0);
2933 conf->next_resync = sector_nr;
2935 r10_bio->master_bio = NULL;
2936 r10_bio->sector = sector_nr;
2937 set_bit(R10BIO_IsSync, &r10_bio->state);
2938 raid10_find_phys(conf, r10_bio);
2939 r10_bio->sectors = (sector_nr | conf->chunk_mask) - sector_nr +1;
2941 for (i=0; i<conf->copies; i++) {
2942 int d = r10_bio->devs[i].devnum;
2943 sector_t first_bad, sector;
2944 int bad_sectors;
2946 if (r10_bio->devs[i].repl_bio)
2947 r10_bio->devs[i].repl_bio->bi_end_io = NULL;
2949 bio = r10_bio->devs[i].bio;
2950 bio->bi_end_io = NULL;
2951 clear_bit(BIO_UPTODATE, &bio->bi_flags);
2952 if (conf->mirrors[d].rdev == NULL ||
2953 test_bit(Faulty, &conf->mirrors[d].rdev->flags))
2954 continue;
2955 sector = r10_bio->devs[i].addr;
2956 if (is_badblock(conf->mirrors[d].rdev,
2957 sector, max_sync,
2958 &first_bad, &bad_sectors)) {
2959 if (first_bad > sector)
2960 max_sync = first_bad - sector;
2961 else {
2962 bad_sectors -= (sector - first_bad);
2963 if (max_sync > bad_sectors)
2964 max_sync = max_sync;
2965 continue;
2968 atomic_inc(&conf->mirrors[d].rdev->nr_pending);
2969 atomic_inc(&r10_bio->remaining);
2970 bio->bi_next = biolist;
2971 biolist = bio;
2972 bio->bi_private = r10_bio;
2973 bio->bi_end_io = end_sync_read;
2974 bio->bi_rw = READ;
2975 bio->bi_sector = sector +
2976 conf->mirrors[d].rdev->data_offset;
2977 bio->bi_bdev = conf->mirrors[d].rdev->bdev;
2978 count++;
2980 if (conf->mirrors[d].replacement == NULL ||
2981 test_bit(Faulty,
2982 &conf->mirrors[d].replacement->flags))
2983 continue;
2985 /* Need to set up for writing to the replacement */
2986 bio = r10_bio->devs[i].repl_bio;
2987 clear_bit(BIO_UPTODATE, &bio->bi_flags);
2989 sector = r10_bio->devs[i].addr;
2990 atomic_inc(&conf->mirrors[d].rdev->nr_pending);
2991 bio->bi_next = biolist;
2992 biolist = bio;
2993 bio->bi_private = r10_bio;
2994 bio->bi_end_io = end_sync_write;
2995 bio->bi_rw = WRITE;
2996 bio->bi_sector = sector +
2997 conf->mirrors[d].replacement->data_offset;
2998 bio->bi_bdev = conf->mirrors[d].replacement->bdev;
2999 count++;
3002 if (count < 2) {
3003 for (i=0; i<conf->copies; i++) {
3004 int d = r10_bio->devs[i].devnum;
3005 if (r10_bio->devs[i].bio->bi_end_io)
3006 rdev_dec_pending(conf->mirrors[d].rdev,
3007 mddev);
3008 if (r10_bio->devs[i].repl_bio &&
3009 r10_bio->devs[i].repl_bio->bi_end_io)
3010 rdev_dec_pending(
3011 conf->mirrors[d].replacement,
3012 mddev);
3014 put_buf(r10_bio);
3015 biolist = NULL;
3016 goto giveup;
3020 for (bio = biolist; bio ; bio=bio->bi_next) {
3022 bio->bi_flags &= ~(BIO_POOL_MASK - 1);
3023 if (bio->bi_end_io)
3024 bio->bi_flags |= 1 << BIO_UPTODATE;
3025 bio->bi_vcnt = 0;
3026 bio->bi_idx = 0;
3027 bio->bi_phys_segments = 0;
3028 bio->bi_size = 0;
3031 nr_sectors = 0;
3032 if (sector_nr + max_sync < max_sector)
3033 max_sector = sector_nr + max_sync;
3034 do {
3035 struct page *page;
3036 int len = PAGE_SIZE;
3037 if (sector_nr + (len>>9) > max_sector)
3038 len = (max_sector - sector_nr) << 9;
3039 if (len == 0)
3040 break;
3041 for (bio= biolist ; bio ; bio=bio->bi_next) {
3042 struct bio *bio2;
3043 page = bio->bi_io_vec[bio->bi_vcnt].bv_page;
3044 if (bio_add_page(bio, page, len, 0))
3045 continue;
3047 /* stop here */
3048 bio->bi_io_vec[bio->bi_vcnt].bv_page = page;
3049 for (bio2 = biolist;
3050 bio2 && bio2 != bio;
3051 bio2 = bio2->bi_next) {
3052 /* remove last page from this bio */
3053 bio2->bi_vcnt--;
3054 bio2->bi_size -= len;
3055 bio2->bi_flags &= ~(1<< BIO_SEG_VALID);
3057 goto bio_full;
3059 nr_sectors += len>>9;
3060 sector_nr += len>>9;
3061 } while (biolist->bi_vcnt < RESYNC_PAGES);
3062 bio_full:
3063 r10_bio->sectors = nr_sectors;
3065 while (biolist) {
3066 bio = biolist;
3067 biolist = biolist->bi_next;
3069 bio->bi_next = NULL;
3070 r10_bio = bio->bi_private;
3071 r10_bio->sectors = nr_sectors;
3073 if (bio->bi_end_io == end_sync_read) {
3074 md_sync_acct(bio->bi_bdev, nr_sectors);
3075 generic_make_request(bio);
3079 if (sectors_skipped)
3080 /* pretend they weren't skipped, it makes
3081 * no important difference in this case
3083 md_done_sync(mddev, sectors_skipped, 1);
3085 return sectors_skipped + nr_sectors;
3086 giveup:
3087 /* There is nowhere to write, so all non-sync
3088 * drives must be failed or in resync, all drives
3089 * have a bad block, so try the next chunk...
3091 if (sector_nr + max_sync < max_sector)
3092 max_sector = sector_nr + max_sync;
3094 sectors_skipped += (max_sector - sector_nr);
3095 chunks_skipped ++;
3096 sector_nr = max_sector;
3097 goto skipped;
3100 static sector_t
3101 raid10_size(struct mddev *mddev, sector_t sectors, int raid_disks)
3103 sector_t size;
3104 struct r10conf *conf = mddev->private;
3106 if (!raid_disks)
3107 raid_disks = conf->raid_disks;
3108 if (!sectors)
3109 sectors = conf->dev_sectors;
3111 size = sectors >> conf->chunk_shift;
3112 sector_div(size, conf->far_copies);
3113 size = size * raid_disks;
3114 sector_div(size, conf->near_copies);
3116 return size << conf->chunk_shift;
3120 static struct r10conf *setup_conf(struct mddev *mddev)
3122 struct r10conf *conf = NULL;
3123 int nc, fc, fo;
3124 sector_t stride, size;
3125 int err = -EINVAL;
3127 if (mddev->new_chunk_sectors < (PAGE_SIZE >> 9) ||
3128 !is_power_of_2(mddev->new_chunk_sectors)) {
3129 printk(KERN_ERR "md/raid10:%s: chunk size must be "
3130 "at least PAGE_SIZE(%ld) and be a power of 2.\n",
3131 mdname(mddev), PAGE_SIZE);
3132 goto out;
3135 nc = mddev->new_layout & 255;
3136 fc = (mddev->new_layout >> 8) & 255;
3137 fo = mddev->new_layout & (1<<16);
3139 if ((nc*fc) <2 || (nc*fc) > mddev->raid_disks ||
3140 (mddev->new_layout >> 17)) {
3141 printk(KERN_ERR "md/raid10:%s: unsupported raid10 layout: 0x%8x\n",
3142 mdname(mddev), mddev->new_layout);
3143 goto out;
3146 err = -ENOMEM;
3147 conf = kzalloc(sizeof(struct r10conf), GFP_KERNEL);
3148 if (!conf)
3149 goto out;
3151 conf->mirrors = kzalloc(sizeof(struct mirror_info)*mddev->raid_disks,
3152 GFP_KERNEL);
3153 if (!conf->mirrors)
3154 goto out;
3156 conf->tmppage = alloc_page(GFP_KERNEL);
3157 if (!conf->tmppage)
3158 goto out;
3161 conf->raid_disks = mddev->raid_disks;
3162 conf->near_copies = nc;
3163 conf->far_copies = fc;
3164 conf->copies = nc*fc;
3165 conf->far_offset = fo;
3166 conf->chunk_mask = mddev->new_chunk_sectors - 1;
3167 conf->chunk_shift = ffz(~mddev->new_chunk_sectors);
3169 conf->r10bio_pool = mempool_create(NR_RAID10_BIOS, r10bio_pool_alloc,
3170 r10bio_pool_free, conf);
3171 if (!conf->r10bio_pool)
3172 goto out;
3174 size = mddev->dev_sectors >> conf->chunk_shift;
3175 sector_div(size, fc);
3176 size = size * conf->raid_disks;
3177 sector_div(size, nc);
3178 /* 'size' is now the number of chunks in the array */
3179 /* calculate "used chunks per device" in 'stride' */
3180 stride = size * conf->copies;
3182 /* We need to round up when dividing by raid_disks to
3183 * get the stride size.
3185 stride += conf->raid_disks - 1;
3186 sector_div(stride, conf->raid_disks);
3188 conf->dev_sectors = stride << conf->chunk_shift;
3190 if (fo)
3191 stride = 1;
3192 else
3193 sector_div(stride, fc);
3194 conf->stride = stride << conf->chunk_shift;
3197 spin_lock_init(&conf->device_lock);
3198 INIT_LIST_HEAD(&conf->retry_list);
3200 spin_lock_init(&conf->resync_lock);
3201 init_waitqueue_head(&conf->wait_barrier);
3203 conf->thread = md_register_thread(raid10d, mddev, NULL);
3204 if (!conf->thread)
3205 goto out;
3207 conf->mddev = mddev;
3208 return conf;
3210 out:
3211 printk(KERN_ERR "md/raid10:%s: couldn't allocate memory.\n",
3212 mdname(mddev));
3213 if (conf) {
3214 if (conf->r10bio_pool)
3215 mempool_destroy(conf->r10bio_pool);
3216 kfree(conf->mirrors);
3217 safe_put_page(conf->tmppage);
3218 kfree(conf);
3220 return ERR_PTR(err);
3223 static int run(struct mddev *mddev)
3225 struct r10conf *conf;
3226 int i, disk_idx, chunk_size;
3227 struct mirror_info *disk;
3228 struct md_rdev *rdev;
3229 sector_t size;
3232 * copy the already verified devices into our private RAID10
3233 * bookkeeping area. [whatever we allocate in run(),
3234 * should be freed in stop()]
3237 if (mddev->private == NULL) {
3238 conf = setup_conf(mddev);
3239 if (IS_ERR(conf))
3240 return PTR_ERR(conf);
3241 mddev->private = conf;
3243 conf = mddev->private;
3244 if (!conf)
3245 goto out;
3247 mddev->thread = conf->thread;
3248 conf->thread = NULL;
3250 chunk_size = mddev->chunk_sectors << 9;
3251 blk_queue_io_min(mddev->queue, chunk_size);
3252 if (conf->raid_disks % conf->near_copies)
3253 blk_queue_io_opt(mddev->queue, chunk_size * conf->raid_disks);
3254 else
3255 blk_queue_io_opt(mddev->queue, chunk_size *
3256 (conf->raid_disks / conf->near_copies));
3258 list_for_each_entry(rdev, &mddev->disks, same_set) {
3260 disk_idx = rdev->raid_disk;
3261 if (disk_idx >= conf->raid_disks
3262 || disk_idx < 0)
3263 continue;
3264 disk = conf->mirrors + disk_idx;
3266 if (test_bit(Replacement, &rdev->flags)) {
3267 if (disk->replacement)
3268 goto out_free_conf;
3269 disk->replacement = rdev;
3270 } else {
3271 if (disk->rdev)
3272 goto out_free_conf;
3273 disk->rdev = rdev;
3276 disk_stack_limits(mddev->gendisk, rdev->bdev,
3277 rdev->data_offset << 9);
3278 /* as we don't honour merge_bvec_fn, we must never risk
3279 * violating it, so limit max_segments to 1 lying
3280 * within a single page.
3282 if (rdev->bdev->bd_disk->queue->merge_bvec_fn) {
3283 blk_queue_max_segments(mddev->queue, 1);
3284 blk_queue_segment_boundary(mddev->queue,
3285 PAGE_CACHE_SIZE - 1);
3288 disk->head_position = 0;
3290 /* need to check that every block has at least one working mirror */
3291 if (!enough(conf, -1)) {
3292 printk(KERN_ERR "md/raid10:%s: not enough operational mirrors.\n",
3293 mdname(mddev));
3294 goto out_free_conf;
3297 mddev->degraded = 0;
3298 for (i = 0; i < conf->raid_disks; i++) {
3300 disk = conf->mirrors + i;
3302 if (!disk->rdev && disk->replacement) {
3303 /* The replacement is all we have - use it */
3304 disk->rdev = disk->replacement;
3305 disk->replacement = NULL;
3306 clear_bit(Replacement, &disk->rdev->flags);
3309 if (!disk->rdev ||
3310 !test_bit(In_sync, &disk->rdev->flags)) {
3311 disk->head_position = 0;
3312 mddev->degraded++;
3313 if (disk->rdev)
3314 conf->fullsync = 1;
3316 disk->recovery_disabled = mddev->recovery_disabled - 1;
3319 if (mddev->recovery_cp != MaxSector)
3320 printk(KERN_NOTICE "md/raid10:%s: not clean"
3321 " -- starting background reconstruction\n",
3322 mdname(mddev));
3323 printk(KERN_INFO
3324 "md/raid10:%s: active with %d out of %d devices\n",
3325 mdname(mddev), conf->raid_disks - mddev->degraded,
3326 conf->raid_disks);
3328 * Ok, everything is just fine now
3330 mddev->dev_sectors = conf->dev_sectors;
3331 size = raid10_size(mddev, 0, 0);
3332 md_set_array_sectors(mddev, size);
3333 mddev->resync_max_sectors = size;
3335 mddev->queue->backing_dev_info.congested_fn = raid10_congested;
3336 mddev->queue->backing_dev_info.congested_data = mddev;
3338 /* Calculate max read-ahead size.
3339 * We need to readahead at least twice a whole stripe....
3340 * maybe...
3343 int stripe = conf->raid_disks *
3344 ((mddev->chunk_sectors << 9) / PAGE_SIZE);
3345 stripe /= conf->near_copies;
3346 if (mddev->queue->backing_dev_info.ra_pages < 2* stripe)
3347 mddev->queue->backing_dev_info.ra_pages = 2* stripe;
3350 if (conf->near_copies < conf->raid_disks)
3351 blk_queue_merge_bvec(mddev->queue, raid10_mergeable_bvec);
3353 if (md_integrity_register(mddev))
3354 goto out_free_conf;
3356 return 0;
3358 out_free_conf:
3359 md_unregister_thread(&mddev->thread);
3360 if (conf->r10bio_pool)
3361 mempool_destroy(conf->r10bio_pool);
3362 safe_put_page(conf->tmppage);
3363 kfree(conf->mirrors);
3364 kfree(conf);
3365 mddev->private = NULL;
3366 out:
3367 return -EIO;
3370 static int stop(struct mddev *mddev)
3372 struct r10conf *conf = mddev->private;
3374 raise_barrier(conf, 0);
3375 lower_barrier(conf);
3377 md_unregister_thread(&mddev->thread);
3378 blk_sync_queue(mddev->queue); /* the unplug fn references 'conf'*/
3379 if (conf->r10bio_pool)
3380 mempool_destroy(conf->r10bio_pool);
3381 kfree(conf->mirrors);
3382 kfree(conf);
3383 mddev->private = NULL;
3384 return 0;
3387 static void raid10_quiesce(struct mddev *mddev, int state)
3389 struct r10conf *conf = mddev->private;
3391 switch(state) {
3392 case 1:
3393 raise_barrier(conf, 0);
3394 break;
3395 case 0:
3396 lower_barrier(conf);
3397 break;
3401 static void *raid10_takeover_raid0(struct mddev *mddev)
3403 struct md_rdev *rdev;
3404 struct r10conf *conf;
3406 if (mddev->degraded > 0) {
3407 printk(KERN_ERR "md/raid10:%s: Error: degraded raid0!\n",
3408 mdname(mddev));
3409 return ERR_PTR(-EINVAL);
3412 /* Set new parameters */
3413 mddev->new_level = 10;
3414 /* new layout: far_copies = 1, near_copies = 2 */
3415 mddev->new_layout = (1<<8) + 2;
3416 mddev->new_chunk_sectors = mddev->chunk_sectors;
3417 mddev->delta_disks = mddev->raid_disks;
3418 mddev->raid_disks *= 2;
3419 /* make sure it will be not marked as dirty */
3420 mddev->recovery_cp = MaxSector;
3422 conf = setup_conf(mddev);
3423 if (!IS_ERR(conf)) {
3424 list_for_each_entry(rdev, &mddev->disks, same_set)
3425 if (rdev->raid_disk >= 0)
3426 rdev->new_raid_disk = rdev->raid_disk * 2;
3427 conf->barrier = 1;
3430 return conf;
3433 static void *raid10_takeover(struct mddev *mddev)
3435 struct r0conf *raid0_conf;
3437 /* raid10 can take over:
3438 * raid0 - providing it has only two drives
3440 if (mddev->level == 0) {
3441 /* for raid0 takeover only one zone is supported */
3442 raid0_conf = mddev->private;
3443 if (raid0_conf->nr_strip_zones > 1) {
3444 printk(KERN_ERR "md/raid10:%s: cannot takeover raid 0"
3445 " with more than one zone.\n",
3446 mdname(mddev));
3447 return ERR_PTR(-EINVAL);
3449 return raid10_takeover_raid0(mddev);
3451 return ERR_PTR(-EINVAL);
3454 static struct md_personality raid10_personality =
3456 .name = "raid10",
3457 .level = 10,
3458 .owner = THIS_MODULE,
3459 .make_request = make_request,
3460 .run = run,
3461 .stop = stop,
3462 .status = status,
3463 .error_handler = error,
3464 .hot_add_disk = raid10_add_disk,
3465 .hot_remove_disk= raid10_remove_disk,
3466 .spare_active = raid10_spare_active,
3467 .sync_request = sync_request,
3468 .quiesce = raid10_quiesce,
3469 .size = raid10_size,
3470 .takeover = raid10_takeover,
3473 static int __init raid_init(void)
3475 return register_md_personality(&raid10_personality);
3478 static void raid_exit(void)
3480 unregister_md_personality(&raid10_personality);
3483 module_init(raid_init);
3484 module_exit(raid_exit);
3485 MODULE_LICENSE("GPL");
3486 MODULE_DESCRIPTION("RAID10 (striped mirror) personality for MD");
3487 MODULE_ALIAS("md-personality-9"); /* RAID10 */
3488 MODULE_ALIAS("md-raid10");
3489 MODULE_ALIAS("md-level-10");
3491 module_param(max_queued_requests, int, S_IRUGO|S_IWUSR);