dk.c revision 1.18.2.3
1 1.18.2.3 yamt /* $NetBSD: dk.c,v 1.18.2.3 2006/12/10 07:17:01 yamt Exp $ */ 2 1.18.2.2 yamt 3 1.18.2.2 yamt /*- 4 1.18.2.2 yamt * Copyright (c) 2004 The NetBSD Foundation, Inc. 5 1.18.2.2 yamt * All rights reserved. 6 1.18.2.2 yamt * 7 1.18.2.2 yamt * This code is derived from software contributed to The NetBSD Foundation 8 1.18.2.2 yamt * by Jason R. Thorpe. 9 1.18.2.2 yamt * 10 1.18.2.2 yamt * Redistribution and use in source and binary forms, with or without 11 1.18.2.2 yamt * modification, are permitted provided that the following conditions 12 1.18.2.2 yamt * are met: 13 1.18.2.2 yamt * 1. Redistributions of source code must retain the above copyright 14 1.18.2.2 yamt * notice, this list of conditions and the following disclaimer. 15 1.18.2.2 yamt * 2. Redistributions in binary form must reproduce the above copyright 16 1.18.2.2 yamt * notice, this list of conditions and the following disclaimer in the 17 1.18.2.2 yamt * documentation and/or other materials provided with the distribution. 18 1.18.2.2 yamt * 3. All advertising materials mentioning features or use of this software 19 1.18.2.2 yamt * must display the following acknowledgement: 20 1.18.2.2 yamt * This product includes software developed by the NetBSD 21 1.18.2.2 yamt * Foundation, Inc. and its contributors. 22 1.18.2.2 yamt * 4. Neither the name of The NetBSD Foundation nor the names of its 23 1.18.2.2 yamt * contributors may be used to endorse or promote products derived 24 1.18.2.2 yamt * from this software without specific prior written permission. 25 1.18.2.2 yamt * 26 1.18.2.2 yamt * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS 27 1.18.2.2 yamt * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 28 1.18.2.2 yamt * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 29 1.18.2.2 yamt * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS 30 1.18.2.2 yamt * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 31 1.18.2.2 yamt * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 32 1.18.2.2 yamt * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 33 1.18.2.2 yamt * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 34 1.18.2.2 yamt * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 35 1.18.2.2 yamt * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 36 1.18.2.2 yamt * POSSIBILITY OF SUCH DAMAGE. 37 1.18.2.2 yamt */ 38 1.18.2.2 yamt 39 1.18.2.2 yamt #include <sys/cdefs.h> 40 1.18.2.3 yamt __KERNEL_RCSID(0, "$NetBSD: dk.c,v 1.18.2.3 2006/12/10 07:17:01 yamt Exp $"); 41 1.18.2.2 yamt 42 1.18.2.2 yamt #include "opt_dkwedge.h" 43 1.18.2.2 yamt 44 1.18.2.2 yamt #include <sys/param.h> 45 1.18.2.2 yamt #include <sys/systm.h> 46 1.18.2.2 yamt #include <sys/proc.h> 47 1.18.2.2 yamt #include <sys/errno.h> 48 1.18.2.2 yamt #include <sys/pool.h> 49 1.18.2.2 yamt #include <sys/ioctl.h> 50 1.18.2.2 yamt #include <sys/disklabel.h> 51 1.18.2.2 yamt #include <sys/disk.h> 52 1.18.2.2 yamt #include <sys/fcntl.h> 53 1.18.2.2 yamt #include <sys/buf.h> 54 1.18.2.2 yamt #include <sys/bufq.h> 55 1.18.2.2 yamt #include <sys/vnode.h> 56 1.18.2.2 yamt #include <sys/stat.h> 57 1.18.2.2 yamt #include <sys/conf.h> 58 1.18.2.2 yamt #include <sys/callout.h> 59 1.18.2.2 yamt #include <sys/kernel.h> 60 1.18.2.2 yamt #include <sys/lock.h> 61 1.18.2.2 yamt #include <sys/malloc.h> 62 1.18.2.2 yamt #include <sys/device.h> 63 1.18.2.2 yamt #include <sys/kauth.h> 64 1.18.2.2 yamt 65 1.18.2.2 yamt #include <miscfs/specfs/specdev.h> 66 1.18.2.2 yamt 67 1.18.2.2 yamt MALLOC_DEFINE(M_DKWEDGE, "dkwedge", "Disk wedge structures"); 68 1.18.2.2 yamt 69 1.18.2.2 yamt typedef enum { 70 1.18.2.2 yamt DKW_STATE_LARVAL = 0, 71 1.18.2.2 yamt DKW_STATE_RUNNING = 1, 72 1.18.2.2 yamt DKW_STATE_DYING = 2, 73 1.18.2.2 yamt DKW_STATE_DEAD = 666 74 1.18.2.2 yamt } dkwedge_state_t; 75 1.18.2.2 yamt 76 1.18.2.2 yamt struct dkwedge_softc { 77 1.18.2.2 yamt struct device *sc_dev; /* pointer to our pseudo-device */ 78 1.18.2.2 yamt struct cfdata sc_cfdata; /* our cfdata structure */ 79 1.18.2.2 yamt uint8_t sc_wname[128]; /* wedge name (Unicode, UTF-8) */ 80 1.18.2.2 yamt 81 1.18.2.2 yamt dkwedge_state_t sc_state; /* state this wedge is in */ 82 1.18.2.2 yamt 83 1.18.2.2 yamt struct disk *sc_parent; /* parent disk */ 84 1.18.2.2 yamt daddr_t sc_offset; /* LBA offset of wedge in parent */ 85 1.18.2.2 yamt uint64_t sc_size; /* size of wedge in blocks */ 86 1.18.2.2 yamt char sc_ptype[32]; /* partition type */ 87 1.18.2.2 yamt dev_t sc_pdev; /* cached parent's dev_t */ 88 1.18.2.2 yamt /* link on parent's wedge list */ 89 1.18.2.2 yamt LIST_ENTRY(dkwedge_softc) sc_plink; 90 1.18.2.2 yamt 91 1.18.2.2 yamt struct disk sc_dk; /* our own disk structure */ 92 1.18.2.2 yamt struct bufq_state *sc_bufq; /* buffer queue */ 93 1.18.2.2 yamt struct callout sc_restart_ch; /* callout to restart I/O */ 94 1.18.2.2 yamt 95 1.18.2.2 yamt u_int sc_iopend; /* I/Os pending */ 96 1.18.2.2 yamt int sc_flags; /* flags (splbio) */ 97 1.18.2.2 yamt }; 98 1.18.2.2 yamt 99 1.18.2.2 yamt #define DK_F_WAIT_DRAIN 0x0001 /* waiting for I/O to drain */ 100 1.18.2.2 yamt 101 1.18.2.2 yamt static void dkstart(struct dkwedge_softc *); 102 1.18.2.2 yamt static void dkiodone(struct buf *); 103 1.18.2.2 yamt static void dkrestart(void *); 104 1.18.2.2 yamt 105 1.18.2.2 yamt static dev_type_open(dkopen); 106 1.18.2.2 yamt static dev_type_close(dkclose); 107 1.18.2.2 yamt static dev_type_read(dkread); 108 1.18.2.2 yamt static dev_type_write(dkwrite); 109 1.18.2.2 yamt static dev_type_ioctl(dkioctl); 110 1.18.2.2 yamt static dev_type_strategy(dkstrategy); 111 1.18.2.2 yamt static dev_type_dump(dkdump); 112 1.18.2.2 yamt static dev_type_size(dksize); 113 1.18.2.2 yamt 114 1.18.2.2 yamt const struct bdevsw dk_bdevsw = { 115 1.18.2.2 yamt dkopen, dkclose, dkstrategy, dkioctl, dkdump, dksize, D_DISK 116 1.18.2.2 yamt }; 117 1.18.2.2 yamt 118 1.18.2.2 yamt const struct cdevsw dk_cdevsw = { 119 1.18.2.2 yamt dkopen, dkclose, dkread, dkwrite, dkioctl, 120 1.18.2.2 yamt nostop, notty, nopoll, nommap, nokqfilter, D_DISK 121 1.18.2.2 yamt }; 122 1.18.2.2 yamt 123 1.18.2.2 yamt static struct dkwedge_softc **dkwedges; 124 1.18.2.2 yamt static u_int ndkwedges; 125 1.18.2.2 yamt static struct lock dkwedges_lock = LOCK_INITIALIZER(PRIBIO, "dkwgs", 0, 0); 126 1.18.2.2 yamt 127 1.18.2.2 yamt static LIST_HEAD(, dkwedge_discovery_method) dkwedge_discovery_methods; 128 1.18.2.2 yamt static int dkwedge_discovery_methods_initialized; 129 1.18.2.2 yamt static struct lock dkwedge_discovery_methods_lock = 130 1.18.2.2 yamt LOCK_INITIALIZER(PRIBIO, "dkddm", 0, 0); 131 1.18.2.2 yamt 132 1.18.2.2 yamt /* 133 1.18.2.2 yamt * dkwedge_match: 134 1.18.2.2 yamt * 135 1.18.2.2 yamt * Autoconfiguration match function for pseudo-device glue. 136 1.18.2.2 yamt */ 137 1.18.2.2 yamt static int 138 1.18.2.3 yamt dkwedge_match(struct device *parent, struct cfdata *match, 139 1.18.2.3 yamt void *aux) 140 1.18.2.2 yamt { 141 1.18.2.2 yamt 142 1.18.2.2 yamt /* Pseudo-device; always present. */ 143 1.18.2.2 yamt return (1); 144 1.18.2.2 yamt } 145 1.18.2.2 yamt 146 1.18.2.2 yamt /* 147 1.18.2.2 yamt * dkwedge_attach: 148 1.18.2.2 yamt * 149 1.18.2.2 yamt * Autoconfiguration attach function for pseudo-device glue. 150 1.18.2.2 yamt */ 151 1.18.2.2 yamt static void 152 1.18.2.3 yamt dkwedge_attach(struct device *parent, struct device *self, 153 1.18.2.3 yamt void *aux) 154 1.18.2.2 yamt { 155 1.18.2.2 yamt 156 1.18.2.2 yamt /* Nothing to do. */ 157 1.18.2.2 yamt } 158 1.18.2.2 yamt 159 1.18.2.2 yamt /* 160 1.18.2.2 yamt * dkwedge_detach: 161 1.18.2.2 yamt * 162 1.18.2.2 yamt * Autoconfiguration detach function for pseudo-device glue. 163 1.18.2.2 yamt */ 164 1.18.2.2 yamt static int 165 1.18.2.3 yamt dkwedge_detach(struct device *self, int flags) 166 1.18.2.2 yamt { 167 1.18.2.2 yamt 168 1.18.2.2 yamt /* Always succeeds. */ 169 1.18.2.2 yamt return (0); 170 1.18.2.2 yamt } 171 1.18.2.2 yamt 172 1.18.2.2 yamt CFDRIVER_DECL(dk, DV_DISK, NULL); 173 1.18.2.2 yamt CFATTACH_DECL(dk, sizeof(struct device), 174 1.18.2.2 yamt dkwedge_match, dkwedge_attach, dkwedge_detach, NULL); 175 1.18.2.2 yamt 176 1.18.2.2 yamt static int dkwedge_cfglue_initialized; 177 1.18.2.2 yamt static struct simplelock dkwedge_cfglue_initialized_slock = 178 1.18.2.2 yamt SIMPLELOCK_INITIALIZER; 179 1.18.2.2 yamt 180 1.18.2.2 yamt static void 181 1.18.2.2 yamt dkwedge_cfglue_init(void) 182 1.18.2.2 yamt { 183 1.18.2.2 yamt 184 1.18.2.2 yamt simple_lock(&dkwedge_cfglue_initialized_slock); 185 1.18.2.2 yamt if (dkwedge_cfglue_initialized == 0) { 186 1.18.2.2 yamt if (config_cfdriver_attach(&dk_cd) != 0) 187 1.18.2.2 yamt panic("dkwedge: unable to attach cfdriver"); 188 1.18.2.2 yamt if (config_cfattach_attach(dk_cd.cd_name, &dk_ca) != 0) 189 1.18.2.2 yamt panic("dkwedge: unable to attach cfattach"); 190 1.18.2.2 yamt 191 1.18.2.2 yamt dkwedge_cfglue_initialized = 1; 192 1.18.2.2 yamt } 193 1.18.2.2 yamt simple_unlock(&dkwedge_cfglue_initialized_slock); 194 1.18.2.2 yamt } 195 1.18.2.2 yamt 196 1.18.2.2 yamt /* 197 1.18.2.2 yamt * dkwedge_wait_drain: 198 1.18.2.2 yamt * 199 1.18.2.2 yamt * Wait for I/O on the wedge to drain. 200 1.18.2.2 yamt * NOTE: Must be called at splbio()! 201 1.18.2.2 yamt */ 202 1.18.2.2 yamt static void 203 1.18.2.2 yamt dkwedge_wait_drain(struct dkwedge_softc *sc) 204 1.18.2.2 yamt { 205 1.18.2.2 yamt 206 1.18.2.2 yamt while (sc->sc_iopend != 0) { 207 1.18.2.2 yamt sc->sc_flags |= DK_F_WAIT_DRAIN; 208 1.18.2.2 yamt (void) tsleep(&sc->sc_iopend, PRIBIO, "dkdrn", 0); 209 1.18.2.2 yamt } 210 1.18.2.2 yamt } 211 1.18.2.2 yamt 212 1.18.2.2 yamt /* 213 1.18.2.2 yamt * dkwedge_compute_pdev: 214 1.18.2.2 yamt * 215 1.18.2.2 yamt * Compute the parent disk's dev_t. 216 1.18.2.2 yamt */ 217 1.18.2.2 yamt static int 218 1.18.2.2 yamt dkwedge_compute_pdev(const char *pname, dev_t *pdevp) 219 1.18.2.2 yamt { 220 1.18.2.2 yamt const char *name, *cp; 221 1.18.2.2 yamt int punit, pmaj; 222 1.18.2.2 yamt char devname[16]; 223 1.18.2.2 yamt 224 1.18.2.2 yamt name = pname; 225 1.18.2.2 yamt if ((pmaj = devsw_name2blk(name, devname, sizeof(devname))) == -1) 226 1.18.2.2 yamt return (ENODEV); 227 1.18.2.2 yamt 228 1.18.2.2 yamt name += strlen(devname); 229 1.18.2.2 yamt for (cp = name, punit = 0; *cp >= '0' && *cp <= '9'; cp++) 230 1.18.2.2 yamt punit = (punit * 10) + (*cp - '0'); 231 1.18.2.2 yamt if (cp == name) { 232 1.18.2.2 yamt /* Invalid parent disk name. */ 233 1.18.2.2 yamt return (ENODEV); 234 1.18.2.2 yamt } 235 1.18.2.2 yamt 236 1.18.2.2 yamt *pdevp = MAKEDISKDEV(pmaj, punit, RAW_PART); 237 1.18.2.2 yamt 238 1.18.2.2 yamt return (0); 239 1.18.2.2 yamt } 240 1.18.2.2 yamt 241 1.18.2.2 yamt /* 242 1.18.2.2 yamt * dkwedge_array_expand: 243 1.18.2.2 yamt * 244 1.18.2.2 yamt * Expand the dkwedges array. 245 1.18.2.2 yamt */ 246 1.18.2.2 yamt static void 247 1.18.2.2 yamt dkwedge_array_expand(void) 248 1.18.2.2 yamt { 249 1.18.2.2 yamt int newcnt = ndkwedges + 16; 250 1.18.2.2 yamt struct dkwedge_softc **newarray, **oldarray; 251 1.18.2.2 yamt 252 1.18.2.2 yamt newarray = malloc(newcnt * sizeof(*newarray), M_DKWEDGE, 253 1.18.2.2 yamt M_WAITOK|M_ZERO); 254 1.18.2.2 yamt if ((oldarray = dkwedges) != NULL) 255 1.18.2.2 yamt memcpy(newarray, dkwedges, ndkwedges * sizeof(*newarray)); 256 1.18.2.2 yamt dkwedges = newarray; 257 1.18.2.2 yamt ndkwedges = newcnt; 258 1.18.2.2 yamt if (oldarray != NULL) 259 1.18.2.2 yamt free(oldarray, M_DKWEDGE); 260 1.18.2.2 yamt } 261 1.18.2.2 yamt 262 1.18.2.2 yamt /* 263 1.18.2.2 yamt * dkwedge_add: [exported function] 264 1.18.2.2 yamt * 265 1.18.2.2 yamt * Add a disk wedge based on the provided information. 266 1.18.2.2 yamt * 267 1.18.2.2 yamt * The incoming dkw_devname[] is ignored, instead being 268 1.18.2.2 yamt * filled in and returned to the caller. 269 1.18.2.2 yamt */ 270 1.18.2.2 yamt int 271 1.18.2.2 yamt dkwedge_add(struct dkwedge_info *dkw) 272 1.18.2.2 yamt { 273 1.18.2.2 yamt struct dkwedge_softc *sc, *lsc; 274 1.18.2.2 yamt struct disk *pdk; 275 1.18.2.2 yamt u_int unit; 276 1.18.2.2 yamt int error; 277 1.18.2.2 yamt dev_t pdev; 278 1.18.2.2 yamt 279 1.18.2.2 yamt if (dkwedge_cfglue_initialized == 0) 280 1.18.2.2 yamt dkwedge_cfglue_init(); 281 1.18.2.2 yamt 282 1.18.2.2 yamt dkw->dkw_parent[sizeof(dkw->dkw_parent) - 1] = '\0'; 283 1.18.2.2 yamt pdk = disk_find(dkw->dkw_parent); 284 1.18.2.2 yamt if (pdk == NULL) 285 1.18.2.2 yamt return (ENODEV); 286 1.18.2.2 yamt 287 1.18.2.2 yamt error = dkwedge_compute_pdev(pdk->dk_name, &pdev); 288 1.18.2.2 yamt if (error) 289 1.18.2.2 yamt return (error); 290 1.18.2.2 yamt 291 1.18.2.2 yamt if (dkw->dkw_offset < 0) 292 1.18.2.2 yamt return (EINVAL); 293 1.18.2.2 yamt 294 1.18.2.2 yamt sc = malloc(sizeof(*sc), M_DKWEDGE, M_WAITOK|M_ZERO); 295 1.18.2.2 yamt sc->sc_state = DKW_STATE_LARVAL; 296 1.18.2.2 yamt sc->sc_parent = pdk; 297 1.18.2.2 yamt sc->sc_pdev = pdev; 298 1.18.2.2 yamt sc->sc_offset = dkw->dkw_offset; 299 1.18.2.2 yamt sc->sc_size = dkw->dkw_size; 300 1.18.2.2 yamt 301 1.18.2.2 yamt memcpy(sc->sc_wname, dkw->dkw_wname, sizeof(sc->sc_wname)); 302 1.18.2.2 yamt sc->sc_wname[sizeof(sc->sc_wname) - 1] = '\0'; 303 1.18.2.2 yamt 304 1.18.2.2 yamt memcpy(sc->sc_ptype, dkw->dkw_ptype, sizeof(sc->sc_ptype)); 305 1.18.2.2 yamt sc->sc_ptype[sizeof(sc->sc_ptype) - 1] = '\0'; 306 1.18.2.2 yamt 307 1.18.2.2 yamt bufq_alloc(&sc->sc_bufq, "fcfs", 0); 308 1.18.2.2 yamt 309 1.18.2.2 yamt callout_init(&sc->sc_restart_ch); 310 1.18.2.2 yamt callout_setfunc(&sc->sc_restart_ch, dkrestart, sc); 311 1.18.2.2 yamt 312 1.18.2.2 yamt /* 313 1.18.2.2 yamt * Wedge will be added; increment the wedge count for the parent. 314 1.18.2.2 yamt * Only allow this to happend if RAW_PART is the only thing open. 315 1.18.2.2 yamt */ 316 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_EXCLUSIVE, NULL); 317 1.18.2.2 yamt if (pdk->dk_openmask & ~(1 << RAW_PART)) 318 1.18.2.2 yamt error = EBUSY; 319 1.18.2.2 yamt else { 320 1.18.2.2 yamt /* Check for wedge overlap. */ 321 1.18.2.2 yamt LIST_FOREACH(lsc, &pdk->dk_wedges, sc_plink) { 322 1.18.2.2 yamt daddr_t lastblk = sc->sc_offset + sc->sc_size - 1; 323 1.18.2.2 yamt daddr_t llastblk = lsc->sc_offset + lsc->sc_size - 1; 324 1.18.2.2 yamt 325 1.18.2.2 yamt if (sc->sc_offset >= lsc->sc_offset && 326 1.18.2.2 yamt sc->sc_offset <= llastblk) { 327 1.18.2.2 yamt /* Overlaps the tail of the exsiting wedge. */ 328 1.18.2.2 yamt break; 329 1.18.2.2 yamt } 330 1.18.2.2 yamt if (lastblk >= lsc->sc_offset && 331 1.18.2.2 yamt lastblk <= llastblk) { 332 1.18.2.2 yamt /* Overlaps the head of the existing wedge. */ 333 1.18.2.2 yamt break; 334 1.18.2.2 yamt } 335 1.18.2.2 yamt } 336 1.18.2.2 yamt if (lsc != NULL) 337 1.18.2.2 yamt error = EINVAL; 338 1.18.2.2 yamt else { 339 1.18.2.2 yamt pdk->dk_nwedges++; 340 1.18.2.2 yamt LIST_INSERT_HEAD(&pdk->dk_wedges, sc, sc_plink); 341 1.18.2.2 yamt } 342 1.18.2.2 yamt } 343 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_RELEASE, NULL); 344 1.18.2.2 yamt if (error) { 345 1.18.2.2 yamt bufq_free(sc->sc_bufq); 346 1.18.2.2 yamt free(sc, M_DKWEDGE); 347 1.18.2.2 yamt return (error); 348 1.18.2.2 yamt } 349 1.18.2.2 yamt 350 1.18.2.2 yamt /* Fill in our cfdata for the pseudo-device glue. */ 351 1.18.2.2 yamt sc->sc_cfdata.cf_name = dk_cd.cd_name; 352 1.18.2.2 yamt sc->sc_cfdata.cf_atname = dk_ca.ca_name; 353 1.18.2.2 yamt /* sc->sc_cfdata.cf_unit set below */ 354 1.18.2.2 yamt sc->sc_cfdata.cf_fstate = FSTATE_STAR; 355 1.18.2.2 yamt 356 1.18.2.2 yamt /* Insert the larval wedge into the array. */ 357 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_EXCLUSIVE, NULL); 358 1.18.2.2 yamt for (error = 0;;) { 359 1.18.2.2 yamt struct dkwedge_softc **scpp; 360 1.18.2.2 yamt 361 1.18.2.2 yamt /* 362 1.18.2.2 yamt * Check for a duplicate wname while searching for 363 1.18.2.2 yamt * a slot. 364 1.18.2.2 yamt */ 365 1.18.2.2 yamt for (scpp = NULL, unit = 0; unit < ndkwedges; unit++) { 366 1.18.2.2 yamt if (dkwedges[unit] == NULL) { 367 1.18.2.2 yamt if (scpp == NULL) { 368 1.18.2.2 yamt scpp = &dkwedges[unit]; 369 1.18.2.2 yamt sc->sc_cfdata.cf_unit = unit; 370 1.18.2.2 yamt } 371 1.18.2.2 yamt } else { 372 1.18.2.2 yamt /* XXX Unicode. */ 373 1.18.2.2 yamt if (strcmp(dkwedges[unit]->sc_wname, 374 1.18.2.2 yamt sc->sc_wname) == 0) { 375 1.18.2.2 yamt error = EEXIST; 376 1.18.2.2 yamt break; 377 1.18.2.2 yamt } 378 1.18.2.2 yamt } 379 1.18.2.2 yamt } 380 1.18.2.2 yamt if (error) 381 1.18.2.2 yamt break; 382 1.18.2.2 yamt KASSERT(unit == ndkwedges); 383 1.18.2.2 yamt if (scpp == NULL) 384 1.18.2.2 yamt dkwedge_array_expand(); 385 1.18.2.2 yamt else { 386 1.18.2.2 yamt KASSERT(scpp == &dkwedges[sc->sc_cfdata.cf_unit]); 387 1.18.2.2 yamt *scpp = sc; 388 1.18.2.2 yamt break; 389 1.18.2.2 yamt } 390 1.18.2.2 yamt } 391 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_RELEASE, NULL); 392 1.18.2.2 yamt if (error) { 393 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_EXCLUSIVE, NULL); 394 1.18.2.2 yamt pdk->dk_nwedges--; 395 1.18.2.2 yamt LIST_REMOVE(sc, sc_plink); 396 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_RELEASE, NULL); 397 1.18.2.2 yamt 398 1.18.2.2 yamt bufq_free(sc->sc_bufq); 399 1.18.2.2 yamt free(sc, M_DKWEDGE); 400 1.18.2.2 yamt return (error); 401 1.18.2.2 yamt } 402 1.18.2.2 yamt 403 1.18.2.2 yamt /* 404 1.18.2.2 yamt * Now that we know the unit #, attach a pseudo-device for 405 1.18.2.2 yamt * this wedge instance. This will provide us with the 406 1.18.2.2 yamt * "struct device" necessary for glue to other parts of the 407 1.18.2.2 yamt * system. 408 1.18.2.2 yamt * 409 1.18.2.2 yamt * This should never fail, unless we're almost totally out of 410 1.18.2.2 yamt * memory. 411 1.18.2.2 yamt */ 412 1.18.2.2 yamt if ((sc->sc_dev = config_attach_pseudo(&sc->sc_cfdata)) == NULL) { 413 1.18.2.2 yamt aprint_error("%s%u: unable to attach pseudo-device\n", 414 1.18.2.2 yamt sc->sc_cfdata.cf_name, sc->sc_cfdata.cf_unit); 415 1.18.2.2 yamt 416 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_EXCLUSIVE, NULL); 417 1.18.2.2 yamt dkwedges[sc->sc_cfdata.cf_unit] = NULL; 418 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_RELEASE, NULL); 419 1.18.2.2 yamt 420 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_EXCLUSIVE, NULL); 421 1.18.2.2 yamt pdk->dk_nwedges--; 422 1.18.2.2 yamt LIST_REMOVE(sc, sc_plink); 423 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_RELEASE, NULL); 424 1.18.2.2 yamt 425 1.18.2.2 yamt bufq_free(sc->sc_bufq); 426 1.18.2.2 yamt free(sc, M_DKWEDGE); 427 1.18.2.2 yamt return (ENOMEM); 428 1.18.2.2 yamt } 429 1.18.2.2 yamt sc->sc_dk.dk_name = sc->sc_dev->dv_xname; 430 1.18.2.2 yamt 431 1.18.2.2 yamt /* Return the devname to the caller. */ 432 1.18.2.2 yamt strcpy(dkw->dkw_devname, sc->sc_dev->dv_xname); 433 1.18.2.2 yamt 434 1.18.2.2 yamt /* 435 1.18.2.2 yamt * XXX Really ought to make the disk_attach() and the changing 436 1.18.2.2 yamt * of state to RUNNING atomic. 437 1.18.2.2 yamt */ 438 1.18.2.2 yamt 439 1.18.2.2 yamt disk_attach(&sc->sc_dk); 440 1.18.2.2 yamt 441 1.18.2.2 yamt /* Disk wedge is ready for use! */ 442 1.18.2.2 yamt sc->sc_state = DKW_STATE_RUNNING; 443 1.18.2.2 yamt 444 1.18.2.2 yamt /* Announce our arrival. */ 445 1.18.2.2 yamt aprint_normal("%s at %s: %s\n", sc->sc_dev->dv_xname, pdk->dk_name, 446 1.18.2.2 yamt sc->sc_wname); /* XXX Unicode */ 447 1.18.2.2 yamt aprint_normal("%s: %"PRIu64" blocks at %"PRId64", type: %s\n", 448 1.18.2.2 yamt sc->sc_dev->dv_xname, sc->sc_size, sc->sc_offset, sc->sc_ptype); 449 1.18.2.2 yamt 450 1.18.2.2 yamt return (0); 451 1.18.2.2 yamt } 452 1.18.2.2 yamt 453 1.18.2.2 yamt /* 454 1.18.2.2 yamt * dkwedge_del: [exported function] 455 1.18.2.2 yamt * 456 1.18.2.2 yamt * Delete a disk wedge based on the provided information. 457 1.18.2.2 yamt * NOTE: We look up the wedge based on the wedge devname, 458 1.18.2.2 yamt * not wname. 459 1.18.2.2 yamt */ 460 1.18.2.2 yamt int 461 1.18.2.2 yamt dkwedge_del(struct dkwedge_info *dkw) 462 1.18.2.2 yamt { 463 1.18.2.2 yamt struct dkwedge_softc *sc = NULL; 464 1.18.2.2 yamt u_int unit; 465 1.18.2.2 yamt int bmaj, cmaj, s; 466 1.18.2.2 yamt 467 1.18.2.2 yamt /* Find our softc. */ 468 1.18.2.2 yamt dkw->dkw_devname[sizeof(dkw->dkw_devname) - 1] = '\0'; 469 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_EXCLUSIVE, NULL); 470 1.18.2.2 yamt for (unit = 0; unit < ndkwedges; unit++) { 471 1.18.2.2 yamt if ((sc = dkwedges[unit]) != NULL && 472 1.18.2.2 yamt strcmp(sc->sc_dev->dv_xname, dkw->dkw_devname) == 0 && 473 1.18.2.2 yamt strcmp(sc->sc_parent->dk_name, dkw->dkw_parent) == 0) { 474 1.18.2.2 yamt /* Mark the wedge as dying. */ 475 1.18.2.2 yamt sc->sc_state = DKW_STATE_DYING; 476 1.18.2.2 yamt break; 477 1.18.2.2 yamt } 478 1.18.2.2 yamt } 479 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_RELEASE, NULL); 480 1.18.2.2 yamt if (unit == ndkwedges) 481 1.18.2.2 yamt return (ESRCH); 482 1.18.2.2 yamt 483 1.18.2.2 yamt KASSERT(sc != NULL); 484 1.18.2.2 yamt 485 1.18.2.2 yamt /* Locate the wedge major numbers. */ 486 1.18.2.2 yamt bmaj = bdevsw_lookup_major(&dk_bdevsw); 487 1.18.2.2 yamt cmaj = cdevsw_lookup_major(&dk_cdevsw); 488 1.18.2.2 yamt 489 1.18.2.2 yamt /* Kill any pending restart. */ 490 1.18.2.2 yamt callout_stop(&sc->sc_restart_ch); 491 1.18.2.2 yamt 492 1.18.2.2 yamt /* 493 1.18.2.2 yamt * dkstart() will kill any queued buffers now that the 494 1.18.2.2 yamt * state of the wedge is not RUNNING. Once we've done 495 1.18.2.2 yamt * that, wait for any other pending I/O to complete. 496 1.18.2.2 yamt */ 497 1.18.2.2 yamt s = splbio(); 498 1.18.2.2 yamt dkstart(sc); 499 1.18.2.2 yamt dkwedge_wait_drain(sc); 500 1.18.2.2 yamt splx(s); 501 1.18.2.2 yamt 502 1.18.2.2 yamt /* Nuke the vnodes for any open instances. */ 503 1.18.2.2 yamt vdevgone(bmaj, unit, unit, VBLK); 504 1.18.2.2 yamt vdevgone(cmaj, unit, unit, VCHR); 505 1.18.2.2 yamt 506 1.18.2.2 yamt /* Clean up the parent. */ 507 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_EXCLUSIVE, NULL); 508 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_EXCLUSIVE, NULL); 509 1.18.2.2 yamt if (sc->sc_dk.dk_openmask) { 510 1.18.2.2 yamt if (sc->sc_parent->dk_rawopens-- == 1) { 511 1.18.2.2 yamt KASSERT(sc->sc_parent->dk_rawvp != NULL); 512 1.18.2.2 yamt (void) vn_close(sc->sc_parent->dk_rawvp, FREAD | FWRITE, 513 1.18.2.2 yamt NOCRED, curlwp); 514 1.18.2.2 yamt sc->sc_parent->dk_rawvp = NULL; 515 1.18.2.2 yamt } 516 1.18.2.2 yamt sc->sc_dk.dk_openmask = 0; 517 1.18.2.2 yamt } 518 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_RELEASE, NULL); 519 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_RELEASE, NULL); 520 1.18.2.2 yamt 521 1.18.2.2 yamt /* Announce our departure. */ 522 1.18.2.2 yamt aprint_normal("%s at %s (%s) deleted\n", sc->sc_dev->dv_xname, 523 1.18.2.2 yamt sc->sc_parent->dk_name, 524 1.18.2.2 yamt sc->sc_wname); /* XXX Unicode */ 525 1.18.2.2 yamt 526 1.18.2.2 yamt /* Delete our pseudo-device. */ 527 1.18.2.2 yamt (void) config_detach(sc->sc_dev, DETACH_FORCE | DETACH_QUIET); 528 1.18.2.2 yamt 529 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_openlock, LK_EXCLUSIVE, NULL); 530 1.18.2.2 yamt sc->sc_parent->dk_nwedges--; 531 1.18.2.2 yamt LIST_REMOVE(sc, sc_plink); 532 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_openlock, LK_RELEASE, NULL); 533 1.18.2.2 yamt 534 1.18.2.2 yamt /* Delete our buffer queue. */ 535 1.18.2.2 yamt bufq_free(sc->sc_bufq); 536 1.18.2.2 yamt 537 1.18.2.2 yamt /* Detach from the disk list. */ 538 1.18.2.2 yamt disk_detach(&sc->sc_dk); 539 1.18.2.2 yamt 540 1.18.2.2 yamt /* Poof. */ 541 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_EXCLUSIVE, NULL); 542 1.18.2.2 yamt dkwedges[unit] = NULL; 543 1.18.2.2 yamt sc->sc_state = DKW_STATE_DEAD; 544 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_RELEASE, NULL); 545 1.18.2.2 yamt 546 1.18.2.2 yamt free(sc, M_DKWEDGE); 547 1.18.2.2 yamt 548 1.18.2.2 yamt return (0); 549 1.18.2.2 yamt } 550 1.18.2.2 yamt 551 1.18.2.2 yamt /* 552 1.18.2.2 yamt * dkwedge_delall: [exported function] 553 1.18.2.2 yamt * 554 1.18.2.2 yamt * Delete all of the wedges on the specified disk. Used when 555 1.18.2.2 yamt * a disk is being detached. 556 1.18.2.2 yamt */ 557 1.18.2.2 yamt void 558 1.18.2.2 yamt dkwedge_delall(struct disk *pdk) 559 1.18.2.2 yamt { 560 1.18.2.2 yamt struct dkwedge_info dkw; 561 1.18.2.2 yamt struct dkwedge_softc *sc; 562 1.18.2.2 yamt 563 1.18.2.2 yamt for (;;) { 564 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_EXCLUSIVE, NULL); 565 1.18.2.2 yamt if ((sc = LIST_FIRST(&pdk->dk_wedges)) == NULL) { 566 1.18.2.2 yamt KASSERT(pdk->dk_nwedges == 0); 567 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_RELEASE, NULL); 568 1.18.2.2 yamt return; 569 1.18.2.2 yamt } 570 1.18.2.2 yamt strcpy(dkw.dkw_parent, pdk->dk_name); 571 1.18.2.2 yamt strcpy(dkw.dkw_devname, sc->sc_dev->dv_xname); 572 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_RELEASE, NULL); 573 1.18.2.2 yamt (void) dkwedge_del(&dkw); 574 1.18.2.2 yamt } 575 1.18.2.2 yamt } 576 1.18.2.2 yamt 577 1.18.2.2 yamt /* 578 1.18.2.2 yamt * dkwedge_list: [exported function] 579 1.18.2.2 yamt * 580 1.18.2.2 yamt * List all of the wedges on a particular disk. 581 1.18.2.2 yamt * If p == NULL, the buffer is in kernel space. Otherwise, it is 582 1.18.2.2 yamt * in user space of the specified process. 583 1.18.2.2 yamt */ 584 1.18.2.2 yamt int 585 1.18.2.2 yamt dkwedge_list(struct disk *pdk, struct dkwedge_list *dkwl, struct lwp *l) 586 1.18.2.2 yamt { 587 1.18.2.2 yamt struct uio uio; 588 1.18.2.2 yamt struct iovec iov; 589 1.18.2.2 yamt struct dkwedge_softc *sc; 590 1.18.2.2 yamt struct dkwedge_info dkw; 591 1.18.2.2 yamt struct vmspace *vm; 592 1.18.2.2 yamt int error = 0; 593 1.18.2.2 yamt 594 1.18.2.2 yamt iov.iov_base = dkwl->dkwl_buf; 595 1.18.2.2 yamt iov.iov_len = dkwl->dkwl_bufsize; 596 1.18.2.2 yamt 597 1.18.2.2 yamt uio.uio_iov = &iov; 598 1.18.2.2 yamt uio.uio_iovcnt = 1; 599 1.18.2.2 yamt uio.uio_offset = 0; 600 1.18.2.2 yamt uio.uio_resid = dkwl->dkwl_bufsize; 601 1.18.2.2 yamt uio.uio_rw = UIO_READ; 602 1.18.2.2 yamt if (l == NULL) { 603 1.18.2.2 yamt UIO_SETUP_SYSSPACE(&uio); 604 1.18.2.2 yamt } else { 605 1.18.2.2 yamt error = proc_vmspace_getref(l->l_proc, &vm); 606 1.18.2.2 yamt if (error) { 607 1.18.2.2 yamt return error; 608 1.18.2.2 yamt } 609 1.18.2.2 yamt uio.uio_vmspace = vm; 610 1.18.2.2 yamt } 611 1.18.2.2 yamt 612 1.18.2.2 yamt dkwl->dkwl_ncopied = 0; 613 1.18.2.2 yamt 614 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_EXCLUSIVE, NULL); 615 1.18.2.2 yamt LIST_FOREACH(sc, &pdk->dk_wedges, sc_plink) { 616 1.18.2.2 yamt if (uio.uio_resid < sizeof(dkw)) 617 1.18.2.2 yamt break; 618 1.18.2.2 yamt 619 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) 620 1.18.2.2 yamt continue; 621 1.18.2.2 yamt 622 1.18.2.2 yamt strcpy(dkw.dkw_devname, sc->sc_dev->dv_xname); 623 1.18.2.2 yamt memcpy(dkw.dkw_wname, sc->sc_wname, sizeof(dkw.dkw_wname)); 624 1.18.2.2 yamt dkw.dkw_wname[sizeof(dkw.dkw_wname) - 1] = '\0'; 625 1.18.2.2 yamt strcpy(dkw.dkw_parent, sc->sc_parent->dk_name); 626 1.18.2.2 yamt dkw.dkw_offset = sc->sc_offset; 627 1.18.2.2 yamt dkw.dkw_size = sc->sc_size; 628 1.18.2.2 yamt strcpy(dkw.dkw_ptype, sc->sc_ptype); 629 1.18.2.2 yamt 630 1.18.2.2 yamt error = uiomove(&dkw, sizeof(dkw), &uio); 631 1.18.2.2 yamt if (error) 632 1.18.2.2 yamt break; 633 1.18.2.2 yamt dkwl->dkwl_ncopied++; 634 1.18.2.2 yamt } 635 1.18.2.2 yamt dkwl->dkwl_nwedges = pdk->dk_nwedges; 636 1.18.2.2 yamt (void) lockmgr(&pdk->dk_openlock, LK_RELEASE, NULL); 637 1.18.2.2 yamt 638 1.18.2.2 yamt if (l != NULL) { 639 1.18.2.2 yamt uvmspace_free(vm); 640 1.18.2.2 yamt } 641 1.18.2.2 yamt 642 1.18.2.2 yamt return (error); 643 1.18.2.2 yamt } 644 1.18.2.2 yamt 645 1.18.2.2 yamt /* 646 1.18.2.2 yamt * dkwedge_set_bootwedge 647 1.18.2.2 yamt * 648 1.18.2.2 yamt * Set the booted_wedge global based on the specified parent name 649 1.18.2.2 yamt * and offset/length. 650 1.18.2.2 yamt */ 651 1.18.2.2 yamt void 652 1.18.2.2 yamt dkwedge_set_bootwedge(struct device *parent, daddr_t startblk, uint64_t nblks) 653 1.18.2.2 yamt { 654 1.18.2.2 yamt struct dkwedge_softc *sc; 655 1.18.2.2 yamt int i; 656 1.18.2.2 yamt 657 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_EXCLUSIVE, NULL); 658 1.18.2.2 yamt for (i = 0; i < ndkwedges; i++) { 659 1.18.2.2 yamt if ((sc = dkwedges[i]) == NULL) 660 1.18.2.2 yamt continue; 661 1.18.2.2 yamt if (strcmp(sc->sc_parent->dk_name, parent->dv_xname) == 0 && 662 1.18.2.2 yamt sc->sc_offset == startblk && 663 1.18.2.2 yamt sc->sc_size == nblks) { 664 1.18.2.2 yamt if (booted_wedge) { 665 1.18.2.2 yamt printf("WARNING: double match for boot wedge " 666 1.18.2.2 yamt "(%s, %s)\n", 667 1.18.2.2 yamt booted_wedge->dv_xname, 668 1.18.2.2 yamt sc->sc_dev->dv_xname); 669 1.18.2.2 yamt continue; 670 1.18.2.2 yamt } 671 1.18.2.2 yamt booted_device = parent; 672 1.18.2.2 yamt booted_wedge = sc->sc_dev; 673 1.18.2.2 yamt booted_partition = 0; 674 1.18.2.2 yamt } 675 1.18.2.2 yamt } 676 1.18.2.2 yamt /* 677 1.18.2.2 yamt * XXX What if we don't find one? Should we create a special 678 1.18.2.2 yamt * XXX root wedge? 679 1.18.2.2 yamt */ 680 1.18.2.2 yamt (void) lockmgr(&dkwedges_lock, LK_RELEASE, NULL); 681 1.18.2.2 yamt } 682 1.18.2.2 yamt 683 1.18.2.2 yamt /* 684 1.18.2.2 yamt * We need a dummy object to stuff into the dkwedge discovery method link 685 1.18.2.2 yamt * set to ensure that there is always at least one object in the set. 686 1.18.2.2 yamt */ 687 1.18.2.2 yamt static struct dkwedge_discovery_method dummy_discovery_method; 688 1.18.2.2 yamt __link_set_add_bss(dkwedge_methods, dummy_discovery_method); 689 1.18.2.2 yamt 690 1.18.2.2 yamt /* 691 1.18.2.2 yamt * dkwedge_discover_init: 692 1.18.2.2 yamt * 693 1.18.2.2 yamt * Initialize the disk wedge discovery method list. 694 1.18.2.2 yamt */ 695 1.18.2.2 yamt static void 696 1.18.2.2 yamt dkwedge_discover_init(void) 697 1.18.2.2 yamt { 698 1.18.2.2 yamt __link_set_decl(dkwedge_methods, struct dkwedge_discovery_method); 699 1.18.2.2 yamt struct dkwedge_discovery_method * const *ddmp; 700 1.18.2.2 yamt struct dkwedge_discovery_method *lddm, *ddm; 701 1.18.2.2 yamt 702 1.18.2.2 yamt (void) lockmgr(&dkwedge_discovery_methods_lock, LK_EXCLUSIVE, NULL); 703 1.18.2.2 yamt 704 1.18.2.2 yamt if (dkwedge_discovery_methods_initialized) { 705 1.18.2.2 yamt (void) lockmgr(&dkwedge_discovery_methods_lock, LK_RELEASE, 706 1.18.2.2 yamt NULL); 707 1.18.2.2 yamt return; 708 1.18.2.2 yamt } 709 1.18.2.2 yamt 710 1.18.2.2 yamt LIST_INIT(&dkwedge_discovery_methods); 711 1.18.2.2 yamt 712 1.18.2.2 yamt __link_set_foreach(ddmp, dkwedge_methods) { 713 1.18.2.2 yamt ddm = *ddmp; 714 1.18.2.2 yamt if (ddm == &dummy_discovery_method) 715 1.18.2.2 yamt continue; 716 1.18.2.2 yamt if (LIST_EMPTY(&dkwedge_discovery_methods)) { 717 1.18.2.2 yamt LIST_INSERT_HEAD(&dkwedge_discovery_methods, 718 1.18.2.2 yamt ddm, ddm_list); 719 1.18.2.2 yamt continue; 720 1.18.2.2 yamt } 721 1.18.2.2 yamt LIST_FOREACH(lddm, &dkwedge_discovery_methods, ddm_list) { 722 1.18.2.2 yamt if (ddm->ddm_priority == lddm->ddm_priority) { 723 1.18.2.2 yamt aprint_error("dk-method-%s: method \"%s\" " 724 1.18.2.2 yamt "already exists at priority %d\n", 725 1.18.2.2 yamt ddm->ddm_name, lddm->ddm_name, 726 1.18.2.2 yamt lddm->ddm_priority); 727 1.18.2.2 yamt /* Not inserted. */ 728 1.18.2.2 yamt break; 729 1.18.2.2 yamt } 730 1.18.2.2 yamt if (ddm->ddm_priority < lddm->ddm_priority) { 731 1.18.2.2 yamt /* Higher priority; insert before. */ 732 1.18.2.2 yamt LIST_INSERT_BEFORE(lddm, ddm, ddm_list); 733 1.18.2.2 yamt break; 734 1.18.2.2 yamt } 735 1.18.2.2 yamt if (LIST_NEXT(lddm, ddm_list) == NULL) { 736 1.18.2.2 yamt /* Last one; insert after. */ 737 1.18.2.2 yamt KASSERT(lddm->ddm_priority < ddm->ddm_priority); 738 1.18.2.2 yamt LIST_INSERT_AFTER(lddm, ddm, ddm_list); 739 1.18.2.2 yamt break; 740 1.18.2.2 yamt } 741 1.18.2.2 yamt } 742 1.18.2.2 yamt } 743 1.18.2.2 yamt 744 1.18.2.2 yamt dkwedge_discovery_methods_initialized = 1; 745 1.18.2.2 yamt 746 1.18.2.2 yamt (void) lockmgr(&dkwedge_discovery_methods_lock, LK_RELEASE, NULL); 747 1.18.2.2 yamt } 748 1.18.2.2 yamt 749 1.18.2.2 yamt #ifdef DKWEDGE_AUTODISCOVER 750 1.18.2.2 yamt int dkwedge_autodiscover = 1; 751 1.18.2.2 yamt #else 752 1.18.2.2 yamt int dkwedge_autodiscover = 0; 753 1.18.2.2 yamt #endif 754 1.18.2.2 yamt 755 1.18.2.2 yamt /* 756 1.18.2.2 yamt * dkwedge_discover: [exported function] 757 1.18.2.2 yamt * 758 1.18.2.2 yamt * Discover the wedges on a newly attached disk. 759 1.18.2.2 yamt */ 760 1.18.2.2 yamt void 761 1.18.2.2 yamt dkwedge_discover(struct disk *pdk) 762 1.18.2.2 yamt { 763 1.18.2.2 yamt struct dkwedge_discovery_method *ddm; 764 1.18.2.2 yamt struct vnode *vp; 765 1.18.2.2 yamt int error; 766 1.18.2.2 yamt dev_t pdev; 767 1.18.2.2 yamt 768 1.18.2.2 yamt /* 769 1.18.2.2 yamt * Require people playing with wedges to enable this explicitly. 770 1.18.2.2 yamt */ 771 1.18.2.2 yamt if (dkwedge_autodiscover == 0) 772 1.18.2.2 yamt return; 773 1.18.2.2 yamt 774 1.18.2.2 yamt if (dkwedge_discovery_methods_initialized == 0) 775 1.18.2.2 yamt dkwedge_discover_init(); 776 1.18.2.2 yamt 777 1.18.2.2 yamt (void) lockmgr(&dkwedge_discovery_methods_lock, LK_SHARED, NULL); 778 1.18.2.2 yamt 779 1.18.2.2 yamt error = dkwedge_compute_pdev(pdk->dk_name, &pdev); 780 1.18.2.2 yamt if (error) { 781 1.18.2.2 yamt aprint_error("%s: unable to compute pdev, error = %d\n", 782 1.18.2.2 yamt pdk->dk_name, error); 783 1.18.2.2 yamt goto out; 784 1.18.2.2 yamt } 785 1.18.2.2 yamt 786 1.18.2.2 yamt error = bdevvp(pdev, &vp); 787 1.18.2.2 yamt if (error) { 788 1.18.2.2 yamt aprint_error("%s: unable to find vnode for pdev, error = %d\n", 789 1.18.2.2 yamt pdk->dk_name, error); 790 1.18.2.2 yamt goto out; 791 1.18.2.2 yamt } 792 1.18.2.2 yamt 793 1.18.2.2 yamt error = vn_lock(vp, LK_EXCLUSIVE | LK_RETRY); 794 1.18.2.2 yamt if (error) { 795 1.18.2.2 yamt aprint_error("%s: unable to lock vnode for pdev, error = %d\n", 796 1.18.2.2 yamt pdk->dk_name, error); 797 1.18.2.2 yamt vrele(vp); 798 1.18.2.2 yamt goto out; 799 1.18.2.2 yamt } 800 1.18.2.2 yamt 801 1.18.2.2 yamt error = VOP_OPEN(vp, FREAD | FWRITE, NOCRED, 0); 802 1.18.2.2 yamt if (error) { 803 1.18.2.2 yamt aprint_error("%s: unable to open device, error = %d\n", 804 1.18.2.2 yamt pdk->dk_name, error); 805 1.18.2.2 yamt vput(vp); 806 1.18.2.2 yamt goto out; 807 1.18.2.2 yamt } 808 1.18.2.2 yamt /* VOP_OPEN() doesn't do this for us. */ 809 1.18.2.2 yamt vp->v_writecount++; 810 1.18.2.2 yamt VOP_UNLOCK(vp, 0); 811 1.18.2.2 yamt 812 1.18.2.2 yamt /* 813 1.18.2.2 yamt * For each supported partition map type, look to see if 814 1.18.2.2 yamt * this map type exists. If so, parse it and add the 815 1.18.2.2 yamt * corresponding wedges. 816 1.18.2.2 yamt */ 817 1.18.2.2 yamt LIST_FOREACH(ddm, &dkwedge_discovery_methods, ddm_list) { 818 1.18.2.2 yamt error = (*ddm->ddm_discover)(pdk, vp); 819 1.18.2.2 yamt if (error == 0) { 820 1.18.2.2 yamt /* Successfully created wedges; we're done. */ 821 1.18.2.2 yamt break; 822 1.18.2.2 yamt } 823 1.18.2.2 yamt } 824 1.18.2.2 yamt 825 1.18.2.2 yamt error = vn_close(vp, FREAD | FWRITE, NOCRED, curlwp); 826 1.18.2.2 yamt if (error) { 827 1.18.2.2 yamt aprint_error("%s: unable to close device, error = %d\n", 828 1.18.2.2 yamt pdk->dk_name, error); 829 1.18.2.2 yamt /* We'll just assume the vnode has been cleaned up. */ 830 1.18.2.2 yamt } 831 1.18.2.2 yamt out: 832 1.18.2.2 yamt (void) lockmgr(&dkwedge_discovery_methods_lock, LK_RELEASE, NULL); 833 1.18.2.2 yamt } 834 1.18.2.2 yamt 835 1.18.2.2 yamt /* 836 1.18.2.2 yamt * dkwedge_read: 837 1.18.2.2 yamt * 838 1.18.2.2 yamt * Read the some data from the specified disk, used for 839 1.18.2.2 yamt * partition discovery. 840 1.18.2.2 yamt */ 841 1.18.2.2 yamt int 842 1.18.2.3 yamt dkwedge_read(struct disk *pdk, struct vnode *vp, daddr_t blkno, 843 1.18.2.2 yamt void *tbuf, size_t len) 844 1.18.2.2 yamt { 845 1.18.2.2 yamt struct buf b; 846 1.18.2.2 yamt 847 1.18.2.2 yamt BUF_INIT(&b); 848 1.18.2.2 yamt 849 1.18.2.2 yamt b.b_vp = vp; 850 1.18.2.2 yamt b.b_dev = vp->v_rdev; 851 1.18.2.2 yamt b.b_blkno = blkno; 852 1.18.2.2 yamt b.b_bcount = b.b_resid = len; 853 1.18.2.2 yamt b.b_flags = B_READ; 854 1.18.2.2 yamt b.b_proc = curproc; 855 1.18.2.2 yamt b.b_data = tbuf; 856 1.18.2.2 yamt 857 1.18.2.2 yamt VOP_STRATEGY(vp, &b); 858 1.18.2.2 yamt return (biowait(&b)); 859 1.18.2.2 yamt } 860 1.18.2.2 yamt 861 1.18.2.2 yamt /* 862 1.18.2.2 yamt * dkwedge_lookup: 863 1.18.2.2 yamt * 864 1.18.2.2 yamt * Look up a dkwedge_softc based on the provided dev_t. 865 1.18.2.2 yamt */ 866 1.18.2.2 yamt static struct dkwedge_softc * 867 1.18.2.2 yamt dkwedge_lookup(dev_t dev) 868 1.18.2.2 yamt { 869 1.18.2.2 yamt int unit = minor(dev); 870 1.18.2.2 yamt 871 1.18.2.2 yamt if (unit >= ndkwedges) 872 1.18.2.2 yamt return (NULL); 873 1.18.2.2 yamt 874 1.18.2.2 yamt KASSERT(dkwedges != NULL); 875 1.18.2.2 yamt 876 1.18.2.2 yamt return (dkwedges[unit]); 877 1.18.2.2 yamt } 878 1.18.2.2 yamt 879 1.18.2.2 yamt /* 880 1.18.2.2 yamt * dkopen: [devsw entry point] 881 1.18.2.2 yamt * 882 1.18.2.2 yamt * Open a wedge. 883 1.18.2.2 yamt */ 884 1.18.2.2 yamt static int 885 1.18.2.3 yamt dkopen(dev_t dev, int flags, int fmt, struct lwp *l) 886 1.18.2.2 yamt { 887 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(dev); 888 1.18.2.2 yamt struct vnode *vp; 889 1.18.2.2 yamt int error = 0; 890 1.18.2.2 yamt 891 1.18.2.2 yamt if (sc == NULL) 892 1.18.2.2 yamt return (ENODEV); 893 1.18.2.2 yamt 894 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) 895 1.18.2.2 yamt return (ENXIO); 896 1.18.2.2 yamt 897 1.18.2.2 yamt /* 898 1.18.2.2 yamt * We go through a complicated little dance to only open the parent 899 1.18.2.2 yamt * vnode once per wedge, no matter how many times the wedge is 900 1.18.2.2 yamt * opened. The reason? We see one dkopen() per open call, but 901 1.18.2.2 yamt * only dkclose() on the last close. 902 1.18.2.2 yamt */ 903 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_EXCLUSIVE, NULL); 904 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_EXCLUSIVE, NULL); 905 1.18.2.2 yamt if (sc->sc_dk.dk_openmask == 0) { 906 1.18.2.2 yamt if (sc->sc_parent->dk_rawopens++ == 0) { 907 1.18.2.2 yamt KASSERT(sc->sc_parent->dk_rawvp == NULL); 908 1.18.2.2 yamt error = bdevvp(sc->sc_pdev, &vp); 909 1.18.2.2 yamt if (error) 910 1.18.2.2 yamt goto popen_fail; 911 1.18.2.2 yamt error = vn_lock(vp, LK_EXCLUSIVE | LK_RETRY); 912 1.18.2.2 yamt if (error) { 913 1.18.2.2 yamt vrele(vp); 914 1.18.2.2 yamt goto popen_fail; 915 1.18.2.2 yamt } 916 1.18.2.2 yamt error = VOP_OPEN(vp, FREAD | FWRITE, NOCRED, 0); 917 1.18.2.2 yamt if (error) { 918 1.18.2.2 yamt vput(vp); 919 1.18.2.2 yamt goto popen_fail; 920 1.18.2.2 yamt } 921 1.18.2.2 yamt /* VOP_OPEN() doesn't do this for us. */ 922 1.18.2.2 yamt vp->v_writecount++; 923 1.18.2.2 yamt VOP_UNLOCK(vp, 0); 924 1.18.2.2 yamt sc->sc_parent->dk_rawvp = vp; 925 1.18.2.2 yamt } 926 1.18.2.2 yamt } 927 1.18.2.2 yamt if (fmt == S_IFCHR) 928 1.18.2.2 yamt sc->sc_dk.dk_copenmask |= 1; 929 1.18.2.2 yamt else 930 1.18.2.2 yamt sc->sc_dk.dk_bopenmask |= 1; 931 1.18.2.2 yamt sc->sc_dk.dk_openmask = 932 1.18.2.2 yamt sc->sc_dk.dk_copenmask | sc->sc_dk.dk_bopenmask; 933 1.18.2.2 yamt 934 1.18.2.2 yamt popen_fail: 935 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_RELEASE, NULL); 936 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_RELEASE, NULL); 937 1.18.2.2 yamt return (error); 938 1.18.2.2 yamt } 939 1.18.2.2 yamt 940 1.18.2.2 yamt /* 941 1.18.2.2 yamt * dkclose: [devsw entry point] 942 1.18.2.2 yamt * 943 1.18.2.2 yamt * Close a wedge. 944 1.18.2.2 yamt */ 945 1.18.2.2 yamt static int 946 1.18.2.3 yamt dkclose(dev_t dev, int flags, int fmt, struct lwp *l) 947 1.18.2.2 yamt { 948 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(dev); 949 1.18.2.2 yamt int error = 0; 950 1.18.2.2 yamt 951 1.18.2.2 yamt KASSERT(sc->sc_dk.dk_openmask != 0); 952 1.18.2.2 yamt 953 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_EXCLUSIVE, NULL); 954 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_EXCLUSIVE, NULL); 955 1.18.2.2 yamt 956 1.18.2.2 yamt if (fmt == S_IFCHR) 957 1.18.2.2 yamt sc->sc_dk.dk_copenmask &= ~1; 958 1.18.2.2 yamt else 959 1.18.2.2 yamt sc->sc_dk.dk_bopenmask &= ~1; 960 1.18.2.2 yamt sc->sc_dk.dk_openmask = 961 1.18.2.2 yamt sc->sc_dk.dk_copenmask | sc->sc_dk.dk_bopenmask; 962 1.18.2.2 yamt 963 1.18.2.2 yamt if (sc->sc_dk.dk_openmask == 0) { 964 1.18.2.2 yamt if (sc->sc_parent->dk_rawopens-- == 1) { 965 1.18.2.2 yamt KASSERT(sc->sc_parent->dk_rawvp != NULL); 966 1.18.2.2 yamt error = vn_close(sc->sc_parent->dk_rawvp, 967 1.18.2.2 yamt FREAD | FWRITE, NOCRED, l); 968 1.18.2.2 yamt sc->sc_parent->dk_rawvp = NULL; 969 1.18.2.2 yamt } 970 1.18.2.2 yamt } 971 1.18.2.2 yamt 972 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_RELEASE, NULL); 973 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_RELEASE, NULL); 974 1.18.2.2 yamt 975 1.18.2.2 yamt return (error); 976 1.18.2.2 yamt } 977 1.18.2.2 yamt 978 1.18.2.2 yamt /* 979 1.18.2.2 yamt * dkstragegy: [devsw entry point] 980 1.18.2.2 yamt * 981 1.18.2.2 yamt * Perform I/O based on the wedge I/O strategy. 982 1.18.2.2 yamt */ 983 1.18.2.2 yamt static void 984 1.18.2.2 yamt dkstrategy(struct buf *bp) 985 1.18.2.2 yamt { 986 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(bp->b_dev); 987 1.18.2.2 yamt int s; 988 1.18.2.2 yamt 989 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) { 990 1.18.2.2 yamt bp->b_error = ENXIO; 991 1.18.2.2 yamt bp->b_flags |= B_ERROR; 992 1.18.2.2 yamt goto done; 993 1.18.2.2 yamt } 994 1.18.2.2 yamt 995 1.18.2.2 yamt /* If it's an empty transfer, wake up the top half now. */ 996 1.18.2.2 yamt if (bp->b_bcount == 0) 997 1.18.2.2 yamt goto done; 998 1.18.2.2 yamt 999 1.18.2.2 yamt /* Make sure it's in-range. */ 1000 1.18.2.2 yamt if (bounds_check_with_mediasize(bp, DEV_BSIZE, sc->sc_size) <= 0) 1001 1.18.2.2 yamt goto done; 1002 1.18.2.2 yamt 1003 1.18.2.2 yamt /* Translate it to the parent's raw LBA. */ 1004 1.18.2.2 yamt bp->b_rawblkno = bp->b_blkno + sc->sc_offset; 1005 1.18.2.2 yamt 1006 1.18.2.2 yamt /* Place it in the queue and start I/O on the unit. */ 1007 1.18.2.2 yamt s = splbio(); 1008 1.18.2.2 yamt sc->sc_iopend++; 1009 1.18.2.2 yamt BUFQ_PUT(sc->sc_bufq, bp); 1010 1.18.2.2 yamt dkstart(sc); 1011 1.18.2.2 yamt splx(s); 1012 1.18.2.2 yamt return; 1013 1.18.2.2 yamt 1014 1.18.2.2 yamt done: 1015 1.18.2.2 yamt bp->b_resid = bp->b_bcount; 1016 1.18.2.2 yamt biodone(bp); 1017 1.18.2.2 yamt } 1018 1.18.2.2 yamt 1019 1.18.2.2 yamt /* 1020 1.18.2.2 yamt * dkstart: 1021 1.18.2.2 yamt * 1022 1.18.2.2 yamt * Start I/O that has been enqueued on the wedge. 1023 1.18.2.2 yamt * NOTE: Must be called at splbio()! 1024 1.18.2.2 yamt */ 1025 1.18.2.2 yamt static void 1026 1.18.2.2 yamt dkstart(struct dkwedge_softc *sc) 1027 1.18.2.2 yamt { 1028 1.18.2.2 yamt struct buf *bp, *nbp; 1029 1.18.2.2 yamt 1030 1.18.2.2 yamt /* Do as much work as has been enqueued. */ 1031 1.18.2.2 yamt while ((bp = BUFQ_PEEK(sc->sc_bufq)) != NULL) { 1032 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) { 1033 1.18.2.2 yamt (void) BUFQ_GET(sc->sc_bufq); 1034 1.18.2.2 yamt if (sc->sc_iopend-- == 1 && 1035 1.18.2.2 yamt (sc->sc_flags & DK_F_WAIT_DRAIN) != 0) { 1036 1.18.2.2 yamt sc->sc_flags &= ~DK_F_WAIT_DRAIN; 1037 1.18.2.2 yamt wakeup(&sc->sc_iopend); 1038 1.18.2.2 yamt } 1039 1.18.2.2 yamt bp->b_error = ENXIO; 1040 1.18.2.2 yamt bp->b_flags |= B_ERROR; 1041 1.18.2.2 yamt bp->b_resid = bp->b_bcount; 1042 1.18.2.2 yamt biodone(bp); 1043 1.18.2.2 yamt } 1044 1.18.2.2 yamt 1045 1.18.2.2 yamt /* Instrumentation. */ 1046 1.18.2.2 yamt disk_busy(&sc->sc_dk); 1047 1.18.2.2 yamt 1048 1.18.2.2 yamt nbp = getiobuf_nowait(); 1049 1.18.2.2 yamt if (nbp == NULL) { 1050 1.18.2.2 yamt /* 1051 1.18.2.2 yamt * No resources to run this request; leave the 1052 1.18.2.2 yamt * buffer queued up, and schedule a timer to 1053 1.18.2.2 yamt * restart the queue in 1/2 a second. 1054 1.18.2.2 yamt */ 1055 1.18.2.2 yamt disk_unbusy(&sc->sc_dk, 0, bp->b_flags & B_READ); 1056 1.18.2.2 yamt callout_schedule(&sc->sc_restart_ch, hz / 2); 1057 1.18.2.2 yamt return; 1058 1.18.2.2 yamt } 1059 1.18.2.2 yamt 1060 1.18.2.2 yamt (void) BUFQ_GET(sc->sc_bufq); 1061 1.18.2.2 yamt 1062 1.18.2.2 yamt BUF_INIT(nbp); 1063 1.18.2.2 yamt nbp->b_data = bp->b_data; 1064 1.18.2.2 yamt nbp->b_flags = bp->b_flags | B_CALL; 1065 1.18.2.2 yamt nbp->b_iodone = dkiodone; 1066 1.18.2.2 yamt nbp->b_proc = bp->b_proc; 1067 1.18.2.2 yamt nbp->b_blkno = bp->b_rawblkno; 1068 1.18.2.2 yamt nbp->b_dev = sc->sc_parent->dk_rawvp->v_rdev; 1069 1.18.2.2 yamt nbp->b_vp = sc->sc_parent->dk_rawvp; 1070 1.18.2.2 yamt nbp->b_bcount = bp->b_bcount; 1071 1.18.2.2 yamt nbp->b_private = bp; 1072 1.18.2.2 yamt BIO_COPYPRIO(nbp, bp); 1073 1.18.2.2 yamt 1074 1.18.2.2 yamt if ((nbp->b_flags & B_READ) == 0) 1075 1.18.2.2 yamt V_INCR_NUMOUTPUT(nbp->b_vp); 1076 1.18.2.2 yamt VOP_STRATEGY(nbp->b_vp, nbp); 1077 1.18.2.2 yamt } 1078 1.18.2.2 yamt } 1079 1.18.2.2 yamt 1080 1.18.2.2 yamt /* 1081 1.18.2.2 yamt * dkiodone: 1082 1.18.2.2 yamt * 1083 1.18.2.2 yamt * I/O to a wedge has completed; alert the top half. 1084 1.18.2.2 yamt * NOTE: Must be called at splbio()! 1085 1.18.2.2 yamt */ 1086 1.18.2.2 yamt static void 1087 1.18.2.2 yamt dkiodone(struct buf *bp) 1088 1.18.2.2 yamt { 1089 1.18.2.2 yamt struct buf *obp = bp->b_private; 1090 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(obp->b_dev); 1091 1.18.2.2 yamt 1092 1.18.2.2 yamt if (bp->b_flags & B_ERROR) { 1093 1.18.2.2 yamt obp->b_flags |= B_ERROR; 1094 1.18.2.2 yamt obp->b_error = bp->b_error; 1095 1.18.2.2 yamt } 1096 1.18.2.2 yamt obp->b_resid = bp->b_resid; 1097 1.18.2.2 yamt putiobuf(bp); 1098 1.18.2.2 yamt 1099 1.18.2.2 yamt if (sc->sc_iopend-- == 1 && (sc->sc_flags & DK_F_WAIT_DRAIN) != 0) { 1100 1.18.2.2 yamt sc->sc_flags &= ~DK_F_WAIT_DRAIN; 1101 1.18.2.2 yamt wakeup(&sc->sc_iopend); 1102 1.18.2.2 yamt } 1103 1.18.2.2 yamt 1104 1.18.2.2 yamt disk_unbusy(&sc->sc_dk, obp->b_bcount - obp->b_resid, 1105 1.18.2.2 yamt obp->b_flags & B_READ); 1106 1.18.2.2 yamt 1107 1.18.2.2 yamt biodone(obp); 1108 1.18.2.2 yamt 1109 1.18.2.2 yamt /* Kick the queue in case there is more work we can do. */ 1110 1.18.2.2 yamt dkstart(sc); 1111 1.18.2.2 yamt } 1112 1.18.2.2 yamt 1113 1.18.2.2 yamt /* 1114 1.18.2.2 yamt * dkrestart: 1115 1.18.2.2 yamt * 1116 1.18.2.2 yamt * Restart the work queue after it was stalled due to 1117 1.18.2.2 yamt * a resource shortage. Invoked via a callout. 1118 1.18.2.2 yamt */ 1119 1.18.2.2 yamt static void 1120 1.18.2.2 yamt dkrestart(void *v) 1121 1.18.2.2 yamt { 1122 1.18.2.2 yamt struct dkwedge_softc *sc = v; 1123 1.18.2.2 yamt int s; 1124 1.18.2.2 yamt 1125 1.18.2.2 yamt s = splbio(); 1126 1.18.2.2 yamt dkstart(sc); 1127 1.18.2.2 yamt splx(s); 1128 1.18.2.2 yamt } 1129 1.18.2.2 yamt 1130 1.18.2.2 yamt /* 1131 1.18.2.2 yamt * dkread: [devsw entry point] 1132 1.18.2.2 yamt * 1133 1.18.2.2 yamt * Read from a wedge. 1134 1.18.2.2 yamt */ 1135 1.18.2.2 yamt static int 1136 1.18.2.3 yamt dkread(dev_t dev, struct uio *uio, int flags) 1137 1.18.2.2 yamt { 1138 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(dev); 1139 1.18.2.2 yamt 1140 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) 1141 1.18.2.2 yamt return (ENXIO); 1142 1.18.2.2 yamt 1143 1.18.2.2 yamt return (physio(dkstrategy, NULL, dev, B_READ, 1144 1.18.2.2 yamt sc->sc_parent->dk_driver->d_minphys, uio)); 1145 1.18.2.2 yamt } 1146 1.18.2.2 yamt 1147 1.18.2.2 yamt /* 1148 1.18.2.2 yamt * dkwrite: [devsw entry point] 1149 1.18.2.2 yamt * 1150 1.18.2.2 yamt * Write to a wedge. 1151 1.18.2.2 yamt */ 1152 1.18.2.2 yamt static int 1153 1.18.2.3 yamt dkwrite(dev_t dev, struct uio *uio, int flags) 1154 1.18.2.2 yamt { 1155 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(dev); 1156 1.18.2.2 yamt 1157 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) 1158 1.18.2.2 yamt return (ENXIO); 1159 1.18.2.2 yamt 1160 1.18.2.2 yamt return (physio(dkstrategy, NULL, dev, B_WRITE, 1161 1.18.2.2 yamt sc->sc_parent->dk_driver->d_minphys, uio)); 1162 1.18.2.2 yamt } 1163 1.18.2.2 yamt 1164 1.18.2.2 yamt /* 1165 1.18.2.2 yamt * dkioctl: [devsw entry point] 1166 1.18.2.2 yamt * 1167 1.18.2.2 yamt * Perform an ioctl request on a wedge. 1168 1.18.2.2 yamt */ 1169 1.18.2.2 yamt static int 1170 1.18.2.2 yamt dkioctl(dev_t dev, u_long cmd, caddr_t data, int flag, struct lwp *l) 1171 1.18.2.2 yamt { 1172 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(dev); 1173 1.18.2.2 yamt int error = 0; 1174 1.18.2.2 yamt 1175 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) 1176 1.18.2.2 yamt return (ENXIO); 1177 1.18.2.2 yamt 1178 1.18.2.2 yamt switch (cmd) { 1179 1.18.2.2 yamt case DIOCCACHESYNC: 1180 1.18.2.2 yamt /* 1181 1.18.2.2 yamt * XXX Do we really need to care about having a writable 1182 1.18.2.2 yamt * file descriptor here? 1183 1.18.2.2 yamt */ 1184 1.18.2.2 yamt if ((flag & FWRITE) == 0) 1185 1.18.2.2 yamt error = EBADF; 1186 1.18.2.2 yamt else 1187 1.18.2.2 yamt error = VOP_IOCTL(sc->sc_parent->dk_rawvp, 1188 1.18.2.2 yamt cmd, data, flag, 1189 1.18.2.2 yamt l != NULL ? l->l_cred : NOCRED, l); 1190 1.18.2.2 yamt break; 1191 1.18.2.2 yamt case DIOCGWEDGEINFO: 1192 1.18.2.2 yamt { 1193 1.18.2.2 yamt struct dkwedge_info *dkw = (void *) data; 1194 1.18.2.2 yamt 1195 1.18.2.2 yamt strcpy(dkw->dkw_devname, sc->sc_dev->dv_xname); 1196 1.18.2.2 yamt memcpy(dkw->dkw_wname, sc->sc_wname, sizeof(dkw->dkw_wname)); 1197 1.18.2.2 yamt dkw->dkw_wname[sizeof(dkw->dkw_wname) - 1] = '\0'; 1198 1.18.2.2 yamt strcpy(dkw->dkw_parent, sc->sc_parent->dk_name); 1199 1.18.2.2 yamt dkw->dkw_offset = sc->sc_offset; 1200 1.18.2.2 yamt dkw->dkw_size = sc->sc_size; 1201 1.18.2.2 yamt strcpy(dkw->dkw_ptype, sc->sc_ptype); 1202 1.18.2.2 yamt 1203 1.18.2.2 yamt break; 1204 1.18.2.2 yamt } 1205 1.18.2.2 yamt 1206 1.18.2.2 yamt default: 1207 1.18.2.2 yamt error = ENOTTY; 1208 1.18.2.2 yamt } 1209 1.18.2.2 yamt 1210 1.18.2.2 yamt return (error); 1211 1.18.2.2 yamt } 1212 1.18.2.2 yamt 1213 1.18.2.2 yamt /* 1214 1.18.2.2 yamt * dksize: [devsw entry point] 1215 1.18.2.2 yamt * 1216 1.18.2.2 yamt * Query the size of a wedge for the purpose of performing a dump 1217 1.18.2.2 yamt * or for swapping to. 1218 1.18.2.2 yamt */ 1219 1.18.2.2 yamt static int 1220 1.18.2.2 yamt dksize(dev_t dev) 1221 1.18.2.2 yamt { 1222 1.18.2.2 yamt struct dkwedge_softc *sc = dkwedge_lookup(dev); 1223 1.18.2.2 yamt int rv = -1; 1224 1.18.2.2 yamt 1225 1.18.2.2 yamt if (sc == NULL) 1226 1.18.2.2 yamt return (-1); 1227 1.18.2.2 yamt 1228 1.18.2.2 yamt if (sc->sc_state != DKW_STATE_RUNNING) 1229 1.18.2.2 yamt return (ENXIO); 1230 1.18.2.2 yamt 1231 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_EXCLUSIVE, NULL); 1232 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_EXCLUSIVE, NULL); 1233 1.18.2.2 yamt 1234 1.18.2.2 yamt /* Our content type is static, no need to open the device. */ 1235 1.18.2.2 yamt 1236 1.18.2.2 yamt if (strcmp(sc->sc_ptype, DKW_PTYPE_SWAP) == 0) { 1237 1.18.2.2 yamt /* Saturate if we are larger than INT_MAX. */ 1238 1.18.2.2 yamt if (sc->sc_size > INT_MAX) 1239 1.18.2.2 yamt rv = INT_MAX; 1240 1.18.2.2 yamt else 1241 1.18.2.2 yamt rv = (int) sc->sc_size; 1242 1.18.2.2 yamt } 1243 1.18.2.2 yamt 1244 1.18.2.2 yamt (void) lockmgr(&sc->sc_parent->dk_rawlock, LK_RELEASE, NULL); 1245 1.18.2.2 yamt (void) lockmgr(&sc->sc_dk.dk_openlock, LK_RELEASE, NULL); 1246 1.18.2.2 yamt 1247 1.18.2.2 yamt return (rv); 1248 1.18.2.2 yamt } 1249 1.18.2.2 yamt 1250 1.18.2.2 yamt /* 1251 1.18.2.2 yamt * dkdump: [devsw entry point] 1252 1.18.2.2 yamt * 1253 1.18.2.2 yamt * Perform a crash dump to a wedge. 1254 1.18.2.2 yamt */ 1255 1.18.2.2 yamt static int 1256 1.18.2.3 yamt dkdump(dev_t dev, daddr_t blkno, caddr_t va, 1257 1.18.2.3 yamt size_t size) 1258 1.18.2.2 yamt { 1259 1.18.2.2 yamt 1260 1.18.2.2 yamt /* XXX */ 1261 1.18.2.2 yamt return (ENXIO); 1262 1.18.2.2 yamt } 1263
Indexes created Tue Oct 21 19:09:51 GMT 2025