ccd.c revision 1.92 1 1.92 lukem /* $NetBSD: ccd.c,v 1.92 2003/10/17 05:16:15 lukem Exp $ */
2 1.11 thorpej
3 1.28 thorpej /*-
4 1.59 thorpej * Copyright (c) 1996, 1997, 1998, 1999 The NetBSD Foundation, Inc.
5 1.11 thorpej * All rights reserved.
6 1.11 thorpej *
7 1.28 thorpej * This code is derived from software contributed to The NetBSD Foundation
8 1.28 thorpej * by Jason R. Thorpe.
9 1.28 thorpej *
10 1.11 thorpej * Redistribution and use in source and binary forms, with or without
11 1.11 thorpej * modification, are permitted provided that the following conditions
12 1.11 thorpej * are met:
13 1.11 thorpej * 1. Redistributions of source code must retain the above copyright
14 1.11 thorpej * notice, this list of conditions and the following disclaimer.
15 1.11 thorpej * 2. Redistributions in binary form must reproduce the above copyright
16 1.11 thorpej * notice, this list of conditions and the following disclaimer in the
17 1.11 thorpej * documentation and/or other materials provided with the distribution.
18 1.11 thorpej * 3. All advertising materials mentioning features or use of this software
19 1.11 thorpej * must display the following acknowledgement:
20 1.28 thorpej * This product includes software developed by the NetBSD
21 1.28 thorpej * Foundation, Inc. and its contributors.
22 1.28 thorpej * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.28 thorpej * contributors may be used to endorse or promote products derived
24 1.28 thorpej * from this software without specific prior written permission.
25 1.11 thorpej *
26 1.28 thorpej * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.28 thorpej * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.28 thorpej * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.45 jtc * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.45 jtc * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.28 thorpej * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.28 thorpej * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.28 thorpej * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.28 thorpej * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.28 thorpej * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.28 thorpej * POSSIBILITY OF SUCH DAMAGE.
37 1.11 thorpej */
38 1.2 cgd
39 1.1 hpeyerl /*
40 1.3 hpeyerl * Copyright (c) 1990, 1993
41 1.3 hpeyerl * The Regents of the University of California. All rights reserved.
42 1.1 hpeyerl *
43 1.1 hpeyerl * This code is derived from software contributed to Berkeley by
44 1.1 hpeyerl * the Systems Programming Group of the University of Utah Computer
45 1.1 hpeyerl * Science Department.
46 1.1 hpeyerl *
47 1.1 hpeyerl * Redistribution and use in source and binary forms, with or without
48 1.1 hpeyerl * modification, are permitted provided that the following conditions
49 1.1 hpeyerl * are met:
50 1.1 hpeyerl * 1. Redistributions of source code must retain the above copyright
51 1.1 hpeyerl * notice, this list of conditions and the following disclaimer.
52 1.1 hpeyerl * 2. Redistributions in binary form must reproduce the above copyright
53 1.1 hpeyerl * notice, this list of conditions and the following disclaimer in the
54 1.1 hpeyerl * documentation and/or other materials provided with the distribution.
55 1.91 agc * 3. Neither the name of the University nor the names of its contributors
56 1.91 agc * may be used to endorse or promote products derived from this software
57 1.91 agc * without specific prior written permission.
58 1.91 agc *
59 1.91 agc * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
60 1.91 agc * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
61 1.91 agc * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
62 1.91 agc * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
63 1.91 agc * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
64 1.91 agc * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
65 1.91 agc * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
66 1.91 agc * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
67 1.91 agc * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
68 1.91 agc * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
69 1.91 agc * SUCH DAMAGE.
70 1.91 agc *
71 1.91 agc * from: Utah $Hdr: cd.c 1.6 90/11/28$
72 1.91 agc *
73 1.91 agc * @(#)cd.c 8.2 (Berkeley) 11/16/93
74 1.91 agc */
75 1.91 agc
76 1.91 agc /*
77 1.91 agc * Copyright (c) 1988 University of Utah.
78 1.91 agc *
79 1.91 agc * This code is derived from software contributed to Berkeley by
80 1.91 agc * the Systems Programming Group of the University of Utah Computer
81 1.91 agc * Science Department.
82 1.91 agc *
83 1.91 agc * Redistribution and use in source and binary forms, with or without
84 1.91 agc * modification, are permitted provided that the following conditions
85 1.91 agc * are met:
86 1.91 agc * 1. Redistributions of source code must retain the above copyright
87 1.91 agc * notice, this list of conditions and the following disclaimer.
88 1.91 agc * 2. Redistributions in binary form must reproduce the above copyright
89 1.91 agc * notice, this list of conditions and the following disclaimer in the
90 1.91 agc * documentation and/or other materials provided with the distribution.
91 1.1 hpeyerl * 3. All advertising materials mentioning features or use of this software
92 1.1 hpeyerl * must display the following acknowledgement:
93 1.1 hpeyerl * This product includes software developed by the University of
94 1.1 hpeyerl * California, Berkeley and its contributors.
95 1.1 hpeyerl * 4. Neither the name of the University nor the names of its contributors
96 1.1 hpeyerl * may be used to endorse or promote products derived from this software
97 1.1 hpeyerl * without specific prior written permission.
98 1.1 hpeyerl *
99 1.1 hpeyerl * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
100 1.1 hpeyerl * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
101 1.1 hpeyerl * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
102 1.1 hpeyerl * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
103 1.1 hpeyerl * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
104 1.1 hpeyerl * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
105 1.1 hpeyerl * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
106 1.1 hpeyerl * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
107 1.1 hpeyerl * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
108 1.1 hpeyerl * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
109 1.1 hpeyerl * SUCH DAMAGE.
110 1.1 hpeyerl *
111 1.2 cgd * from: Utah $Hdr: cd.c 1.6 90/11/28$
112 1.2 cgd *
113 1.3 hpeyerl * @(#)cd.c 8.2 (Berkeley) 11/16/93
114 1.1 hpeyerl */
115 1.1 hpeyerl
116 1.1 hpeyerl /*
117 1.1 hpeyerl * "Concatenated" disk driver.
118 1.11 thorpej *
119 1.11 thorpej * Dynamic configuration and disklabel support by:
120 1.11 thorpej * Jason R. Thorpe <thorpej (at) nas.nasa.gov>
121 1.11 thorpej * Numerical Aerodynamic Simulation Facility
122 1.11 thorpej * Mail Stop 258-6
123 1.11 thorpej * NASA Ames Research Center
124 1.11 thorpej * Moffett Field, CA 94035
125 1.1 hpeyerl */
126 1.74 lukem
127 1.74 lukem #include <sys/cdefs.h>
128 1.92 lukem __KERNEL_RCSID(0, "$NetBSD: ccd.c,v 1.92 2003/10/17 05:16:15 lukem Exp $");
129 1.1 hpeyerl
130 1.1 hpeyerl #include <sys/param.h>
131 1.1 hpeyerl #include <sys/systm.h>
132 1.3 hpeyerl #include <sys/proc.h>
133 1.1 hpeyerl #include <sys/errno.h>
134 1.1 hpeyerl #include <sys/buf.h>
135 1.1 hpeyerl #include <sys/malloc.h>
136 1.63 thorpej #include <sys/pool.h>
137 1.11 thorpej #include <sys/namei.h>
138 1.3 hpeyerl #include <sys/stat.h>
139 1.3 hpeyerl #include <sys/ioctl.h>
140 1.3 hpeyerl #include <sys/disklabel.h>
141 1.11 thorpej #include <sys/device.h>
142 1.11 thorpej #include <sys/disk.h>
143 1.11 thorpej #include <sys/syslog.h>
144 1.3 hpeyerl #include <sys/fcntl.h>
145 1.11 thorpej #include <sys/vnode.h>
146 1.31 christos #include <sys/conf.h>
147 1.57 thorpej #include <sys/lock.h>
148 1.56 thorpej #include <sys/queue.h>
149 1.1 hpeyerl
150 1.1 hpeyerl #include <dev/ccdvar.h>
151 1.1 hpeyerl
152 1.11 thorpej #if defined(CCDDEBUG) && !defined(DEBUG)
153 1.11 thorpej #define DEBUG
154 1.11 thorpej #endif
155 1.11 thorpej
156 1.1 hpeyerl #ifdef DEBUG
157 1.3 hpeyerl #define CCDB_FOLLOW 0x01
158 1.3 hpeyerl #define CCDB_INIT 0x02
159 1.3 hpeyerl #define CCDB_IO 0x04
160 1.11 thorpej #define CCDB_LABEL 0x08
161 1.11 thorpej #define CCDB_VNODE 0x10
162 1.24 thorpej int ccddebug = 0x00;
163 1.1 hpeyerl #endif
164 1.1 hpeyerl
165 1.6 cgd #define ccdunit(x) DISKUNIT(x)
166 1.6 cgd
167 1.6 cgd struct ccdbuf {
168 1.6 cgd struct buf cb_buf; /* new I/O buf */
169 1.6 cgd struct buf *cb_obp; /* ptr. to original I/O buf */
170 1.59 thorpej struct ccd_softc *cb_sc; /* pointer to ccd softc */
171 1.6 cgd int cb_comp; /* target component */
172 1.56 thorpej SIMPLEQ_ENTRY(ccdbuf) cb_q; /* fifo of component buffers */
173 1.38 thorpej };
174 1.24 thorpej
175 1.63 thorpej /* component buffer pool */
176 1.63 thorpej struct pool ccd_cbufpool;
177 1.63 thorpej
178 1.63 thorpej #define CCD_GETBUF() pool_get(&ccd_cbufpool, PR_NOWAIT)
179 1.63 thorpej #define CCD_PUTBUF(cbp) pool_put(&ccd_cbufpool, cbp)
180 1.1 hpeyerl
181 1.11 thorpej #define CCDLABELDEV(dev) \
182 1.11 thorpej (MAKEDISKDEV(major((dev)), ccdunit((dev)), RAW_PART))
183 1.1 hpeyerl
184 1.11 thorpej /* called by main() at boot time */
185 1.11 thorpej void ccdattach __P((int));
186 1.11 thorpej
187 1.11 thorpej /* called by biodone() at interrupt time */
188 1.29 christos void ccdiodone __P((struct buf *));
189 1.11 thorpej
190 1.88 thorpej static void ccdstart __P((struct ccd_softc *));
191 1.57 thorpej static void ccdinterleave __P((struct ccd_softc *));
192 1.11 thorpej static void ccdintr __P((struct ccd_softc *, struct buf *));
193 1.57 thorpej static int ccdinit __P((struct ccd_softc *, char **, struct vnode **,
194 1.90 fvdl struct proc *));
195 1.90 fvdl static int ccdlookup __P((char *, struct proc *p, struct vnode **));
196 1.55 thorpej static struct ccdbuf *ccdbuffer __P((struct ccd_softc *, struct buf *,
197 1.55 thorpej daddr_t, caddr_t, long));
198 1.44 thorpej static void ccdgetdefaultlabel __P((struct ccd_softc *, struct disklabel *));
199 1.11 thorpej static void ccdgetdisklabel __P((dev_t));
200 1.11 thorpej static void ccdmakedisklabel __P((struct ccd_softc *));
201 1.78 gehenna
202 1.78 gehenna dev_type_open(ccdopen);
203 1.78 gehenna dev_type_close(ccdclose);
204 1.78 gehenna dev_type_read(ccdread);
205 1.78 gehenna dev_type_write(ccdwrite);
206 1.78 gehenna dev_type_ioctl(ccdioctl);
207 1.78 gehenna dev_type_strategy(ccdstrategy);
208 1.78 gehenna dev_type_dump(ccddump);
209 1.78 gehenna dev_type_size(ccdsize);
210 1.78 gehenna
211 1.78 gehenna const struct bdevsw ccd_bdevsw = {
212 1.78 gehenna ccdopen, ccdclose, ccdstrategy, ccdioctl, ccddump, ccdsize, D_DISK
213 1.78 gehenna };
214 1.78 gehenna
215 1.78 gehenna const struct cdevsw ccd_cdevsw = {
216 1.78 gehenna ccdopen, ccdclose, ccdread, ccdwrite, ccdioctl,
217 1.79 jdolecek nostop, notty, nopoll, nommap, nokqfilter, D_DISK
218 1.78 gehenna };
219 1.3 hpeyerl
220 1.11 thorpej #ifdef DEBUG
221 1.11 thorpej static void printiinfo __P((struct ccdiinfo *));
222 1.11 thorpej #endif
223 1.11 thorpej
224 1.11 thorpej /* Non-private for the benefit of libkvm. */
225 1.11 thorpej struct ccd_softc *ccd_softc;
226 1.11 thorpej int numccd = 0;
227 1.1 hpeyerl
228 1.3 hpeyerl /*
229 1.11 thorpej * Called by main() during pseudo-device attachment. All we need
230 1.11 thorpej * to do is allocate enough space for devices to be configured later.
231 1.1 hpeyerl */
232 1.1 hpeyerl void
233 1.3 hpeyerl ccdattach(num)
234 1.3 hpeyerl int num;
235 1.3 hpeyerl {
236 1.57 thorpej struct ccd_softc *cs;
237 1.57 thorpej int i;
238 1.57 thorpej
239 1.11 thorpej if (num <= 0) {
240 1.11 thorpej #ifdef DIAGNOSTIC
241 1.11 thorpej panic("ccdattach: count <= 0");
242 1.11 thorpej #endif
243 1.3 hpeyerl return;
244 1.11 thorpej }
245 1.11 thorpej
246 1.11 thorpej ccd_softc = (struct ccd_softc *)malloc(num * sizeof(struct ccd_softc),
247 1.75 tsutsui M_DEVBUF, M_NOWAIT|M_ZERO);
248 1.57 thorpej if (ccd_softc == NULL) {
249 1.35 christos printf("WARNING: no memory for concatenated disks\n");
250 1.3 hpeyerl return;
251 1.3 hpeyerl }
252 1.3 hpeyerl numccd = num;
253 1.57 thorpej
254 1.63 thorpej /* Initialize the component buffer pool. */
255 1.63 thorpej pool_init(&ccd_cbufpool, sizeof(struct ccdbuf), 0,
256 1.76 thorpej 0, 0, "ccdpl", NULL);
257 1.63 thorpej
258 1.57 thorpej /* Initialize per-softc structures. */
259 1.57 thorpej for (i = 0; i < num; i++) {
260 1.57 thorpej cs = &ccd_softc[i];
261 1.57 thorpej sprintf(cs->sc_xname, "ccd%d", i); /* XXX */
262 1.57 thorpej cs->sc_dkdev.dk_name = cs->sc_xname; /* XXX */
263 1.57 thorpej lockinit(&cs->sc_lock, PRIBIO, "ccdlk", 0, 0);
264 1.57 thorpej }
265 1.1 hpeyerl }
266 1.1 hpeyerl
267 1.11 thorpej static int
268 1.90 fvdl ccdinit(cs, cpaths, vpp, p)
269 1.57 thorpej struct ccd_softc *cs;
270 1.11 thorpej char **cpaths;
271 1.57 thorpej struct vnode **vpp;
272 1.90 fvdl struct proc *p;
273 1.1 hpeyerl {
274 1.68 augustss struct ccdcinfo *ci = NULL;
275 1.68 augustss size_t size;
276 1.68 augustss int ix;
277 1.11 thorpej struct vattr va;
278 1.1 hpeyerl size_t minsize;
279 1.11 thorpej int maxsecsize;
280 1.7 cgd struct partinfo dpart;
281 1.11 thorpej struct ccdgeom *ccg = &cs->sc_geom;
282 1.11 thorpej char tmppath[MAXPATHLEN];
283 1.67 enami int error, path_alloced;
284 1.1 hpeyerl
285 1.1 hpeyerl #ifdef DEBUG
286 1.3 hpeyerl if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
287 1.59 thorpej printf("%s: ccdinit\n", cs->sc_xname);
288 1.1 hpeyerl #endif
289 1.11 thorpej
290 1.11 thorpej /* Allocate space for the component info. */
291 1.11 thorpej cs->sc_cinfo = malloc(cs->sc_nccdisks * sizeof(struct ccdcinfo),
292 1.11 thorpej M_DEVBUF, M_WAITOK);
293 1.11 thorpej
294 1.57 thorpej cs->sc_size = 0;
295 1.57 thorpej
296 1.1 hpeyerl /*
297 1.1 hpeyerl * Verify that each component piece exists and record
298 1.1 hpeyerl * relevant information about it.
299 1.1 hpeyerl */
300 1.11 thorpej maxsecsize = 0;
301 1.1 hpeyerl minsize = 0;
302 1.67 enami for (ix = 0, path_alloced = 0; ix < cs->sc_nccdisks; ix++) {
303 1.1 hpeyerl ci = &cs->sc_cinfo[ix];
304 1.57 thorpej ci->ci_vp = vpp[ix];
305 1.11 thorpej
306 1.11 thorpej /*
307 1.11 thorpej * Copy in the pathname of the component.
308 1.11 thorpej */
309 1.72 thorpej memset(tmppath, 0, sizeof(tmppath)); /* sanity */
310 1.29 christos error = copyinstr(cpaths[ix], tmppath,
311 1.29 christos MAXPATHLEN, &ci->ci_pathlen);
312 1.29 christos if (error) {
313 1.11 thorpej #ifdef DEBUG
314 1.11 thorpej if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
315 1.35 christos printf("%s: can't copy path, error = %d\n",
316 1.23 thorpej cs->sc_xname, error);
317 1.11 thorpej #endif
318 1.67 enami goto out;
319 1.11 thorpej }
320 1.11 thorpej ci->ci_path = malloc(ci->ci_pathlen, M_DEVBUF, M_WAITOK);
321 1.72 thorpej memcpy(ci->ci_path, tmppath, ci->ci_pathlen);
322 1.67 enami path_alloced++;
323 1.11 thorpej
324 1.11 thorpej /*
325 1.11 thorpej * XXX: Cache the component's dev_t.
326 1.11 thorpej */
327 1.90 fvdl if ((error = VOP_GETATTR(vpp[ix], &va, p->p_ucred, p)) != 0) {
328 1.11 thorpej #ifdef DEBUG
329 1.11 thorpej if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
330 1.35 christos printf("%s: %s: getattr failed %s = %d\n",
331 1.23 thorpej cs->sc_xname, ci->ci_path,
332 1.11 thorpej "error", error);
333 1.11 thorpej #endif
334 1.67 enami goto out;
335 1.11 thorpej }
336 1.11 thorpej ci->ci_dev = va.va_rdev;
337 1.11 thorpej
338 1.3 hpeyerl /*
339 1.11 thorpej * Get partition information for the component.
340 1.3 hpeyerl */
341 1.84 dsl error = VOP_IOCTL(vpp[ix], DIOCGPART, &dpart,
342 1.90 fvdl FREAD, p->p_ucred, p);
343 1.29 christos if (error) {
344 1.11 thorpej #ifdef DEBUG
345 1.11 thorpej if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
346 1.35 christos printf("%s: %s: ioctl failed, error = %d\n",
347 1.23 thorpej cs->sc_xname, ci->ci_path, error);
348 1.11 thorpej #endif
349 1.67 enami goto out;
350 1.11 thorpej }
351 1.69 enami
352 1.69 enami /*
353 1.69 enami * This diagnostic test is disabled (for now?) since not all port supports
354 1.69 enami * on-disk BSD disklabel.
355 1.69 enami */
356 1.69 enami #if 0 /* def DIAGNOSTIC */
357 1.69 enami /* Check fstype field of component. */
358 1.69 enami if (dpart.part->p_fstype != FS_CCD)
359 1.69 enami printf("%s: WARNING: %s: fstype %d != FS_CCD\n",
360 1.69 enami cs->sc_xname, ci->ci_path, dpart.part->p_fstype);
361 1.69 enami #endif
362 1.7 cgd
363 1.11 thorpej /*
364 1.11 thorpej * Calculate the size, truncating to an interleave
365 1.11 thorpej * boundary if necessary.
366 1.11 thorpej */
367 1.46 thorpej maxsecsize =
368 1.46 thorpej ((dpart.disklab->d_secsize > maxsecsize) ?
369 1.46 thorpej dpart.disklab->d_secsize : maxsecsize);
370 1.46 thorpej size = dpart.part->p_size;
371 1.1 hpeyerl if (cs->sc_ileave > 1)
372 1.1 hpeyerl size -= size % cs->sc_ileave;
373 1.11 thorpej
374 1.1 hpeyerl if (size == 0) {
375 1.11 thorpej #ifdef DEBUG
376 1.11 thorpej if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
377 1.35 christos printf("%s: %s: size == 0\n",
378 1.23 thorpej cs->sc_xname, ci->ci_path);
379 1.11 thorpej #endif
380 1.67 enami error = ENODEV;
381 1.67 enami goto out;
382 1.3 hpeyerl }
383 1.11 thorpej
384 1.1 hpeyerl if (minsize == 0 || size < minsize)
385 1.1 hpeyerl minsize = size;
386 1.1 hpeyerl ci->ci_size = size;
387 1.1 hpeyerl cs->sc_size += size;
388 1.1 hpeyerl }
389 1.11 thorpej
390 1.11 thorpej /*
391 1.11 thorpej * Don't allow the interleave to be smaller than
392 1.11 thorpej * the biggest component sector.
393 1.11 thorpej */
394 1.11 thorpej if ((cs->sc_ileave > 0) &&
395 1.11 thorpej (cs->sc_ileave < (maxsecsize / DEV_BSIZE))) {
396 1.11 thorpej #ifdef DEBUG
397 1.11 thorpej if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
398 1.35 christos printf("%s: interleave must be at least %d\n",
399 1.23 thorpej cs->sc_xname, (maxsecsize / DEV_BSIZE));
400 1.11 thorpej #endif
401 1.67 enami error = EINVAL;
402 1.67 enami goto out;
403 1.11 thorpej }
404 1.11 thorpej
405 1.1 hpeyerl /*
406 1.1 hpeyerl * If uniform interleave is desired set all sizes to that of
407 1.1 hpeyerl * the smallest component.
408 1.1 hpeyerl */
409 1.57 thorpej if (cs->sc_flags & CCDF_UNIFORM) {
410 1.1 hpeyerl for (ci = cs->sc_cinfo;
411 1.1 hpeyerl ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
412 1.1 hpeyerl ci->ci_size = minsize;
413 1.24 thorpej
414 1.53 thorpej cs->sc_size = cs->sc_nccdisks * minsize;
415 1.1 hpeyerl }
416 1.11 thorpej
417 1.11 thorpej /*
418 1.11 thorpej * Construct the interleave table.
419 1.11 thorpej */
420 1.57 thorpej ccdinterleave(cs);
421 1.11 thorpej
422 1.1 hpeyerl /*
423 1.11 thorpej * Create pseudo-geometry based on 1MB cylinders. It's
424 1.11 thorpej * pretty close.
425 1.1 hpeyerl */
426 1.11 thorpej ccg->ccg_secsize = DEV_BSIZE;
427 1.19 thorpej ccg->ccg_ntracks = 1;
428 1.11 thorpej ccg->ccg_nsectors = 1024 * (1024 / ccg->ccg_secsize);
429 1.11 thorpej ccg->ccg_ncylinders = cs->sc_size / ccg->ccg_nsectors;
430 1.11 thorpej
431 1.11 thorpej cs->sc_flags |= CCDF_INITED;
432 1.23 thorpej
433 1.11 thorpej return (0);
434 1.67 enami
435 1.67 enami out:
436 1.67 enami for (ix = 0; ix < path_alloced; ix++)
437 1.67 enami free(cs->sc_cinfo[ix].ci_path, M_DEVBUF);
438 1.67 enami free(cs->sc_cinfo, M_DEVBUF);
439 1.67 enami return (error);
440 1.1 hpeyerl }
441 1.1 hpeyerl
442 1.11 thorpej static void
443 1.57 thorpej ccdinterleave(cs)
444 1.68 augustss struct ccd_softc *cs;
445 1.1 hpeyerl {
446 1.68 augustss struct ccdcinfo *ci, *smallci;
447 1.68 augustss struct ccdiinfo *ii;
448 1.68 augustss daddr_t bn, lbn;
449 1.68 augustss int ix;
450 1.1 hpeyerl u_long size;
451 1.1 hpeyerl
452 1.1 hpeyerl #ifdef DEBUG
453 1.3 hpeyerl if (ccddebug & CCDB_INIT)
454 1.35 christos printf("ccdinterleave(%p): ileave %d\n", cs, cs->sc_ileave);
455 1.1 hpeyerl #endif
456 1.1 hpeyerl /*
457 1.1 hpeyerl * Allocate an interleave table.
458 1.1 hpeyerl * Chances are this is too big, but we don't care.
459 1.1 hpeyerl */
460 1.1 hpeyerl size = (cs->sc_nccdisks + 1) * sizeof(struct ccdiinfo);
461 1.75 tsutsui cs->sc_itable = (struct ccdiinfo *)malloc(size, M_DEVBUF,
462 1.75 tsutsui M_WAITOK|M_ZERO);
463 1.11 thorpej
464 1.1 hpeyerl /*
465 1.1 hpeyerl * Trivial case: no interleave (actually interleave of disk size).
466 1.11 thorpej * Each table entry represents a single component in its entirety.
467 1.1 hpeyerl */
468 1.1 hpeyerl if (cs->sc_ileave == 0) {
469 1.1 hpeyerl bn = 0;
470 1.1 hpeyerl ii = cs->sc_itable;
471 1.11 thorpej
472 1.1 hpeyerl for (ix = 0; ix < cs->sc_nccdisks; ix++) {
473 1.19 thorpej /* Allocate space for ii_index. */
474 1.19 thorpej ii->ii_index = malloc(sizeof(int), M_DEVBUF, M_WAITOK);
475 1.1 hpeyerl ii->ii_ndisk = 1;
476 1.1 hpeyerl ii->ii_startblk = bn;
477 1.1 hpeyerl ii->ii_startoff = 0;
478 1.1 hpeyerl ii->ii_index[0] = ix;
479 1.1 hpeyerl bn += cs->sc_cinfo[ix].ci_size;
480 1.1 hpeyerl ii++;
481 1.1 hpeyerl }
482 1.1 hpeyerl ii->ii_ndisk = 0;
483 1.1 hpeyerl #ifdef DEBUG
484 1.3 hpeyerl if (ccddebug & CCDB_INIT)
485 1.1 hpeyerl printiinfo(cs->sc_itable);
486 1.1 hpeyerl #endif
487 1.11 thorpej return;
488 1.1 hpeyerl }
489 1.11 thorpej
490 1.1 hpeyerl /*
491 1.1 hpeyerl * The following isn't fast or pretty; it doesn't have to be.
492 1.1 hpeyerl */
493 1.1 hpeyerl size = 0;
494 1.1 hpeyerl bn = lbn = 0;
495 1.1 hpeyerl for (ii = cs->sc_itable; ; ii++) {
496 1.11 thorpej /* Allocate space for ii_index. */
497 1.19 thorpej ii->ii_index = malloc((sizeof(int) * cs->sc_nccdisks),
498 1.19 thorpej M_DEVBUF, M_WAITOK);
499 1.11 thorpej
500 1.1 hpeyerl /*
501 1.1 hpeyerl * Locate the smallest of the remaining components
502 1.1 hpeyerl */
503 1.1 hpeyerl smallci = NULL;
504 1.1 hpeyerl for (ci = cs->sc_cinfo;
505 1.1 hpeyerl ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
506 1.1 hpeyerl if (ci->ci_size > size &&
507 1.1 hpeyerl (smallci == NULL ||
508 1.1 hpeyerl ci->ci_size < smallci->ci_size))
509 1.1 hpeyerl smallci = ci;
510 1.11 thorpej
511 1.1 hpeyerl /*
512 1.1 hpeyerl * Nobody left, all done
513 1.1 hpeyerl */
514 1.1 hpeyerl if (smallci == NULL) {
515 1.1 hpeyerl ii->ii_ndisk = 0;
516 1.1 hpeyerl break;
517 1.1 hpeyerl }
518 1.11 thorpej
519 1.1 hpeyerl /*
520 1.1 hpeyerl * Record starting logical block and component offset
521 1.1 hpeyerl */
522 1.1 hpeyerl ii->ii_startblk = bn / cs->sc_ileave;
523 1.1 hpeyerl ii->ii_startoff = lbn;
524 1.11 thorpej
525 1.1 hpeyerl /*
526 1.1 hpeyerl * Determine how many disks take part in this interleave
527 1.1 hpeyerl * and record their indices.
528 1.1 hpeyerl */
529 1.1 hpeyerl ix = 0;
530 1.1 hpeyerl for (ci = cs->sc_cinfo;
531 1.1 hpeyerl ci < &cs->sc_cinfo[cs->sc_nccdisks]; ci++)
532 1.1 hpeyerl if (ci->ci_size >= smallci->ci_size)
533 1.1 hpeyerl ii->ii_index[ix++] = ci - cs->sc_cinfo;
534 1.1 hpeyerl ii->ii_ndisk = ix;
535 1.1 hpeyerl bn += ix * (smallci->ci_size - size);
536 1.1 hpeyerl lbn = smallci->ci_size / cs->sc_ileave;
537 1.1 hpeyerl size = smallci->ci_size;
538 1.1 hpeyerl }
539 1.1 hpeyerl #ifdef DEBUG
540 1.3 hpeyerl if (ccddebug & CCDB_INIT)
541 1.1 hpeyerl printiinfo(cs->sc_itable);
542 1.1 hpeyerl #endif
543 1.1 hpeyerl }
544 1.1 hpeyerl
545 1.11 thorpej /* ARGSUSED */
546 1.11 thorpej int
547 1.90 fvdl ccdopen(dev, flags, fmt, p)
548 1.1 hpeyerl dev_t dev;
549 1.11 thorpej int flags, fmt;
550 1.90 fvdl struct proc *p;
551 1.1 hpeyerl {
552 1.1 hpeyerl int unit = ccdunit(dev);
553 1.11 thorpej struct ccd_softc *cs;
554 1.11 thorpej struct disklabel *lp;
555 1.15 thorpej int error = 0, part, pmask;
556 1.1 hpeyerl
557 1.1 hpeyerl #ifdef DEBUG
558 1.3 hpeyerl if (ccddebug & CCDB_FOLLOW)
559 1.43 fair printf("ccdopen(0x%x, 0x%x)\n", dev, flags);
560 1.1 hpeyerl #endif
561 1.11 thorpej if (unit >= numccd)
562 1.11 thorpej return (ENXIO);
563 1.11 thorpej cs = &ccd_softc[unit];
564 1.15 thorpej
565 1.57 thorpej if ((error = lockmgr(&cs->sc_lock, LK_EXCLUSIVE, NULL)) != 0)
566 1.15 thorpej return (error);
567 1.15 thorpej
568 1.23 thorpej lp = cs->sc_dkdev.dk_label;
569 1.11 thorpej
570 1.11 thorpej part = DISKPART(dev);
571 1.11 thorpej pmask = (1 << part);
572 1.11 thorpej
573 1.15 thorpej /*
574 1.15 thorpej * If we're initialized, check to see if there are any other
575 1.15 thorpej * open partitions. If not, then it's safe to update
576 1.87 thorpej * the in-core disklabel. Only read the disklabel if it is
577 1.87 thorpej * not already valid.
578 1.15 thorpej */
579 1.87 thorpej if ((cs->sc_flags & (CCDF_INITED|CCDF_VLABEL)) == CCDF_INITED &&
580 1.87 thorpej cs->sc_dkdev.dk_openmask == 0)
581 1.15 thorpej ccdgetdisklabel(dev);
582 1.15 thorpej
583 1.11 thorpej /* Check that the partition exists. */
584 1.27 thorpej if (part != RAW_PART) {
585 1.27 thorpej if (((cs->sc_flags & CCDF_INITED) == 0) ||
586 1.37 thorpej ((part >= lp->d_npartitions) ||
587 1.27 thorpej (lp->d_partitions[part].p_fstype == FS_UNUSED))) {
588 1.27 thorpej error = ENXIO;
589 1.27 thorpej goto done;
590 1.27 thorpej }
591 1.15 thorpej }
592 1.11 thorpej
593 1.11 thorpej /* Prevent our unit from being unconfigured while open. */
594 1.11 thorpej switch (fmt) {
595 1.11 thorpej case S_IFCHR:
596 1.11 thorpej cs->sc_dkdev.dk_copenmask |= pmask;
597 1.11 thorpej break;
598 1.11 thorpej
599 1.11 thorpej case S_IFBLK:
600 1.11 thorpej cs->sc_dkdev.dk_bopenmask |= pmask;
601 1.11 thorpej break;
602 1.11 thorpej }
603 1.11 thorpej cs->sc_dkdev.dk_openmask =
604 1.11 thorpej cs->sc_dkdev.dk_copenmask | cs->sc_dkdev.dk_bopenmask;
605 1.11 thorpej
606 1.15 thorpej done:
607 1.57 thorpej (void) lockmgr(&cs->sc_lock, LK_RELEASE, NULL);
608 1.33 thorpej return (error);
609 1.7 cgd }
610 1.7 cgd
611 1.11 thorpej /* ARGSUSED */
612 1.11 thorpej int
613 1.90 fvdl ccdclose(dev, flags, fmt, p)
614 1.7 cgd dev_t dev;
615 1.11 thorpej int flags, fmt;
616 1.90 fvdl struct proc *p;
617 1.7 cgd {
618 1.11 thorpej int unit = ccdunit(dev);
619 1.11 thorpej struct ccd_softc *cs;
620 1.15 thorpej int error = 0, part;
621 1.11 thorpej
622 1.7 cgd #ifdef DEBUG
623 1.7 cgd if (ccddebug & CCDB_FOLLOW)
624 1.43 fair printf("ccdclose(0x%x, 0x%x)\n", dev, flags);
625 1.7 cgd #endif
626 1.11 thorpej
627 1.11 thorpej if (unit >= numccd)
628 1.11 thorpej return (ENXIO);
629 1.11 thorpej cs = &ccd_softc[unit];
630 1.15 thorpej
631 1.57 thorpej if ((error = lockmgr(&cs->sc_lock, LK_EXCLUSIVE, NULL)) != 0)
632 1.15 thorpej return (error);
633 1.15 thorpej
634 1.11 thorpej part = DISKPART(dev);
635 1.11 thorpej
636 1.11 thorpej /* ...that much closer to allowing unconfiguration... */
637 1.11 thorpej switch (fmt) {
638 1.11 thorpej case S_IFCHR:
639 1.11 thorpej cs->sc_dkdev.dk_copenmask &= ~(1 << part);
640 1.11 thorpej break;
641 1.11 thorpej
642 1.11 thorpej case S_IFBLK:
643 1.11 thorpej cs->sc_dkdev.dk_bopenmask &= ~(1 << part);
644 1.11 thorpej break;
645 1.11 thorpej }
646 1.11 thorpej cs->sc_dkdev.dk_openmask =
647 1.11 thorpej cs->sc_dkdev.dk_copenmask | cs->sc_dkdev.dk_bopenmask;
648 1.11 thorpej
649 1.87 thorpej if (cs->sc_dkdev.dk_openmask == 0) {
650 1.87 thorpej if ((cs->sc_flags & CCDF_KLABEL) == 0)
651 1.87 thorpej cs->sc_flags &= ~CCDF_VLABEL;
652 1.87 thorpej }
653 1.87 thorpej
654 1.57 thorpej (void) lockmgr(&cs->sc_lock, LK_RELEASE, NULL);
655 1.7 cgd return (0);
656 1.1 hpeyerl }
657 1.1 hpeyerl
658 1.11 thorpej void
659 1.1 hpeyerl ccdstrategy(bp)
660 1.68 augustss struct buf *bp;
661 1.1 hpeyerl {
662 1.68 augustss int unit = ccdunit(bp->b_dev);
663 1.68 augustss struct ccd_softc *cs = &ccd_softc[unit];
664 1.88 thorpej daddr_t blkno;
665 1.68 augustss int s;
666 1.11 thorpej int wlabel;
667 1.15 thorpej struct disklabel *lp;
668 1.1 hpeyerl
669 1.1 hpeyerl #ifdef DEBUG
670 1.3 hpeyerl if (ccddebug & CCDB_FOLLOW)
671 1.35 christos printf("ccdstrategy(%p): unit %d\n", bp, unit);
672 1.1 hpeyerl #endif
673 1.3 hpeyerl if ((cs->sc_flags & CCDF_INITED) == 0) {
674 1.59 thorpej #ifdef DEBUG
675 1.59 thorpej if (ccddebug & CCDB_FOLLOW)
676 1.59 thorpej printf("ccdstrategy: unit %d: not inited\n", unit);
677 1.59 thorpej #endif
678 1.1 hpeyerl bp->b_error = ENXIO;
679 1.1 hpeyerl bp->b_flags |= B_ERROR;
680 1.1 hpeyerl goto done;
681 1.1 hpeyerl }
682 1.11 thorpej
683 1.11 thorpej /* If it's a nil transfer, wake up the top half now. */
684 1.11 thorpej if (bp->b_bcount == 0)
685 1.11 thorpej goto done;
686 1.11 thorpej
687 1.23 thorpej lp = cs->sc_dkdev.dk_label;
688 1.15 thorpej
689 1.11 thorpej /*
690 1.17 thorpej * Do bounds checking and adjust transfer. If there's an
691 1.88 thorpej * error, the bounds check will flag that for us. Convert
692 1.88 thorpej * the partition relative block number to an absolute.
693 1.11 thorpej */
694 1.88 thorpej blkno = bp->b_blkno;
695 1.11 thorpej wlabel = cs->sc_flags & (CCDF_WLABEL|CCDF_LABELLING);
696 1.88 thorpej if (DISKPART(bp->b_dev) != RAW_PART) {
697 1.86 thorpej if (bounds_check_with_label(&cs->sc_dkdev, bp, wlabel) <= 0)
698 1.1 hpeyerl goto done;
699 1.88 thorpej blkno += lp->d_partitions[DISKPART(bp->b_dev)].p_offset;
700 1.88 thorpej }
701 1.88 thorpej bp->b_rawblkno = blkno;
702 1.11 thorpej
703 1.88 thorpej /* Place it in the queue and start I/O on the unit. */
704 1.1 hpeyerl s = splbio();
705 1.88 thorpej BUFQ_PUT(&cs->sc_bufq, bp);
706 1.88 thorpej ccdstart(cs);
707 1.1 hpeyerl splx(s);
708 1.1 hpeyerl return;
709 1.88 thorpej
710 1.88 thorpej done:
711 1.88 thorpej bp->b_resid = bp->b_bcount;
712 1.1 hpeyerl biodone(bp);
713 1.1 hpeyerl }
714 1.1 hpeyerl
715 1.11 thorpej static void
716 1.88 thorpej ccdstart(cs)
717 1.68 augustss struct ccd_softc *cs;
718 1.1 hpeyerl {
719 1.68 augustss long bcount, rcount;
720 1.88 thorpej struct buf *bp;
721 1.55 thorpej struct ccdbuf *cbp;
722 1.1 hpeyerl caddr_t addr;
723 1.1 hpeyerl daddr_t bn;
724 1.56 thorpej SIMPLEQ_HEAD(, ccdbuf) cbufq;
725 1.1 hpeyerl
726 1.1 hpeyerl #ifdef DEBUG
727 1.3 hpeyerl if (ccddebug & CCDB_FOLLOW)
728 1.35 christos printf("ccdstart(%p, %p)\n", cs, bp);
729 1.1 hpeyerl #endif
730 1.11 thorpej
731 1.88 thorpej /* See if there is work for us to do. */
732 1.88 thorpej while ((bp = BUFQ_PEEK(&cs->sc_bufq)) != NULL) {
733 1.88 thorpej /* Instrumentation. */
734 1.88 thorpej disk_busy(&cs->sc_dkdev);
735 1.11 thorpej
736 1.88 thorpej bp->b_resid = bp->b_bcount;
737 1.88 thorpej bn = bp->b_rawblkno;
738 1.17 thorpej
739 1.88 thorpej /* Allocate the component buffers. */
740 1.88 thorpej SIMPLEQ_INIT(&cbufq);
741 1.88 thorpej addr = bp->b_data;
742 1.88 thorpej for (bcount = bp->b_bcount; bcount > 0; bcount -= rcount) {
743 1.88 thorpej cbp = ccdbuffer(cs, bp, bn, addr, bcount);
744 1.88 thorpej if (cbp == NULL) {
745 1.88 thorpej /*
746 1.88 thorpej * Can't allocate a component buffer; just
747 1.88 thorpej * defer the job until later.
748 1.88 thorpej *
749 1.88 thorpej * XXX We might consider a watchdog timer
750 1.88 thorpej * XXX to make sure we are kicked into action,
751 1.88 thorpej * XXX or consider a low-water mark for our
752 1.88 thorpej * XXX component buffer pool.
753 1.88 thorpej */
754 1.88 thorpej while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
755 1.88 thorpej SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
756 1.88 thorpej CCD_PUTBUF(cbp);
757 1.88 thorpej }
758 1.88 thorpej disk_unbusy(&cs->sc_dkdev, 0, 0);
759 1.88 thorpej return;
760 1.56 thorpej }
761 1.88 thorpej SIMPLEQ_INSERT_TAIL(&cbufq, cbp, cb_q);
762 1.88 thorpej rcount = cbp->cb_buf.b_bcount;
763 1.88 thorpej bn += btodb(rcount);
764 1.88 thorpej addr += rcount;
765 1.88 thorpej }
766 1.88 thorpej
767 1.88 thorpej /* Transfer all set up, remove job from the queue. */
768 1.88 thorpej (void) BUFQ_GET(&cs->sc_bufq);
769 1.56 thorpej
770 1.88 thorpej /* Now fire off the requests. */
771 1.88 thorpej while ((cbp = SIMPLEQ_FIRST(&cbufq)) != NULL) {
772 1.88 thorpej SIMPLEQ_REMOVE_HEAD(&cbufq, cb_q);
773 1.88 thorpej if ((cbp->cb_buf.b_flags & B_READ) == 0)
774 1.88 thorpej cbp->cb_buf.b_vp->v_numoutput++;
775 1.88 thorpej VOP_STRATEGY(&cbp->cb_buf);
776 1.56 thorpej }
777 1.1 hpeyerl }
778 1.1 hpeyerl }
779 1.1 hpeyerl
780 1.1 hpeyerl /*
781 1.1 hpeyerl * Build a component buffer header.
782 1.1 hpeyerl */
783 1.55 thorpej static struct ccdbuf *
784 1.55 thorpej ccdbuffer(cs, bp, bn, addr, bcount)
785 1.68 augustss struct ccd_softc *cs;
786 1.1 hpeyerl struct buf *bp;
787 1.1 hpeyerl daddr_t bn;
788 1.1 hpeyerl caddr_t addr;
789 1.1 hpeyerl long bcount;
790 1.1 hpeyerl {
791 1.68 augustss struct ccdcinfo *ci;
792 1.68 augustss struct ccdbuf *cbp;
793 1.68 augustss daddr_t cbn, cboff;
794 1.68 augustss u_int64_t cbc;
795 1.36 thorpej int ccdisk;
796 1.1 hpeyerl
797 1.1 hpeyerl #ifdef DEBUG
798 1.3 hpeyerl if (ccddebug & CCDB_IO)
799 1.81 kleink printf("ccdbuffer(%p, %p, %" PRId64 ", %p, %ld)\n",
800 1.1 hpeyerl cs, bp, bn, addr, bcount);
801 1.1 hpeyerl #endif
802 1.1 hpeyerl /*
803 1.1 hpeyerl * Determine which component bn falls in.
804 1.1 hpeyerl */
805 1.1 hpeyerl cbn = bn;
806 1.1 hpeyerl cboff = 0;
807 1.11 thorpej
808 1.1 hpeyerl /*
809 1.1 hpeyerl * Serially concatenated
810 1.1 hpeyerl */
811 1.1 hpeyerl if (cs->sc_ileave == 0) {
812 1.68 augustss daddr_t sblk;
813 1.1 hpeyerl
814 1.1 hpeyerl sblk = 0;
815 1.36 thorpej for (ccdisk = 0, ci = &cs->sc_cinfo[ccdisk];
816 1.36 thorpej cbn >= sblk + ci->ci_size;
817 1.36 thorpej ccdisk++, ci = &cs->sc_cinfo[ccdisk])
818 1.1 hpeyerl sblk += ci->ci_size;
819 1.1 hpeyerl cbn -= sblk;
820 1.1 hpeyerl }
821 1.1 hpeyerl /*
822 1.1 hpeyerl * Interleaved
823 1.1 hpeyerl */
824 1.1 hpeyerl else {
825 1.68 augustss struct ccdiinfo *ii;
826 1.36 thorpej int off;
827 1.1 hpeyerl
828 1.1 hpeyerl cboff = cbn % cs->sc_ileave;
829 1.1 hpeyerl cbn /= cs->sc_ileave;
830 1.1 hpeyerl for (ii = cs->sc_itable; ii->ii_ndisk; ii++)
831 1.1 hpeyerl if (ii->ii_startblk > cbn)
832 1.1 hpeyerl break;
833 1.1 hpeyerl ii--;
834 1.1 hpeyerl off = cbn - ii->ii_startblk;
835 1.1 hpeyerl if (ii->ii_ndisk == 1) {
836 1.1 hpeyerl ccdisk = ii->ii_index[0];
837 1.1 hpeyerl cbn = ii->ii_startoff + off;
838 1.1 hpeyerl } else {
839 1.53 thorpej ccdisk = ii->ii_index[off % ii->ii_ndisk];
840 1.53 thorpej cbn = ii->ii_startoff + off / ii->ii_ndisk;
841 1.1 hpeyerl }
842 1.1 hpeyerl cbn *= cs->sc_ileave;
843 1.1 hpeyerl ci = &cs->sc_cinfo[ccdisk];
844 1.1 hpeyerl }
845 1.11 thorpej
846 1.1 hpeyerl /*
847 1.1 hpeyerl * Fill in the component buf structure.
848 1.1 hpeyerl */
849 1.63 thorpej cbp = CCD_GETBUF();
850 1.55 thorpej if (cbp == NULL)
851 1.55 thorpej return (NULL);
852 1.83 thorpej BUF_INIT(&cbp->cb_buf);
853 1.6 cgd cbp->cb_buf.b_flags = bp->b_flags | B_CALL;
854 1.29 christos cbp->cb_buf.b_iodone = ccdiodone;
855 1.6 cgd cbp->cb_buf.b_proc = bp->b_proc;
856 1.11 thorpej cbp->cb_buf.b_dev = ci->ci_dev; /* XXX */
857 1.6 cgd cbp->cb_buf.b_blkno = cbn + cboff;
858 1.6 cgd cbp->cb_buf.b_data = addr;
859 1.11 thorpej cbp->cb_buf.b_vp = ci->ci_vp;
860 1.1 hpeyerl if (cs->sc_ileave == 0)
861 1.50 thorpej cbc = dbtob((u_int64_t)(ci->ci_size - cbn));
862 1.1 hpeyerl else
863 1.50 thorpej cbc = dbtob((u_int64_t)(cs->sc_ileave - cboff));
864 1.50 thorpej cbp->cb_buf.b_bcount = cbc < bcount ? cbc : bcount;
865 1.6 cgd
866 1.1 hpeyerl /*
867 1.6 cgd * context for ccdiodone
868 1.1 hpeyerl */
869 1.6 cgd cbp->cb_obp = bp;
870 1.59 thorpej cbp->cb_sc = cs;
871 1.36 thorpej cbp->cb_comp = ccdisk;
872 1.6 cgd
873 1.1 hpeyerl #ifdef DEBUG
874 1.3 hpeyerl if (ccddebug & CCDB_IO)
875 1.81 kleink printf(" dev 0x%x(u%lu): cbp %p bn %" PRId64 " addr %p"
876 1.81 kleink " bcnt %ld\n",
877 1.62 mjacob ci->ci_dev, (unsigned long) (ci-cs->sc_cinfo), cbp,
878 1.62 mjacob cbp->cb_buf.b_blkno, cbp->cb_buf.b_data,
879 1.62 mjacob cbp->cb_buf.b_bcount);
880 1.1 hpeyerl #endif
881 1.55 thorpej
882 1.55 thorpej return (cbp);
883 1.1 hpeyerl }
884 1.1 hpeyerl
885 1.11 thorpej static void
886 1.3 hpeyerl ccdintr(cs, bp)
887 1.68 augustss struct ccd_softc *cs;
888 1.68 augustss struct buf *bp;
889 1.1 hpeyerl {
890 1.1 hpeyerl
891 1.1 hpeyerl #ifdef DEBUG
892 1.3 hpeyerl if (ccddebug & CCDB_FOLLOW)
893 1.35 christos printf("ccdintr(%p, %p)\n", cs, bp);
894 1.1 hpeyerl #endif
895 1.1 hpeyerl /*
896 1.1 hpeyerl * Request is done for better or worse, wakeup the top half.
897 1.1 hpeyerl */
898 1.1 hpeyerl if (bp->b_flags & B_ERROR)
899 1.1 hpeyerl bp->b_resid = bp->b_bcount;
900 1.80 mrg disk_unbusy(&cs->sc_dkdev, (bp->b_bcount - bp->b_resid),
901 1.80 mrg (bp->b_flags & B_READ));
902 1.1 hpeyerl biodone(bp);
903 1.1 hpeyerl }
904 1.1 hpeyerl
905 1.1 hpeyerl /*
906 1.11 thorpej * Called at interrupt time.
907 1.1 hpeyerl * Mark the component as done and if all components are done,
908 1.1 hpeyerl * take a ccd interrupt.
909 1.1 hpeyerl */
910 1.3 hpeyerl void
911 1.29 christos ccdiodone(vbp)
912 1.29 christos struct buf *vbp;
913 1.1 hpeyerl {
914 1.29 christos struct ccdbuf *cbp = (struct ccdbuf *) vbp;
915 1.59 thorpej struct buf *bp = cbp->cb_obp;
916 1.59 thorpej struct ccd_softc *cs = cbp->cb_sc;
917 1.53 thorpej int count, s;
918 1.1 hpeyerl
919 1.1 hpeyerl s = splbio();
920 1.1 hpeyerl #ifdef DEBUG
921 1.3 hpeyerl if (ccddebug & CCDB_FOLLOW)
922 1.35 christos printf("ccdiodone(%p)\n", cbp);
923 1.3 hpeyerl if (ccddebug & CCDB_IO) {
924 1.53 thorpej printf("ccdiodone: bp %p bcount %ld resid %ld\n",
925 1.53 thorpej bp, bp->b_bcount, bp->b_resid);
926 1.81 kleink printf(" dev 0x%x(u%d), cbp %p bn %" PRId64 " addr %p"
927 1.81 kleink " bcnt %ld\n",
928 1.6 cgd cbp->cb_buf.b_dev, cbp->cb_comp, cbp,
929 1.6 cgd cbp->cb_buf.b_blkno, cbp->cb_buf.b_data,
930 1.6 cgd cbp->cb_buf.b_bcount);
931 1.1 hpeyerl }
932 1.1 hpeyerl #endif
933 1.1 hpeyerl
934 1.6 cgd if (cbp->cb_buf.b_flags & B_ERROR) {
935 1.53 thorpej bp->b_flags |= B_ERROR;
936 1.53 thorpej bp->b_error = cbp->cb_buf.b_error ?
937 1.53 thorpej cbp->cb_buf.b_error : EIO;
938 1.24 thorpej
939 1.53 thorpej printf("%s: error %d on component %d\n",
940 1.53 thorpej cs->sc_xname, bp->b_error, cbp->cb_comp);
941 1.1 hpeyerl }
942 1.6 cgd count = cbp->cb_buf.b_bcount;
943 1.63 thorpej CCD_PUTBUF(cbp);
944 1.1 hpeyerl
945 1.1 hpeyerl /*
946 1.1 hpeyerl * If all done, "interrupt".
947 1.53 thorpej */
948 1.53 thorpej bp->b_resid -= count;
949 1.53 thorpej if (bp->b_resid < 0)
950 1.53 thorpej panic("ccdiodone: count");
951 1.53 thorpej if (bp->b_resid == 0)
952 1.59 thorpej ccdintr(cs, bp);
953 1.1 hpeyerl splx(s);
954 1.1 hpeyerl }
955 1.1 hpeyerl
956 1.11 thorpej /* ARGSUSED */
957 1.10 mycroft int
958 1.11 thorpej ccdread(dev, uio, flags)
959 1.3 hpeyerl dev_t dev;
960 1.3 hpeyerl struct uio *uio;
961 1.11 thorpej int flags;
962 1.3 hpeyerl {
963 1.11 thorpej int unit = ccdunit(dev);
964 1.11 thorpej struct ccd_softc *cs;
965 1.3 hpeyerl
966 1.3 hpeyerl #ifdef DEBUG
967 1.3 hpeyerl if (ccddebug & CCDB_FOLLOW)
968 1.43 fair printf("ccdread(0x%x, %p)\n", dev, uio);
969 1.3 hpeyerl #endif
970 1.11 thorpej if (unit >= numccd)
971 1.11 thorpej return (ENXIO);
972 1.11 thorpej cs = &ccd_softc[unit];
973 1.11 thorpej
974 1.11 thorpej if ((cs->sc_flags & CCDF_INITED) == 0)
975 1.11 thorpej return (ENXIO);
976 1.11 thorpej
977 1.11 thorpej /*
978 1.11 thorpej * XXX: It's not clear that using minphys() is completely safe,
979 1.11 thorpej * in particular, for raw I/O. Underlying devices might have some
980 1.11 thorpej * non-obvious limits, because of the copy to user-space.
981 1.11 thorpej */
982 1.10 mycroft return (physio(ccdstrategy, NULL, dev, B_READ, minphys, uio));
983 1.3 hpeyerl }
984 1.3 hpeyerl
985 1.11 thorpej /* ARGSUSED */
986 1.10 mycroft int
987 1.11 thorpej ccdwrite(dev, uio, flags)
988 1.3 hpeyerl dev_t dev;
989 1.3 hpeyerl struct uio *uio;
990 1.11 thorpej int flags;
991 1.3 hpeyerl {
992 1.11 thorpej int unit = ccdunit(dev);
993 1.11 thorpej struct ccd_softc *cs;
994 1.3 hpeyerl
995 1.3 hpeyerl #ifdef DEBUG
996 1.3 hpeyerl if (ccddebug & CCDB_FOLLOW)
997 1.43 fair printf("ccdwrite(0x%x, %p)\n", dev, uio);
998 1.3 hpeyerl #endif
999 1.11 thorpej if (unit >= numccd)
1000 1.11 thorpej return (ENXIO);
1001 1.11 thorpej cs = &ccd_softc[unit];
1002 1.11 thorpej
1003 1.11 thorpej if ((cs->sc_flags & CCDF_INITED) == 0)
1004 1.11 thorpej return (ENXIO);
1005 1.11 thorpej
1006 1.11 thorpej /*
1007 1.11 thorpej * XXX: It's not clear that using minphys() is completely safe,
1008 1.11 thorpej * in particular, for raw I/O. Underlying devices might have some
1009 1.11 thorpej * non-obvious limits, because of the copy to user-space.
1010 1.11 thorpej */
1011 1.10 mycroft return (physio(ccdstrategy, NULL, dev, B_WRITE, minphys, uio));
1012 1.3 hpeyerl }
1013 1.3 hpeyerl
1014 1.11 thorpej int
1015 1.90 fvdl ccdioctl(dev, cmd, data, flag, p)
1016 1.1 hpeyerl dev_t dev;
1017 1.5 cgd u_long cmd;
1018 1.1 hpeyerl caddr_t data;
1019 1.1 hpeyerl int flag;
1020 1.90 fvdl struct proc *p;
1021 1.1 hpeyerl {
1022 1.11 thorpej int unit = ccdunit(dev);
1023 1.88 thorpej int s, i, j, lookedup = 0, error;
1024 1.39 mycroft int part, pmask;
1025 1.88 thorpej struct buf *bp;
1026 1.11 thorpej struct ccd_softc *cs;
1027 1.11 thorpej struct ccd_ioctl *ccio = (struct ccd_ioctl *)data;
1028 1.11 thorpej char **cpp;
1029 1.11 thorpej struct vnode **vpp;
1030 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1031 1.70 fvdl struct disklabel newlabel;
1032 1.70 fvdl #endif
1033 1.11 thorpej
1034 1.11 thorpej if (unit >= numccd)
1035 1.11 thorpej return (ENXIO);
1036 1.11 thorpej cs = &ccd_softc[unit];
1037 1.11 thorpej
1038 1.41 thorpej /* Must be open for writes for these commands... */
1039 1.41 thorpej switch (cmd) {
1040 1.41 thorpej case CCDIOCSET:
1041 1.41 thorpej case CCDIOCCLR:
1042 1.41 thorpej case DIOCSDINFO:
1043 1.41 thorpej case DIOCWDINFO:
1044 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1045 1.70 fvdl case ODIOCSDINFO:
1046 1.70 fvdl case ODIOCWDINFO:
1047 1.70 fvdl #endif
1048 1.87 thorpej case DIOCKLABEL:
1049 1.41 thorpej case DIOCWLABEL:
1050 1.41 thorpej if ((flag & FWRITE) == 0)
1051 1.41 thorpej return (EBADF);
1052 1.41 thorpej }
1053 1.41 thorpej
1054 1.57 thorpej if ((error = lockmgr(&cs->sc_lock, LK_EXCLUSIVE, NULL)) != 0)
1055 1.57 thorpej return (error);
1056 1.57 thorpej
1057 1.41 thorpej /* Must be initialized for these... */
1058 1.41 thorpej switch (cmd) {
1059 1.41 thorpej case CCDIOCCLR:
1060 1.42 kleink case DIOCGDINFO:
1061 1.42 kleink case DIOCSDINFO:
1062 1.42 kleink case DIOCWDINFO:
1063 1.42 kleink case DIOCGPART:
1064 1.41 thorpej case DIOCWLABEL:
1065 1.87 thorpej case DIOCKLABEL:
1066 1.44 thorpej case DIOCGDEFLABEL:
1067 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1068 1.70 fvdl case ODIOCGDINFO:
1069 1.70 fvdl case ODIOCSDINFO:
1070 1.70 fvdl case ODIOCWDINFO:
1071 1.70 fvdl case ODIOCGDEFLABEL:
1072 1.70 fvdl #endif
1073 1.57 thorpej if ((cs->sc_flags & CCDF_INITED) == 0) {
1074 1.57 thorpej error = ENXIO;
1075 1.57 thorpej goto out;
1076 1.57 thorpej }
1077 1.41 thorpej }
1078 1.41 thorpej
1079 1.11 thorpej switch (cmd) {
1080 1.11 thorpej case CCDIOCSET:
1081 1.57 thorpej if (cs->sc_flags & CCDF_INITED) {
1082 1.57 thorpej error = EBUSY;
1083 1.57 thorpej goto out;
1084 1.57 thorpej }
1085 1.54 thorpej
1086 1.54 thorpej /* Validate the flags. */
1087 1.57 thorpej if ((ccio->ccio_flags & CCDF_USERMASK) != ccio->ccio_flags) {
1088 1.57 thorpej error = EINVAL;
1089 1.57 thorpej goto out;
1090 1.57 thorpej }
1091 1.15 thorpej
1092 1.73 jdolecek if (ccio->ccio_ndisks > CCD_MAXNDISKS) {
1093 1.73 jdolecek error = EINVAL;
1094 1.73 jdolecek goto out;
1095 1.73 jdolecek }
1096 1.73 jdolecek
1097 1.11 thorpej /* Fill in some important bits. */
1098 1.57 thorpej cs->sc_ileave = ccio->ccio_ileave;
1099 1.57 thorpej cs->sc_nccdisks = ccio->ccio_ndisks;
1100 1.57 thorpej cs->sc_flags = ccio->ccio_flags & CCDF_USERMASK;
1101 1.11 thorpej
1102 1.11 thorpej /*
1103 1.11 thorpej * Allocate space for and copy in the array of
1104 1.11 thorpej * componet pathnames and device numbers.
1105 1.11 thorpej */
1106 1.11 thorpej cpp = malloc(ccio->ccio_ndisks * sizeof(char *),
1107 1.11 thorpej M_DEVBUF, M_WAITOK);
1108 1.11 thorpej vpp = malloc(ccio->ccio_ndisks * sizeof(struct vnode *),
1109 1.11 thorpej M_DEVBUF, M_WAITOK);
1110 1.11 thorpej
1111 1.84 dsl error = copyin(ccio->ccio_disks, cpp,
1112 1.11 thorpej ccio->ccio_ndisks * sizeof(char **));
1113 1.11 thorpej if (error) {
1114 1.11 thorpej free(vpp, M_DEVBUF);
1115 1.11 thorpej free(cpp, M_DEVBUF);
1116 1.57 thorpej goto out;
1117 1.11 thorpej }
1118 1.11 thorpej
1119 1.11 thorpej #ifdef DEBUG
1120 1.11 thorpej if (ccddebug & CCDB_INIT)
1121 1.11 thorpej for (i = 0; i < ccio->ccio_ndisks; ++i)
1122 1.35 christos printf("ccdioctl: component %d: 0x%p\n",
1123 1.11 thorpej i, cpp[i]);
1124 1.11 thorpej #endif
1125 1.11 thorpej
1126 1.11 thorpej for (i = 0; i < ccio->ccio_ndisks; ++i) {
1127 1.11 thorpej #ifdef DEBUG
1128 1.11 thorpej if (ccddebug & CCDB_INIT)
1129 1.35 christos printf("ccdioctl: lookedup = %d\n", lookedup);
1130 1.11 thorpej #endif
1131 1.90 fvdl if ((error = ccdlookup(cpp[i], p, &vpp[i])) != 0) {
1132 1.11 thorpej for (j = 0; j < lookedup; ++j)
1133 1.12 thorpej (void)vn_close(vpp[j], FREAD|FWRITE,
1134 1.90 fvdl p->p_ucred, p);
1135 1.11 thorpej free(vpp, M_DEVBUF);
1136 1.11 thorpej free(cpp, M_DEVBUF);
1137 1.57 thorpej goto out;
1138 1.11 thorpej }
1139 1.11 thorpej ++lookedup;
1140 1.11 thorpej }
1141 1.11 thorpej
1142 1.11 thorpej /*
1143 1.11 thorpej * Initialize the ccd. Fills in the softc for us.
1144 1.11 thorpej */
1145 1.90 fvdl if ((error = ccdinit(cs, cpp, vpp, p)) != 0) {
1146 1.11 thorpej for (j = 0; j < lookedup; ++j)
1147 1.18 thorpej (void)vn_close(vpp[j], FREAD|FWRITE,
1148 1.90 fvdl p->p_ucred, p);
1149 1.11 thorpej free(vpp, M_DEVBUF);
1150 1.11 thorpej free(cpp, M_DEVBUF);
1151 1.57 thorpej goto out;
1152 1.11 thorpej }
1153 1.11 thorpej
1154 1.57 thorpej /* We can free the temporary variables now. */
1155 1.57 thorpej free(vpp, M_DEVBUF);
1156 1.57 thorpej free(cpp, M_DEVBUF);
1157 1.57 thorpej
1158 1.11 thorpej /*
1159 1.11 thorpej * The ccd has been successfully initialized, so
1160 1.23 thorpej * we can place it into the array. Don't try to
1161 1.23 thorpej * read the disklabel until the disk has been attached,
1162 1.23 thorpej * because space for the disklabel is allocated
1163 1.23 thorpej * in disk_attach();
1164 1.11 thorpej */
1165 1.11 thorpej ccio->ccio_unit = unit;
1166 1.11 thorpej ccio->ccio_size = cs->sc_size;
1167 1.23 thorpej
1168 1.88 thorpej bufq_alloc(&cs->sc_bufq, BUFQ_FCFS);
1169 1.88 thorpej
1170 1.23 thorpej /* Attach the disk. */
1171 1.23 thorpej disk_attach(&cs->sc_dkdev);
1172 1.23 thorpej
1173 1.23 thorpej /* Try and read the disklabel. */
1174 1.11 thorpej ccdgetdisklabel(dev);
1175 1.11 thorpej break;
1176 1.11 thorpej
1177 1.11 thorpej case CCDIOCCLR:
1178 1.11 thorpej /*
1179 1.11 thorpej * Don't unconfigure if any other partitions are open
1180 1.11 thorpej * or if both the character and block flavors of this
1181 1.11 thorpej * partition are open.
1182 1.11 thorpej */
1183 1.11 thorpej part = DISKPART(dev);
1184 1.11 thorpej pmask = (1 << part);
1185 1.11 thorpej if ((cs->sc_dkdev.dk_openmask & ~pmask) ||
1186 1.11 thorpej ((cs->sc_dkdev.dk_bopenmask & pmask) &&
1187 1.15 thorpej (cs->sc_dkdev.dk_copenmask & pmask))) {
1188 1.57 thorpej error = EBUSY;
1189 1.57 thorpej goto out;
1190 1.15 thorpej }
1191 1.88 thorpej
1192 1.88 thorpej /* Kill off any queued buffers. */
1193 1.88 thorpej s = splbio();
1194 1.88 thorpej while ((bp = BUFQ_GET(&cs->sc_bufq)) != NULL) {
1195 1.88 thorpej bp->b_error = EIO;
1196 1.88 thorpej bp->b_flags |= B_ERROR;
1197 1.88 thorpej bp->b_resid = bp->b_bcount;
1198 1.88 thorpej biodone(bp);
1199 1.88 thorpej }
1200 1.88 thorpej splx(s);
1201 1.88 thorpej
1202 1.88 thorpej bufq_free(&cs->sc_bufq);
1203 1.11 thorpej
1204 1.11 thorpej /*
1205 1.11 thorpej * Free ccd_softc information and clear entry.
1206 1.11 thorpej */
1207 1.22 thorpej
1208 1.22 thorpej /* Close the components and free their pathnames. */
1209 1.11 thorpej for (i = 0; i < cs->sc_nccdisks; ++i) {
1210 1.11 thorpej /*
1211 1.11 thorpej * XXX: this close could potentially fail and
1212 1.11 thorpej * cause Bad Things. Maybe we need to force
1213 1.11 thorpej * the close to happen?
1214 1.11 thorpej */
1215 1.11 thorpej #ifdef DEBUG
1216 1.11 thorpej if (ccddebug & CCDB_VNODE)
1217 1.11 thorpej vprint("CCDIOCCLR: vnode info",
1218 1.11 thorpej cs->sc_cinfo[i].ci_vp);
1219 1.11 thorpej #endif
1220 1.11 thorpej (void)vn_close(cs->sc_cinfo[i].ci_vp, FREAD|FWRITE,
1221 1.90 fvdl p->p_ucred, p);
1222 1.11 thorpej free(cs->sc_cinfo[i].ci_path, M_DEVBUF);
1223 1.38 thorpej }
1224 1.38 thorpej
1225 1.22 thorpej /* Free interleave index. */
1226 1.22 thorpej for (i = 0; cs->sc_itable[i].ii_ndisk; ++i)
1227 1.19 thorpej free(cs->sc_itable[i].ii_index, M_DEVBUF);
1228 1.22 thorpej
1229 1.22 thorpej /* Free component info and interleave table. */
1230 1.11 thorpej free(cs->sc_cinfo, M_DEVBUF);
1231 1.11 thorpej free(cs->sc_itable, M_DEVBUF);
1232 1.87 thorpej cs->sc_flags &= ~(CCDF_INITED|CCDF_VLABEL);
1233 1.15 thorpej
1234 1.23 thorpej /* Detatch the disk. */
1235 1.26 hpeyerl disk_detach(&cs->sc_dkdev);
1236 1.11 thorpej break;
1237 1.11 thorpej
1238 1.11 thorpej case DIOCGDINFO:
1239 1.23 thorpej *(struct disklabel *)data = *(cs->sc_dkdev.dk_label);
1240 1.11 thorpej break;
1241 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1242 1.70 fvdl case ODIOCGDINFO:
1243 1.70 fvdl newlabel = *(cs->sc_dkdev.dk_label);
1244 1.70 fvdl if (newlabel.d_npartitions > OLDMAXPARTITIONS)
1245 1.71 fvdl return ENOTTY;
1246 1.70 fvdl memcpy(data, &newlabel, sizeof (struct olddisklabel));
1247 1.70 fvdl break;
1248 1.70 fvdl #endif
1249 1.11 thorpej
1250 1.11 thorpej case DIOCGPART:
1251 1.23 thorpej ((struct partinfo *)data)->disklab = cs->sc_dkdev.dk_label;
1252 1.11 thorpej ((struct partinfo *)data)->part =
1253 1.23 thorpej &cs->sc_dkdev.dk_label->d_partitions[DISKPART(dev)];
1254 1.11 thorpej break;
1255 1.11 thorpej
1256 1.11 thorpej case DIOCWDINFO:
1257 1.11 thorpej case DIOCSDINFO:
1258 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1259 1.70 fvdl case ODIOCWDINFO:
1260 1.70 fvdl case ODIOCSDINFO:
1261 1.70 fvdl #endif
1262 1.70 fvdl {
1263 1.70 fvdl struct disklabel *lp;
1264 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1265 1.70 fvdl if (cmd == ODIOCSDINFO || cmd == ODIOCWDINFO) {
1266 1.70 fvdl memset(&newlabel, 0, sizeof newlabel);
1267 1.70 fvdl memcpy(&newlabel, data, sizeof (struct olddisklabel));
1268 1.70 fvdl lp = &newlabel;
1269 1.70 fvdl } else
1270 1.70 fvdl #endif
1271 1.70 fvdl lp = (struct disklabel *)data;
1272 1.70 fvdl
1273 1.11 thorpej cs->sc_flags |= CCDF_LABELLING;
1274 1.11 thorpej
1275 1.23 thorpej error = setdisklabel(cs->sc_dkdev.dk_label,
1276 1.70 fvdl lp, 0, cs->sc_dkdev.dk_cpulabel);
1277 1.11 thorpej if (error == 0) {
1278 1.70 fvdl if (cmd == DIOCWDINFO
1279 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1280 1.70 fvdl || cmd == ODIOCWDINFO
1281 1.70 fvdl #endif
1282 1.70 fvdl )
1283 1.11 thorpej error = writedisklabel(CCDLABELDEV(dev),
1284 1.23 thorpej ccdstrategy, cs->sc_dkdev.dk_label,
1285 1.23 thorpej cs->sc_dkdev.dk_cpulabel);
1286 1.11 thorpej }
1287 1.11 thorpej
1288 1.11 thorpej cs->sc_flags &= ~CCDF_LABELLING;
1289 1.11 thorpej break;
1290 1.70 fvdl }
1291 1.11 thorpej
1292 1.87 thorpej case DIOCKLABEL:
1293 1.87 thorpej if (*(int *)data != 0)
1294 1.87 thorpej cs->sc_flags |= CCDF_KLABEL;
1295 1.87 thorpej else
1296 1.87 thorpej cs->sc_flags &= ~CCDF_KLABEL;
1297 1.87 thorpej break;
1298 1.87 thorpej
1299 1.11 thorpej case DIOCWLABEL:
1300 1.11 thorpej if (*(int *)data != 0)
1301 1.11 thorpej cs->sc_flags |= CCDF_WLABEL;
1302 1.11 thorpej else
1303 1.11 thorpej cs->sc_flags &= ~CCDF_WLABEL;
1304 1.11 thorpej break;
1305 1.11 thorpej
1306 1.44 thorpej case DIOCGDEFLABEL:
1307 1.44 thorpej ccdgetdefaultlabel(cs, (struct disklabel *)data);
1308 1.44 thorpej break;
1309 1.70 fvdl
1310 1.70 fvdl #ifdef __HAVE_OLD_DISKLABEL
1311 1.70 fvdl case ODIOCGDEFLABEL:
1312 1.70 fvdl ccdgetdefaultlabel(cs, &newlabel);
1313 1.70 fvdl if (newlabel.d_npartitions > OLDMAXPARTITIONS)
1314 1.71 fvdl return ENOTTY;
1315 1.70 fvdl memcpy(data, &newlabel, sizeof (struct olddisklabel));
1316 1.70 fvdl break;
1317 1.70 fvdl #endif
1318 1.44 thorpej
1319 1.11 thorpej default:
1320 1.57 thorpej error = ENOTTY;
1321 1.11 thorpej }
1322 1.11 thorpej
1323 1.57 thorpej out:
1324 1.57 thorpej (void) lockmgr(&cs->sc_lock, LK_RELEASE, NULL);
1325 1.57 thorpej return (error);
1326 1.1 hpeyerl }
1327 1.1 hpeyerl
1328 1.11 thorpej int
1329 1.1 hpeyerl ccdsize(dev)
1330 1.1 hpeyerl dev_t dev;
1331 1.1 hpeyerl {
1332 1.11 thorpej struct ccd_softc *cs;
1333 1.40 thorpej struct disklabel *lp;
1334 1.40 thorpej int part, unit, omask, size;
1335 1.40 thorpej
1336 1.40 thorpej unit = ccdunit(dev);
1337 1.40 thorpej if (unit >= numccd)
1338 1.40 thorpej return (-1);
1339 1.40 thorpej cs = &ccd_softc[unit];
1340 1.11 thorpej
1341 1.40 thorpej if ((cs->sc_flags & CCDF_INITED) == 0)
1342 1.11 thorpej return (-1);
1343 1.11 thorpej
1344 1.11 thorpej part = DISKPART(dev);
1345 1.40 thorpej omask = cs->sc_dkdev.dk_openmask & (1 << part);
1346 1.40 thorpej lp = cs->sc_dkdev.dk_label;
1347 1.11 thorpej
1348 1.90 fvdl if (omask == 0 && ccdopen(dev, 0, S_IFBLK, curproc))
1349 1.11 thorpej return (-1);
1350 1.11 thorpej
1351 1.40 thorpej if (lp->d_partitions[part].p_fstype != FS_SWAP)
1352 1.11 thorpej size = -1;
1353 1.11 thorpej else
1354 1.40 thorpej size = lp->d_partitions[part].p_size *
1355 1.40 thorpej (lp->d_secsize / DEV_BSIZE);
1356 1.11 thorpej
1357 1.90 fvdl if (omask == 0 && ccdclose(dev, 0, S_IFBLK, curproc))
1358 1.11 thorpej return (-1);
1359 1.1 hpeyerl
1360 1.11 thorpej return (size);
1361 1.1 hpeyerl }
1362 1.1 hpeyerl
1363 1.9 cgd int
1364 1.9 cgd ccddump(dev, blkno, va, size)
1365 1.9 cgd dev_t dev;
1366 1.9 cgd daddr_t blkno;
1367 1.9 cgd caddr_t va;
1368 1.9 cgd size_t size;
1369 1.1 hpeyerl {
1370 1.9 cgd
1371 1.9 cgd /* Not implemented. */
1372 1.9 cgd return ENXIO;
1373 1.11 thorpej }
1374 1.11 thorpej
1375 1.11 thorpej /*
1376 1.11 thorpej * Lookup the provided name in the filesystem. If the file exists,
1377 1.11 thorpej * is a valid block device, and isn't being used by anyone else,
1378 1.11 thorpej * set *vpp to the file's vnode.
1379 1.11 thorpej */
1380 1.11 thorpej static int
1381 1.90 fvdl ccdlookup(path, p, vpp)
1382 1.11 thorpej char *path;
1383 1.90 fvdl struct proc *p;
1384 1.11 thorpej struct vnode **vpp; /* result */
1385 1.11 thorpej {
1386 1.11 thorpej struct nameidata nd;
1387 1.11 thorpej struct vnode *vp;
1388 1.11 thorpej struct vattr va;
1389 1.11 thorpej int error;
1390 1.11 thorpej
1391 1.90 fvdl NDINIT(&nd, LOOKUP, FOLLOW, UIO_USERSPACE, path, p);
1392 1.29 christos if ((error = vn_open(&nd, FREAD|FWRITE, 0)) != 0) {
1393 1.11 thorpej #ifdef DEBUG
1394 1.29 christos if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
1395 1.35 christos printf("ccdlookup: vn_open error = %d\n", error);
1396 1.11 thorpej #endif
1397 1.11 thorpej return (error);
1398 1.11 thorpej }
1399 1.11 thorpej vp = nd.ni_vp;
1400 1.11 thorpej
1401 1.11 thorpej if (vp->v_usecount > 1) {
1402 1.49 ross VOP_UNLOCK(vp, 0);
1403 1.90 fvdl (void)vn_close(vp, FREAD|FWRITE, p->p_ucred, p);
1404 1.11 thorpej return (EBUSY);
1405 1.11 thorpej }
1406 1.11 thorpej
1407 1.90 fvdl if ((error = VOP_GETATTR(vp, &va, p->p_ucred, p)) != 0) {
1408 1.11 thorpej #ifdef DEBUG
1409 1.29 christos if (ccddebug & (CCDB_FOLLOW|CCDB_INIT))
1410 1.35 christos printf("ccdlookup: getattr error = %d\n", error);
1411 1.11 thorpej #endif
1412 1.49 ross VOP_UNLOCK(vp, 0);
1413 1.90 fvdl (void)vn_close(vp, FREAD|FWRITE, p->p_ucred, p);
1414 1.11 thorpej return (error);
1415 1.11 thorpej }
1416 1.11 thorpej
1417 1.11 thorpej /* XXX: eventually we should handle VREG, too. */
1418 1.11 thorpej if (va.va_type != VBLK) {
1419 1.49 ross VOP_UNLOCK(vp, 0);
1420 1.90 fvdl (void)vn_close(vp, FREAD|FWRITE, p->p_ucred, p);
1421 1.11 thorpej return (ENOTBLK);
1422 1.11 thorpej }
1423 1.11 thorpej
1424 1.11 thorpej #ifdef DEBUG
1425 1.11 thorpej if (ccddebug & CCDB_VNODE)
1426 1.11 thorpej vprint("ccdlookup: vnode info", vp);
1427 1.11 thorpej #endif
1428 1.11 thorpej
1429 1.49 ross VOP_UNLOCK(vp, 0);
1430 1.11 thorpej *vpp = vp;
1431 1.11 thorpej return (0);
1432 1.11 thorpej }
1433 1.11 thorpej
1434 1.11 thorpej static void
1435 1.44 thorpej ccdgetdefaultlabel(cs, lp)
1436 1.44 thorpej struct ccd_softc *cs;
1437 1.44 thorpej struct disklabel *lp;
1438 1.11 thorpej {
1439 1.11 thorpej struct ccdgeom *ccg = &cs->sc_geom;
1440 1.11 thorpej
1441 1.72 thorpej memset(lp, 0, sizeof(*lp));
1442 1.11 thorpej
1443 1.11 thorpej lp->d_secperunit = cs->sc_size;
1444 1.11 thorpej lp->d_secsize = ccg->ccg_secsize;
1445 1.11 thorpej lp->d_nsectors = ccg->ccg_nsectors;
1446 1.11 thorpej lp->d_ntracks = ccg->ccg_ntracks;
1447 1.11 thorpej lp->d_ncylinders = ccg->ccg_ncylinders;
1448 1.19 thorpej lp->d_secpercyl = lp->d_ntracks * lp->d_nsectors;
1449 1.11 thorpej
1450 1.11 thorpej strncpy(lp->d_typename, "ccd", sizeof(lp->d_typename));
1451 1.11 thorpej lp->d_type = DTYPE_CCD;
1452 1.11 thorpej strncpy(lp->d_packname, "fictitious", sizeof(lp->d_packname));
1453 1.11 thorpej lp->d_rpm = 3600;
1454 1.11 thorpej lp->d_interleave = 1;
1455 1.11 thorpej lp->d_flags = 0;
1456 1.11 thorpej
1457 1.11 thorpej lp->d_partitions[RAW_PART].p_offset = 0;
1458 1.11 thorpej lp->d_partitions[RAW_PART].p_size = cs->sc_size;
1459 1.11 thorpej lp->d_partitions[RAW_PART].p_fstype = FS_UNUSED;
1460 1.11 thorpej lp->d_npartitions = RAW_PART + 1;
1461 1.11 thorpej
1462 1.11 thorpej lp->d_magic = DISKMAGIC;
1463 1.11 thorpej lp->d_magic2 = DISKMAGIC;
1464 1.23 thorpej lp->d_checksum = dkcksum(cs->sc_dkdev.dk_label);
1465 1.44 thorpej }
1466 1.44 thorpej
1467 1.44 thorpej /*
1468 1.44 thorpej * Read the disklabel from the ccd. If one is not present, fake one
1469 1.44 thorpej * up.
1470 1.44 thorpej */
1471 1.44 thorpej static void
1472 1.44 thorpej ccdgetdisklabel(dev)
1473 1.44 thorpej dev_t dev;
1474 1.44 thorpej {
1475 1.44 thorpej int unit = ccdunit(dev);
1476 1.44 thorpej struct ccd_softc *cs = &ccd_softc[unit];
1477 1.85 dsl const char *errstring;
1478 1.44 thorpej struct disklabel *lp = cs->sc_dkdev.dk_label;
1479 1.44 thorpej struct cpu_disklabel *clp = cs->sc_dkdev.dk_cpulabel;
1480 1.44 thorpej
1481 1.72 thorpej memset(clp, 0, sizeof(*clp));
1482 1.44 thorpej
1483 1.44 thorpej ccdgetdefaultlabel(cs, lp);
1484 1.11 thorpej
1485 1.11 thorpej /*
1486 1.11 thorpej * Call the generic disklabel extraction routine.
1487 1.11 thorpej */
1488 1.92 lukem if ((cs->sc_flags & CCDF_NOLABEL) != 0)
1489 1.92 lukem errstring = "CCDF_NOLABEL set; ignoring on-disk label";
1490 1.92 lukem else
1491 1.92 lukem errstring = readdisklabel(CCDLABELDEV(dev), ccdstrategy,
1492 1.92 lukem cs->sc_dkdev.dk_label, cs->sc_dkdev.dk_cpulabel);
1493 1.29 christos if (errstring)
1494 1.11 thorpej ccdmakedisklabel(cs);
1495 1.47 enami else {
1496 1.47 enami int i;
1497 1.47 enami struct partition *pp;
1498 1.47 enami
1499 1.47 enami /*
1500 1.47 enami * Sanity check whether the found disklabel is valid.
1501 1.47 enami *
1502 1.47 enami * This is necessary since total size of ccd may vary
1503 1.47 enami * when an interleave is changed even though exactly
1504 1.47 enami * same componets are used, and old disklabel may used
1505 1.47 enami * if that is found.
1506 1.47 enami */
1507 1.47 enami if (lp->d_secperunit != cs->sc_size)
1508 1.47 enami printf("WARNING: %s: "
1509 1.47 enami "total sector size in disklabel (%d) != "
1510 1.60 thorpej "the size of ccd (%lu)\n", cs->sc_xname,
1511 1.60 thorpej lp->d_secperunit, (u_long)cs->sc_size);
1512 1.47 enami for (i = 0; i < lp->d_npartitions; i++) {
1513 1.47 enami pp = &lp->d_partitions[i];
1514 1.47 enami if (pp->p_offset + pp->p_size > cs->sc_size)
1515 1.48 enami printf("WARNING: %s: end of partition `%c' "
1516 1.60 thorpej "exceeds the size of ccd (%lu)\n",
1517 1.60 thorpej cs->sc_xname, 'a' + i, (u_long)cs->sc_size);
1518 1.47 enami }
1519 1.47 enami }
1520 1.11 thorpej
1521 1.11 thorpej #ifdef DEBUG
1522 1.11 thorpej /* It's actually extremely common to have unlabeled ccds. */
1523 1.11 thorpej if (ccddebug & CCDB_LABEL)
1524 1.11 thorpej if (errstring != NULL)
1525 1.35 christos printf("%s: %s\n", cs->sc_xname, errstring);
1526 1.11 thorpej #endif
1527 1.87 thorpej
1528 1.87 thorpej /* In-core label now valid. */
1529 1.87 thorpej cs->sc_flags |= CCDF_VLABEL;
1530 1.11 thorpej }
1531 1.11 thorpej
1532 1.11 thorpej /*
1533 1.11 thorpej * Take care of things one might want to take care of in the event
1534 1.11 thorpej * that a disklabel isn't present.
1535 1.11 thorpej */
1536 1.11 thorpej static void
1537 1.11 thorpej ccdmakedisklabel(cs)
1538 1.11 thorpej struct ccd_softc *cs;
1539 1.11 thorpej {
1540 1.23 thorpej struct disklabel *lp = cs->sc_dkdev.dk_label;
1541 1.11 thorpej
1542 1.11 thorpej /*
1543 1.11 thorpej * For historical reasons, if there's no disklabel present
1544 1.11 thorpej * the raw partition must be marked FS_BSDFFS.
1545 1.11 thorpej */
1546 1.11 thorpej lp->d_partitions[RAW_PART].p_fstype = FS_BSDFFS;
1547 1.11 thorpej
1548 1.11 thorpej strncpy(lp->d_packname, "default label", sizeof(lp->d_packname));
1549 1.44 thorpej
1550 1.44 thorpej lp->d_checksum = dkcksum(lp);
1551 1.11 thorpej }
1552 1.11 thorpej
1553 1.11 thorpej #ifdef DEBUG
1554 1.11 thorpej static void
1555 1.11 thorpej printiinfo(ii)
1556 1.11 thorpej struct ccdiinfo *ii;
1557 1.11 thorpej {
1558 1.68 augustss int ix, i;
1559 1.11 thorpej
1560 1.11 thorpej for (ix = 0; ii->ii_ndisk; ix++, ii++) {
1561 1.81 kleink printf(" itab[%d]: #dk %d sblk %" PRId64 " soff %" PRId64,
1562 1.34 christos ix, ii->ii_ndisk, ii->ii_startblk, ii->ii_startoff);
1563 1.11 thorpej for (i = 0; i < ii->ii_ndisk; i++)
1564 1.35 christos printf(" %d", ii->ii_index[i]);
1565 1.35 christos printf("\n");
1566 1.11 thorpej }
1567 1.1 hpeyerl }
1568 1.1 hpeyerl #endif
1569