dm_target_linear.c revision 1.3 1 1.3 haad /* $NetBSD: dm_target_linear.c,v 1.3 2008/12/19 16:30:41 haad Exp $ */
2 1.2 haad
3 1.2 haad /*
4 1.2 haad * Copyright (c) 2008 The NetBSD Foundation, Inc.
5 1.2 haad * All rights reserved.
6 1.2 haad *
7 1.2 haad * This code is derived from software contributed to The NetBSD Foundation
8 1.2 haad * by Adam Hamsik.
9 1.2 haad *
10 1.2 haad * Redistribution and use in source and binary forms, with or without
11 1.2 haad * modification, are permitted provided that the following conditions
12 1.2 haad * are met:
13 1.2 haad * 1. Redistributions of source code must retain the above copyright
14 1.2 haad * notice, this list of conditions and the following disclaimer.
15 1.2 haad * 2. Redistributions in binary form must reproduce the above copyright
16 1.2 haad * notice, this list of conditions and the following disclaimer in the
17 1.2 haad * documentation and/or other materials provided with the distribution.
18 1.2 haad *
19 1.2 haad * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.2 haad * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.2 haad * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.2 haad * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.2 haad * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.2 haad * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.2 haad * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.2 haad * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.2 haad * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.2 haad * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.2 haad * POSSIBILITY OF SUCH DAMAGE.
30 1.2 haad */
31 1.2 haad
32 1.2 haad
33 1.2 haad /*
34 1.2 haad * This file implements initial version of device-mapper dklinear target.
35 1.2 haad */
36 1.2 haad
37 1.2 haad #include <sys/types.h>
38 1.2 haad #include <sys/param.h>
39 1.2 haad
40 1.2 haad #include <sys/buf.h>
41 1.2 haad #include <sys/kmem.h>
42 1.2 haad #include <sys/vnode.h>
43 1.2 haad
44 1.2 haad #include <machine/int_fmtio.h>
45 1.2 haad
46 1.2 haad #include "dm.h"
47 1.2 haad
48 1.2 haad /*
49 1.2 haad * Allocate target specific config data, and link them to table.
50 1.2 haad * This function is called only when, flags is not READONLY and
51 1.2 haad * therefore we can add things to pdev list. This should not a
52 1.2 haad * problem because this routine is called onyl from dm_table_load_ioctl.
53 1.2 haad * @argv[0] is name,
54 1.2 haad * @argv[1] is physical data offset.
55 1.2 haad */
56 1.2 haad int
57 1.2 haad dm_target_linear_init(dm_dev_t *dmv, void **target_config, char *params)
58 1.2 haad {
59 1.2 haad dm_target_linear_config_t *tlc;
60 1.2 haad dm_pdev_t *dmp;
61 1.2 haad
62 1.2 haad char **ap, *argv[3];
63 1.2 haad
64 1.2 haad if(params == NULL)
65 1.2 haad return EINVAL;
66 1.2 haad
67 1.2 haad /*
68 1.2 haad * Parse a string, containing tokens delimited by white space,
69 1.2 haad * into an argument vector
70 1.2 haad */
71 1.2 haad for (ap = argv; ap < &argv[9] &&
72 1.2 haad (*ap = strsep(¶ms, " \t")) != NULL;) {
73 1.2 haad if (**ap != '\0')
74 1.2 haad ap++;
75 1.2 haad }
76 1.2 haad
77 1.2 haad /* Insert dmp to global pdev list */
78 1.2 haad if ((dmp = dm_pdev_insert(argv[0])) == NULL)
79 1.2 haad return ENOENT;
80 1.2 haad
81 1.2 haad aprint_debug("Linear target init function called %s--%s!!\n",
82 1.2 haad argv[0], argv[1]);
83 1.2 haad
84 1.2 haad if ((tlc = kmem_alloc(sizeof(dm_target_linear_config_t), KM_NOSLEEP))
85 1.2 haad == NULL)
86 1.2 haad return 1;
87 1.2 haad
88 1.2 haad tlc->pdev = dmp;
89 1.2 haad tlc->offset = 0; /* default settings */
90 1.2 haad
91 1.2 haad /* Check user input if it is not leave offset as 0. */
92 1.2 haad tlc->offset = atoi(argv[1]);
93 1.2 haad
94 1.2 haad *target_config = tlc;
95 1.2 haad
96 1.2 haad dmv->dev_type = DM_LINEAR_DEV;
97 1.2 haad
98 1.2 haad return 0;
99 1.2 haad }
100 1.2 haad
101 1.2 haad /*
102 1.2 haad * Status routine is called to get params string, which is target
103 1.2 haad * specific. When dm_table_status_ioctl is called with flag
104 1.2 haad * DM_STATUS_TABLE_FLAG I have to sent params string back.
105 1.2 haad */
106 1.2 haad char *
107 1.2 haad dm_target_linear_status(void *target_config)
108 1.2 haad {
109 1.2 haad dm_target_linear_config_t *tlc;
110 1.2 haad char *params;
111 1.2 haad uint32_t i;
112 1.2 haad uint32_t count;
113 1.2 haad size_t prm_len;
114 1.2 haad
115 1.2 haad tlc = target_config;
116 1.2 haad prm_len = 0;
117 1.2 haad count = 0;
118 1.2 haad
119 1.2 haad /* count number of chars in offset */
120 1.2 haad for(i = tlc->offset; i != 0; i /= 10)
121 1.2 haad count++;
122 1.2 haad
123 1.2 haad aprint_debug("Linear target status function called\n");
124 1.2 haad
125 1.2 haad /* length of name + count of chars + one space and null char */
126 1.2 haad prm_len = strlen(tlc->pdev->name) + count + 2;
127 1.2 haad
128 1.2 haad if ((params = kmem_alloc(prm_len, KM_NOSLEEP)) == NULL)
129 1.2 haad return NULL;
130 1.2 haad
131 1.2 haad aprint_debug("%s %"PRIu64, tlc->pdev->name, tlc->offset);
132 1.2 haad snprintf(params, prm_len,"%s %"PRIu64, tlc->pdev->name, tlc->offset);
133 1.2 haad
134 1.2 haad return params;
135 1.2 haad }
136 1.2 haad
137 1.2 haad /*
138 1.2 haad * Do IO operation, called from dmstrategy routine.
139 1.2 haad */
140 1.2 haad int
141 1.2 haad dm_target_linear_strategy(dm_table_entry_t *table_en, struct buf *bp)
142 1.2 haad {
143 1.2 haad dm_target_linear_config_t *tlc;
144 1.2 haad
145 1.2 haad tlc = table_en->target_config;
146 1.2 haad
147 1.2 haad /* printf("Linear target read function called %" PRIu64 "!!\n",
148 1.2 haad tlc->offset);*/
149 1.2 haad
150 1.2 haad bp->b_blkno += tlc->offset;
151 1.2 haad
152 1.2 haad VOP_STRATEGY(tlc->pdev->pdev_vnode, bp);
153 1.2 haad
154 1.2 haad return 0;
155 1.2 haad
156 1.2 haad }
157 1.2 haad
158 1.2 haad /*
159 1.2 haad * Destroy target specific data. Decrement table pdevs.
160 1.2 haad */
161 1.2 haad int
162 1.2 haad dm_target_linear_destroy(dm_table_entry_t *table_en)
163 1.2 haad {
164 1.2 haad dm_target_linear_config_t *tlc;
165 1.2 haad
166 1.2 haad /*
167 1.2 haad * Destroy function is called for every target even if it
168 1.2 haad * doesn't have target_config.
169 1.2 haad */
170 1.2 haad
171 1.2 haad if (table_en->target_config == NULL)
172 1.2 haad return 0;
173 1.2 haad
174 1.2 haad tlc = table_en->target_config;
175 1.2 haad
176 1.2 haad /* Decrement pdev ref counter if 0 remove it */
177 1.2 haad dm_pdev_decr(tlc->pdev);
178 1.2 haad
179 1.3 haad /* Unbusy target so we can unload it */
180 1.3 haad dm_target_unbusy(table_en->target);
181 1.3 haad
182 1.2 haad kmem_free(table_en->target_config, sizeof(dm_target_linear_config_t));
183 1.2 haad
184 1.2 haad table_en->target_config = NULL;
185 1.2 haad
186 1.2 haad return 0;
187 1.2 haad }
188 1.2 haad
189 1.2 haad /* Add this target pdev dependiences to prop_array_t */
190 1.2 haad int
191 1.2 haad dm_target_linear_deps(dm_table_entry_t *table_en, prop_array_t prop_array)
192 1.2 haad {
193 1.2 haad dm_target_linear_config_t *tlc;
194 1.2 haad struct vattr va;
195 1.2 haad
196 1.2 haad int error;
197 1.2 haad
198 1.2 haad if (table_en->target_config == NULL)
199 1.2 haad return ENOENT;
200 1.2 haad
201 1.2 haad tlc = table_en->target_config;
202 1.2 haad
203 1.2 haad if ((error = VOP_GETATTR(tlc->pdev->pdev_vnode, &va, curlwp->l_cred)) != 0)
204 1.2 haad return error;
205 1.2 haad
206 1.2 haad prop_array_add_uint64(prop_array, (uint64_t)va.va_rdev);
207 1.2 haad
208 1.2 haad return 0;
209 1.2 haad }
210 1.2 haad
211 1.2 haad /*
212 1.2 haad * Register upcall device.
213 1.2 haad * Linear target doesn't need any upcall devices but other targets like
214 1.2 haad * mirror, snapshot, multipath, stripe will use this functionality.
215 1.2 haad */
216 1.2 haad int
217 1.2 haad dm_target_linear_upcall(dm_table_entry_t *table_en, struct buf *bp)
218 1.2 haad {
219 1.2 haad return 0;
220 1.2 haad }
221 1.2 haad
222 1.2 haad /*
223 1.2 haad * Transform char s to uint64_t offset number.
224 1.2 haad */
225 1.2 haad uint64_t
226 1.2 haad atoi(const char *s)
227 1.2 haad {
228 1.2 haad uint64_t n;
229 1.2 haad n = 0;
230 1.2 haad
231 1.2 haad while (*s != '\0') {
232 1.2 haad if (!isdigit(*s))
233 1.2 haad break;
234 1.2 haad
235 1.2 haad n = (10 * n) + (*s - '0');
236 1.2 haad s++;
237 1.2 haad }
238 1.2 haad
239 1.2 haad return n;
240 1.2 haad }
241