]>
Commit | Line | Data |
---|---|---|
1da177e4 LT |
1 | /* |
2 | linear.c : Multiple Devices driver for Linux | |
3 | Copyright (C) 1994-96 Marc ZYNGIER | |
4 | <[email protected]> or | |
5 | <[email protected]> | |
6 | ||
7 | Linear mode management functions. | |
8 | ||
9 | This program is free software; you can redistribute it and/or modify | |
10 | it under the terms of the GNU General Public License as published by | |
11 | the Free Software Foundation; either version 2, or (at your option) | |
12 | any later version. | |
13 | ||
14 | You should have received a copy of the GNU General Public License | |
15 | (for example /usr/src/linux/COPYING); if not, write to the Free | |
16 | Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. | |
17 | */ | |
18 | ||
bff61975 N |
19 | #include <linux/blkdev.h> |
20 | #include <linux/raid/md_u.h> | |
bff61975 | 21 | #include <linux/seq_file.h> |
5a0e3ad6 | 22 | #include <linux/slab.h> |
43b2e5d8 | 23 | #include "md.h" |
ef740c37 | 24 | #include "linear.h" |
1da177e4 | 25 | |
1da177e4 LT |
26 | /* |
27 | * find which device holds a particular offset | |
28 | */ | |
29 | static inline dev_info_t *which_dev(mddev_t *mddev, sector_t sector) | |
30 | { | |
aece3d1f | 31 | int lo, mid, hi; |
af11c397 | 32 | linear_conf_t *conf; |
1da177e4 | 33 | |
aece3d1f SS |
34 | lo = 0; |
35 | hi = mddev->raid_disks - 1; | |
af11c397 | 36 | conf = rcu_dereference(mddev->private); |
1da177e4 | 37 | |
aece3d1f SS |
38 | /* |
39 | * Binary Search | |
40 | */ | |
41 | ||
42 | while (hi > lo) { | |
43 | ||
44 | mid = (hi + lo) / 2; | |
45 | if (sector < conf->disks[mid].end_sector) | |
46 | hi = mid; | |
47 | else | |
48 | lo = mid + 1; | |
49 | } | |
50 | ||
51 | return conf->disks + lo; | |
1da177e4 LT |
52 | } |
53 | ||
54 | /** | |
15945fee | 55 | * linear_mergeable_bvec -- tell bio layer if two requests can be merged |
1da177e4 | 56 | * @q: request queue |
cc371e66 | 57 | * @bvm: properties of new bio |
1da177e4 LT |
58 | * @biovec: the request that could be merged to it. |
59 | * | |
60 | * Return amount of bytes we can take at this offset | |
61 | */ | |
cc371e66 AK |
62 | static int linear_mergeable_bvec(struct request_queue *q, |
63 | struct bvec_merge_data *bvm, | |
64 | struct bio_vec *biovec) | |
1da177e4 LT |
65 | { |
66 | mddev_t *mddev = q->queuedata; | |
67 | dev_info_t *dev0; | |
cc371e66 AK |
68 | unsigned long maxsectors, bio_sectors = bvm->bi_size >> 9; |
69 | sector_t sector = bvm->bi_sector + get_start_sect(bvm->bi_bdev); | |
1da177e4 | 70 | |
af11c397 | 71 | rcu_read_lock(); |
1da177e4 | 72 | dev0 = which_dev(mddev, sector); |
4db7cdc8 | 73 | maxsectors = dev0->end_sector - sector; |
af11c397 | 74 | rcu_read_unlock(); |
1da177e4 LT |
75 | |
76 | if (maxsectors < bio_sectors) | |
77 | maxsectors = 0; | |
78 | else | |
79 | maxsectors -= bio_sectors; | |
80 | ||
81 | if (maxsectors <= (PAGE_SIZE >> 9 ) && bio_sectors == 0) | |
82 | return biovec->bv_len; | |
83 | /* The bytes available at this offset could be really big, | |
84 | * so we cap at 2^31 to avoid overflow */ | |
85 | if (maxsectors > (1 << (31-9))) | |
86 | return 1<<31; | |
87 | return maxsectors << 9; | |
88 | } | |
89 | ||
26be34dc N |
90 | static int linear_congested(void *data, int bits) |
91 | { | |
92 | mddev_t *mddev = data; | |
af11c397 | 93 | linear_conf_t *conf; |
26be34dc N |
94 | int i, ret = 0; |
95 | ||
3fa841d7 N |
96 | if (mddev_congested(mddev, bits)) |
97 | return 1; | |
98 | ||
af11c397 S |
99 | rcu_read_lock(); |
100 | conf = rcu_dereference(mddev->private); | |
101 | ||
26be34dc | 102 | for (i = 0; i < mddev->raid_disks && !ret ; i++) { |
165125e1 | 103 | struct request_queue *q = bdev_get_queue(conf->disks[i].rdev->bdev); |
26be34dc N |
104 | ret |= bdi_congested(&q->backing_dev_info, bits); |
105 | } | |
af11c397 S |
106 | |
107 | rcu_read_unlock(); | |
26be34dc N |
108 | return ret; |
109 | } | |
110 | ||
80c3a6ce DW |
111 | static sector_t linear_size(mddev_t *mddev, sector_t sectors, int raid_disks) |
112 | { | |
af11c397 S |
113 | linear_conf_t *conf; |
114 | sector_t array_sectors; | |
80c3a6ce | 115 | |
af11c397 S |
116 | rcu_read_lock(); |
117 | conf = rcu_dereference(mddev->private); | |
80c3a6ce DW |
118 | WARN_ONCE(sectors || raid_disks, |
119 | "%s does not support generic reshape\n", __func__); | |
af11c397 S |
120 | array_sectors = conf->array_sectors; |
121 | rcu_read_unlock(); | |
80c3a6ce | 122 | |
af11c397 | 123 | return array_sectors; |
80c3a6ce DW |
124 | } |
125 | ||
7c7546cc | 126 | static linear_conf_t *linear_conf(mddev_t *mddev, int raid_disks) |
1da177e4 LT |
127 | { |
128 | linear_conf_t *conf; | |
1da177e4 | 129 | mdk_rdev_t *rdev; |
45d4582f | 130 | int i, cnt; |
1da177e4 | 131 | |
7c7546cc | 132 | conf = kzalloc (sizeof (*conf) + raid_disks*sizeof(dev_info_t), |
1da177e4 LT |
133 | GFP_KERNEL); |
134 | if (!conf) | |
7c7546cc N |
135 | return NULL; |
136 | ||
1da177e4 | 137 | cnt = 0; |
d6e22150 | 138 | conf->array_sectors = 0; |
1da177e4 | 139 | |
159ec1fc | 140 | list_for_each_entry(rdev, &mddev->disks, same_set) { |
1da177e4 LT |
141 | int j = rdev->raid_disk; |
142 | dev_info_t *disk = conf->disks + j; | |
13f2682b | 143 | sector_t sectors; |
1da177e4 | 144 | |
13864515 | 145 | if (j < 0 || j >= raid_disks || disk->rdev) { |
2dc40f80 N |
146 | printk(KERN_ERR "md/linear:%s: disk numbering problem. Aborting!\n", |
147 | mdname(mddev)); | |
1da177e4 LT |
148 | goto out; |
149 | } | |
150 | ||
151 | disk->rdev = rdev; | |
13f2682b N |
152 | if (mddev->chunk_sectors) { |
153 | sectors = rdev->sectors; | |
154 | sector_div(sectors, mddev->chunk_sectors); | |
155 | rdev->sectors = sectors * mddev->chunk_sectors; | |
156 | } | |
1da177e4 | 157 | |
8f6c2e4b MP |
158 | disk_stack_limits(mddev->gendisk, rdev->bdev, |
159 | rdev->data_offset << 9); | |
1da177e4 | 160 | /* as we don't honour merge_bvec_fn, we must never risk |
627a2d3c N |
161 | * violating it, so limit max_segments to 1 lying within |
162 | * a single page. | |
1da177e4 | 163 | */ |
627a2d3c N |
164 | if (rdev->bdev->bd_disk->queue->merge_bvec_fn) { |
165 | blk_queue_max_segments(mddev->queue, 1); | |
166 | blk_queue_segment_boundary(mddev->queue, | |
167 | PAGE_CACHE_SIZE - 1); | |
168 | } | |
1da177e4 | 169 | |
dd8ac336 | 170 | conf->array_sectors += rdev->sectors; |
1da177e4 | 171 | cnt++; |
4db7cdc8 | 172 | |
1da177e4 | 173 | } |
7c7546cc | 174 | if (cnt != raid_disks) { |
2dc40f80 N |
175 | printk(KERN_ERR "md/linear:%s: not enough drives present. Aborting!\n", |
176 | mdname(mddev)); | |
1da177e4 LT |
177 | goto out; |
178 | } | |
179 | ||
180 | /* | |
45d4582f | 181 | * Here we calculate the device offsets. |
1da177e4 | 182 | */ |
4db7cdc8 SS |
183 | conf->disks[0].end_sector = conf->disks[0].rdev->sectors; |
184 | ||
a778b73f | 185 | for (i = 1; i < raid_disks; i++) |
4db7cdc8 SS |
186 | conf->disks[i].end_sector = |
187 | conf->disks[i-1].end_sector + | |
188 | conf->disks[i].rdev->sectors; | |
15945fee | 189 | |
7c7546cc N |
190 | return conf; |
191 | ||
192 | out: | |
193 | kfree(conf); | |
194 | return NULL; | |
195 | } | |
196 | ||
197 | static int linear_run (mddev_t *mddev) | |
198 | { | |
199 | linear_conf_t *conf; | |
200 | ||
0894cc30 AN |
201 | if (md_check_no_bitmap(mddev)) |
202 | return -EINVAL; | |
7c7546cc N |
203 | conf = linear_conf(mddev, mddev->raid_disks); |
204 | ||
205 | if (!conf) | |
206 | return 1; | |
207 | mddev->private = conf; | |
1f403624 | 208 | md_set_array_sectors(mddev, linear_size(mddev, 0, 0)); |
7c7546cc | 209 | |
1da177e4 | 210 | blk_queue_merge_bvec(mddev->queue, linear_mergeable_bvec); |
26be34dc N |
211 | mddev->queue->backing_dev_info.congested_fn = linear_congested; |
212 | mddev->queue->backing_dev_info.congested_data = mddev; | |
a91a2785 | 213 | return md_integrity_register(mddev); |
7c7546cc | 214 | } |
1da177e4 | 215 | |
495d3573 N |
216 | static void free_conf(struct rcu_head *head) |
217 | { | |
218 | linear_conf_t *conf = container_of(head, linear_conf_t, rcu); | |
219 | kfree(conf); | |
220 | } | |
221 | ||
7c7546cc N |
222 | static int linear_add(mddev_t *mddev, mdk_rdev_t *rdev) |
223 | { | |
224 | /* Adding a drive to a linear array allows the array to grow. | |
225 | * It is permitted if the new drive has a matching superblock | |
226 | * already on it, with raid_disk equal to raid_disks. | |
227 | * It is achieved by creating a new linear_private_data structure | |
228 | * and swapping it in in-place of the current one. | |
229 | * The current one is never freed until the array is stopped. | |
230 | * This avoids races. | |
231 | */ | |
495d3573 | 232 | linear_conf_t *newconf, *oldconf; |
7c7546cc | 233 | |
a778b73f | 234 | if (rdev->saved_raid_disk != mddev->raid_disks) |
7c7546cc N |
235 | return -EINVAL; |
236 | ||
a778b73f N |
237 | rdev->raid_disk = rdev->saved_raid_disk; |
238 | ||
7c7546cc N |
239 | newconf = linear_conf(mddev,mddev->raid_disks+1); |
240 | ||
241 | if (!newconf) | |
242 | return -ENOMEM; | |
243 | ||
495d3573 | 244 | oldconf = rcu_dereference(mddev->private); |
7c7546cc | 245 | mddev->raid_disks++; |
af11c397 | 246 | rcu_assign_pointer(mddev->private, newconf); |
1f403624 | 247 | md_set_array_sectors(mddev, linear_size(mddev, 0, 0)); |
f233ea5c | 248 | set_capacity(mddev->gendisk, mddev->array_sectors); |
449aad3e | 249 | revalidate_disk(mddev->gendisk); |
495d3573 | 250 | call_rcu(&oldconf->rcu, free_conf); |
7c7546cc | 251 | return 0; |
1da177e4 LT |
252 | } |
253 | ||
254 | static int linear_stop (mddev_t *mddev) | |
255 | { | |
070ec55d | 256 | linear_conf_t *conf = mddev->private; |
af11c397 S |
257 | |
258 | /* | |
259 | * We do not require rcu protection here since | |
260 | * we hold reconfig_mutex for both linear_add and | |
261 | * linear_stop, so they cannot race. | |
495d3573 N |
262 | * We should make sure any old 'conf's are properly |
263 | * freed though. | |
af11c397 | 264 | */ |
495d3573 | 265 | rcu_barrier(); |
1da177e4 | 266 | blk_sync_queue(mddev->queue); /* the unplug fn references 'conf'*/ |
495d3573 | 267 | kfree(conf); |
ef2f80ff | 268 | mddev->private = NULL; |
1da177e4 LT |
269 | |
270 | return 0; | |
271 | } | |
272 | ||
21a52c6d | 273 | static int linear_make_request (mddev_t *mddev, struct bio *bio) |
1da177e4 | 274 | { |
1da177e4 | 275 | dev_info_t *tmp_dev; |
4db7cdc8 | 276 | sector_t start_sector; |
1da177e4 | 277 | |
e9c7469b TH |
278 | if (unlikely(bio->bi_rw & REQ_FLUSH)) { |
279 | md_flush_request(mddev, bio); | |
e5dcdd80 N |
280 | return 0; |
281 | } | |
282 | ||
af11c397 | 283 | rcu_read_lock(); |
1da177e4 | 284 | tmp_dev = which_dev(mddev, bio->bi_sector); |
4db7cdc8 SS |
285 | start_sector = tmp_dev->end_sector - tmp_dev->rdev->sectors; |
286 | ||
af11c397 | 287 | |
4db7cdc8 SS |
288 | if (unlikely(bio->bi_sector >= (tmp_dev->end_sector) |
289 | || (bio->bi_sector < start_sector))) { | |
1da177e4 LT |
290 | char b[BDEVNAME_SIZE]; |
291 | ||
2dc40f80 N |
292 | printk(KERN_ERR |
293 | "md/linear:%s: make_request: Sector %llu out of bounds on " | |
294 | "dev %s: %llu sectors, offset %llu\n", | |
295 | mdname(mddev), | |
296 | (unsigned long long)bio->bi_sector, | |
297 | bdevname(tmp_dev->rdev->bdev, b), | |
298 | (unsigned long long)tmp_dev->rdev->sectors, | |
299 | (unsigned long long)start_sector); | |
af11c397 | 300 | rcu_read_unlock(); |
6712ecf8 | 301 | bio_io_error(bio); |
1da177e4 LT |
302 | return 0; |
303 | } | |
304 | if (unlikely(bio->bi_sector + (bio->bi_size >> 9) > | |
4db7cdc8 | 305 | tmp_dev->end_sector)) { |
1da177e4 LT |
306 | /* This bio crosses a device boundary, so we have to |
307 | * split it. | |
308 | */ | |
309 | struct bio_pair *bp; | |
af11c397 S |
310 | sector_t end_sector = tmp_dev->end_sector; |
311 | ||
312 | rcu_read_unlock(); | |
6283815d | 313 | |
af11c397 | 314 | bp = bio_split(bio, end_sector - bio->bi_sector); |
6283815d | 315 | |
21a52c6d | 316 | if (linear_make_request(mddev, &bp->bio1)) |
1da177e4 | 317 | generic_make_request(&bp->bio1); |
21a52c6d | 318 | if (linear_make_request(mddev, &bp->bio2)) |
1da177e4 LT |
319 | generic_make_request(&bp->bio2); |
320 | bio_pair_release(bp); | |
321 | return 0; | |
322 | } | |
323 | ||
324 | bio->bi_bdev = tmp_dev->rdev->bdev; | |
4db7cdc8 | 325 | bio->bi_sector = bio->bi_sector - start_sector |
6283815d | 326 | + tmp_dev->rdev->data_offset; |
af11c397 | 327 | rcu_read_unlock(); |
1da177e4 LT |
328 | |
329 | return 1; | |
330 | } | |
331 | ||
332 | static void linear_status (struct seq_file *seq, mddev_t *mddev) | |
333 | { | |
334 | ||
9d8f0363 | 335 | seq_printf(seq, " %dk rounding", mddev->chunk_sectors / 2); |
1da177e4 LT |
336 | } |
337 | ||
338 | ||
2604b703 | 339 | static struct mdk_personality linear_personality = |
1da177e4 LT |
340 | { |
341 | .name = "linear", | |
2604b703 | 342 | .level = LEVEL_LINEAR, |
1da177e4 LT |
343 | .owner = THIS_MODULE, |
344 | .make_request = linear_make_request, | |
345 | .run = linear_run, | |
346 | .stop = linear_stop, | |
347 | .status = linear_status, | |
7c7546cc | 348 | .hot_add_disk = linear_add, |
80c3a6ce | 349 | .size = linear_size, |
1da177e4 LT |
350 | }; |
351 | ||
352 | static int __init linear_init (void) | |
353 | { | |
2604b703 | 354 | return register_md_personality (&linear_personality); |
1da177e4 LT |
355 | } |
356 | ||
357 | static void linear_exit (void) | |
358 | { | |
2604b703 | 359 | unregister_md_personality (&linear_personality); |
1da177e4 LT |
360 | } |
361 | ||
362 | ||
363 | module_init(linear_init); | |
364 | module_exit(linear_exit); | |
365 | MODULE_LICENSE("GPL"); | |
0efb9e61 | 366 | MODULE_DESCRIPTION("Linear device concatenation personality for MD"); |
d9d166c2 N |
367 | MODULE_ALIAS("md-personality-1"); /* LINEAR - deprecated*/ |
368 | MODULE_ALIAS("md-linear"); | |
2604b703 | 369 | MODULE_ALIAS("md-level--1"); |