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