raid0.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745
  1. /*
  2. raid0.c : Multiple Devices driver for Linux
  3. Copyright (C) 1994-96 Marc ZYNGIER
  4. <zyngier@ufr-info-p7.ibp.fr> or
  5. <maz@gloups.fdn.fr>
  6. Copyright (C) 1999, 2000 Ingo Molnar, Red Hat
  7. RAID-0 management functions.
  8. This program is free software; you can redistribute it and/or modify
  9. it under the terms of the GNU General Public License as published by
  10. the Free Software Foundation; either version 2, or (at your option)
  11. any later version.
  12. You should have received a copy of the GNU General Public License
  13. (for example /usr/src/linux/COPYING); if not, write to the Free
  14. Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  15. */
  16. #include <linux/blkdev.h>
  17. #include <linux/seq_file.h>
  18. #include <linux/slab.h>
  19. #include "md.h"
  20. #include "raid0.h"
  21. #include "raid5.h"
  22. static void raid0_unplug(struct request_queue *q)
  23. {
  24. mddev_t *mddev = q->queuedata;
  25. raid0_conf_t *conf = mddev->private;
  26. mdk_rdev_t **devlist = conf->devlist;
  27. int raid_disks = conf->strip_zone[0].nb_dev;
  28. int i;
  29. for (i=0; i < raid_disks; i++) {
  30. struct request_queue *r_queue = bdev_get_queue(devlist[i]->bdev);
  31. blk_unplug(r_queue);
  32. }
  33. }
  34. static int raid0_congested(void *data, int bits)
  35. {
  36. mddev_t *mddev = data;
  37. raid0_conf_t *conf = mddev->private;
  38. mdk_rdev_t **devlist = conf->devlist;
  39. int raid_disks = conf->strip_zone[0].nb_dev;
  40. int i, ret = 0;
  41. if (mddev_congested(mddev, bits))
  42. return 1;
  43. for (i = 0; i < raid_disks && !ret ; i++) {
  44. struct request_queue *q = bdev_get_queue(devlist[i]->bdev);
  45. ret |= bdi_congested(&q->backing_dev_info, bits);
  46. }
  47. return ret;
  48. }
  49. /*
  50. * inform the user of the raid configuration
  51. */
  52. static void dump_zones(mddev_t *mddev)
  53. {
  54. int j, k, h;
  55. sector_t zone_size = 0;
  56. sector_t zone_start = 0;
  57. char b[BDEVNAME_SIZE];
  58. raid0_conf_t *conf = mddev->private;
  59. int raid_disks = conf->strip_zone[0].nb_dev;
  60. printk(KERN_INFO "******* %s configuration *********\n",
  61. mdname(mddev));
  62. h = 0;
  63. for (j = 0; j < conf->nr_strip_zones; j++) {
  64. printk(KERN_INFO "zone%d=[", j);
  65. for (k = 0; k < conf->strip_zone[j].nb_dev; k++)
  66. printk(KERN_CONT "%s/",
  67. bdevname(conf->devlist[j*raid_disks
  68. + k]->bdev, b));
  69. printk(KERN_CONT "]\n");
  70. zone_size = conf->strip_zone[j].zone_end - zone_start;
  71. printk(KERN_INFO " zone offset=%llukb "
  72. "device offset=%llukb size=%llukb\n",
  73. (unsigned long long)zone_start>>1,
  74. (unsigned long long)conf->strip_zone[j].dev_start>>1,
  75. (unsigned long long)zone_size>>1);
  76. zone_start = conf->strip_zone[j].zone_end;
  77. }
  78. printk(KERN_INFO "**********************************\n\n");
  79. }
  80. static int create_strip_zones(mddev_t *mddev, raid0_conf_t **private_conf)
  81. {
  82. int i, c, err;
  83. sector_t curr_zone_end, sectors;
  84. mdk_rdev_t *smallest, *rdev1, *rdev2, *rdev, **dev;
  85. struct strip_zone *zone;
  86. int cnt;
  87. char b[BDEVNAME_SIZE];
  88. raid0_conf_t *conf = kzalloc(sizeof(*conf), GFP_KERNEL);
  89. if (!conf)
  90. return -ENOMEM;
  91. list_for_each_entry(rdev1, &mddev->disks, same_set) {
  92. printk(KERN_INFO "md/raid0:%s: looking at %s\n",
  93. mdname(mddev),
  94. bdevname(rdev1->bdev, b));
  95. c = 0;
  96. /* round size to chunk_size */
  97. sectors = rdev1->sectors;
  98. sector_div(sectors, mddev->chunk_sectors);
  99. rdev1->sectors = sectors * mddev->chunk_sectors;
  100. list_for_each_entry(rdev2, &mddev->disks, same_set) {
  101. printk(KERN_INFO "md/raid0:%s: comparing %s(%llu)",
  102. mdname(mddev),
  103. bdevname(rdev1->bdev,b),
  104. (unsigned long long)rdev1->sectors);
  105. printk(KERN_CONT " with %s(%llu)\n",
  106. bdevname(rdev2->bdev,b),
  107. (unsigned long long)rdev2->sectors);
  108. if (rdev2 == rdev1) {
  109. printk(KERN_INFO "md/raid0:%s: END\n",
  110. mdname(mddev));
  111. break;
  112. }
  113. if (rdev2->sectors == rdev1->sectors) {
  114. /*
  115. * Not unique, don't count it as a new
  116. * group
  117. */
  118. printk(KERN_INFO "md/raid0:%s: EQUAL\n",
  119. mdname(mddev));
  120. c = 1;
  121. break;
  122. }
  123. printk(KERN_INFO "md/raid0:%s: NOT EQUAL\n",
  124. mdname(mddev));
  125. }
  126. if (!c) {
  127. printk(KERN_INFO "md/raid0:%s: ==> UNIQUE\n",
  128. mdname(mddev));
  129. conf->nr_strip_zones++;
  130. printk(KERN_INFO "md/raid0:%s: %d zones\n",
  131. mdname(mddev), conf->nr_strip_zones);
  132. }
  133. }
  134. printk(KERN_INFO "md/raid0:%s: FINAL %d zones\n",
  135. mdname(mddev), conf->nr_strip_zones);
  136. err = -ENOMEM;
  137. conf->strip_zone = kzalloc(sizeof(struct strip_zone)*
  138. conf->nr_strip_zones, GFP_KERNEL);
  139. if (!conf->strip_zone)
  140. goto abort;
  141. conf->devlist = kzalloc(sizeof(mdk_rdev_t*)*
  142. conf->nr_strip_zones*mddev->raid_disks,
  143. GFP_KERNEL);
  144. if (!conf->devlist)
  145. goto abort;
  146. /* The first zone must contain all devices, so here we check that
  147. * there is a proper alignment of slots to devices and find them all
  148. */
  149. zone = &conf->strip_zone[0];
  150. cnt = 0;
  151. smallest = NULL;
  152. dev = conf->devlist;
  153. err = -EINVAL;
  154. list_for_each_entry(rdev1, &mddev->disks, same_set) {
  155. int j = rdev1->raid_disk;
  156. if (mddev->level == 10) {
  157. /* taking over a raid10-n2 array */
  158. j /= 2;
  159. rdev1->new_raid_disk = j;
  160. }
  161. if (mddev->level == 1) {
  162. /* taiking over a raid1 array-
  163. * we have only one active disk
  164. */
  165. j = 0;
  166. rdev1->new_raid_disk = j;
  167. }
  168. if (j < 0 || j >= mddev->raid_disks) {
  169. printk(KERN_ERR "md/raid0:%s: bad disk number %d - "
  170. "aborting!\n", mdname(mddev), j);
  171. goto abort;
  172. }
  173. if (dev[j]) {
  174. printk(KERN_ERR "md/raid0:%s: multiple devices for %d - "
  175. "aborting!\n", mdname(mddev), j);
  176. goto abort;
  177. }
  178. dev[j] = rdev1;
  179. disk_stack_limits(mddev->gendisk, rdev1->bdev,
  180. rdev1->data_offset << 9);
  181. /* as we don't honour merge_bvec_fn, we must never risk
  182. * violating it, so limit ->max_segments to 1, lying within
  183. * a single page.
  184. */
  185. if (rdev1->bdev->bd_disk->queue->merge_bvec_fn) {
  186. blk_queue_max_segments(mddev->queue, 1);
  187. blk_queue_segment_boundary(mddev->queue,
  188. PAGE_CACHE_SIZE - 1);
  189. }
  190. if (!smallest || (rdev1->sectors < smallest->sectors))
  191. smallest = rdev1;
  192. cnt++;
  193. }
  194. if (cnt != mddev->raid_disks) {
  195. printk(KERN_ERR "md/raid0:%s: too few disks (%d of %d) - "
  196. "aborting!\n", mdname(mddev), cnt, mddev->raid_disks);
  197. goto abort;
  198. }
  199. zone->nb_dev = cnt;
  200. zone->zone_end = smallest->sectors * cnt;
  201. curr_zone_end = zone->zone_end;
  202. /* now do the other zones */
  203. for (i = 1; i < conf->nr_strip_zones; i++)
  204. {
  205. int j;
  206. zone = conf->strip_zone + i;
  207. dev = conf->devlist + i * mddev->raid_disks;
  208. printk(KERN_INFO "md/raid0:%s: zone %d\n",
  209. mdname(mddev), i);
  210. zone->dev_start = smallest->sectors;
  211. smallest = NULL;
  212. c = 0;
  213. for (j=0; j<cnt; j++) {
  214. rdev = conf->devlist[j];
  215. printk(KERN_INFO "md/raid0:%s: checking %s ...",
  216. mdname(mddev),
  217. bdevname(rdev->bdev, b));
  218. if (rdev->sectors <= zone->dev_start) {
  219. printk(KERN_CONT " nope.\n");
  220. continue;
  221. }
  222. printk(KERN_CONT " contained as device %d\n", c);
  223. dev[c] = rdev;
  224. c++;
  225. if (!smallest || rdev->sectors < smallest->sectors) {
  226. smallest = rdev;
  227. printk(KERN_INFO "md/raid0:%s: (%llu) is smallest!.\n",
  228. mdname(mddev),
  229. (unsigned long long)rdev->sectors);
  230. }
  231. }
  232. zone->nb_dev = c;
  233. sectors = (smallest->sectors - zone->dev_start) * c;
  234. printk(KERN_INFO "md/raid0:%s: zone->nb_dev: %d, sectors: %llu\n",
  235. mdname(mddev),
  236. zone->nb_dev, (unsigned long long)sectors);
  237. curr_zone_end += sectors;
  238. zone->zone_end = curr_zone_end;
  239. printk(KERN_INFO "md/raid0:%s: current zone start: %llu\n",
  240. mdname(mddev),
  241. (unsigned long long)smallest->sectors);
  242. }
  243. mddev->queue->unplug_fn = raid0_unplug;
  244. mddev->queue->backing_dev_info.congested_fn = raid0_congested;
  245. mddev->queue->backing_dev_info.congested_data = mddev;
  246. /*
  247. * now since we have the hard sector sizes, we can make sure
  248. * chunk size is a multiple of that sector size
  249. */
  250. if ((mddev->chunk_sectors << 9) % queue_logical_block_size(mddev->queue)) {
  251. printk(KERN_ERR "md/raid0:%s: chunk_size of %d not valid\n",
  252. mdname(mddev),
  253. mddev->chunk_sectors << 9);
  254. goto abort;
  255. }
  256. blk_queue_io_min(mddev->queue, mddev->chunk_sectors << 9);
  257. blk_queue_io_opt(mddev->queue,
  258. (mddev->chunk_sectors << 9) * mddev->raid_disks);
  259. printk(KERN_INFO "md/raid0:%s: done.\n", mdname(mddev));
  260. *private_conf = conf;
  261. return 0;
  262. abort:
  263. kfree(conf->strip_zone);
  264. kfree(conf->devlist);
  265. kfree(conf);
  266. *private_conf = NULL;
  267. return err;
  268. }
  269. /**
  270. * raid0_mergeable_bvec -- tell bio layer if a two requests can be merged
  271. * @q: request queue
  272. * @bvm: properties of new bio
  273. * @biovec: the request that could be merged to it.
  274. *
  275. * Return amount of bytes we can accept at this offset
  276. */
  277. static int raid0_mergeable_bvec(struct request_queue *q,
  278. struct bvec_merge_data *bvm,
  279. struct bio_vec *biovec)
  280. {
  281. mddev_t *mddev = q->queuedata;
  282. sector_t sector = bvm->bi_sector + get_start_sect(bvm->bi_bdev);
  283. int max;
  284. unsigned int chunk_sectors = mddev->chunk_sectors;
  285. unsigned int bio_sectors = bvm->bi_size >> 9;
  286. if (is_power_of_2(chunk_sectors))
  287. max = (chunk_sectors - ((sector & (chunk_sectors-1))
  288. + bio_sectors)) << 9;
  289. else
  290. max = (chunk_sectors - (sector_div(sector, chunk_sectors)
  291. + bio_sectors)) << 9;
  292. if (max < 0) max = 0; /* bio_add cannot handle a negative return */
  293. if (max <= biovec->bv_len && bio_sectors == 0)
  294. return biovec->bv_len;
  295. else
  296. return max;
  297. }
  298. static sector_t raid0_size(mddev_t *mddev, sector_t sectors, int raid_disks)
  299. {
  300. sector_t array_sectors = 0;
  301. mdk_rdev_t *rdev;
  302. WARN_ONCE(sectors || raid_disks,
  303. "%s does not support generic reshape\n", __func__);
  304. list_for_each_entry(rdev, &mddev->disks, same_set)
  305. array_sectors += rdev->sectors;
  306. return array_sectors;
  307. }
  308. static int raid0_run(mddev_t *mddev)
  309. {
  310. raid0_conf_t *conf;
  311. int ret;
  312. if (mddev->chunk_sectors == 0) {
  313. printk(KERN_ERR "md/raid0:%s: chunk size must be set.\n",
  314. mdname(mddev));
  315. return -EINVAL;
  316. }
  317. if (md_check_no_bitmap(mddev))
  318. return -EINVAL;
  319. blk_queue_max_hw_sectors(mddev->queue, mddev->chunk_sectors);
  320. mddev->queue->queue_lock = &mddev->queue->__queue_lock;
  321. /* if private is not null, we are here after takeover */
  322. if (mddev->private == NULL) {
  323. ret = create_strip_zones(mddev, &conf);
  324. if (ret < 0)
  325. return ret;
  326. mddev->private = conf;
  327. }
  328. conf = mddev->private;
  329. /* calculate array device size */
  330. md_set_array_sectors(mddev, raid0_size(mddev, 0, 0));
  331. printk(KERN_INFO "md/raid0:%s: md_size is %llu sectors.\n",
  332. mdname(mddev),
  333. (unsigned long long)mddev->array_sectors);
  334. /* calculate the max read-ahead size.
  335. * For read-ahead of large files to be effective, we need to
  336. * readahead at least twice a whole stripe. i.e. number of devices
  337. * multiplied by chunk size times 2.
  338. * If an individual device has an ra_pages greater than the
  339. * chunk size, then we will not drive that device as hard as it
  340. * wants. We consider this a configuration error: a larger
  341. * chunksize should be used in that case.
  342. */
  343. {
  344. int stripe = mddev->raid_disks *
  345. (mddev->chunk_sectors << 9) / PAGE_SIZE;
  346. if (mddev->queue->backing_dev_info.ra_pages < 2* stripe)
  347. mddev->queue->backing_dev_info.ra_pages = 2* stripe;
  348. }
  349. blk_queue_merge_bvec(mddev->queue, raid0_mergeable_bvec);
  350. dump_zones(mddev);
  351. md_integrity_register(mddev);
  352. return 0;
  353. }
  354. static int raid0_stop(mddev_t *mddev)
  355. {
  356. raid0_conf_t *conf = mddev->private;
  357. blk_sync_queue(mddev->queue); /* the unplug fn references 'conf'*/
  358. kfree(conf->strip_zone);
  359. kfree(conf->devlist);
  360. kfree(conf);
  361. mddev->private = NULL;
  362. return 0;
  363. }
  364. /* Find the zone which holds a particular offset
  365. * Update *sectorp to be an offset in that zone
  366. */
  367. static struct strip_zone *find_zone(struct raid0_private_data *conf,
  368. sector_t *sectorp)
  369. {
  370. int i;
  371. struct strip_zone *z = conf->strip_zone;
  372. sector_t sector = *sectorp;
  373. for (i = 0; i < conf->nr_strip_zones; i++)
  374. if (sector < z[i].zone_end) {
  375. if (i)
  376. *sectorp = sector - z[i-1].zone_end;
  377. return z + i;
  378. }
  379. BUG();
  380. }
  381. /*
  382. * remaps the bio to the target device. we separate two flows.
  383. * power 2 flow and a general flow for the sake of perfromance
  384. */
  385. static mdk_rdev_t *map_sector(mddev_t *mddev, struct strip_zone *zone,
  386. sector_t sector, sector_t *sector_offset)
  387. {
  388. unsigned int sect_in_chunk;
  389. sector_t chunk;
  390. raid0_conf_t *conf = mddev->private;
  391. int raid_disks = conf->strip_zone[0].nb_dev;
  392. unsigned int chunk_sects = mddev->chunk_sectors;
  393. if (is_power_of_2(chunk_sects)) {
  394. int chunksect_bits = ffz(~chunk_sects);
  395. /* find the sector offset inside the chunk */
  396. sect_in_chunk = sector & (chunk_sects - 1);
  397. sector >>= chunksect_bits;
  398. /* chunk in zone */
  399. chunk = *sector_offset;
  400. /* quotient is the chunk in real device*/
  401. sector_div(chunk, zone->nb_dev << chunksect_bits);
  402. } else{
  403. sect_in_chunk = sector_div(sector, chunk_sects);
  404. chunk = *sector_offset;
  405. sector_div(chunk, chunk_sects * zone->nb_dev);
  406. }
  407. /*
  408. * position the bio over the real device
  409. * real sector = chunk in device + starting of zone
  410. * + the position in the chunk
  411. */
  412. *sector_offset = (chunk * chunk_sects) + sect_in_chunk;
  413. return conf->devlist[(zone - conf->strip_zone)*raid_disks
  414. + sector_div(sector, zone->nb_dev)];
  415. }
  416. /*
  417. * Is io distribute over 1 or more chunks ?
  418. */
  419. static inline int is_io_in_chunk_boundary(mddev_t *mddev,
  420. unsigned int chunk_sects, struct bio *bio)
  421. {
  422. if (likely(is_power_of_2(chunk_sects))) {
  423. return chunk_sects >= ((bio->bi_sector & (chunk_sects-1))
  424. + (bio->bi_size >> 9));
  425. } else{
  426. sector_t sector = bio->bi_sector;
  427. return chunk_sects >= (sector_div(sector, chunk_sects)
  428. + (bio->bi_size >> 9));
  429. }
  430. }
  431. static int raid0_make_request(mddev_t *mddev, struct bio *bio)
  432. {
  433. unsigned int chunk_sects;
  434. sector_t sector_offset;
  435. struct strip_zone *zone;
  436. mdk_rdev_t *tmp_dev;
  437. if (unlikely(bio->bi_rw & REQ_FLUSH)) {
  438. md_flush_request(mddev, bio);
  439. return 0;
  440. }
  441. chunk_sects = mddev->chunk_sectors;
  442. if (unlikely(!is_io_in_chunk_boundary(mddev, chunk_sects, bio))) {
  443. sector_t sector = bio->bi_sector;
  444. struct bio_pair *bp;
  445. /* Sanity check -- queue functions should prevent this happening */
  446. if (bio->bi_vcnt != 1 ||
  447. bio->bi_idx != 0)
  448. goto bad_map;
  449. /* This is a one page bio that upper layers
  450. * refuse to split for us, so we need to split it.
  451. */
  452. if (likely(is_power_of_2(chunk_sects)))
  453. bp = bio_split(bio, chunk_sects - (sector &
  454. (chunk_sects-1)));
  455. else
  456. bp = bio_split(bio, chunk_sects -
  457. sector_div(sector, chunk_sects));
  458. if (raid0_make_request(mddev, &bp->bio1))
  459. generic_make_request(&bp->bio1);
  460. if (raid0_make_request(mddev, &bp->bio2))
  461. generic_make_request(&bp->bio2);
  462. bio_pair_release(bp);
  463. return 0;
  464. }
  465. sector_offset = bio->bi_sector;
  466. zone = find_zone(mddev->private, &sector_offset);
  467. tmp_dev = map_sector(mddev, zone, bio->bi_sector,
  468. &sector_offset);
  469. bio->bi_bdev = tmp_dev->bdev;
  470. bio->bi_sector = sector_offset + zone->dev_start +
  471. tmp_dev->data_offset;
  472. /*
  473. * Let the main block layer submit the IO and resolve recursion:
  474. */
  475. return 1;
  476. bad_map:
  477. printk("md/raid0:%s: make_request bug: can't convert block across chunks"
  478. " or bigger than %dk %llu %d\n",
  479. mdname(mddev), chunk_sects / 2,
  480. (unsigned long long)bio->bi_sector, bio->bi_size >> 10);
  481. bio_io_error(bio);
  482. return 0;
  483. }
  484. static void raid0_status(struct seq_file *seq, mddev_t *mddev)
  485. {
  486. #undef MD_DEBUG
  487. #ifdef MD_DEBUG
  488. int j, k, h;
  489. char b[BDEVNAME_SIZE];
  490. raid0_conf_t *conf = mddev->private;
  491. int raid_disks = conf->strip_zone[0].nb_dev;
  492. sector_t zone_size;
  493. sector_t zone_start = 0;
  494. h = 0;
  495. for (j = 0; j < conf->nr_strip_zones; j++) {
  496. seq_printf(seq, " z%d", j);
  497. seq_printf(seq, "=[");
  498. for (k = 0; k < conf->strip_zone[j].nb_dev; k++)
  499. seq_printf(seq, "%s/", bdevname(
  500. conf->devlist[j*raid_disks + k]
  501. ->bdev, b));
  502. zone_size = conf->strip_zone[j].zone_end - zone_start;
  503. seq_printf(seq, "] ze=%lld ds=%lld s=%lld\n",
  504. (unsigned long long)zone_start>>1,
  505. (unsigned long long)conf->strip_zone[j].dev_start>>1,
  506. (unsigned long long)zone_size>>1);
  507. zone_start = conf->strip_zone[j].zone_end;
  508. }
  509. #endif
  510. seq_printf(seq, " %dk chunks", mddev->chunk_sectors / 2);
  511. return;
  512. }
  513. static void *raid0_takeover_raid45(mddev_t *mddev)
  514. {
  515. mdk_rdev_t *rdev;
  516. raid0_conf_t *priv_conf;
  517. if (mddev->degraded != 1) {
  518. printk(KERN_ERR "md/raid0:%s: raid5 must be degraded! Degraded disks: %d\n",
  519. mdname(mddev),
  520. mddev->degraded);
  521. return ERR_PTR(-EINVAL);
  522. }
  523. list_for_each_entry(rdev, &mddev->disks, same_set) {
  524. /* check slot number for a disk */
  525. if (rdev->raid_disk == mddev->raid_disks-1) {
  526. printk(KERN_ERR "md/raid0:%s: raid5 must have missing parity disk!\n",
  527. mdname(mddev));
  528. return ERR_PTR(-EINVAL);
  529. }
  530. }
  531. /* Set new parameters */
  532. mddev->new_level = 0;
  533. mddev->new_layout = 0;
  534. mddev->new_chunk_sectors = mddev->chunk_sectors;
  535. mddev->raid_disks--;
  536. mddev->delta_disks = -1;
  537. /* make sure it will be not marked as dirty */
  538. mddev->recovery_cp = MaxSector;
  539. create_strip_zones(mddev, &priv_conf);
  540. return priv_conf;
  541. }
  542. static void *raid0_takeover_raid10(mddev_t *mddev)
  543. {
  544. raid0_conf_t *priv_conf;
  545. /* Check layout:
  546. * - far_copies must be 1
  547. * - near_copies must be 2
  548. * - disks number must be even
  549. * - all mirrors must be already degraded
  550. */
  551. if (mddev->layout != ((1 << 8) + 2)) {
  552. printk(KERN_ERR "md/raid0:%s:: Raid0 cannot takover layout: 0x%x\n",
  553. mdname(mddev),
  554. mddev->layout);
  555. return ERR_PTR(-EINVAL);
  556. }
  557. if (mddev->raid_disks & 1) {
  558. printk(KERN_ERR "md/raid0:%s: Raid0 cannot takover Raid10 with odd disk number.\n",
  559. mdname(mddev));
  560. return ERR_PTR(-EINVAL);
  561. }
  562. if (mddev->degraded != (mddev->raid_disks>>1)) {
  563. printk(KERN_ERR "md/raid0:%s: All mirrors must be already degraded!\n",
  564. mdname(mddev));
  565. return ERR_PTR(-EINVAL);
  566. }
  567. /* Set new parameters */
  568. mddev->new_level = 0;
  569. mddev->new_layout = 0;
  570. mddev->new_chunk_sectors = mddev->chunk_sectors;
  571. mddev->delta_disks = - mddev->raid_disks / 2;
  572. mddev->raid_disks += mddev->delta_disks;
  573. mddev->degraded = 0;
  574. /* make sure it will be not marked as dirty */
  575. mddev->recovery_cp = MaxSector;
  576. create_strip_zones(mddev, &priv_conf);
  577. return priv_conf;
  578. }
  579. static void *raid0_takeover_raid1(mddev_t *mddev)
  580. {
  581. raid0_conf_t *priv_conf;
  582. /* Check layout:
  583. * - (N - 1) mirror drives must be already faulty
  584. */
  585. if ((mddev->raid_disks - 1) != mddev->degraded) {
  586. printk(KERN_ERR "md/raid0:%s: (N - 1) mirrors drives must be already faulty!\n",
  587. mdname(mddev));
  588. return ERR_PTR(-EINVAL);
  589. }
  590. /* Set new parameters */
  591. mddev->new_level = 0;
  592. mddev->new_layout = 0;
  593. mddev->new_chunk_sectors = 128; /* by default set chunk size to 64k */
  594. mddev->delta_disks = 1 - mddev->raid_disks;
  595. /* make sure it will be not marked as dirty */
  596. mddev->recovery_cp = MaxSector;
  597. create_strip_zones(mddev, &priv_conf);
  598. return priv_conf;
  599. }
  600. static void *raid0_takeover(mddev_t *mddev)
  601. {
  602. /* raid0 can take over:
  603. * raid4 - if all data disks are active.
  604. * raid5 - providing it is Raid4 layout and one disk is faulty
  605. * raid10 - assuming we have all necessary active disks
  606. * raid1 - with (N -1) mirror drives faulty
  607. */
  608. if (mddev->level == 4)
  609. return raid0_takeover_raid45(mddev);
  610. if (mddev->level == 5) {
  611. if (mddev->layout == ALGORITHM_PARITY_N)
  612. return raid0_takeover_raid45(mddev);
  613. printk(KERN_ERR "md/raid0:%s: Raid can only takeover Raid5 with layout: %d\n",
  614. mdname(mddev), ALGORITHM_PARITY_N);
  615. }
  616. if (mddev->level == 10)
  617. return raid0_takeover_raid10(mddev);
  618. if (mddev->level == 1)
  619. return raid0_takeover_raid1(mddev);
  620. printk(KERN_ERR "Takeover from raid%i to raid0 not supported\n",
  621. mddev->level);
  622. return ERR_PTR(-EINVAL);
  623. }
  624. static void raid0_quiesce(mddev_t *mddev, int state)
  625. {
  626. }
  627. static struct mdk_personality raid0_personality=
  628. {
  629. .name = "raid0",
  630. .level = 0,
  631. .owner = THIS_MODULE,
  632. .make_request = raid0_make_request,
  633. .run = raid0_run,
  634. .stop = raid0_stop,
  635. .status = raid0_status,
  636. .size = raid0_size,
  637. .takeover = raid0_takeover,
  638. .quiesce = raid0_quiesce,
  639. };
  640. static int __init raid0_init (void)
  641. {
  642. return register_md_personality (&raid0_personality);
  643. }
  644. static void raid0_exit (void)
  645. {
  646. unregister_md_personality (&raid0_personality);
  647. }
  648. module_init(raid0_init);
  649. module_exit(raid0_exit);
  650. MODULE_LICENSE("GPL");
  651. MODULE_DESCRIPTION("RAID0 (striping) personality for MD");
  652. MODULE_ALIAS("md-personality-2"); /* RAID0 */
  653. MODULE_ALIAS("md-raid0");
  654. MODULE_ALIAS("md-level-0");