dm_target_stripe.c revision 1.10 1 1.10 haad /*$NetBSD: dm_target_stripe.c,v 1.10 2010/05/18 15:10:41 haad Exp $*/
2 1.1 haad
3 1.1 haad /*
4 1.1 haad * Copyright (c) 2009 The NetBSD Foundation, Inc.
5 1.1 haad * All rights reserved.
6 1.1 haad *
7 1.1 haad * This code is derived from software contributed to The NetBSD Foundation
8 1.1 haad * by Adam Hamsik.
9 1.1 haad *
10 1.1 haad * Redistribution and use in source and binary forms, with or without
11 1.1 haad * modification, are permitted provided that the following conditions
12 1.1 haad * are met:
13 1.1 haad * 1. Redistributions of source code must retain the above copyright
14 1.1 haad * notice, this list of conditions and the following disclaimer.
15 1.1 haad * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 haad * notice, this list of conditions and the following disclaimer in the
17 1.1 haad * documentation and/or other materials provided with the distribution.
18 1.1 haad *
19 1.1 haad * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.1 haad * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.1 haad * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.1 haad * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.1 haad * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.1 haad * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.1 haad * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.1 haad * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.1 haad * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.1 haad * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.1 haad * POSSIBILITY OF SUCH DAMAGE.
30 1.1 haad */
31 1.1 haad
32 1.1 haad /*
33 1.1 haad * This file implements initial version of device-mapper stripe target.
34 1.1 haad */
35 1.1 haad #include <sys/types.h>
36 1.1 haad #include <sys/param.h>
37 1.1 haad
38 1.1 haad #include <sys/buf.h>
39 1.3 haad #include <sys/kmem.h>
40 1.3 haad #include <sys/vnode.h>
41 1.1 haad
42 1.1 haad #include "dm.h"
43 1.1 haad
44 1.1 haad #ifdef DM_TARGET_MODULE
45 1.1 haad /*
46 1.1 haad * Every target can be compiled directly to dm driver or as a
47 1.1 haad * separate module this part of target is used for loading targets
48 1.1 haad * to dm driver.
49 1.1 haad * Target can be unloaded from kernel only if there are no users of
50 1.1 haad * it e.g. there are no devices which uses that target.
51 1.1 haad */
52 1.1 haad #include <sys/kernel.h>
53 1.1 haad #include <sys/module.h>
54 1.1 haad
55 1.1 haad MODULE(MODULE_CLASS_MISC, dm_target_stripe, NULL);
56 1.1 haad
57 1.1 haad static int
58 1.1 haad dm_target_stripe_modcmd(modcmd_t cmd, void *arg)
59 1.1 haad {
60 1.1 haad dm_target_t *dmt;
61 1.1 haad int r;
62 1.1 haad dmt = NULL;
63 1.9 haad
64 1.1 haad switch (cmd) {
65 1.1 haad case MODULE_CMD_INIT:
66 1.3 haad if ((dmt = dm_target_lookup("stripe")) != NULL) {
67 1.3 haad dm_target_unbusy(dmt);
68 1.1 haad return EEXIST;
69 1.3 haad }
70 1.1 haad dmt = dm_target_alloc("stripe");
71 1.9 haad
72 1.1 haad dmt->version[0] = 1;
73 1.1 haad dmt->version[1] = 0;
74 1.1 haad dmt->version[2] = 0;
75 1.1 haad strlcpy(dmt->name, "stripe", DM_MAX_TYPE_NAME);
76 1.1 haad dmt->init = &dm_target_stripe_init;
77 1.1 haad dmt->status = &dm_target_stripe_status;
78 1.1 haad dmt->strategy = &dm_target_stripe_strategy;
79 1.10 haad dmt->sync = &dm_target_stripe_sync;
80 1.1 haad dmt->deps = &dm_target_stripe_deps;
81 1.1 haad dmt->destroy = &dm_target_stripe_destroy;
82 1.1 haad dmt->upcall = &dm_target_stripe_upcall;
83 1.1 haad
84 1.1 haad r = dm_target_insert(dmt);
85 1.9 haad
86 1.1 haad break;
87 1.1 haad
88 1.1 haad case MODULE_CMD_FINI:
89 1.1 haad r = dm_target_rem("stripe");
90 1.1 haad break;
91 1.1 haad
92 1.1 haad case MODULE_CMD_STAT:
93 1.1 haad return ENOTTY;
94 1.1 haad
95 1.1 haad default:
96 1.1 haad return ENOTTY;
97 1.1 haad }
98 1.1 haad
99 1.1 haad return r;
100 1.1 haad }
101 1.1 haad #endif
102 1.1 haad
103 1.3 haad /*
104 1.3 haad * Init function called from dm_table_load_ioctl.
105 1.3 haad * Example line sent to dm from lvm tools when using striped target.
106 1.3 haad * start length striped #stripes chunk_size device1 offset1 ... deviceN offsetN
107 1.3 haad * 0 65536 striped 2 512 /dev/hda 0 /dev/hdb 0
108 1.3 haad */
109 1.1 haad int
110 1.9 haad dm_target_stripe_init(dm_dev_t * dmv, void **target_config, char *params)
111 1.1 haad {
112 1.3 haad dm_target_stripe_config_t *tsc;
113 1.8 haad size_t len;
114 1.8 haad char **ap, *argv[10];
115 1.8 haad
116 1.9 haad if (params == NULL)
117 1.3 haad return EINVAL;
118 1.8 haad
119 1.8 haad len = strlen(params) + 1;
120 1.9 haad
121 1.8 haad /*
122 1.8 haad * Parse a string, containing tokens delimited by white space,
123 1.8 haad * into an argument vector
124 1.8 haad */
125 1.8 haad for (ap = argv; ap < &argv[9] &&
126 1.9 haad (*ap = strsep(¶ms, " \t")) != NULL;) {
127 1.8 haad if (**ap != '\0')
128 1.8 haad ap++;
129 1.8 haad }
130 1.9 haad
131 1.8 haad printf("Stripe target init function called!!\n");
132 1.1 haad
133 1.8 haad printf("Stripe target chunk size %s number of stripes %s\n", argv[1], argv[0]);
134 1.8 haad printf("Stripe target device name %s -- offset %s\n", argv[2], argv[3]);
135 1.8 haad printf("Stripe target device name %s -- offset %s\n", argv[4], argv[5]);
136 1.3 haad
137 1.8 haad if (atoi(argv[0]) > MAX_STRIPES)
138 1.3 haad return ENOTSUP;
139 1.3 haad
140 1.3 haad if ((tsc = kmem_alloc(sizeof(dm_target_stripe_config_t), KM_NOSLEEP))
141 1.3 haad == NULL)
142 1.3 haad return ENOMEM;
143 1.9 haad
144 1.3 haad /* Insert dmp to global pdev list */
145 1.8 haad if ((tsc->stripe_devs[0].pdev = dm_pdev_insert(argv[2])) == NULL)
146 1.3 haad return ENOENT;
147 1.3 haad
148 1.3 haad /* Insert dmp to global pdev list */
149 1.8 haad if ((tsc->stripe_devs[1].pdev = dm_pdev_insert(argv[4])) == NULL)
150 1.3 haad return ENOENT;
151 1.3 haad
152 1.8 haad tsc->stripe_devs[0].offset = atoi(argv[3]);
153 1.8 haad tsc->stripe_devs[1].offset = atoi(argv[5]);
154 1.3 haad
155 1.8 haad /* Save length of param string */
156 1.8 haad tsc->params_len = len;
157 1.8 haad tsc->stripe_chunksize = atoi(argv[1]);
158 1.9 haad tsc->stripe_num = (uint8_t) atoi(argv[0]);
159 1.9 haad
160 1.3 haad *target_config = tsc;
161 1.1 haad
162 1.1 haad dmv->dev_type = DM_STRIPE_DEV;
163 1.9 haad
164 1.3 haad return 0;
165 1.1 haad }
166 1.1 haad /* Status routine called to get params string. */
167 1.1 haad char *
168 1.1 haad dm_target_stripe_status(void *target_config)
169 1.1 haad {
170 1.3 haad dm_target_stripe_config_t *tsc;
171 1.3 haad char *params;
172 1.3 haad
173 1.3 haad tsc = target_config;
174 1.9 haad
175 1.7 haad if ((params = kmem_alloc(DM_MAX_PARAMS_SIZE, KM_SLEEP)) == NULL)
176 1.3 haad return NULL;
177 1.3 haad
178 1.9 haad snprintf(params, DM_MAX_PARAMS_SIZE, "%d %" PRIu64 " %s %" PRIu64 " %s %" PRIu64,
179 1.5 haad tsc->stripe_num, tsc->stripe_chunksize,
180 1.3 haad tsc->stripe_devs[0].pdev->name, tsc->stripe_devs[0].offset,
181 1.3 haad tsc->stripe_devs[1].pdev->name, tsc->stripe_devs[1].offset);
182 1.9 haad
183 1.3 haad return params;
184 1.9 haad }
185 1.1 haad /* Strategy routine called from dm_strategy. */
186 1.1 haad int
187 1.9 haad dm_target_stripe_strategy(dm_table_entry_t * table_en, struct buf * bp)
188 1.1 haad {
189 1.4 reinoud dm_target_stripe_config_t *tsc;
190 1.4 reinoud struct buf *nestbuf;
191 1.4 reinoud uint64_t blkno, blkoff;
192 1.4 reinoud uint64_t stripe, stripe_blknr;
193 1.4 reinoud uint32_t stripe_off, stripe_rest, num_blks, issue_blks;
194 1.4 reinoud int stripe_devnr;
195 1.4 reinoud
196 1.4 reinoud tsc = table_en->target_config;
197 1.4 reinoud if (tsc == NULL)
198 1.4 reinoud return 0;
199 1.4 reinoud
200 1.8 haad /* printf("Stripe target read function called %" PRIu64 "!!\n",
201 1.4 reinoud tlc->offset);*/
202 1.4 reinoud
203 1.4 reinoud /* calculate extent of request */
204 1.4 reinoud KASSERT(bp->b_resid % DEV_BSIZE == 0);
205 1.4 reinoud
206 1.9 haad blkno = bp->b_blkno;
207 1.4 reinoud blkoff = 0;
208 1.4 reinoud num_blks = bp->b_resid / DEV_BSIZE;
209 1.4 reinoud for (;;) {
210 1.4 reinoud /* blockno to strip piece nr */
211 1.9 haad stripe = blkno / tsc->stripe_chunksize;
212 1.4 reinoud stripe_off = blkno % tsc->stripe_chunksize;
213 1.4 reinoud
214 1.4 reinoud /* where we are inside the strip */
215 1.4 reinoud stripe_devnr = stripe % tsc->stripe_num;
216 1.4 reinoud stripe_blknr = stripe / tsc->stripe_num;
217 1.4 reinoud
218 1.4 reinoud /* how much is left before we hit a boundary */
219 1.4 reinoud stripe_rest = tsc->stripe_chunksize - stripe_off;
220 1.4 reinoud
221 1.4 reinoud /* issue this piece on stripe `stripe' */
222 1.4 reinoud issue_blks = MIN(stripe_rest, num_blks);
223 1.4 reinoud nestbuf = getiobuf(NULL, true);
224 1.4 reinoud
225 1.4 reinoud nestiobuf_setup(bp, nestbuf, blkoff, issue_blks * DEV_BSIZE);
226 1.4 reinoud nestbuf->b_blkno = stripe_blknr * tsc->stripe_chunksize + stripe_off;
227 1.4 reinoud nestbuf->b_blkno += tsc->stripe_devs[stripe_devnr].offset;
228 1.4 reinoud
229 1.4 reinoud VOP_STRATEGY(tsc->stripe_devs[stripe_devnr].pdev->pdev_vnode, nestbuf);
230 1.4 reinoud
231 1.9 haad blkno += issue_blks;
232 1.9 haad blkoff += issue_blks * DEV_BSIZE;
233 1.4 reinoud num_blks -= issue_blks;
234 1.4 reinoud
235 1.4 reinoud if (num_blks <= 0)
236 1.4 reinoud break;
237 1.4 reinoud }
238 1.1 haad
239 1.1 haad return 0;
240 1.1 haad }
241 1.10 haad /* Sync underlying disk caches. */
242 1.10 haad int
243 1.10 haad dm_target_stripe_sync(dm_table_entry_t * table_en)
244 1.10 haad {
245 1.10 haad int cmd, err, i;
246 1.10 haad dm_target_stripe_config_t *tsc;
247 1.10 haad
248 1.10 haad tsc = table_en->target_config;
249 1.10 haad
250 1.10 haad err = 0;
251 1.10 haad cmd = 1;
252 1.10 haad
253 1.10 haad for (i = 0; i < tsc->stripe_num; i++) {
254 1.10 haad if ((err = VOP_IOCTL(tsc->stripe_devs[i].pdev->pdev_vnode, DIOCCACHESYNC,
255 1.10 haad &cmd, FREAD|FWRITE, kauth_cred_get())) != 0)
256 1.10 haad return err;
257 1.10 haad }
258 1.10 haad
259 1.10 haad return err;
260 1.10 haad
261 1.10 haad }
262 1.10 haad /* Destroy target specific data. */
263 1.1 haad int
264 1.9 haad dm_target_stripe_destroy(dm_table_entry_t * table_en)
265 1.1 haad {
266 1.3 haad dm_target_stripe_config_t *tsc;
267 1.9 haad
268 1.3 haad tsc = table_en->target_config;
269 1.3 haad
270 1.3 haad if (tsc == NULL)
271 1.3 haad return 0;
272 1.9 haad
273 1.3 haad dm_pdev_decr(tsc->stripe_devs[0].pdev);
274 1.3 haad dm_pdev_decr(tsc->stripe_devs[1].pdev);
275 1.1 haad
276 1.1 haad /* Unbusy target so we can unload it */
277 1.1 haad dm_target_unbusy(table_en->target);
278 1.9 haad
279 1.3 haad kmem_free(tsc, sizeof(dm_target_stripe_config_t));
280 1.9 haad
281 1.3 haad table_en->target_config = NULL;
282 1.3 haad
283 1.1 haad return 0;
284 1.1 haad }
285 1.1 haad /* Doesn't not need to do anything here. */
286 1.1 haad int
287 1.9 haad dm_target_stripe_deps(dm_table_entry_t * table_en, prop_array_t prop_array)
288 1.9 haad {
289 1.3 haad dm_target_stripe_config_t *tsc;
290 1.3 haad struct vattr va;
291 1.9 haad
292 1.3 haad int error;
293 1.9 haad
294 1.3 haad if (table_en->target_config == NULL)
295 1.3 haad return ENOENT;
296 1.9 haad
297 1.3 haad tsc = table_en->target_config;
298 1.9 haad
299 1.3 haad if ((error = VOP_GETATTR(tsc->stripe_devs[0].pdev->pdev_vnode, &va, curlwp->l_cred)) != 0)
300 1.3 haad return error;
301 1.3 haad
302 1.9 haad prop_array_add_uint64(prop_array, (uint64_t) va.va_rdev);
303 1.9 haad
304 1.3 haad if ((error = VOP_GETATTR(tsc->stripe_devs[1].pdev->pdev_vnode, &va, curlwp->l_cred)) != 0)
305 1.3 haad return error;
306 1.9 haad
307 1.9 haad prop_array_add_uint64(prop_array, (uint64_t) va.va_rdev);
308 1.9 haad
309 1.1 haad return 0;
310 1.1 haad }
311 1.1 haad /* Unsupported for this target. */
312 1.1 haad int
313 1.9 haad dm_target_stripe_upcall(dm_table_entry_t * table_en, struct buf * bp)
314 1.1 haad {
315 1.1 haad return 0;
316 1.1 haad }
317