Home | History | Annotate | Line # | Download | only in dev
vnd.c revision 1.284
      1  1.284   mlelstv /*	$NetBSD: vnd.c,v 1.284 2022/03/28 11:16:59 mlelstv Exp $	*/
      2   1.41   thorpej 
      3   1.41   thorpej /*-
      4  1.274        ad  * Copyright (c) 1996, 1997, 1998, 2008, 2020 The NetBSD Foundation, Inc.
      5   1.41   thorpej  * All rights reserved.
      6   1.41   thorpej  *
      7   1.41   thorpej  * This code is derived from software contributed to The NetBSD Foundation
      8   1.41   thorpej  * by Jason R. Thorpe.
      9   1.41   thorpej  *
     10   1.41   thorpej  * Redistribution and use in source and binary forms, with or without
     11   1.41   thorpej  * modification, are permitted provided that the following conditions
     12   1.41   thorpej  * are met:
     13   1.41   thorpej  * 1. Redistributions of source code must retain the above copyright
     14   1.41   thorpej  *    notice, this list of conditions and the following disclaimer.
     15   1.41   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     16   1.41   thorpej  *    notice, this list of conditions and the following disclaimer in the
     17   1.41   thorpej  *    documentation and/or other materials provided with the distribution.
     18   1.41   thorpej  *
     19   1.41   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     20   1.41   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     21   1.41   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     22   1.48       jtc  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     23   1.48       jtc  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     24   1.41   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     25   1.41   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     26   1.41   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     27   1.41   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     28   1.41   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     29   1.41   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     30   1.41   thorpej  */
     31   1.11       cgd 
     32    1.1    brezak /*
     33  1.215     rmind  * Copyright (c) 1988 University of Utah.
     34    1.1    brezak  * Copyright (c) 1990, 1993
     35    1.1    brezak  *	The Regents of the University of California.  All rights reserved.
     36    1.1    brezak  *
     37    1.1    brezak  * This code is derived from software contributed to Berkeley by
     38    1.1    brezak  * the Systems Programming Group of the University of Utah Computer
     39    1.1    brezak  * Science Department.
     40    1.1    brezak  *
     41    1.1    brezak  * Redistribution and use in source and binary forms, with or without
     42    1.1    brezak  * modification, are permitted provided that the following conditions
     43    1.1    brezak  * are met:
     44    1.1    brezak  * 1. Redistributions of source code must retain the above copyright
     45    1.1    brezak  *    notice, this list of conditions and the following disclaimer.
     46    1.1    brezak  * 2. Redistributions in binary form must reproduce the above copyright
     47    1.1    brezak  *    notice, this list of conditions and the following disclaimer in the
     48    1.1    brezak  *    documentation and/or other materials provided with the distribution.
     49  1.102       agc  * 3. Neither the name of the University nor the names of its contributors
     50  1.102       agc  *    may be used to endorse or promote products derived from this software
     51  1.102       agc  *    without specific prior written permission.
     52  1.102       agc  *
     53  1.102       agc  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     54  1.102       agc  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     55  1.102       agc  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     56  1.102       agc  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     57  1.102       agc  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     58  1.102       agc  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     59  1.102       agc  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     60  1.102       agc  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     61  1.102       agc  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     62  1.102       agc  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     63  1.102       agc  * SUCH DAMAGE.
     64  1.102       agc  *
     65  1.102       agc  * from: Utah $Hdr: vn.c 1.13 94/04/02$
     66  1.102       agc  *
     67  1.102       agc  *	@(#)vn.c	8.9 (Berkeley) 5/14/95
     68  1.102       agc  */
     69  1.102       agc 
     70  1.102       agc /*
     71    1.1    brezak  * Vnode disk driver.
     72    1.1    brezak  *
     73    1.1    brezak  * Block/character interface to a vnode.  Allows one to treat a file
     74    1.1    brezak  * as a disk (e.g. build a filesystem in it, mount it, etc.).
     75    1.1    brezak  *
     76  1.157      jmmv  * NOTE 1: If the vnode supports the VOP_BMAP and VOP_STRATEGY operations,
     77  1.157      jmmv  * this uses them to avoid distorting the local buffer cache.  If those
     78  1.157      jmmv  * block-level operations are not available, this falls back to the regular
     79  1.157      jmmv  * read and write calls.  Using these may distort the cache in some cases
     80  1.157      jmmv  * but better have the driver working than preventing it to work on file
     81  1.157      jmmv  * systems where the block-level operations are not implemented for
     82  1.157      jmmv  * whatever reason.
     83    1.1    brezak  *
     84    1.1    brezak  * NOTE 2: There is a security issue involved with this driver.
     85    1.1    brezak  * Once mounted all access to the contents of the "mapped" file via
     86    1.1    brezak  * the special file is controlled by the permissions on the special
     87    1.1    brezak  * file, the protection of the mapped file is ignored (effectively,
     88    1.1    brezak  * by using root credentials in all transactions).
     89    1.1    brezak  *
     90    1.1    brezak  * NOTE 3: Doesn't interact with leases, should it?
     91    1.1    brezak  */
     92   1.75     lukem 
     93   1.75     lukem #include <sys/cdefs.h>
     94  1.284   mlelstv __KERNEL_RCSID(0, "$NetBSD: vnd.c,v 1.284 2022/03/28 11:16:59 mlelstv Exp $");
     95   1.55   thorpej 
     96   1.74       mrg #if defined(_KERNEL_OPT)
     97  1.115   hubertf #include "opt_vnd.h"
     98  1.211       mrg #include "opt_compat_netbsd.h"
     99   1.74       mrg #endif
    100    1.1    brezak 
    101    1.1    brezak #include <sys/param.h>
    102    1.1    brezak #include <sys/systm.h>
    103    1.1    brezak #include <sys/namei.h>
    104    1.1    brezak #include <sys/proc.h>
    105  1.112    bouyer #include <sys/kthread.h>
    106    1.1    brezak #include <sys/errno.h>
    107    1.1    brezak #include <sys/buf.h>
    108  1.111      yamt #include <sys/bufq.h>
    109    1.1    brezak #include <sys/malloc.h>
    110    1.1    brezak #include <sys/ioctl.h>
    111   1.16       cgd #include <sys/disklabel.h>
    112   1.22   thorpej #include <sys/device.h>
    113   1.22   thorpej #include <sys/disk.h>
    114   1.22   thorpej #include <sys/stat.h>
    115    1.1    brezak #include <sys/mount.h>
    116    1.1    brezak #include <sys/vnode.h>
    117  1.266   hannken #include <sys/fstrans.h>
    118    1.1    brezak #include <sys/file.h>
    119    1.1    brezak #include <sys/uio.h>
    120   1.26  christos #include <sys/conf.h>
    121  1.147      elad #include <sys/kauth.h>
    122  1.257  pgoyette #include <sys/module.h>
    123  1.271  pgoyette #include <sys/compat_stub.h>
    124  1.274        ad #include <sys/atomic.h>
    125  1.181        ad 
    126  1.181        ad #include <net/zlib.h>
    127    1.1    brezak 
    128  1.157      jmmv #include <miscfs/genfs/genfs.h>
    129    1.1    brezak #include <miscfs/specfs/specdev.h>
    130    1.1    brezak 
    131  1.204    dyoung #include <dev/dkvar.h>
    132   1.41   thorpej #include <dev/vndvar.h>
    133   1.41   thorpej 
    134  1.248  christos #include "ioconf.h"
    135  1.248  christos 
    136   1.41   thorpej #if defined(VNDDEBUG) && !defined(DEBUG)
    137  1.116  christos #define DEBUG
    138   1.41   thorpej #endif
    139    1.1    brezak 
    140    1.1    brezak #ifdef DEBUG
    141   1.17       cgd int dovndcluster = 1;
    142  1.116  christos #define VDB_FOLLOW	0x01
    143  1.116  christos #define VDB_INIT	0x02
    144  1.116  christos #define VDB_IO		0x04
    145  1.116  christos #define VDB_LABEL	0x08
    146  1.250  christos int vnddebug = 0;
    147    1.1    brezak #endif
    148    1.1    brezak 
    149  1.116  christos #define vndunit(x)	DISKUNIT(x)
    150   1.18       cgd 
    151   1.36        pk struct vndxfer {
    152  1.129      yamt 	struct buf vx_buf;
    153  1.129      yamt 	struct vnd_softc *vx_vnd;
    154   1.18       cgd };
    155  1.129      yamt #define	VND_BUFTOXFER(bp)	((struct vndxfer *)(void *)bp)
    156    1.1    brezak 
    157  1.116  christos #define VND_GETXFER(vnd)	pool_get(&(vnd)->sc_vxpool, PR_WAITOK)
    158  1.116  christos #define VND_PUTXFER(vnd, vx)	pool_put(&(vnd)->sc_vxpool, (vx))
    159   1.59   thorpej 
    160  1.116  christos #define VNDLABELDEV(dev) \
    161  1.116  christos     (MAKEDISKDEV(major((dev)), vndunit((dev)), RAW_PART))
    162   1.41   thorpej 
    163  1.220   hannken #define	VND_MAXPENDING(vnd)	((vnd)->sc_maxactive * 4)
    164  1.269   mlelstv #define	VND_MAXPAGES(vnd)	(1024 * 1024 / PAGE_SIZE)
    165  1.220   hannken 
    166    1.1    brezak 
    167  1.108   thorpej static void	vndclear(struct vnd_softc *, int);
    168  1.199    dyoung static int	vnddoclear(struct vnd_softc *, int, int, bool);
    169  1.147      elad static int	vndsetcred(struct vnd_softc *, kauth_cred_t);
    170  1.108   thorpej static void	vndthrottle(struct vnd_softc *, struct vnode *);
    171  1.108   thorpej static void	vndiodone(struct buf *);
    172   1.95  drochner #if 0
    173  1.108   thorpej static void	vndshutdown(void);
    174   1.95  drochner #endif
    175   1.16       cgd 
    176  1.108   thorpej static void	vndgetdefaultlabel(struct vnd_softc *, struct disklabel *);
    177  1.131      cube static void	vndgetdisklabel(dev_t, struct vnd_softc *);
    178   1.41   thorpej 
    179  1.108   thorpej static int	vndlock(struct vnd_softc *);
    180  1.108   thorpej static void	vndunlock(struct vnd_softc *);
    181  1.115   hubertf #ifdef VND_COMPRESSION
    182  1.115   hubertf static void	compstrategy(struct buf *, off_t);
    183  1.115   hubertf static void	*vnd_alloc(void *, u_int, u_int);
    184  1.115   hubertf static void	vnd_free(void *, void *);
    185  1.115   hubertf #endif /* VND_COMPRESSION */
    186   1.86   gehenna 
    187  1.157      jmmv static void	vndthread(void *);
    188  1.162   thorpej static bool	vnode_has_op(const struct vnode *, int);
    189  1.157      jmmv static void	handle_with_rdwr(struct vnd_softc *, const struct buf *,
    190  1.157      jmmv 		    struct buf *);
    191  1.157      jmmv static void	handle_with_strategy(struct vnd_softc *, const struct buf *,
    192  1.157      jmmv 		    struct buf *);
    193  1.222  christos static void	vnd_set_geometry(struct vnd_softc *);
    194  1.112    bouyer 
    195  1.108   thorpej static dev_type_open(vndopen);
    196  1.108   thorpej static dev_type_close(vndclose);
    197  1.108   thorpej static dev_type_read(vndread);
    198  1.108   thorpej static dev_type_write(vndwrite);
    199  1.108   thorpej static dev_type_ioctl(vndioctl);
    200  1.108   thorpej static dev_type_strategy(vndstrategy);
    201  1.108   thorpej static dev_type_dump(vnddump);
    202  1.108   thorpej static dev_type_size(vndsize);
    203   1.86   gehenna 
    204   1.86   gehenna const struct bdevsw vnd_bdevsw = {
    205  1.228  dholland 	.d_open = vndopen,
    206  1.228  dholland 	.d_close = vndclose,
    207  1.228  dholland 	.d_strategy = vndstrategy,
    208  1.228  dholland 	.d_ioctl = vndioctl,
    209  1.228  dholland 	.d_dump = vnddump,
    210  1.228  dholland 	.d_psize = vndsize,
    211  1.231  dholland 	.d_discard = nodiscard,
    212  1.228  dholland 	.d_flag = D_DISK
    213   1.86   gehenna };
    214   1.86   gehenna 
    215   1.86   gehenna const struct cdevsw vnd_cdevsw = {
    216  1.228  dholland 	.d_open = vndopen,
    217  1.228  dholland 	.d_close = vndclose,
    218  1.228  dholland 	.d_read = vndread,
    219  1.228  dholland 	.d_write = vndwrite,
    220  1.228  dholland 	.d_ioctl = vndioctl,
    221  1.228  dholland 	.d_stop = nostop,
    222  1.228  dholland 	.d_tty = notty,
    223  1.228  dholland 	.d_poll = nopoll,
    224  1.228  dholland 	.d_mmap = nommap,
    225  1.228  dholland 	.d_kqfilter = nokqfilter,
    226  1.232  dholland 	.d_discard = nodiscard,
    227  1.228  dholland 	.d_flag = D_DISK
    228   1.86   gehenna };
    229   1.22   thorpej 
    230  1.176      cube static int	vnd_match(device_t, cfdata_t, void *);
    231  1.176      cube static void	vnd_attach(device_t, device_t, void *);
    232  1.176      cube static int	vnd_detach(device_t, int);
    233  1.131      cube 
    234  1.199    dyoung CFATTACH_DECL3_NEW(vnd, sizeof(struct vnd_softc),
    235  1.199    dyoung     vnd_match, vnd_attach, vnd_detach, NULL, NULL, NULL, DVF_DETACH_SHUTDOWN);
    236  1.131      cube 
    237  1.131      cube static struct vnd_softc	*vnd_spawn(int);
    238  1.276      maxv static int	vnd_destroy(device_t);
    239   1.89       mrg 
    240  1.276      maxv static const struct	dkdriver vnddkdriver = {
    241  1.243   mlelstv 	.d_strategy = vndstrategy,
    242  1.243   mlelstv 	.d_minphys = minphys
    243  1.243   mlelstv };
    244  1.210       riz 
    245    1.1    brezak void
    246  1.160  christos vndattach(int num)
    247    1.1    brezak {
    248  1.131      cube 	int error;
    249  1.131      cube 
    250  1.131      cube 	error = config_cfattach_attach(vnd_cd.cd_name, &vnd_ca);
    251  1.131      cube 	if (error)
    252  1.246     prlw1 		aprint_error("%s: unable to register cfattach, error = %d\n",
    253  1.246     prlw1 		    vnd_cd.cd_name, error);
    254  1.131      cube }
    255    1.1    brezak 
    256  1.131      cube static int
    257  1.176      cube vnd_match(device_t self, cfdata_t cfdata, void *aux)
    258  1.131      cube {
    259  1.176      cube 
    260  1.131      cube 	return 1;
    261   1.76       mrg }
    262   1.76       mrg 
    263  1.131      cube static void
    264  1.176      cube vnd_attach(device_t parent, device_t self, void *aux)
    265   1.76       mrg {
    266  1.176      cube 	struct vnd_softc *sc = device_private(self);
    267  1.131      cube 
    268  1.176      cube 	sc->sc_dev = self;
    269  1.131      cube 	sc->sc_comp_offsets = NULL;
    270  1.131      cube 	sc->sc_comp_buff = NULL;
    271  1.131      cube 	sc->sc_comp_decombuf = NULL;
    272  1.131      cube 	bufq_alloc(&sc->sc_tab, "disksort", BUFQ_SORT_RAWBLOCK);
    273  1.210       riz 	disk_init(&sc->sc_dkdev, device_xname(self), &vnddkdriver);
    274  1.173       smb 	if (!pmf_device_register(self, NULL, NULL))
    275  1.173       smb 		aprint_error_dev(self, "couldn't establish power handler\n");
    276  1.131      cube }
    277   1.82   hannken 
    278  1.131      cube static int
    279  1.176      cube vnd_detach(device_t self, int flags)
    280  1.131      cube {
    281  1.199    dyoung 	int error;
    282  1.176      cube 	struct vnd_softc *sc = device_private(self);
    283  1.199    dyoung 
    284  1.199    dyoung 	if (sc->sc_flags & VNF_INITED) {
    285  1.199    dyoung 		error = vnddoclear(sc, 0, -1, (flags & DETACH_FORCE) != 0);
    286  1.199    dyoung 		if (error != 0)
    287  1.199    dyoung 			return error;
    288  1.199    dyoung 	}
    289  1.132      cube 
    290  1.173       smb 	pmf_device_deregister(self);
    291  1.132      cube 	bufq_free(sc->sc_tab);
    292  1.170        ad 	disk_destroy(&sc->sc_dkdev);
    293  1.132      cube 
    294  1.131      cube 	return 0;
    295  1.131      cube }
    296   1.89       mrg 
    297  1.131      cube static struct vnd_softc *
    298  1.131      cube vnd_spawn(int unit)
    299  1.131      cube {
    300  1.201    cegger 	cfdata_t cf;
    301   1.76       mrg 
    302  1.131      cube 	cf = malloc(sizeof(*cf), M_DEVBUF, M_WAITOK);
    303  1.131      cube 	cf->cf_name = vnd_cd.cd_name;
    304  1.131      cube 	cf->cf_atname = vnd_cd.cd_name;
    305  1.131      cube 	cf->cf_unit = unit;
    306  1.131      cube 	cf->cf_fstate = FSTATE_STAR;
    307   1.89       mrg 
    308  1.176      cube 	return device_private(config_attach_pseudo(cf));
    309    1.1    brezak }
    310    1.1    brezak 
    311  1.276      maxv static int
    312  1.176      cube vnd_destroy(device_t dev)
    313  1.133      cube {
    314  1.133      cube 	int error;
    315  1.176      cube 	cfdata_t cf;
    316  1.133      cube 
    317  1.145   thorpej 	cf = device_cfdata(dev);
    318  1.146      cube 	error = config_detach(dev, DETACH_QUIET);
    319  1.133      cube 	if (error)
    320  1.133      cube 		return error;
    321  1.136      yamt 	free(cf, M_DEVBUF);
    322  1.133      cube 	return 0;
    323  1.133      cube }
    324  1.133      cube 
    325  1.108   thorpej static int
    326  1.160  christos vndopen(dev_t dev, int flags, int mode, struct lwp *l)
    327    1.1    brezak {
    328   1.17       cgd 	int unit = vndunit(dev);
    329   1.22   thorpej 	struct vnd_softc *sc;
    330   1.22   thorpej 	int error = 0, part, pmask;
    331   1.41   thorpej 	struct disklabel *lp;
    332    1.1    brezak 
    333    1.1    brezak #ifdef DEBUG
    334   1.17       cgd 	if (vnddebug & VDB_FOLLOW)
    335  1.191    cegger 		printf("vndopen(0x%"PRIx64", 0x%x, 0x%x, %p)\n", dev, flags, mode, l);
    336    1.1    brezak #endif
    337  1.182    cegger 	sc = device_lookup_private(&vnd_cd, unit);
    338  1.131      cube 	if (sc == NULL) {
    339  1.131      cube 		sc = vnd_spawn(unit);
    340  1.131      cube 		if (sc == NULL)
    341  1.131      cube 			return ENOMEM;
    342  1.242   mlelstv 
    343  1.242   mlelstv 		/* compatibility, keep disklabel after close */
    344  1.242   mlelstv 		sc->sc_flags = VNF_KLABEL;
    345  1.131      cube 	}
    346   1.22   thorpej 
    347   1.24  christos 	if ((error = vndlock(sc)) != 0)
    348  1.197    dyoung 		return error;
    349   1.22   thorpej 
    350  1.247   mlelstv 	mutex_enter(&sc->sc_dkdev.dk_openlock);
    351  1.247   mlelstv 
    352  1.202    dyoung 	if ((sc->sc_flags & VNF_CLEARING) != 0) {
    353  1.202    dyoung 		error = ENXIO;
    354  1.202    dyoung 		goto done;
    355  1.202    dyoung 	}
    356  1.199    dyoung 
    357   1.41   thorpej 	lp = sc->sc_dkdev.dk_label;
    358   1.41   thorpej 
    359   1.22   thorpej 	part = DISKPART(dev);
    360   1.22   thorpej 	pmask = (1 << part);
    361   1.22   thorpej 
    362  1.221   mlelstv 	if (sc->sc_dkdev.dk_nwedges != 0 && part != RAW_PART) {
    363  1.221   mlelstv 		error = EBUSY;
    364  1.221   mlelstv 		goto done;
    365  1.221   mlelstv 	}
    366  1.221   mlelstv 
    367  1.281   mlelstv 	if ((flags & FWRITE) && (sc->sc_flags & VNF_READONLY)) {
    368  1.281   mlelstv 		error = EROFS;
    369  1.281   mlelstv 		goto done;
    370  1.281   mlelstv 	}
    371  1.281   mlelstv 
    372  1.221   mlelstv 	if (sc->sc_flags & VNF_INITED) {
    373  1.221   mlelstv 		if ((sc->sc_dkdev.dk_openmask & ~(1<<RAW_PART)) != 0) {
    374  1.221   mlelstv 			/*
    375  1.221   mlelstv 			 * If any non-raw partition is open, but the disk
    376  1.221   mlelstv 			 * has been invalidated, disallow further opens.
    377  1.221   mlelstv 			 */
    378  1.221   mlelstv 			if ((sc->sc_flags & VNF_VLABEL) == 0) {
    379  1.221   mlelstv 				error = EIO;
    380  1.221   mlelstv 				goto done;
    381  1.221   mlelstv 			}
    382  1.221   mlelstv 		} else {
    383  1.221   mlelstv 			/*
    384  1.221   mlelstv 			 * Load the partition info if not already loaded.
    385  1.221   mlelstv 			 */
    386  1.221   mlelstv 			if ((sc->sc_flags & VNF_VLABEL) == 0) {
    387  1.221   mlelstv 				sc->sc_flags |= VNF_VLABEL;
    388  1.221   mlelstv 				vndgetdisklabel(dev, sc);
    389  1.221   mlelstv 			}
    390  1.221   mlelstv 		}
    391  1.221   mlelstv 	}
    392   1.41   thorpej 
    393   1.41   thorpej 	/* Check that the partitions exists. */
    394   1.41   thorpej 	if (part != RAW_PART) {
    395   1.41   thorpej 		if (((sc->sc_flags & VNF_INITED) == 0) ||
    396   1.41   thorpej 		    ((part >= lp->d_npartitions) ||
    397   1.41   thorpej 		     (lp->d_partitions[part].p_fstype == FS_UNUSED))) {
    398   1.41   thorpej 			error = ENXIO;
    399   1.41   thorpej 			goto done;
    400   1.41   thorpej 		}
    401   1.41   thorpej 	}
    402   1.41   thorpej 
    403   1.22   thorpej 	/* Prevent our unit from being unconfigured while open. */
    404   1.22   thorpej 	switch (mode) {
    405   1.22   thorpej 	case S_IFCHR:
    406   1.22   thorpej 		sc->sc_dkdev.dk_copenmask |= pmask;
    407   1.22   thorpej 		break;
    408   1.22   thorpej 
    409   1.22   thorpej 	case S_IFBLK:
    410   1.22   thorpej 		sc->sc_dkdev.dk_bopenmask |= pmask;
    411   1.22   thorpej 		break;
    412   1.22   thorpej 	}
    413   1.22   thorpej 	sc->sc_dkdev.dk_openmask =
    414   1.22   thorpej 	    sc->sc_dkdev.dk_copenmask | sc->sc_dkdev.dk_bopenmask;
    415   1.22   thorpej 
    416   1.41   thorpej  done:
    417  1.247   mlelstv 	mutex_exit(&sc->sc_dkdev.dk_openlock);
    418   1.22   thorpej 	vndunlock(sc);
    419  1.197    dyoung 	return error;
    420    1.1    brezak }
    421    1.1    brezak 
    422  1.108   thorpej static int
    423  1.160  christos vndclose(dev_t dev, int flags, int mode, struct lwp *l)
    424    1.4   deraadt {
    425   1.22   thorpej 	int unit = vndunit(dev);
    426   1.22   thorpej 	struct vnd_softc *sc;
    427   1.22   thorpej 	int error = 0, part;
    428   1.22   thorpej 
    429    1.4   deraadt #ifdef DEBUG
    430   1.17       cgd 	if (vnddebug & VDB_FOLLOW)
    431  1.191    cegger 		printf("vndclose(0x%"PRIx64", 0x%x, 0x%x, %p)\n", dev, flags, mode, l);
    432    1.4   deraadt #endif
    433  1.182    cegger 	sc = device_lookup_private(&vnd_cd, unit);
    434  1.131      cube 	if (sc == NULL)
    435  1.131      cube 		return ENXIO;
    436   1.22   thorpej 
    437   1.24  christos 	if ((error = vndlock(sc)) != 0)
    438  1.197    dyoung 		return error;
    439   1.22   thorpej 
    440  1.247   mlelstv 	mutex_enter(&sc->sc_dkdev.dk_openlock);
    441  1.247   mlelstv 
    442   1.22   thorpej 	part = DISKPART(dev);
    443   1.22   thorpej 
    444   1.22   thorpej 	/* ...that much closer to allowing unconfiguration... */
    445   1.22   thorpej 	switch (mode) {
    446   1.22   thorpej 	case S_IFCHR:
    447   1.22   thorpej 		sc->sc_dkdev.dk_copenmask &= ~(1 << part);
    448   1.22   thorpej 		break;
    449   1.22   thorpej 
    450   1.22   thorpej 	case S_IFBLK:
    451   1.22   thorpej 		sc->sc_dkdev.dk_bopenmask &= ~(1 << part);
    452   1.22   thorpej 		break;
    453   1.22   thorpej 	}
    454   1.22   thorpej 	sc->sc_dkdev.dk_openmask =
    455   1.22   thorpej 	    sc->sc_dkdev.dk_copenmask | sc->sc_dkdev.dk_bopenmask;
    456   1.22   thorpej 
    457  1.242   mlelstv 	/* are we last opener ? */
    458  1.242   mlelstv 	if (sc->sc_dkdev.dk_openmask == 0) {
    459  1.242   mlelstv 		if ((sc->sc_flags & VNF_KLABEL) == 0)
    460  1.242   mlelstv 			sc->sc_flags &= ~VNF_VLABEL;
    461  1.242   mlelstv 	}
    462  1.242   mlelstv 
    463  1.247   mlelstv 	mutex_exit(&sc->sc_dkdev.dk_openlock);
    464  1.247   mlelstv 
    465   1.22   thorpej 	vndunlock(sc);
    466  1.134      cube 
    467  1.134      cube 	if ((sc->sc_flags & VNF_INITED) == 0) {
    468  1.176      cube 		if ((error = vnd_destroy(sc->sc_dev)) != 0) {
    469  1.176      cube 			aprint_error_dev(sc->sc_dev,
    470  1.176      cube 			    "unable to detach instance\n");
    471  1.134      cube 			return error;
    472  1.134      cube 		}
    473  1.134      cube 	}
    474  1.134      cube 
    475  1.197    dyoung 	return 0;
    476    1.4   deraadt }
    477    1.4   deraadt 
    478    1.1    brezak /*
    479  1.135      cube  * Queue the request, and wakeup the kernel thread to handle it.
    480    1.1    brezak  */
    481  1.108   thorpej static void
    482  1.108   thorpej vndstrategy(struct buf *bp)
    483    1.1    brezak {
    484   1.17       cgd 	int unit = vndunit(bp->b_dev);
    485  1.131      cube 	struct vnd_softc *vnd =
    486  1.182    cegger 	    device_lookup_private(&vnd_cd, unit);
    487  1.189    bouyer 	struct disklabel *lp;
    488  1.127      yamt 	daddr_t blkno;
    489  1.112    bouyer 	int s = splbio();
    490  1.112    bouyer 
    491  1.189    bouyer 	if (vnd == NULL) {
    492  1.189    bouyer 		bp->b_error = ENXIO;
    493  1.189    bouyer 		goto done;
    494  1.189    bouyer 	}
    495  1.189    bouyer 	lp = vnd->sc_dkdev.dk_label;
    496  1.189    bouyer 
    497   1.17       cgd 	if ((vnd->sc_flags & VNF_INITED) == 0) {
    498    1.1    brezak 		bp->b_error = ENXIO;
    499  1.169        ad 		goto done;
    500   1.41   thorpej 	}
    501   1.41   thorpej 
    502   1.41   thorpej 	/*
    503   1.41   thorpej 	 * The transfer must be a whole number of blocks.
    504   1.41   thorpej 	 */
    505   1.41   thorpej 	if ((bp->b_bcount % lp->d_secsize) != 0) {
    506   1.41   thorpej 		bp->b_error = EINVAL;
    507  1.169        ad 		goto done;
    508    1.1    brezak 	}
    509   1.41   thorpej 
    510   1.41   thorpej 	/*
    511   1.94      yamt 	 * check if we're read-only.
    512   1.94      yamt 	 */
    513   1.94      yamt 	if ((vnd->sc_flags & VNF_READONLY) && !(bp->b_flags & B_READ)) {
    514   1.94      yamt 		bp->b_error = EACCES;
    515  1.169        ad 		goto done;
    516  1.165      yamt 	}
    517  1.165      yamt 
    518  1.165      yamt 	/* If it's a nil transfer, wake up the top half now. */
    519  1.165      yamt 	if (bp->b_bcount == 0) {
    520   1.94      yamt 		goto done;
    521   1.94      yamt 	}
    522   1.94      yamt 
    523   1.41   thorpej 	/*
    524  1.112    bouyer 	 * Do bounds checking and adjust transfer.  If there's an error,
    525  1.112    bouyer 	 * the bounds check will flag that for us.
    526   1.41   thorpej 	 */
    527  1.139      yamt 	if (DISKPART(bp->b_dev) == RAW_PART) {
    528  1.139      yamt 		if (bounds_check_with_mediasize(bp, DEV_BSIZE,
    529  1.139      yamt 		    vnd->sc_size) <= 0)
    530  1.139      yamt 			goto done;
    531  1.139      yamt 	} else {
    532  1.112    bouyer 		if (bounds_check_with_label(&vnd->sc_dkdev,
    533  1.112    bouyer 		    bp, vnd->sc_flags & (VNF_WLABEL|VNF_LABELLING)) <= 0)
    534  1.112    bouyer 			goto done;
    535    1.1    brezak 	}
    536  1.127      yamt 
    537  1.127      yamt 	/*
    538  1.127      yamt 	 * Put the block number in terms of the logical blocksize
    539  1.127      yamt 	 * of the "device".
    540  1.127      yamt 	 */
    541  1.127      yamt 
    542  1.127      yamt 	blkno = bp->b_blkno / (lp->d_secsize / DEV_BSIZE);
    543  1.127      yamt 
    544  1.127      yamt 	/*
    545  1.127      yamt 	 * Translate the partition-relative block number to an absolute.
    546  1.127      yamt 	 */
    547  1.127      yamt 	if (DISKPART(bp->b_dev) != RAW_PART) {
    548  1.127      yamt 		struct partition *pp;
    549  1.127      yamt 
    550  1.127      yamt 		pp = &vnd->sc_dkdev.dk_label->d_partitions[
    551  1.127      yamt 		    DISKPART(bp->b_dev)];
    552  1.127      yamt 		blkno += pp->p_offset;
    553  1.127      yamt 	}
    554  1.127      yamt 	bp->b_rawblkno = blkno;
    555  1.127      yamt 
    556  1.112    bouyer #ifdef DEBUG
    557  1.112    bouyer 	if (vnddebug & VDB_FOLLOW)
    558  1.112    bouyer 		printf("vndstrategy(%p): unit %d\n", bp, unit);
    559  1.112    bouyer #endif
    560  1.220   hannken 	if ((vnd->sc_flags & VNF_USE_VN_RDWR)) {
    561  1.220   hannken 		KASSERT(vnd->sc_pending >= 0 &&
    562  1.220   hannken 		    vnd->sc_pending <= VND_MAXPENDING(vnd));
    563  1.220   hannken 		while (vnd->sc_pending == VND_MAXPENDING(vnd))
    564  1.220   hannken 			tsleep(&vnd->sc_pending, PRIBIO, "vndpc", 0);
    565  1.220   hannken 		vnd->sc_pending++;
    566  1.220   hannken 	}
    567  1.192      yamt 	bufq_put(vnd->sc_tab, bp);
    568  1.112    bouyer 	wakeup(&vnd->sc_tab);
    569  1.112    bouyer 	splx(s);
    570  1.112    bouyer 	return;
    571  1.165      yamt 
    572  1.112    bouyer done:
    573  1.165      yamt 	bp->b_resid = bp->b_bcount;
    574  1.112    bouyer 	biodone(bp);
    575  1.112    bouyer 	splx(s);
    576  1.112    bouyer }
    577   1.41   thorpej 
    578  1.184    cegger static bool
    579  1.184    cegger vnode_has_strategy(struct vnd_softc *vnd)
    580  1.184    cegger {
    581  1.184    cegger 	return vnode_has_op(vnd->sc_vp, VOFFSET(vop_bmap)) &&
    582  1.184    cegger 	    vnode_has_op(vnd->sc_vp, VOFFSET(vop_strategy));
    583  1.184    cegger }
    584  1.184    cegger 
    585  1.265   mlelstv /* Verify that I/O requests cannot be smaller than the
    586  1.265   mlelstv  * smallest I/O size supported by the backend.
    587  1.265   mlelstv  */
    588  1.255   mlelstv static bool
    589  1.255   mlelstv vnode_has_large_blocks(struct vnd_softc *vnd)
    590  1.255   mlelstv {
    591  1.265   mlelstv 	u_int32_t vnd_secsize, iosize;
    592  1.255   mlelstv 
    593  1.265   mlelstv 	iosize = vnd->sc_iosize;
    594  1.255   mlelstv 	vnd_secsize = vnd->sc_geom.vng_secsize;
    595  1.255   mlelstv 
    596  1.265   mlelstv 	return vnd_secsize % iosize != 0;
    597  1.255   mlelstv }
    598  1.255   mlelstv 
    599  1.185    cegger /* XXX this function needs a reliable check to detect
    600  1.185    cegger  * sparse files. Otherwise, bmap/strategy may be used
    601  1.185    cegger  * and fail on non-allocated blocks. VOP_READ/VOP_WRITE
    602  1.185    cegger  * works on sparse files.
    603  1.185    cegger  */
    604  1.185    cegger #if notyet
    605  1.184    cegger static bool
    606  1.184    cegger vnode_strategy_probe(struct vnd_softc *vnd)
    607  1.184    cegger {
    608  1.184    cegger 	int error;
    609  1.184    cegger 	daddr_t nbn;
    610  1.184    cegger 
    611  1.184    cegger 	if (!vnode_has_strategy(vnd))
    612  1.184    cegger 		return false;
    613  1.184    cegger 
    614  1.255   mlelstv 	if (vnode_has_large_blocks(vnd))
    615  1.255   mlelstv 		return false;
    616  1.255   mlelstv 
    617  1.184    cegger 	/* Convert the first logical block number to its
    618  1.184    cegger 	 * physical block number.
    619  1.184    cegger 	 */
    620  1.184    cegger 	error = 0;
    621  1.200        ad 	vn_lock(vnd->sc_vp, LK_EXCLUSIVE | LK_RETRY);
    622  1.184    cegger 	error = VOP_BMAP(vnd->sc_vp, 0, NULL, &nbn, NULL);
    623  1.209   hannken 	VOP_UNLOCK(vnd->sc_vp);
    624  1.184    cegger 
    625  1.184    cegger 	/* Test if that worked. */
    626  1.184    cegger 	if (error == 0 && (long)nbn == -1)
    627  1.184    cegger 		return false;
    628  1.184    cegger 
    629  1.184    cegger 	return true;
    630  1.184    cegger }
    631  1.185    cegger #endif
    632  1.184    cegger 
    633  1.126      yamt static void
    634  1.112    bouyer vndthread(void *arg)
    635  1.112    bouyer {
    636  1.112    bouyer 	struct vnd_softc *vnd = arg;
    637  1.157      jmmv 	int s;
    638  1.157      jmmv 
    639  1.184    cegger 	/* Determine whether we can *use* VOP_BMAP and VOP_STRATEGY to
    640  1.157      jmmv 	 * directly access the backing vnode.  If we can, use these two
    641  1.157      jmmv 	 * operations to avoid messing with the local buffer cache.
    642  1.157      jmmv 	 * Otherwise fall back to regular VOP_READ/VOP_WRITE operations
    643  1.157      jmmv 	 * which are guaranteed to work with any file system. */
    644  1.218   hannken 	if ((vnd->sc_flags & VNF_USE_VN_RDWR) == 0 &&
    645  1.218   hannken 	    ! vnode_has_strategy(vnd))
    646  1.218   hannken 		vnd->sc_flags |= VNF_USE_VN_RDWR;
    647  1.157      jmmv 
    648  1.255   mlelstv 	/* VOP_STRATEGY can only be used if the backing vnode allows
    649  1.255   mlelstv 	 * to access blocks as small as defined by the vnd geometry.
    650  1.255   mlelstv 	 */
    651  1.255   mlelstv 	if ((vnd->sc_flags & VNF_USE_VN_RDWR) == 0 &&
    652  1.255   mlelstv 	    vnode_has_large_blocks(vnd))
    653  1.255   mlelstv 		vnd->sc_flags |= VNF_USE_VN_RDWR;
    654  1.255   mlelstv 
    655  1.157      jmmv #ifdef DEBUG
    656  1.157      jmmv 	if (vnddebug & VDB_INIT)
    657  1.157      jmmv 		printf("vndthread: vp %p, %s\n", vnd->sc_vp,
    658  1.218   hannken 		    (vnd->sc_flags & VNF_USE_VN_RDWR) == 0 ?
    659  1.157      jmmv 		    "using bmap/strategy operations" :
    660  1.157      jmmv 		    "using read/write operations");
    661  1.157      jmmv #endif
    662   1.36        pk 
    663   1.61   thorpej 	s = splbio();
    664  1.112    bouyer 	vnd->sc_flags |= VNF_KTHREAD;
    665  1.112    bouyer 	wakeup(&vnd->sc_kthread);
    666   1.37        pk 
    667  1.112    bouyer 	/*
    668  1.157      jmmv 	 * Dequeue requests and serve them depending on the available
    669  1.157      jmmv 	 * vnode operations.
    670  1.112    bouyer 	 */
    671  1.112    bouyer 	while ((vnd->sc_flags & VNF_VUNCONF) == 0) {
    672  1.129      yamt 		struct vndxfer *vnx;
    673  1.129      yamt 		struct buf *obp;
    674  1.129      yamt 		struct buf *bp;
    675  1.129      yamt 
    676  1.192      yamt 		obp = bufq_get(vnd->sc_tab);
    677  1.129      yamt 		if (obp == NULL) {
    678  1.112    bouyer 			tsleep(&vnd->sc_tab, PRIBIO, "vndbp", 0);
    679  1.112    bouyer 			continue;
    680  1.112    bouyer 		};
    681  1.220   hannken 		if ((vnd->sc_flags & VNF_USE_VN_RDWR)) {
    682  1.220   hannken 			KASSERT(vnd->sc_pending > 0 &&
    683  1.220   hannken 			    vnd->sc_pending <= VND_MAXPENDING(vnd));
    684  1.220   hannken 			if (vnd->sc_pending-- == VND_MAXPENDING(vnd))
    685  1.220   hannken 				wakeup(&vnd->sc_pending);
    686  1.220   hannken 		}
    687  1.112    bouyer 		splx(s);
    688    1.5       cgd #ifdef DEBUG
    689  1.112    bouyer 		if (vnddebug & VDB_FOLLOW)
    690  1.183    cegger 			printf("vndthread(%p)\n", obp);
    691    1.1    brezak #endif
    692   1.18       cgd 
    693  1.112    bouyer 		if (vnd->sc_vp->v_mount == NULL) {
    694  1.129      yamt 			obp->b_error = ENXIO;
    695  1.112    bouyer 			goto done;
    696  1.112    bouyer 		}
    697  1.115   hubertf #ifdef VND_COMPRESSION
    698  1.115   hubertf 		/* handle a compressed read */
    699  1.226    martin 		if ((obp->b_flags & B_READ) != 0 && (vnd->sc_flags & VNF_COMP)) {
    700  1.157      jmmv 			off_t bn;
    701  1.244     prlw1 
    702  1.157      jmmv 			/* Convert to a byte offset within the file. */
    703  1.157      jmmv 			bn = obp->b_rawblkno *
    704  1.157      jmmv 			    vnd->sc_dkdev.dk_label->d_secsize;
    705  1.157      jmmv 
    706  1.129      yamt 			compstrategy(obp, bn);
    707  1.115   hubertf 			goto done;
    708  1.115   hubertf 		}
    709  1.115   hubertf #endif /* VND_COMPRESSION */
    710  1.244     prlw1 
    711    1.1    brezak 		/*
    712  1.112    bouyer 		 * Allocate a header for this transfer and link it to the
    713  1.112    bouyer 		 * buffer
    714    1.1    brezak 		 */
    715    1.1    brezak 		s = splbio();
    716  1.112    bouyer 		vnx = VND_GETXFER(vnd);
    717    1.1    brezak 		splx(s);
    718  1.129      yamt 		vnx->vx_vnd = vnd;
    719  1.129      yamt 
    720  1.157      jmmv 		s = splbio();
    721  1.157      jmmv 		while (vnd->sc_active >= vnd->sc_maxactive) {
    722  1.157      jmmv 			tsleep(&vnd->sc_tab, PRIBIO, "vndac", 0);
    723  1.157      jmmv 		}
    724  1.157      jmmv 		vnd->sc_active++;
    725  1.157      jmmv 		splx(s);
    726  1.157      jmmv 
    727  1.157      jmmv 		/* Instrumentation. */
    728  1.157      jmmv 		disk_busy(&vnd->sc_dkdev);
    729  1.157      jmmv 
    730  1.129      yamt 		bp = &vnx->vx_buf;
    731  1.175        ad 		buf_init(bp);
    732  1.277  jdolecek 		bp->b_flags = (obp->b_flags & (B_READ | B_PHYS | B_RAW));
    733  1.175        ad 		bp->b_oflags = obp->b_oflags;
    734  1.175        ad 		bp->b_cflags = obp->b_cflags;
    735  1.129      yamt 		bp->b_iodone = vndiodone;
    736  1.129      yamt 		bp->b_private = obp;
    737  1.138      yamt 		bp->b_vp = vnd->sc_vp;
    738  1.217     rmind 		bp->b_objlock = bp->b_vp->v_interlock;
    739  1.129      yamt 		bp->b_data = obp->b_data;
    740  1.165      yamt 		bp->b_bcount = obp->b_bcount;
    741  1.129      yamt 		BIO_COPYPRIO(bp, obp);
    742  1.129      yamt 
    743  1.270   hannken 		/* Make sure the request succeeds while suspending this fs. */
    744  1.270   hannken 		fstrans_start_lazy(vnd->sc_vp->v_mount);
    745  1.270   hannken 
    746  1.157      jmmv 		/* Handle the request using the appropriate operations. */
    747  1.218   hannken 		if ((vnd->sc_flags & VNF_USE_VN_RDWR) == 0)
    748  1.157      jmmv 			handle_with_strategy(vnd, obp, bp);
    749  1.157      jmmv 		else
    750  1.157      jmmv 			handle_with_rdwr(vnd, obp, bp);
    751  1.157      jmmv 
    752  1.270   hannken 		fstrans_done(vnd->sc_vp->v_mount);
    753  1.270   hannken 
    754  1.157      jmmv 		s = splbio();
    755  1.157      jmmv 		continue;
    756  1.157      jmmv 
    757  1.157      jmmv done:
    758  1.157      jmmv 		biodone(obp);
    759  1.129      yamt 		s = splbio();
    760  1.157      jmmv 	}
    761  1.157      jmmv 
    762  1.157      jmmv 	vnd->sc_flags &= (~VNF_KTHREAD | VNF_VUNCONF);
    763  1.157      jmmv 	wakeup(&vnd->sc_kthread);
    764  1.157      jmmv 	splx(s);
    765  1.157      jmmv 	kthread_exit(0);
    766  1.157      jmmv }
    767  1.157      jmmv 
    768  1.157      jmmv /*
    769  1.157      jmmv  * Checks if the given vnode supports the requested operation.
    770  1.157      jmmv  * The operation is specified the offset returned by VOFFSET.
    771  1.157      jmmv  *
    772  1.157      jmmv  * XXX The test below used to determine this is quite fragile
    773  1.157      jmmv  * because it relies on the file system to use genfs to specify
    774  1.157      jmmv  * unimplemented operations.  There might be another way to do
    775  1.157      jmmv  * it more cleanly.
    776  1.157      jmmv  */
    777  1.162   thorpej static bool
    778  1.157      jmmv vnode_has_op(const struct vnode *vp, int opoffset)
    779  1.157      jmmv {
    780  1.157      jmmv 	int (*defaultp)(void *);
    781  1.157      jmmv 	int (*opp)(void *);
    782  1.157      jmmv 
    783  1.157      jmmv 	defaultp = vp->v_op[VOFFSET(vop_default)];
    784  1.157      jmmv 	opp = vp->v_op[opoffset];
    785  1.157      jmmv 
    786  1.157      jmmv 	return opp != defaultp && opp != genfs_eopnotsupp &&
    787  1.157      jmmv 	    opp != genfs_badop && opp != genfs_nullop;
    788  1.157      jmmv }
    789  1.157      jmmv 
    790  1.157      jmmv /*
    791  1.245     prlw1  * Handles the read/write request given in 'bp' using the vnode's VOP_READ
    792  1.157      jmmv  * and VOP_WRITE operations.
    793  1.157      jmmv  *
    794  1.157      jmmv  * 'obp' is a pointer to the original request fed to the vnd device.
    795  1.157      jmmv  */
    796  1.157      jmmv static void
    797  1.157      jmmv handle_with_rdwr(struct vnd_softc *vnd, const struct buf *obp, struct buf *bp)
    798  1.157      jmmv {
    799  1.162   thorpej 	bool doread;
    800  1.157      jmmv 	off_t offset;
    801  1.218   hannken 	size_t len, resid;
    802  1.157      jmmv 	struct vnode *vp;
    803  1.274        ad 	int npages;
    804  1.157      jmmv 
    805  1.157      jmmv 	doread = bp->b_flags & B_READ;
    806  1.157      jmmv 	offset = obp->b_rawblkno * vnd->sc_dkdev.dk_label->d_secsize;
    807  1.218   hannken 	len = bp->b_bcount;
    808  1.157      jmmv 	vp = vnd->sc_vp;
    809  1.157      jmmv 
    810  1.157      jmmv #if defined(DEBUG)
    811  1.157      jmmv 	if (vnddebug & VDB_IO)
    812  1.157      jmmv 		printf("vnd (rdwr): vp %p, %s, rawblkno 0x%" PRIx64
    813  1.157      jmmv 		    ", secsize %d, offset %" PRIu64
    814  1.161       chs 		    ", bcount %d\n",
    815  1.157      jmmv 		    vp, doread ? "read" : "write", obp->b_rawblkno,
    816  1.157      jmmv 		    vnd->sc_dkdev.dk_label->d_secsize, offset,
    817  1.161       chs 		    bp->b_bcount);
    818  1.157      jmmv #endif
    819  1.157      jmmv 
    820  1.157      jmmv 	/* Issue the read or write operation. */
    821  1.157      jmmv 	bp->b_error =
    822  1.157      jmmv 	    vn_rdwr(doread ? UIO_READ : UIO_WRITE,
    823  1.218   hannken 	    vp, bp->b_data, len, offset, UIO_SYSSPACE,
    824  1.269   mlelstv 	    IO_ADV_ENCODE(POSIX_FADV_NOREUSE) | IO_DIRECT,
    825  1.269   mlelstv 		vnd->sc_cred, &resid, NULL);
    826  1.158    martin 	bp->b_resid = resid;
    827  1.157      jmmv 
    828  1.269   mlelstv 	/*
    829  1.269   mlelstv 	 * Avoid caching too many pages, the vnd user
    830  1.269   mlelstv 	 * is usually a filesystem and caches itself.
    831  1.269   mlelstv 	 * We need some amount of caching to not hinder
    832  1.269   mlelstv 	 * read-ahead and write-behind operations.
    833  1.269   mlelstv 	 */
    834  1.274        ad 	npages = atomic_load_relaxed(&vp->v_uobj.uo_npages);
    835  1.274        ad 	if (npages > VND_MAXPAGES(vnd)) {
    836  1.274        ad 		rw_enter(vp->v_uobj.vmobjlock, RW_WRITER);
    837  1.269   mlelstv 		(void) VOP_PUTPAGES(vp, 0, 0,
    838  1.269   mlelstv 		    PGO_ALLPAGES | PGO_CLEANIT | PGO_FREE);
    839  1.274        ad 	}
    840  1.218   hannken 
    841  1.157      jmmv 	/* We need to increase the number of outputs on the vnode if
    842  1.159      jmmv 	 * there was any write to it. */
    843  1.175        ad 	if (!doread) {
    844  1.217     rmind 		mutex_enter(vp->v_interlock);
    845  1.175        ad 		vp->v_numoutput++;
    846  1.217     rmind 		mutex_exit(vp->v_interlock);
    847  1.175        ad 	}
    848  1.157      jmmv 
    849  1.157      jmmv 	biodone(bp);
    850  1.157      jmmv }
    851  1.157      jmmv 
    852  1.157      jmmv /*
    853  1.157      jmmv  * Handes the read/write request given in 'bp' using the vnode's VOP_BMAP
    854  1.157      jmmv  * and VOP_STRATEGY operations.
    855  1.157      jmmv  *
    856  1.157      jmmv  * 'obp' is a pointer to the original request fed to the vnd device.
    857  1.157      jmmv  */
    858  1.157      jmmv static void
    859  1.157      jmmv handle_with_strategy(struct vnd_softc *vnd, const struct buf *obp,
    860  1.157      jmmv     struct buf *bp)
    861  1.157      jmmv {
    862  1.157      jmmv 	int bsize, error, flags, skipped;
    863  1.157      jmmv 	size_t resid, sz;
    864  1.157      jmmv 	off_t bn, offset;
    865  1.175        ad 	struct vnode *vp;
    866  1.240    bouyer 	struct buf *nbp = NULL;
    867  1.157      jmmv 
    868  1.157      jmmv 	flags = obp->b_flags;
    869  1.157      jmmv 
    870  1.157      jmmv 
    871  1.157      jmmv 	/* convert to a byte offset within the file. */
    872  1.157      jmmv 	bn = obp->b_rawblkno * vnd->sc_dkdev.dk_label->d_secsize;
    873  1.157      jmmv 
    874  1.157      jmmv 	bsize = vnd->sc_vp->v_mount->mnt_stat.f_iosize;
    875  1.157      jmmv 	skipped = 0;
    876  1.138      yamt 
    877  1.157      jmmv 	/*
    878  1.157      jmmv 	 * Break the request into bsize pieces and feed them
    879  1.157      jmmv 	 * sequentially using VOP_BMAP/VOP_STRATEGY.
    880  1.157      jmmv 	 * We do it this way to keep from flooding NFS servers if we
    881  1.157      jmmv 	 * are connected to an NFS file.  This places the burden on
    882  1.157      jmmv 	 * the client rather than the server.
    883  1.157      jmmv 	 */
    884  1.157      jmmv 	error = 0;
    885  1.165      yamt 	bp->b_resid = bp->b_bcount;
    886  1.240    bouyer 	for (offset = 0, resid = bp->b_resid; /* true */;
    887  1.157      jmmv 	    resid -= sz, offset += sz) {
    888  1.157      jmmv 		daddr_t nbn;
    889  1.157      jmmv 		int off, nra;
    890  1.157      jmmv 
    891  1.157      jmmv 		nra = 0;
    892  1.200        ad 		vn_lock(vnd->sc_vp, LK_EXCLUSIVE | LK_RETRY);
    893  1.157      jmmv 		error = VOP_BMAP(vnd->sc_vp, bn / bsize, &vp, &nbn, &nra);
    894  1.209   hannken 		VOP_UNLOCK(vnd->sc_vp);
    895   1.51        pk 
    896  1.157      jmmv 		if (error == 0 && (long)nbn == -1)
    897  1.157      jmmv 			error = EIO;
    898  1.126      yamt 
    899  1.112    bouyer 		/*
    900  1.157      jmmv 		 * If there was an error or a hole in the file...punt.
    901  1.157      jmmv 		 * Note that we may have to wait for any operations
    902  1.157      jmmv 		 * that we have already fired off before releasing
    903  1.157      jmmv 		 * the buffer.
    904  1.157      jmmv 		 *
    905  1.157      jmmv 		 * XXX we could deal with holes here but it would be
    906  1.157      jmmv 		 * a hassle (in the write case).
    907  1.112    bouyer 		 */
    908  1.157      jmmv 		if (error) {
    909  1.157      jmmv 			skipped += resid;
    910  1.157      jmmv 			break;
    911  1.157      jmmv 		}
    912   1.41   thorpej 
    913  1.157      jmmv #ifdef DEBUG
    914  1.157      jmmv 		if (!dovndcluster)
    915  1.112    bouyer 			nra = 0;
    916  1.112    bouyer #endif
    917   1.51        pk 
    918  1.157      jmmv 		off = bn % bsize;
    919  1.157      jmmv 		sz = MIN(((off_t)1 + nra) * bsize - off, resid);
    920  1.116  christos #ifdef	DEBUG
    921  1.157      jmmv 		if (vnddebug & VDB_IO)
    922  1.157      jmmv 			printf("vndstrategy: vp %p/%p bn 0x%qx/0x%" PRIx64
    923  1.175        ad 			    " sz 0x%zx\n", vnd->sc_vp, vp, (long long)bn,
    924  1.175        ad 			    nbn, sz);
    925  1.112    bouyer #endif
    926   1.51        pk 
    927  1.175        ad 		nbp = getiobuf(vp, true);
    928  1.157      jmmv 		nestiobuf_setup(bp, nbp, offset, sz);
    929  1.157      jmmv 		nbp->b_blkno = nbn + btodb(off);
    930   1.51        pk 
    931  1.129      yamt #if 0 /* XXX #ifdef DEBUG */
    932  1.157      jmmv 		if (vnddebug & VDB_IO)
    933  1.157      jmmv 			printf("vndstart(%ld): bp %p vp %p blkno "
    934  1.157      jmmv 			    "0x%" PRIx64 " flags %x addr %p cnt 0x%x\n",
    935  1.157      jmmv 			    (long) (vnd-vnd_softc), &nbp->vb_buf,
    936  1.157      jmmv 			    nbp->vb_buf.b_vp, nbp->vb_buf.b_blkno,
    937  1.157      jmmv 			    nbp->vb_buf.b_flags, nbp->vb_buf.b_data,
    938  1.157      jmmv 			    nbp->vb_buf.b_bcount);
    939  1.157      jmmv #endif
    940  1.240    bouyer 		if (resid == sz) {
    941  1.240    bouyer 			break;
    942  1.240    bouyer 		}
    943  1.157      jmmv 		VOP_STRATEGY(vp, nbp);
    944  1.157      jmmv 		bn += sz;
    945  1.157      jmmv 	}
    946  1.240    bouyer 	if (!(flags & B_READ)) {
    947  1.240    bouyer 		struct vnode *w_vp;
    948  1.240    bouyer 		/*
    949  1.240    bouyer 		 * this is the last nested buf, account for
    950  1.240    bouyer 		 * the parent buf write too.
    951  1.240    bouyer 		 * This has to be done last, so that
    952  1.240    bouyer 		 * fsync won't wait for this write which
    953  1.241    bouyer 		 * has no chance to complete before all nested bufs
    954  1.240    bouyer 		 * have been queued. But it has to be done
    955  1.244     prlw1 		 * before the last VOP_STRATEGY()
    956  1.240    bouyer 		 * or the call to nestiobuf_done().
    957  1.240    bouyer 		 */
    958  1.240    bouyer 		w_vp = bp->b_vp;
    959  1.240    bouyer 		mutex_enter(w_vp->v_interlock);
    960  1.240    bouyer 		w_vp->v_numoutput++;
    961  1.240    bouyer 		mutex_exit(w_vp->v_interlock);
    962  1.240    bouyer 	}
    963  1.240    bouyer 	KASSERT(skipped != 0 || nbp != NULL);
    964  1.244     prlw1 	if (skipped)
    965  1.240    bouyer 		nestiobuf_done(bp, skipped, error);
    966  1.244     prlw1 	else
    967  1.240    bouyer 		VOP_STRATEGY(vp, nbp);
    968    1.1    brezak }
    969    1.1    brezak 
    970  1.126      yamt static void
    971  1.129      yamt vndiodone(struct buf *bp)
    972  1.126      yamt {
    973  1.129      yamt 	struct vndxfer *vnx = VND_BUFTOXFER(bp);
    974  1.129      yamt 	struct vnd_softc *vnd = vnx->vx_vnd;
    975  1.129      yamt 	struct buf *obp = bp->b_private;
    976  1.206    bouyer 	int s = splbio();
    977  1.126      yamt 
    978  1.273        ad 	KERNEL_LOCK(1, NULL);		/* XXXSMP */
    979  1.129      yamt 	KASSERT(&vnx->vx_buf == bp);
    980  1.129      yamt 	KASSERT(vnd->sc_active > 0);
    981  1.126      yamt #ifdef DEBUG
    982  1.126      yamt 	if (vnddebug & VDB_IO) {
    983  1.126      yamt 		printf("vndiodone1: bp %p iodone: error %d\n",
    984  1.169        ad 		    bp, bp->b_error);
    985  1.126      yamt 	}
    986  1.126      yamt #endif
    987  1.126      yamt 	disk_unbusy(&vnd->sc_dkdev, bp->b_bcount - bp->b_resid,
    988  1.126      yamt 	    (bp->b_flags & B_READ));
    989  1.129      yamt 	vnd->sc_active--;
    990  1.129      yamt 	if (vnd->sc_active == 0) {
    991  1.129      yamt 		wakeup(&vnd->sc_tab);
    992    1.1    brezak 	}
    993  1.273        ad 	KERNEL_UNLOCK_ONE(NULL);	/* XXXSMP */
    994  1.206    bouyer 	splx(s);
    995  1.129      yamt 	obp->b_error = bp->b_error;
    996  1.129      yamt 	obp->b_resid = bp->b_resid;
    997  1.186    kardel 	buf_destroy(bp);
    998  1.129      yamt 	VND_PUTXFER(vnd, vnx);
    999  1.129      yamt 	biodone(obp);
   1000   1.20   mycroft }
   1001   1.20   mycroft 
   1002   1.22   thorpej /* ARGSUSED */
   1003  1.108   thorpej static int
   1004  1.160  christos vndread(dev_t dev, struct uio *uio, int flags)
   1005   1.20   mycroft {
   1006   1.22   thorpej 	int unit = vndunit(dev);
   1007   1.22   thorpej 	struct vnd_softc *sc;
   1008   1.20   mycroft 
   1009   1.20   mycroft #ifdef DEBUG
   1010   1.20   mycroft 	if (vnddebug & VDB_FOLLOW)
   1011  1.191    cegger 		printf("vndread(0x%"PRIx64", %p)\n", dev, uio);
   1012   1.20   mycroft #endif
   1013   1.22   thorpej 
   1014  1.182    cegger 	sc = device_lookup_private(&vnd_cd, unit);
   1015  1.131      cube 	if (sc == NULL)
   1016  1.131      cube 		return ENXIO;
   1017   1.22   thorpej 
   1018   1.22   thorpej 	if ((sc->sc_flags & VNF_INITED) == 0)
   1019  1.197    dyoung 		return ENXIO;
   1020   1.22   thorpej 
   1021  1.197    dyoung 	return physio(vndstrategy, NULL, dev, B_READ, minphys, uio);
   1022   1.20   mycroft }
   1023   1.20   mycroft 
   1024   1.22   thorpej /* ARGSUSED */
   1025  1.108   thorpej static int
   1026  1.160  christos vndwrite(dev_t dev, struct uio *uio, int flags)
   1027   1.20   mycroft {
   1028   1.22   thorpej 	int unit = vndunit(dev);
   1029   1.22   thorpej 	struct vnd_softc *sc;
   1030   1.20   mycroft 
   1031   1.20   mycroft #ifdef DEBUG
   1032   1.20   mycroft 	if (vnddebug & VDB_FOLLOW)
   1033  1.191    cegger 		printf("vndwrite(0x%"PRIx64", %p)\n", dev, uio);
   1034   1.20   mycroft #endif
   1035   1.22   thorpej 
   1036  1.182    cegger 	sc = device_lookup_private(&vnd_cd, unit);
   1037  1.131      cube 	if (sc == NULL)
   1038  1.131      cube 		return ENXIO;
   1039   1.22   thorpej 
   1040   1.22   thorpej 	if ((sc->sc_flags & VNF_INITED) == 0)
   1041  1.197    dyoung 		return ENXIO;
   1042   1.22   thorpej 
   1043  1.197    dyoung 	return physio(vndstrategy, NULL, dev, B_WRITE, minphys, uio);
   1044    1.1    brezak }
   1045    1.1    brezak 
   1046  1.120  christos static int
   1047  1.124  christos vnd_cget(struct lwp *l, int unit, int *un, struct vattr *va)
   1048  1.120  christos {
   1049  1.219   hannken 	int error;
   1050  1.120  christos 	struct vnd_softc *vnd;
   1051  1.120  christos 
   1052  1.120  christos 	if (*un == -1)
   1053  1.120  christos 		*un = unit;
   1054  1.120  christos 	if (*un < 0)
   1055  1.120  christos 		return EINVAL;
   1056  1.120  christos 
   1057  1.182    cegger 	vnd = device_lookup_private(&vnd_cd, *un);
   1058  1.131      cube 	if (vnd == NULL)
   1059  1.225  christos 		return -1;
   1060  1.120  christos 
   1061  1.120  christos 	if ((vnd->sc_flags & VNF_INITED) == 0)
   1062  1.122  christos 		return -1;
   1063  1.120  christos 
   1064  1.219   hannken 	vn_lock(vnd->sc_vp, LK_SHARED | LK_RETRY);
   1065  1.219   hannken 	error = VOP_GETATTR(vnd->sc_vp, va, l->l_cred);
   1066  1.219   hannken 	VOP_UNLOCK(vnd->sc_vp);
   1067  1.219   hannken 	return error;
   1068  1.120  christos }
   1069  1.120  christos 
   1070  1.199    dyoung static int
   1071  1.199    dyoung vnddoclear(struct vnd_softc *vnd, int pmask, int minor, bool force)
   1072  1.199    dyoung {
   1073  1.199    dyoung 	int error;
   1074  1.199    dyoung 
   1075  1.199    dyoung 	if ((error = vndlock(vnd)) != 0)
   1076  1.199    dyoung 		return error;
   1077  1.199    dyoung 
   1078  1.199    dyoung 	/*
   1079  1.199    dyoung 	 * Don't unconfigure if any other partitions are open
   1080  1.199    dyoung 	 * or if both the character and block flavors of this
   1081  1.199    dyoung 	 * partition are open.
   1082  1.199    dyoung 	 */
   1083  1.204    dyoung 	if (DK_BUSY(vnd, pmask) && !force) {
   1084  1.199    dyoung 		vndunlock(vnd);
   1085  1.199    dyoung 		return EBUSY;
   1086  1.199    dyoung 	}
   1087  1.199    dyoung 
   1088  1.221   mlelstv 	/* Delete all of our wedges */
   1089  1.221   mlelstv 	dkwedge_delall(&vnd->sc_dkdev);
   1090  1.221   mlelstv 
   1091  1.199    dyoung 	/*
   1092  1.199    dyoung 	 * XXX vndclear() might call vndclose() implicitly;
   1093  1.199    dyoung 	 * release lock to avoid recursion
   1094  1.199    dyoung 	 *
   1095  1.199    dyoung 	 * Set VNF_CLEARING to prevent vndopen() from
   1096  1.199    dyoung 	 * sneaking in after we vndunlock().
   1097  1.199    dyoung 	 */
   1098  1.199    dyoung 	vnd->sc_flags |= VNF_CLEARING;
   1099  1.199    dyoung 	vndunlock(vnd);
   1100  1.199    dyoung 	vndclear(vnd, minor);
   1101  1.199    dyoung #ifdef DEBUG
   1102  1.199    dyoung 	if (vnddebug & VDB_INIT)
   1103  1.249  christos 		printf("%s: CLRed\n", __func__);
   1104  1.199    dyoung #endif
   1105  1.199    dyoung 
   1106  1.199    dyoung 	/* Destroy the xfer and buffer pools. */
   1107  1.199    dyoung 	pool_destroy(&vnd->sc_vxpool);
   1108  1.199    dyoung 
   1109  1.199    dyoung 	/* Detach the disk. */
   1110  1.199    dyoung 	disk_detach(&vnd->sc_dkdev);
   1111  1.199    dyoung 
   1112  1.199    dyoung 	return 0;
   1113  1.199    dyoung }
   1114  1.199    dyoung 
   1115  1.249  christos static int
   1116  1.249  christos vndioctl_get(struct lwp *l, void *data, int unit, struct vattr *va)
   1117  1.249  christos {
   1118  1.249  christos 	int error;
   1119  1.249  christos 
   1120  1.249  christos 	KASSERT(l);
   1121  1.251  christos 
   1122  1.252  christos 	/* the first member is always int vnd_unit in all the versions */
   1123  1.249  christos 	if (*(int *)data >= vnd_cd.cd_ndevs)
   1124  1.249  christos 		return ENXIO;
   1125  1.249  christos 
   1126  1.249  christos 	switch (error = vnd_cget(l, unit, (int *)data, va)) {
   1127  1.249  christos 	case -1:
   1128  1.249  christos 		/* unused is not an error */
   1129  1.253  christos 		memset(va, 0, sizeof(*va));
   1130  1.249  christos 		/*FALLTHROUGH*/
   1131  1.249  christos 	case 0:
   1132  1.249  christos 		return 0;
   1133  1.249  christos 	default:
   1134  1.249  christos 		return error;
   1135  1.249  christos 	}
   1136  1.249  christos }
   1137  1.249  christos 
   1138    1.1    brezak /* ARGSUSED */
   1139  1.108   thorpej static int
   1140  1.163  christos vndioctl(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
   1141    1.1    brezak {
   1142  1.199    dyoung 	bool force;
   1143   1.17       cgd 	int unit = vndunit(dev);
   1144   1.65  augustss 	struct vnd_softc *vnd;
   1145   1.17       cgd 	struct vnd_ioctl *vio;
   1146    1.1    brezak 	struct vattr vattr;
   1147  1.214  dholland 	struct pathbuf *pb;
   1148  1.282  dholland 	struct vnode *vp;
   1149   1.32   mycroft 	int error, part, pmask;
   1150  1.223  christos 	uint64_t geomsize;
   1151   1.94      yamt 	int fflags;
   1152   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1153   1.70      fvdl 	struct disklabel newlabel;
   1154   1.70      fvdl #endif
   1155    1.1    brezak 
   1156    1.1    brezak #ifdef DEBUG
   1157   1.17       cgd 	if (vnddebug & VDB_FOLLOW)
   1158  1.191    cegger 		printf("vndioctl(0x%"PRIx64", 0x%lx, %p, 0x%x, %p): unit %d\n",
   1159  1.148        ad 		    dev, cmd, data, flag, l->l_proc, unit);
   1160    1.1    brezak #endif
   1161  1.249  christos 	/* Do the get's first; they don't need initialization or verification */
   1162  1.249  christos 	switch (cmd) {
   1163  1.271  pgoyette 	case VNDIOCGET:
   1164  1.249  christos 		if ((error = vndioctl_get(l, data, unit, &vattr)) != 0)
   1165  1.249  christos 			return error;
   1166  1.249  christos 
   1167  1.271  pgoyette 		struct vnd_user *vnu = data;
   1168  1.249  christos 		vnu->vnu_dev = vattr.va_fsid;
   1169  1.249  christos 		vnu->vnu_ino = vattr.va_fileid;
   1170  1.249  christos 		return 0;
   1171  1.249  christos 
   1172  1.271  pgoyette 	default:
   1173  1.271  pgoyette 		/* First check for COMPAT_50 hook */
   1174  1.272  pgoyette 		MODULE_HOOK_CALL(compat_vndioctl_50_hook,
   1175  1.271  pgoyette 		    (cmd, l, data, unit, &vattr, vndioctl_get),
   1176  1.271  pgoyette 		    enosys(), error);
   1177  1.249  christos 
   1178  1.271  pgoyette 		/*
   1179  1.271  pgoyette 		 * If not present, then COMPAT_30 hook also not
   1180  1.271  pgoyette 		 * present, so just continue with checks for the
   1181  1.271  pgoyette 		 * "write" commands
   1182  1.271  pgoyette 		 */
   1183  1.271  pgoyette 		if (error == ENOSYS) {
   1184  1.271  pgoyette 			error = 0;
   1185  1.271  pgoyette 			break;
   1186  1.271  pgoyette 		}
   1187  1.249  christos 
   1188  1.271  pgoyette 		/* If not already handled, try the COMPAT_30 hook */
   1189  1.271  pgoyette 		if (error == EPASSTHROUGH)
   1190  1.272  pgoyette 			MODULE_HOOK_CALL(compat_vndioctl_30_hook,
   1191  1.271  pgoyette 			    (cmd, l, data, unit, &vattr, vndioctl_get),
   1192  1.271  pgoyette 			    enosys(), error);
   1193  1.271  pgoyette 
   1194  1.271  pgoyette 		/* If no COMPAT_30 module, or not handled, check writes */
   1195  1.271  pgoyette 		if (error == ENOSYS || error == EPASSTHROUGH) {
   1196  1.271  pgoyette 			error = 0;
   1197  1.271  pgoyette 			break;
   1198  1.271  pgoyette 		}
   1199  1.271  pgoyette 		return error;
   1200  1.249  christos 	}
   1201  1.249  christos 
   1202  1.249  christos 	vnd = device_lookup_private(&vnd_cd, unit);
   1203  1.249  christos 	if (vnd == NULL)
   1204  1.131      cube 		return ENXIO;
   1205   1.17       cgd 	vio = (struct vnd_ioctl *)data;
   1206   1.43   thorpej 
   1207   1.43   thorpej 	/* Must be open for writes for these commands... */
   1208   1.43   thorpej 	switch (cmd) {
   1209  1.271  pgoyette 	case VNDIOCSET50:
   1210  1.271  pgoyette 	case VNDIOCCLR50:
   1211  1.271  pgoyette 		if (!compat_vndioctl_50_hook.hooked)
   1212  1.271  pgoyette 			return EINVAL;
   1213  1.271  pgoyette 		/* FALLTHROUGH */
   1214   1.43   thorpej 	case VNDIOCSET:
   1215   1.43   thorpej 	case VNDIOCCLR:
   1216   1.43   thorpej 	case DIOCSDINFO:
   1217   1.43   thorpej 	case DIOCWDINFO:
   1218   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1219   1.70      fvdl 	case ODIOCSDINFO:
   1220   1.70      fvdl 	case ODIOCWDINFO:
   1221   1.70      fvdl #endif
   1222   1.99   thorpej 	case DIOCKLABEL:
   1223   1.43   thorpej 	case DIOCWLABEL:
   1224  1.275  jdolecek 	case DIOCCACHESYNC:
   1225   1.43   thorpej 		if ((flag & FWRITE) == 0)
   1226  1.197    dyoung 			return EBADF;
   1227   1.43   thorpej 	}
   1228   1.43   thorpej 
   1229    1.1    brezak 	switch (cmd) {
   1230  1.284   mlelstv 	case VNDIOCSET50:
   1231  1.284   mlelstv 	case VNDIOCSET:
   1232  1.284   mlelstv 		/* Must not be initialized */
   1233  1.284   mlelstv 		if (vnd->sc_flags & VNF_INITED)
   1234  1.284   mlelstv 			return EBUSY;
   1235  1.284   mlelstv 		break;
   1236  1.284   mlelstv 	default:
   1237  1.284   mlelstv 		/* Must be initialized */
   1238   1.43   thorpej 		if ((vnd->sc_flags & VNF_INITED) == 0)
   1239  1.197    dyoung 			return ENXIO;
   1240  1.284   mlelstv 		break;
   1241   1.43   thorpej 	}
   1242    1.1    brezak 
   1243  1.238  christos 	error = disk_ioctl(&vnd->sc_dkdev, dev, cmd, data, flag, l);
   1244  1.238  christos 	if (error != EPASSTHROUGH)
   1245  1.238  christos 		return error;
   1246  1.238  christos 
   1247   1.43   thorpej 	switch (cmd) {
   1248  1.212       mrg 	case VNDIOCSET50:
   1249   1.17       cgd 	case VNDIOCSET:
   1250   1.24  christos 		if ((error = vndlock(vnd)) != 0)
   1251  1.197    dyoung 			return error;
   1252   1.22   thorpej 
   1253   1.94      yamt 		fflags = FREAD;
   1254   1.94      yamt 		if ((vio->vnd_flags & VNDIOF_READONLY) == 0)
   1255   1.94      yamt 			fflags |= FWRITE;
   1256  1.267   mlelstv 		if ((vio->vnd_flags & VNDIOF_FILEIO) != 0)
   1257  1.267   mlelstv 			vnd->sc_flags |= VNF_USE_VN_RDWR;
   1258  1.214  dholland 		error = pathbuf_copyin(vio->vnd_file, &pb);
   1259  1.214  dholland 		if (error) {
   1260  1.214  dholland 			goto unlock_and_exit;
   1261  1.214  dholland 		}
   1262  1.282  dholland 		error = vn_open(NULL, pb, 0, fflags, 0, &vp, NULL, NULL);
   1263  1.282  dholland 		if (error != 0) {
   1264  1.214  dholland 			pathbuf_destroy(pb);
   1265   1.83     enami 			goto unlock_and_exit;
   1266  1.214  dholland 		}
   1267  1.143    dogcow 		KASSERT(l);
   1268  1.282  dholland 		error = VOP_GETATTR(vp, &vattr, l->l_cred);
   1269  1.282  dholland 		if (!error && vp->v_type != VREG)
   1270   1.94      yamt 			error = EOPNOTSUPP;
   1271  1.205       dsl 		if (!error && vattr.va_bytes < vattr.va_size)
   1272  1.218   hannken 			/* File is definitely sparse, use vn_rdwr() */
   1273  1.218   hannken 			vnd->sc_flags |= VNF_USE_VN_RDWR;
   1274  1.115   hubertf 		if (error) {
   1275  1.282  dholland 			VOP_UNLOCK(vp);
   1276  1.115   hubertf 			goto close_and_exit;
   1277  1.115   hubertf 		}
   1278  1.115   hubertf 
   1279  1.116  christos 		/* If using a compressed file, initialize its info */
   1280  1.115   hubertf 		/* (or abort with an error if kernel has no compression) */
   1281  1.267   mlelstv 		if (vio->vnd_flags & VNDIOF_COMP) {
   1282  1.115   hubertf #ifdef VND_COMPRESSION
   1283  1.116  christos 			struct vnd_comp_header *ch;
   1284  1.116  christos 			int i;
   1285  1.261  riastrad 			uint32_t comp_size;
   1286  1.261  riastrad 			uint32_t comp_maxsize;
   1287  1.244     prlw1 
   1288  1.283    andvar 			/* allocate space for compressed file header */
   1289  1.116  christos 			ch = malloc(sizeof(struct vnd_comp_header),
   1290  1.261  riastrad 			    M_TEMP, M_WAITOK);
   1291  1.244     prlw1 
   1292  1.116  christos 			/* read compressed file header */
   1293  1.282  dholland 			error = vn_rdwr(UIO_READ, vp, (void *)ch,
   1294  1.261  riastrad 			    sizeof(struct vnd_comp_header), 0, UIO_SYSSPACE,
   1295  1.261  riastrad 			    IO_UNIT|IO_NODELOCKED, l->l_cred, NULL, NULL);
   1296  1.198    dyoung 			if (error) {
   1297  1.116  christos 				free(ch, M_TEMP);
   1298  1.282  dholland 				VOP_UNLOCK(vp);
   1299  1.116  christos 				goto close_and_exit;
   1300  1.116  christos 			}
   1301  1.244     prlw1 
   1302  1.261  riastrad 			if (be32toh(ch->block_size) == 0 ||
   1303  1.261  riastrad 			    be32toh(ch->num_blocks) > UINT32_MAX - 1) {
   1304  1.260  riastrad 				free(ch, M_TEMP);
   1305  1.282  dholland 				VOP_UNLOCK(vp);
   1306  1.260  riastrad 				goto close_and_exit;
   1307  1.260  riastrad 			}
   1308  1.260  riastrad 
   1309  1.116  christos 			/* save some header info */
   1310  1.261  riastrad 			vnd->sc_comp_blksz = be32toh(ch->block_size);
   1311  1.116  christos 			/* note last offset is the file byte size */
   1312  1.261  riastrad 			vnd->sc_comp_numoffs = be32toh(ch->num_blocks) + 1;
   1313  1.116  christos 			free(ch, M_TEMP);
   1314  1.254  christos 			if (!DK_DEV_BSIZE_OK(vnd->sc_comp_blksz)) {
   1315  1.282  dholland 				VOP_UNLOCK(vp);
   1316  1.116  christos 				error = EINVAL;
   1317  1.116  christos 				goto close_and_exit;
   1318  1.116  christos 			}
   1319  1.260  riastrad 			KASSERT(0 < vnd->sc_comp_blksz);
   1320  1.260  riastrad 			KASSERT(0 < vnd->sc_comp_numoffs);
   1321  1.262  riastrad 			/*
   1322  1.262  riastrad 			 * @#^@!$& gcc -Wtype-limits refuses to let me
   1323  1.262  riastrad 			 * write SIZE_MAX/sizeof(uint64_t) < numoffs,
   1324  1.262  riastrad 			 * because the range of the type on amd64 makes
   1325  1.262  riastrad 			 * the comparisons always false.
   1326  1.262  riastrad 			 */
   1327  1.262  riastrad #if SIZE_MAX <= UINT32_MAX*(64/CHAR_BIT)
   1328  1.262  riastrad 			if (SIZE_MAX/sizeof(uint64_t) < vnd->sc_comp_numoffs) {
   1329  1.282  dholland 				VOP_UNLOCK(vp);
   1330  1.262  riastrad 				error = EINVAL;
   1331  1.262  riastrad 				goto close_and_exit;
   1332  1.262  riastrad 			}
   1333  1.262  riastrad #endif
   1334  1.262  riastrad 			if ((vattr.va_size < sizeof(struct vnd_comp_header)) ||
   1335  1.260  riastrad 			    (vattr.va_size - sizeof(struct vnd_comp_header) <
   1336  1.260  riastrad 				sizeof(uint64_t)*vnd->sc_comp_numoffs) ||
   1337  1.260  riastrad 			    (UQUAD_MAX/vnd->sc_comp_blksz <
   1338  1.260  riastrad 				vnd->sc_comp_numoffs - 1)) {
   1339  1.282  dholland 				VOP_UNLOCK(vp);
   1340  1.116  christos 				error = EINVAL;
   1341  1.116  christos 				goto close_and_exit;
   1342  1.116  christos 			}
   1343  1.244     prlw1 
   1344  1.116  christos 			/* set decompressed file size */
   1345  1.260  riastrad 			KASSERT(vnd->sc_comp_numoffs - 1 <=
   1346  1.260  riastrad 			    UQUAD_MAX/vnd->sc_comp_blksz);
   1347  1.116  christos 			vattr.va_size =
   1348  1.152      elad 			    ((u_quad_t)vnd->sc_comp_numoffs - 1) *
   1349  1.152      elad 			     (u_quad_t)vnd->sc_comp_blksz;
   1350  1.244     prlw1 
   1351  1.116  christos 			/* allocate space for all the compressed offsets */
   1352  1.260  riastrad 			__CTASSERT(UINT32_MAX <= UQUAD_MAX/sizeof(uint64_t));
   1353  1.116  christos 			vnd->sc_comp_offsets =
   1354  1.261  riastrad 			    malloc(sizeof(uint64_t) * vnd->sc_comp_numoffs,
   1355  1.261  riastrad 				M_DEVBUF, M_WAITOK);
   1356  1.244     prlw1 
   1357  1.116  christos 			/* read in the offsets */
   1358  1.282  dholland 			error = vn_rdwr(UIO_READ, vp,
   1359  1.261  riastrad 			    (void *)vnd->sc_comp_offsets,
   1360  1.261  riastrad 			    sizeof(uint64_t) * vnd->sc_comp_numoffs,
   1361  1.261  riastrad 			    sizeof(struct vnd_comp_header), UIO_SYSSPACE,
   1362  1.148        ad 			  IO_UNIT|IO_NODELOCKED, l->l_cred, NULL, NULL);
   1363  1.198    dyoung 			if (error) {
   1364  1.282  dholland 				VOP_UNLOCK(vp);
   1365  1.116  christos 				goto close_and_exit;
   1366  1.116  christos 			}
   1367  1.116  christos 			/*
   1368  1.116  christos 			 * find largest block size (used for allocation limit).
   1369  1.116  christos 			 * Also convert offset to native byte order.
   1370  1.116  christos 			 */
   1371  1.116  christos 			comp_maxsize = 0;
   1372  1.116  christos 			for (i = 0; i < vnd->sc_comp_numoffs - 1; i++) {
   1373  1.116  christos 				vnd->sc_comp_offsets[i] =
   1374  1.261  riastrad 				    be64toh(vnd->sc_comp_offsets[i]);
   1375  1.261  riastrad 				comp_size =
   1376  1.261  riastrad 				    be64toh(vnd->sc_comp_offsets[i + 1])
   1377  1.261  riastrad 				    - vnd->sc_comp_offsets[i];
   1378  1.116  christos 				if (comp_size > comp_maxsize)
   1379  1.116  christos 					comp_maxsize = comp_size;
   1380  1.116  christos 			}
   1381  1.116  christos 			vnd->sc_comp_offsets[vnd->sc_comp_numoffs - 1] =
   1382  1.261  riastrad 			    be64toh(vnd->sc_comp_offsets[vnd->sc_comp_numoffs
   1383  1.261  riastrad 				    - 1]);
   1384  1.244     prlw1 
   1385  1.116  christos 			/* create compressed data buffer */
   1386  1.116  christos 			vnd->sc_comp_buff = malloc(comp_maxsize,
   1387  1.261  riastrad 			    M_DEVBUF, M_WAITOK);
   1388  1.244     prlw1 
   1389  1.116  christos 			/* create decompressed buffer */
   1390  1.116  christos 			vnd->sc_comp_decombuf = malloc(vnd->sc_comp_blksz,
   1391  1.261  riastrad 			    M_DEVBUF, M_WAITOK);
   1392  1.116  christos 			vnd->sc_comp_buffblk = -1;
   1393  1.244     prlw1 
   1394  1.116  christos 			/* Initialize decompress stream */
   1395  1.196    cegger 			memset(&vnd->sc_comp_stream, 0, sizeof(z_stream));
   1396  1.116  christos 			vnd->sc_comp_stream.zalloc = vnd_alloc;
   1397  1.116  christos 			vnd->sc_comp_stream.zfree = vnd_free;
   1398  1.116  christos 			error = inflateInit2(&vnd->sc_comp_stream, MAX_WBITS);
   1399  1.198    dyoung 			if (error) {
   1400  1.198    dyoung 				if (vnd->sc_comp_stream.msg)
   1401  1.116  christos 					printf("vnd%d: compressed file, %s\n",
   1402  1.261  riastrad 					    unit, vnd->sc_comp_stream.msg);
   1403  1.282  dholland 				VOP_UNLOCK(vp);
   1404  1.116  christos 				error = EINVAL;
   1405  1.116  christos 				goto close_and_exit;
   1406  1.116  christos 			}
   1407  1.244     prlw1 
   1408  1.116  christos 			vnd->sc_flags |= VNF_COMP | VNF_READONLY;
   1409  1.115   hubertf #else /* !VND_COMPRESSION */
   1410  1.282  dholland 			VOP_UNLOCK(vp);
   1411  1.115   hubertf 			error = EOPNOTSUPP;
   1412   1.83     enami 			goto close_and_exit;
   1413  1.115   hubertf #endif /* VND_COMPRESSION */
   1414  1.116  christos 		}
   1415  1.244     prlw1 
   1416  1.282  dholland 		VOP_UNLOCK(vp);
   1417  1.282  dholland 		vnd->sc_vp = vp;
   1418   1.17       cgd 		vnd->sc_size = btodb(vattr.va_size);	/* note truncation */
   1419   1.41   thorpej 
   1420  1.265   mlelstv 		/* get smallest I/O size for underlying device, fall back to
   1421  1.265   mlelstv 		 * fundamental I/O size of underlying filesystem
   1422  1.265   mlelstv 		 */
   1423  1.265   mlelstv 		error = bdev_ioctl(vattr.va_fsid, DIOCGSECTORSIZE, &vnd->sc_iosize, FKIOCTL, l);
   1424  1.265   mlelstv 		if (error)
   1425  1.265   mlelstv 			vnd->sc_iosize = vnd->sc_vp->v_mount->mnt_stat.f_frsize;
   1426  1.265   mlelstv 
   1427  1.280   mlelstv 		/* Default I/O size to DEV_BSIZE */
   1428  1.280   mlelstv 		if (vnd->sc_iosize == 0)
   1429  1.280   mlelstv 			vnd->sc_iosize = DEV_BSIZE;
   1430  1.280   mlelstv 
   1431   1.41   thorpej 		/*
   1432   1.41   thorpej 		 * Use pseudo-geometry specified.  If none was provided,
   1433   1.41   thorpej 		 * use "standard" Adaptec fictitious geometry.
   1434   1.41   thorpej 		 */
   1435   1.41   thorpej 		if (vio->vnd_flags & VNDIOF_HASGEOM) {
   1436   1.41   thorpej 
   1437   1.72   thorpej 			memcpy(&vnd->sc_geom, &vio->vnd_geom,
   1438   1.41   thorpej 			    sizeof(vio->vnd_geom));
   1439   1.41   thorpej 
   1440   1.41   thorpej 			/*
   1441   1.41   thorpej 			 * Sanity-check the sector size.
   1442   1.41   thorpej 			 */
   1443  1.254  christos 			if (!DK_DEV_BSIZE_OK(vnd->sc_geom.vng_secsize) ||
   1444  1.254  christos 			    vnd->sc_geom.vng_ntracks == 0 ||
   1445  1.254  christos 			    vnd->sc_geom.vng_nsectors == 0) {
   1446   1.83     enami 				error = EINVAL;
   1447   1.83     enami 				goto close_and_exit;
   1448   1.41   thorpej 			}
   1449   1.41   thorpej 
   1450   1.41   thorpej 			/*
   1451  1.268   mlelstv 			 * Compute missing cylinder count from size
   1452  1.268   mlelstv 			 */
   1453  1.268   mlelstv 			if (vnd->sc_geom.vng_ncylinders == 0)
   1454  1.278   mlelstv 				vnd->sc_geom.vng_ncylinders = vnd->sc_size / (
   1455  1.278   mlelstv 					(vnd->sc_geom.vng_secsize / DEV_BSIZE) *
   1456  1.278   mlelstv 					vnd->sc_geom.vng_ntracks *
   1457  1.268   mlelstv 					vnd->sc_geom.vng_nsectors);
   1458  1.268   mlelstv 
   1459  1.268   mlelstv 			/*
   1460   1.41   thorpej 			 * Compute the size (in DEV_BSIZE blocks) specified
   1461   1.41   thorpej 			 * by the geometry.
   1462   1.41   thorpej 			 */
   1463  1.235   mlelstv 			geomsize = (int64_t)vnd->sc_geom.vng_nsectors *
   1464   1.41   thorpej 			    vnd->sc_geom.vng_ntracks *
   1465  1.235   mlelstv 			    vnd->sc_geom.vng_ncylinders *
   1466   1.41   thorpej 			    (vnd->sc_geom.vng_secsize / DEV_BSIZE);
   1467   1.41   thorpej 
   1468   1.41   thorpej 			/*
   1469   1.41   thorpej 			 * Sanity-check the size against the specified
   1470   1.41   thorpej 			 * geometry.
   1471   1.41   thorpej 			 */
   1472   1.41   thorpej 			if (vnd->sc_size < geomsize) {
   1473   1.83     enami 				error = EINVAL;
   1474   1.83     enami 				goto close_and_exit;
   1475   1.41   thorpej 			}
   1476  1.118  drochner 		} else if (vnd->sc_size >= (32 * 64)) {
   1477   1.41   thorpej 			/*
   1478   1.41   thorpej 			 * Size must be at least 2048 DEV_BSIZE blocks
   1479   1.41   thorpej 			 * (1M) in order to use this geometry.
   1480   1.41   thorpej 			 */
   1481   1.41   thorpej 			vnd->sc_geom.vng_secsize = DEV_BSIZE;
   1482   1.41   thorpej 			vnd->sc_geom.vng_nsectors = 32;
   1483   1.41   thorpej 			vnd->sc_geom.vng_ntracks = 64;
   1484   1.41   thorpej 			vnd->sc_geom.vng_ncylinders = vnd->sc_size / (64 * 32);
   1485  1.118  drochner 		} else {
   1486  1.118  drochner 			vnd->sc_geom.vng_secsize = DEV_BSIZE;
   1487  1.118  drochner 			vnd->sc_geom.vng_nsectors = 1;
   1488  1.118  drochner 			vnd->sc_geom.vng_ntracks = 1;
   1489  1.118  drochner 			vnd->sc_geom.vng_ncylinders = vnd->sc_size;
   1490   1.41   thorpej 		}
   1491   1.41   thorpej 
   1492  1.222  christos 		vnd_set_geometry(vnd);
   1493  1.174       riz 
   1494   1.94      yamt 		if (vio->vnd_flags & VNDIOF_READONLY) {
   1495   1.94      yamt 			vnd->sc_flags |= VNF_READONLY;
   1496   1.94      yamt 		}
   1497   1.94      yamt 
   1498  1.148        ad 		if ((error = vndsetcred(vnd, l->l_cred)) != 0)
   1499   1.83     enami 			goto close_and_exit;
   1500  1.112    bouyer 
   1501   1.17       cgd 		vndthrottle(vnd, vnd->sc_vp);
   1502  1.205       dsl 		vio->vnd_osize = dbtob(vnd->sc_size);
   1503  1.212       mrg 		if (cmd != VNDIOCSET50)
   1504  1.205       dsl 			vio->vnd_size = dbtob(vnd->sc_size);
   1505   1.17       cgd 		vnd->sc_flags |= VNF_INITED;
   1506  1.112    bouyer 
   1507  1.112    bouyer 		/* create the kernel thread, wait for it to be up */
   1508  1.168        ad 		error = kthread_create(PRI_NONE, 0, NULL, vndthread, vnd,
   1509  1.216     joerg 		    &vnd->sc_kthread, "%s", device_xname(vnd->sc_dev));
   1510  1.112    bouyer 		if (error)
   1511  1.112    bouyer 			goto close_and_exit;
   1512  1.112    bouyer 		while ((vnd->sc_flags & VNF_KTHREAD) == 0) {
   1513  1.112    bouyer 			tsleep(&vnd->sc_kthread, PRIBIO, "vndthr", 0);
   1514  1.112    bouyer 		}
   1515   1.17       cgd #ifdef DEBUG
   1516   1.17       cgd 		if (vnddebug & VDB_INIT)
   1517   1.45      fair 			printf("vndioctl: SET vp %p size 0x%lx %d/%d/%d/%d\n",
   1518   1.41   thorpej 			    vnd->sc_vp, (unsigned long) vnd->sc_size,
   1519   1.41   thorpej 			    vnd->sc_geom.vng_secsize,
   1520   1.41   thorpej 			    vnd->sc_geom.vng_nsectors,
   1521   1.41   thorpej 			    vnd->sc_geom.vng_ntracks,
   1522   1.41   thorpej 			    vnd->sc_geom.vng_ncylinders);
   1523    1.1    brezak #endif
   1524   1.22   thorpej 
   1525   1.23   thorpej 		/* Attach the disk. */
   1526  1.170        ad 		disk_attach(&vnd->sc_dkdev);
   1527   1.23   thorpej 
   1528   1.59   thorpej 		/* Initialize the xfer and buffer pools. */
   1529   1.59   thorpej 		pool_init(&vnd->sc_vxpool, sizeof(struct vndxfer), 0,
   1530  1.166        ad 		    0, 0, "vndxpl", NULL, IPL_BIO);
   1531   1.59   thorpej 
   1532   1.22   thorpej 		vndunlock(vnd);
   1533   1.22   thorpej 
   1534  1.214  dholland 		pathbuf_destroy(pb);
   1535  1.221   mlelstv 
   1536  1.221   mlelstv 		/* Discover wedges on this disk */
   1537  1.221   mlelstv 		dkwedge_discover(&vnd->sc_dkdev);
   1538  1.221   mlelstv 
   1539    1.1    brezak 		break;
   1540   1.83     enami 
   1541   1.83     enami close_and_exit:
   1542  1.282  dholland 		(void) vn_close(vp, fflags, l->l_cred);
   1543  1.214  dholland 		pathbuf_destroy(pb);
   1544   1.83     enami unlock_and_exit:
   1545  1.115   hubertf #ifdef VND_COMPRESSION
   1546  1.116  christos 		/* free any allocated memory (for compressed file) */
   1547  1.198    dyoung 		if (vnd->sc_comp_offsets) {
   1548  1.116  christos 			free(vnd->sc_comp_offsets, M_DEVBUF);
   1549  1.116  christos 			vnd->sc_comp_offsets = NULL;
   1550  1.116  christos 		}
   1551  1.198    dyoung 		if (vnd->sc_comp_buff) {
   1552  1.116  christos 			free(vnd->sc_comp_buff, M_DEVBUF);
   1553  1.116  christos 			vnd->sc_comp_buff = NULL;
   1554  1.116  christos 		}
   1555  1.198    dyoung 		if (vnd->sc_comp_decombuf) {
   1556  1.116  christos 			free(vnd->sc_comp_decombuf, M_DEVBUF);
   1557  1.116  christos 			vnd->sc_comp_decombuf = NULL;
   1558  1.116  christos 		}
   1559  1.115   hubertf #endif /* VND_COMPRESSION */
   1560   1.83     enami 		vndunlock(vnd);
   1561  1.197    dyoung 		return error;
   1562    1.1    brezak 
   1563  1.212       mrg 	case VNDIOCCLR50:
   1564   1.17       cgd 	case VNDIOCCLR:
   1565   1.22   thorpej 		part = DISKPART(dev);
   1566   1.22   thorpej 		pmask = (1 << part);
   1567  1.199    dyoung 		force = (vio->vnd_flags & VNDIOF_FORCE) != 0;
   1568   1.22   thorpej 
   1569  1.199    dyoung 		if ((error = vnddoclear(vnd, pmask, minor(dev), force)) != 0)
   1570  1.199    dyoung 			return error;
   1571   1.23   thorpej 
   1572    1.1    brezak 		break;
   1573   1.80    atatat 
   1574    1.1    brezak 
   1575   1.41   thorpej 	case DIOCWDINFO:
   1576   1.41   thorpej 	case DIOCSDINFO:
   1577   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1578   1.70      fvdl 	case ODIOCWDINFO:
   1579   1.70      fvdl 	case ODIOCSDINFO:
   1580   1.70      fvdl #endif
   1581   1.70      fvdl 	{
   1582   1.70      fvdl 		struct disklabel *lp;
   1583   1.70      fvdl 
   1584   1.41   thorpej 		if ((error = vndlock(vnd)) != 0)
   1585  1.197    dyoung 			return error;
   1586   1.41   thorpej 
   1587   1.41   thorpej 		vnd->sc_flags |= VNF_LABELLING;
   1588   1.41   thorpej 
   1589   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1590   1.70      fvdl 		if (cmd == ODIOCSDINFO || cmd == ODIOCWDINFO) {
   1591   1.70      fvdl 			memset(&newlabel, 0, sizeof newlabel);
   1592   1.70      fvdl 			memcpy(&newlabel, data, sizeof (struct olddisklabel));
   1593   1.70      fvdl 			lp = &newlabel;
   1594   1.70      fvdl 		} else
   1595   1.70      fvdl #endif
   1596   1.70      fvdl 		lp = (struct disklabel *)data;
   1597   1.70      fvdl 
   1598   1.41   thorpej 		error = setdisklabel(vnd->sc_dkdev.dk_label,
   1599   1.70      fvdl 		    lp, 0, vnd->sc_dkdev.dk_cpulabel);
   1600   1.41   thorpej 		if (error == 0) {
   1601   1.70      fvdl 			if (cmd == DIOCWDINFO
   1602   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1603   1.70      fvdl 			    || cmd == ODIOCWDINFO
   1604   1.70      fvdl #endif
   1605   1.70      fvdl 			   )
   1606   1.41   thorpej 				error = writedisklabel(VNDLABELDEV(dev),
   1607   1.41   thorpej 				    vndstrategy, vnd->sc_dkdev.dk_label,
   1608   1.41   thorpej 				    vnd->sc_dkdev.dk_cpulabel);
   1609   1.41   thorpej 		}
   1610   1.41   thorpej 
   1611   1.41   thorpej 		vnd->sc_flags &= ~VNF_LABELLING;
   1612   1.41   thorpej 
   1613   1.41   thorpej 		vndunlock(vnd);
   1614   1.41   thorpej 
   1615   1.41   thorpej 		if (error)
   1616  1.197    dyoung 			return error;
   1617   1.41   thorpej 		break;
   1618   1.70      fvdl 	}
   1619   1.41   thorpej 
   1620   1.99   thorpej 	case DIOCKLABEL:
   1621   1.99   thorpej 		if (*(int *)data != 0)
   1622   1.99   thorpej 			vnd->sc_flags |= VNF_KLABEL;
   1623   1.99   thorpej 		else
   1624   1.99   thorpej 			vnd->sc_flags &= ~VNF_KLABEL;
   1625   1.99   thorpej 		break;
   1626   1.99   thorpej 
   1627   1.41   thorpej 	case DIOCWLABEL:
   1628   1.41   thorpej 		if (*(int *)data != 0)
   1629   1.41   thorpej 			vnd->sc_flags |= VNF_WLABEL;
   1630   1.41   thorpej 		else
   1631   1.41   thorpej 			vnd->sc_flags &= ~VNF_WLABEL;
   1632   1.41   thorpej 		break;
   1633   1.22   thorpej 
   1634   1.47   thorpej 	case DIOCGDEFLABEL:
   1635   1.47   thorpej 		vndgetdefaultlabel(vnd, (struct disklabel *)data);
   1636   1.47   thorpej 		break;
   1637   1.70      fvdl 
   1638   1.70      fvdl #ifdef __HAVE_OLD_DISKLABEL
   1639   1.70      fvdl 	case ODIOCGDEFLABEL:
   1640   1.70      fvdl 		vndgetdefaultlabel(vnd, &newlabel);
   1641   1.70      fvdl 		if (newlabel.d_npartitions > OLDMAXPARTITIONS)
   1642   1.71      fvdl 			return ENOTTY;
   1643   1.70      fvdl 		memcpy(data, &newlabel, sizeof (struct olddisklabel));
   1644   1.70      fvdl 		break;
   1645   1.70      fvdl #endif
   1646  1.195       apb 
   1647  1.275  jdolecek 	case DIOCGSTRATEGY:
   1648  1.275  jdolecek 	    {
   1649  1.275  jdolecek 		struct disk_strategy *dks = (void *)data;
   1650  1.275  jdolecek 
   1651  1.275  jdolecek 		/* No lock needed, never changed */
   1652  1.275  jdolecek 		strlcpy(dks->dks_name,
   1653  1.275  jdolecek 		    bufq_getstrategyname(vnd->sc_tab),
   1654  1.275  jdolecek 		    sizeof(dks->dks_name));
   1655  1.275  jdolecek 		dks->dks_paramlen = 0;
   1656  1.275  jdolecek 		break;
   1657  1.275  jdolecek 	    }
   1658  1.275  jdolecek 	case DIOCGCACHE:
   1659  1.275  jdolecek 	    {
   1660  1.275  jdolecek 		int *bits = (int *)data;
   1661  1.275  jdolecek 		*bits |= DKCACHE_READ | DKCACHE_WRITE;
   1662  1.275  jdolecek 		break;
   1663  1.275  jdolecek 	    }
   1664  1.194  christos 	case DIOCCACHESYNC:
   1665  1.194  christos 		vn_lock(vnd->sc_vp, LK_EXCLUSIVE | LK_RETRY);
   1666  1.194  christos 		error = VOP_FSYNC(vnd->sc_vp, vnd->sc_cred,
   1667  1.195       apb 		    FSYNC_WAIT | FSYNC_DATAONLY | FSYNC_CACHE, 0, 0);
   1668  1.209   hannken 		VOP_UNLOCK(vnd->sc_vp);
   1669  1.194  christos 		return error;
   1670   1.47   thorpej 
   1671    1.1    brezak 	default:
   1672  1.197    dyoung 		return ENOTTY;
   1673    1.1    brezak 	}
   1674   1.22   thorpej 
   1675  1.197    dyoung 	return 0;
   1676    1.1    brezak }
   1677    1.1    brezak 
   1678    1.1    brezak /*
   1679    1.1    brezak  * Duplicate the current processes' credentials.  Since we are called only
   1680    1.1    brezak  * as the result of a SET ioctl and only root can do that, any future access
   1681    1.1    brezak  * to this "disk" is essentially as root.  Note that credentials may change
   1682    1.1    brezak  * if some other uid can write directly to the mapped file (NFS).
   1683    1.1    brezak  */
   1684  1.108   thorpej static int
   1685  1.147      elad vndsetcred(struct vnd_softc *vnd, kauth_cred_t cred)
   1686    1.1    brezak {
   1687    1.1    brezak 	struct uio auio;
   1688    1.1    brezak 	struct iovec aiov;
   1689    1.5       cgd 	char *tmpbuf;
   1690    1.5       cgd 	int error;
   1691    1.1    brezak 
   1692  1.147      elad 	vnd->sc_cred = kauth_cred_dup(cred);
   1693    1.5       cgd 	tmpbuf = malloc(DEV_BSIZE, M_TEMP, M_WAITOK);
   1694    1.5       cgd 
   1695    1.1    brezak 	/* XXX: Horrible kludge to establish credentials for NFS */
   1696    1.1    brezak 	aiov.iov_base = tmpbuf;
   1697  1.264  riastrad 	aiov.iov_len = uimin(DEV_BSIZE, dbtob(vnd->sc_size));
   1698    1.1    brezak 	auio.uio_iov = &aiov;
   1699    1.1    brezak 	auio.uio_iovcnt = 1;
   1700    1.1    brezak 	auio.uio_offset = 0;
   1701    1.1    brezak 	auio.uio_rw = UIO_READ;
   1702    1.1    brezak 	auio.uio_resid = aiov.iov_len;
   1703  1.141      yamt 	UIO_SETUP_SYSSPACE(&auio);
   1704   1.56      fvdl 	vn_lock(vnd->sc_vp, LK_EXCLUSIVE | LK_RETRY);
   1705   1.17       cgd 	error = VOP_READ(vnd->sc_vp, &auio, 0, vnd->sc_cred);
   1706   1.54       bad 	if (error == 0) {
   1707   1.54       bad 		/*
   1708   1.54       bad 		 * Because vnd does all IO directly through the vnode
   1709   1.56      fvdl 		 * we need to flush (at least) the buffer from the above
   1710   1.54       bad 		 * VOP_READ from the buffer cache to prevent cache
   1711   1.54       bad 		 * incoherencies.  Also, be careful to write dirty
   1712   1.54       bad 		 * buffers back to stable storage.
   1713   1.54       bad 		 */
   1714   1.54       bad 		error = vinvalbuf(vnd->sc_vp, V_SAVE, vnd->sc_cred,
   1715  1.124  christos 			    curlwp, 0, 0);
   1716   1.54       bad 	}
   1717  1.209   hannken 	VOP_UNLOCK(vnd->sc_vp);
   1718    1.5       cgd 
   1719    1.5       cgd 	free(tmpbuf, M_TEMP);
   1720  1.197    dyoung 	return error;
   1721    1.1    brezak }
   1722    1.1    brezak 
   1723    1.1    brezak /*
   1724    1.1    brezak  * Set maxactive based on FS type
   1725    1.1    brezak  */
   1726  1.108   thorpej static void
   1727  1.108   thorpej vndthrottle(struct vnd_softc *vnd, struct vnode *vp)
   1728    1.1    brezak {
   1729    1.5       cgd 
   1730  1.208     pooka 	if (vp->v_tag == VT_NFS)
   1731   1.17       cgd 		vnd->sc_maxactive = 2;
   1732    1.1    brezak 	else
   1733   1.17       cgd 		vnd->sc_maxactive = 8;
   1734    1.1    brezak 
   1735   1.17       cgd 	if (vnd->sc_maxactive < 1)
   1736   1.17       cgd 		vnd->sc_maxactive = 1;
   1737    1.1    brezak }
   1738    1.1    brezak 
   1739   1.95  drochner #if 0
   1740  1.108   thorpej static void
   1741  1.108   thorpej vndshutdown(void)
   1742    1.1    brezak {
   1743   1.65  augustss 	struct vnd_softc *vnd;
   1744    1.1    brezak 
   1745   1.17       cgd 	for (vnd = &vnd_softc[0]; vnd < &vnd_softc[numvnd]; vnd++)
   1746   1.17       cgd 		if (vnd->sc_flags & VNF_INITED)
   1747   1.17       cgd 			vndclear(vnd);
   1748    1.1    brezak }
   1749   1.95  drochner #endif
   1750    1.1    brezak 
   1751  1.108   thorpej static void
   1752  1.108   thorpej vndclear(struct vnd_softc *vnd, int myminor)
   1753    1.1    brezak {
   1754   1.65  augustss 	struct vnode *vp = vnd->sc_vp;
   1755   1.94      yamt 	int fflags = FREAD;
   1756   1.95  drochner 	int bmaj, cmaj, i, mn;
   1757  1.113      yamt 	int s;
   1758    1.1    brezak 
   1759    1.1    brezak #ifdef DEBUG
   1760   1.17       cgd 	if (vnddebug & VDB_FOLLOW)
   1761   1.30  christos 		printf("vndclear(%p): vp %p\n", vnd, vp);
   1762    1.1    brezak #endif
   1763   1.95  drochner 	/* locate the major number */
   1764   1.95  drochner 	bmaj = bdevsw_lookup_major(&vnd_bdevsw);
   1765   1.95  drochner 	cmaj = cdevsw_lookup_major(&vnd_cdevsw);
   1766   1.95  drochner 
   1767   1.95  drochner 	/* Nuke the vnodes for any open instances */
   1768   1.95  drochner 	for (i = 0; i < MAXPARTITIONS; i++) {
   1769  1.176      cube 		mn = DISKMINOR(device_unit(vnd->sc_dev), i);
   1770   1.95  drochner 		vdevgone(bmaj, mn, mn, VBLK);
   1771   1.95  drochner 		if (mn != myminor) /* XXX avoid to kill own vnode */
   1772   1.95  drochner 			vdevgone(cmaj, mn, mn, VCHR);
   1773   1.95  drochner 	}
   1774   1.95  drochner 
   1775   1.94      yamt 	if ((vnd->sc_flags & VNF_READONLY) == 0)
   1776   1.94      yamt 		fflags |= FWRITE;
   1777  1.112    bouyer 
   1778  1.113      yamt 	s = splbio();
   1779  1.123      yamt 	bufq_drain(vnd->sc_tab);
   1780  1.113      yamt 	splx(s);
   1781  1.113      yamt 
   1782  1.112    bouyer 	vnd->sc_flags |= VNF_VUNCONF;
   1783  1.112    bouyer 	wakeup(&vnd->sc_tab);
   1784  1.112    bouyer 	while (vnd->sc_flags & VNF_KTHREAD)
   1785  1.112    bouyer 		tsleep(&vnd->sc_kthread, PRIBIO, "vnthr", 0);
   1786  1.112    bouyer 
   1787  1.115   hubertf #ifdef VND_COMPRESSION
   1788  1.116  christos 	/* free the compressed file buffers */
   1789  1.198    dyoung 	if (vnd->sc_flags & VNF_COMP) {
   1790  1.198    dyoung 		if (vnd->sc_comp_offsets) {
   1791  1.116  christos 			free(vnd->sc_comp_offsets, M_DEVBUF);
   1792  1.116  christos 			vnd->sc_comp_offsets = NULL;
   1793  1.116  christos 		}
   1794  1.198    dyoung 		if (vnd->sc_comp_buff) {
   1795  1.116  christos 			free(vnd->sc_comp_buff, M_DEVBUF);
   1796  1.116  christos 			vnd->sc_comp_buff = NULL;
   1797  1.116  christos 		}
   1798  1.198    dyoung 		if (vnd->sc_comp_decombuf) {
   1799  1.116  christos 			free(vnd->sc_comp_decombuf, M_DEVBUF);
   1800  1.116  christos 			vnd->sc_comp_decombuf = NULL;
   1801  1.116  christos 		}
   1802  1.116  christos 	}
   1803  1.115   hubertf #endif /* VND_COMPRESSION */
   1804  1.112    bouyer 	vnd->sc_flags &=
   1805  1.242   mlelstv 	    ~(VNF_INITED | VNF_READONLY | VNF_KLABEL | VNF_VLABEL
   1806  1.203    dyoung 	      | VNF_VUNCONF | VNF_COMP | VNF_CLEARING);
   1807  1.197    dyoung 	if (vp == NULL)
   1808  1.112    bouyer 		panic("vndclear: null vp");
   1809  1.177        ad 	(void) vn_close(vp, fflags, vnd->sc_cred);
   1810  1.147      elad 	kauth_cred_free(vnd->sc_cred);
   1811  1.197    dyoung 	vnd->sc_vp = NULL;
   1812  1.197    dyoung 	vnd->sc_cred = NULL;
   1813   1.17       cgd 	vnd->sc_size = 0;
   1814    1.1    brezak }
   1815    1.1    brezak 
   1816  1.108   thorpej static int
   1817  1.108   thorpej vndsize(dev_t dev)
   1818    1.1    brezak {
   1819   1.41   thorpej 	struct vnd_softc *sc;
   1820   1.41   thorpej 	struct disklabel *lp;
   1821   1.41   thorpej 	int part, unit, omask;
   1822   1.41   thorpej 	int size;
   1823   1.41   thorpej 
   1824   1.41   thorpej 	unit = vndunit(dev);
   1825  1.182    cegger 	sc = device_lookup_private(&vnd_cd, unit);
   1826  1.131      cube 	if (sc == NULL)
   1827  1.131      cube 		return -1;
   1828   1.41   thorpej 
   1829   1.41   thorpej 	if ((sc->sc_flags & VNF_INITED) == 0)
   1830  1.197    dyoung 		return -1;
   1831   1.41   thorpej 
   1832   1.41   thorpej 	part = DISKPART(dev);
   1833   1.41   thorpej 	omask = sc->sc_dkdev.dk_openmask & (1 << part);
   1834   1.41   thorpej 	lp = sc->sc_dkdev.dk_label;
   1835   1.41   thorpej 
   1836  1.124  christos 	if (omask == 0 && vndopen(dev, 0, S_IFBLK, curlwp))	/* XXX */
   1837  1.197    dyoung 		return -1;
   1838   1.41   thorpej 
   1839   1.41   thorpej 	if (lp->d_partitions[part].p_fstype != FS_SWAP)
   1840   1.41   thorpej 		size = -1;
   1841   1.41   thorpej 	else
   1842   1.41   thorpej 		size = lp->d_partitions[part].p_size *
   1843   1.41   thorpej 		    (lp->d_secsize / DEV_BSIZE);
   1844   1.41   thorpej 
   1845  1.124  christos 	if (omask == 0 && vndclose(dev, 0, S_IFBLK, curlwp))	/* XXX */
   1846  1.197    dyoung 		return -1;
   1847    1.1    brezak 
   1848  1.197    dyoung 	return size;
   1849    1.1    brezak }
   1850    1.1    brezak 
   1851  1.108   thorpej static int
   1852  1.163  christos vnddump(dev_t dev, daddr_t blkno, void *va,
   1853  1.160  christos     size_t size)
   1854    1.1    brezak {
   1855   1.16       cgd 
   1856   1.19       cgd 	/* Not implemented. */
   1857   1.19       cgd 	return ENXIO;
   1858   1.41   thorpej }
   1859   1.41   thorpej 
   1860  1.108   thorpej static void
   1861  1.108   thorpej vndgetdefaultlabel(struct vnd_softc *sc, struct disklabel *lp)
   1862   1.41   thorpej {
   1863   1.41   thorpej 	struct vndgeom *vng = &sc->sc_geom;
   1864   1.41   thorpej 	struct partition *pp;
   1865  1.235   mlelstv 	unsigned spb;
   1866   1.41   thorpej 
   1867   1.72   thorpej 	memset(lp, 0, sizeof(*lp));
   1868   1.41   thorpej 
   1869  1.235   mlelstv 	spb = vng->vng_secsize / DEV_BSIZE;
   1870  1.235   mlelstv 	if (sc->sc_size / spb > UINT32_MAX)
   1871  1.233   mlelstv 		lp->d_secperunit = UINT32_MAX;
   1872  1.233   mlelstv 	else
   1873  1.235   mlelstv 		lp->d_secperunit = sc->sc_size / spb;
   1874   1.41   thorpej 	lp->d_secsize = vng->vng_secsize;
   1875   1.41   thorpej 	lp->d_nsectors = vng->vng_nsectors;
   1876   1.41   thorpej 	lp->d_ntracks = vng->vng_ntracks;
   1877   1.41   thorpej 	lp->d_ncylinders = vng->vng_ncylinders;
   1878   1.41   thorpej 	lp->d_secpercyl = lp->d_ntracks * lp->d_nsectors;
   1879   1.41   thorpej 
   1880   1.41   thorpej 	strncpy(lp->d_typename, "vnd", sizeof(lp->d_typename));
   1881  1.239  christos 	lp->d_type = DKTYPE_VND;
   1882   1.41   thorpej 	strncpy(lp->d_packname, "fictitious", sizeof(lp->d_packname));
   1883   1.41   thorpej 	lp->d_rpm = 3600;
   1884   1.41   thorpej 	lp->d_interleave = 1;
   1885   1.41   thorpej 	lp->d_flags = 0;
   1886   1.41   thorpej 
   1887   1.41   thorpej 	pp = &lp->d_partitions[RAW_PART];
   1888   1.41   thorpej 	pp->p_offset = 0;
   1889   1.41   thorpej 	pp->p_size = lp->d_secperunit;
   1890   1.41   thorpej 	pp->p_fstype = FS_UNUSED;
   1891   1.41   thorpej 	lp->d_npartitions = RAW_PART + 1;
   1892   1.41   thorpej 
   1893   1.41   thorpej 	lp->d_magic = DISKMAGIC;
   1894   1.41   thorpej 	lp->d_magic2 = DISKMAGIC;
   1895   1.41   thorpej 	lp->d_checksum = dkcksum(lp);
   1896   1.47   thorpej }
   1897   1.47   thorpej 
   1898   1.47   thorpej /*
   1899   1.47   thorpej  * Read the disklabel from a vnd.  If one is not present, create a fake one.
   1900   1.47   thorpej  */
   1901  1.108   thorpej static void
   1902  1.131      cube vndgetdisklabel(dev_t dev, struct vnd_softc *sc)
   1903   1.47   thorpej {
   1904   1.97       dsl 	const char *errstring;
   1905   1.47   thorpej 	struct disklabel *lp = sc->sc_dkdev.dk_label;
   1906   1.47   thorpej 	struct cpu_disklabel *clp = sc->sc_dkdev.dk_cpulabel;
   1907   1.47   thorpej 	int i;
   1908   1.47   thorpej 
   1909   1.72   thorpej 	memset(clp, 0, sizeof(*clp));
   1910   1.47   thorpej 
   1911   1.47   thorpej 	vndgetdefaultlabel(sc, lp);
   1912   1.41   thorpej 
   1913   1.41   thorpej 	/*
   1914   1.41   thorpej 	 * Call the generic disklabel extraction routine.
   1915   1.41   thorpej 	 */
   1916   1.41   thorpej 	errstring = readdisklabel(VNDLABELDEV(dev), vndstrategy, lp, clp);
   1917   1.41   thorpej 	if (errstring) {
   1918   1.41   thorpej 		/*
   1919   1.41   thorpej 		 * Lack of disklabel is common, but we print the warning
   1920   1.41   thorpej 		 * anyway, since it might contain other useful information.
   1921   1.41   thorpej 		 */
   1922  1.176      cube 		aprint_normal_dev(sc->sc_dev, "%s\n", errstring);
   1923   1.41   thorpej 
   1924   1.41   thorpej 		/*
   1925   1.41   thorpej 		 * For historical reasons, if there's no disklabel
   1926   1.41   thorpej 		 * present, all partitions must be FS_BSDFFS and
   1927   1.41   thorpej 		 * occupy the entire disk.
   1928   1.41   thorpej 		 */
   1929   1.41   thorpej 		for (i = 0; i < MAXPARTITIONS; i++) {
   1930   1.52     enami 			/*
   1931   1.52     enami 			 * Don't wipe out port specific hack (such as
   1932   1.52     enami 			 * dos partition hack of i386 port).
   1933   1.52     enami 			 */
   1934   1.96       dsl 			if (lp->d_partitions[i].p_size != 0)
   1935   1.52     enami 				continue;
   1936   1.52     enami 
   1937   1.41   thorpej 			lp->d_partitions[i].p_size = lp->d_secperunit;
   1938   1.41   thorpej 			lp->d_partitions[i].p_offset = 0;
   1939   1.41   thorpej 			lp->d_partitions[i].p_fstype = FS_BSDFFS;
   1940   1.41   thorpej 		}
   1941   1.41   thorpej 
   1942   1.41   thorpej 		strncpy(lp->d_packname, "default label",
   1943   1.41   thorpej 		    sizeof(lp->d_packname));
   1944   1.47   thorpej 
   1945   1.96       dsl 		lp->d_npartitions = MAXPARTITIONS;
   1946   1.47   thorpej 		lp->d_checksum = dkcksum(lp);
   1947   1.41   thorpej 	}
   1948    1.1    brezak }
   1949   1.22   thorpej 
   1950   1.22   thorpej /*
   1951   1.22   thorpej  * Wait interruptibly for an exclusive lock.
   1952   1.22   thorpej  *
   1953   1.22   thorpej  * XXX
   1954   1.22   thorpej  * Several drivers do this; it should be abstracted and made MP-safe.
   1955   1.22   thorpej  */
   1956   1.22   thorpej static int
   1957  1.108   thorpej vndlock(struct vnd_softc *sc)
   1958   1.22   thorpej {
   1959   1.22   thorpej 	int error;
   1960   1.22   thorpej 
   1961   1.22   thorpej 	while ((sc->sc_flags & VNF_LOCKED) != 0) {
   1962   1.22   thorpej 		sc->sc_flags |= VNF_WANTED;
   1963   1.22   thorpej 		if ((error = tsleep(sc, PRIBIO | PCATCH, "vndlck", 0)) != 0)
   1964  1.197    dyoung 			return error;
   1965   1.22   thorpej 	}
   1966   1.22   thorpej 	sc->sc_flags |= VNF_LOCKED;
   1967  1.197    dyoung 	return 0;
   1968   1.22   thorpej }
   1969   1.22   thorpej 
   1970   1.22   thorpej /*
   1971   1.22   thorpej  * Unlock and wake up any waiters.
   1972   1.22   thorpej  */
   1973   1.22   thorpej static void
   1974  1.108   thorpej vndunlock(struct vnd_softc *sc)
   1975   1.22   thorpej {
   1976   1.22   thorpej 
   1977   1.22   thorpej 	sc->sc_flags &= ~VNF_LOCKED;
   1978   1.22   thorpej 	if ((sc->sc_flags & VNF_WANTED) != 0) {
   1979   1.22   thorpej 		sc->sc_flags &= ~VNF_WANTED;
   1980   1.22   thorpej 		wakeup(sc);
   1981   1.22   thorpej 	}
   1982   1.22   thorpej }
   1983  1.115   hubertf 
   1984  1.115   hubertf #ifdef VND_COMPRESSION
   1985  1.115   hubertf /* compressed file read */
   1986  1.115   hubertf static void
   1987  1.116  christos compstrategy(struct buf *bp, off_t bn)
   1988  1.116  christos {
   1989  1.116  christos 	int error;
   1990  1.116  christos 	int unit = vndunit(bp->b_dev);
   1991  1.131      cube 	struct vnd_softc *vnd =
   1992  1.182    cegger 	    device_lookup_private(&vnd_cd, unit);
   1993  1.116  christos 	u_int32_t comp_block;
   1994  1.116  christos 	struct uio auio;
   1995  1.163  christos 	char *addr;
   1996  1.116  christos 	int s;
   1997  1.116  christos 
   1998  1.116  christos 	/* set up constants for data move */
   1999  1.116  christos 	auio.uio_rw = UIO_READ;
   2000  1.141      yamt 	UIO_SETUP_SYSSPACE(&auio);
   2001  1.116  christos 
   2002  1.116  christos 	/* read, and transfer the data */
   2003  1.116  christos 	addr = bp->b_data;
   2004  1.165      yamt 	bp->b_resid = bp->b_bcount;
   2005  1.116  christos 	s = splbio();
   2006  1.116  christos 	while (bp->b_resid > 0) {
   2007  1.116  christos 		unsigned length;
   2008  1.116  christos 		size_t length_in_buffer;
   2009  1.116  christos 		u_int32_t offset_in_buffer;
   2010  1.116  christos 		struct iovec aiov;
   2011  1.116  christos 
   2012  1.116  christos 		/* calculate the compressed block number */
   2013  1.116  christos 		comp_block = bn / (off_t)vnd->sc_comp_blksz;
   2014  1.116  christos 
   2015  1.116  christos 		/* check for good block number */
   2016  1.116  christos 		if (comp_block >= vnd->sc_comp_numoffs) {
   2017  1.116  christos 			bp->b_error = EINVAL;
   2018  1.116  christos 			splx(s);
   2019  1.116  christos 			return;
   2020  1.116  christos 		}
   2021  1.116  christos 
   2022  1.116  christos 		/* read in the compressed block, if not in buffer */
   2023  1.116  christos 		if (comp_block != vnd->sc_comp_buffblk) {
   2024  1.116  christos 			length = vnd->sc_comp_offsets[comp_block + 1] -
   2025  1.116  christos 			    vnd->sc_comp_offsets[comp_block];
   2026  1.116  christos 			vn_lock(vnd->sc_vp, LK_EXCLUSIVE | LK_RETRY);
   2027  1.116  christos 			error = vn_rdwr(UIO_READ, vnd->sc_vp, vnd->sc_comp_buff,
   2028  1.116  christos 			    length, vnd->sc_comp_offsets[comp_block],
   2029  1.187        ad 			    UIO_SYSSPACE, IO_NODELOCKED|IO_UNIT, vnd->sc_cred,
   2030  1.187        ad 			    NULL, NULL);
   2031  1.116  christos 			if (error) {
   2032  1.116  christos 				bp->b_error = error;
   2033  1.209   hannken 				VOP_UNLOCK(vnd->sc_vp);
   2034  1.116  christos 				splx(s);
   2035  1.116  christos 				return;
   2036  1.116  christos 			}
   2037  1.116  christos 			/* uncompress the buffer */
   2038  1.116  christos 			vnd->sc_comp_stream.next_in = vnd->sc_comp_buff;
   2039  1.116  christos 			vnd->sc_comp_stream.avail_in = length;
   2040  1.116  christos 			vnd->sc_comp_stream.next_out = vnd->sc_comp_decombuf;
   2041  1.116  christos 			vnd->sc_comp_stream.avail_out = vnd->sc_comp_blksz;
   2042  1.116  christos 			inflateReset(&vnd->sc_comp_stream);
   2043  1.116  christos 			error = inflate(&vnd->sc_comp_stream, Z_FINISH);
   2044  1.116  christos 			if (error != Z_STREAM_END) {
   2045  1.116  christos 				if (vnd->sc_comp_stream.msg)
   2046  1.176      cube 					aprint_normal_dev(vnd->sc_dev,
   2047  1.176      cube 					    "compressed file, %s\n",
   2048  1.116  christos 					    vnd->sc_comp_stream.msg);
   2049  1.116  christos 				bp->b_error = EBADMSG;
   2050  1.209   hannken 				VOP_UNLOCK(vnd->sc_vp);
   2051  1.116  christos 				splx(s);
   2052  1.116  christos 				return;
   2053  1.116  christos 			}
   2054  1.116  christos 			vnd->sc_comp_buffblk = comp_block;
   2055  1.209   hannken 			VOP_UNLOCK(vnd->sc_vp);
   2056  1.116  christos 		}
   2057  1.116  christos 
   2058  1.116  christos 		/* transfer the usable uncompressed data */
   2059  1.116  christos 		offset_in_buffer = bn % (off_t)vnd->sc_comp_blksz;
   2060  1.116  christos 		length_in_buffer = vnd->sc_comp_blksz - offset_in_buffer;
   2061  1.116  christos 		if (length_in_buffer > bp->b_resid)
   2062  1.116  christos 			length_in_buffer = bp->b_resid;
   2063  1.116  christos 		auio.uio_iov = &aiov;
   2064  1.116  christos 		auio.uio_iovcnt = 1;
   2065  1.116  christos 		aiov.iov_base = addr;
   2066  1.116  christos 		aiov.iov_len = length_in_buffer;
   2067  1.116  christos 		auio.uio_resid = aiov.iov_len;
   2068  1.116  christos 		auio.uio_offset = 0;
   2069  1.116  christos 		error = uiomove(vnd->sc_comp_decombuf + offset_in_buffer,
   2070  1.116  christos 		    length_in_buffer, &auio);
   2071  1.116  christos 		if (error) {
   2072  1.116  christos 			bp->b_error = error;
   2073  1.116  christos 			splx(s);
   2074  1.116  christos 			return;
   2075  1.116  christos 		}
   2076  1.116  christos 
   2077  1.116  christos 		bn += length_in_buffer;
   2078  1.116  christos 		addr += length_in_buffer;
   2079  1.116  christos 		bp->b_resid -= length_in_buffer;
   2080  1.116  christos 	}
   2081  1.116  christos 	splx(s);
   2082  1.115   hubertf }
   2083  1.115   hubertf 
   2084  1.115   hubertf /* compression memory allocation routines */
   2085  1.115   hubertf static void *
   2086  1.160  christos vnd_alloc(void *aux, u_int items, u_int siz)
   2087  1.116  christos {
   2088  1.117  christos 	return malloc(items * siz, M_TEMP, M_NOWAIT);
   2089  1.115   hubertf }
   2090  1.115   hubertf 
   2091  1.115   hubertf static void
   2092  1.160  christos vnd_free(void *aux, void *ptr)
   2093  1.115   hubertf {
   2094  1.116  christos 	free(ptr, M_TEMP);
   2095  1.115   hubertf }
   2096  1.115   hubertf #endif /* VND_COMPRESSION */
   2097  1.174       riz 
   2098  1.174       riz static void
   2099  1.222  christos vnd_set_geometry(struct vnd_softc *vnd)
   2100  1.174       riz {
   2101  1.222  christos 	struct disk_geom *dg = &vnd->sc_dkdev.dk_geom;
   2102  1.279   mlelstv 	unsigned spb;
   2103  1.174       riz 
   2104  1.222  christos 	memset(dg, 0, sizeof(*dg));
   2105  1.174       riz 
   2106  1.279   mlelstv 	spb = vnd->sc_geom.vng_secsize / DEV_BSIZE;
   2107  1.279   mlelstv 	dg->dg_secperunit = vnd->sc_size / spb;
   2108  1.222  christos 	dg->dg_secsize = vnd->sc_geom.vng_secsize;
   2109  1.222  christos 	dg->dg_nsectors = vnd->sc_geom.vng_nsectors;
   2110  1.222  christos 	dg->dg_ntracks = vnd->sc_geom.vng_ntracks;
   2111  1.222  christos 	dg->dg_ncylinders = vnd->sc_geom.vng_ncylinders;
   2112  1.174       riz 
   2113  1.229     prlw1 #ifdef DEBUG
   2114  1.229     prlw1 	if (vnddebug & VDB_LABEL) {
   2115  1.229     prlw1 		printf("dg->dg_secperunit: %" PRId64 "\n", dg->dg_secperunit);
   2116  1.229     prlw1 		printf("dg->dg_ncylinders: %u\n", dg->dg_ncylinders);
   2117  1.229     prlw1 	}
   2118  1.229     prlw1 #endif
   2119  1.222  christos 	disk_set_info(vnd->sc_dev, &vnd->sc_dkdev, NULL);
   2120  1.174       riz }
   2121  1.193      haad 
   2122  1.230     pooka #ifdef VND_COMPRESSION
   2123  1.230     pooka #define VND_DEPENDS "zlib"
   2124  1.230     pooka #else
   2125  1.230     pooka #define VND_DEPENDS NULL
   2126  1.230     pooka #endif
   2127  1.230     pooka 
   2128  1.230     pooka MODULE(MODULE_CLASS_DRIVER, vnd, VND_DEPENDS);
   2129  1.257  pgoyette 
   2130  1.257  pgoyette #ifdef _MODULE
   2131  1.257  pgoyette int vnd_bmajor = -1, vnd_cmajor = -1;
   2132  1.257  pgoyette 
   2133  1.193      haad CFDRIVER_DECL(vnd, DV_DISK, NULL);
   2134  1.257  pgoyette #endif
   2135  1.193      haad 
   2136  1.193      haad static int
   2137  1.193      haad vnd_modcmd(modcmd_t cmd, void *arg)
   2138  1.193      haad {
   2139  1.257  pgoyette 	int error = 0;
   2140  1.244     prlw1 
   2141  1.193      haad 	switch (cmd) {
   2142  1.193      haad 	case MODULE_CMD_INIT:
   2143  1.257  pgoyette #ifdef _MODULE
   2144  1.193      haad 		error = config_cfdriver_attach(&vnd_cd);
   2145  1.193      haad 		if (error)
   2146  1.193      haad 			break;
   2147  1.193      haad 
   2148  1.193      haad 		error = config_cfattach_attach(vnd_cd.cd_name, &vnd_ca);
   2149  1.193      haad 	        if (error) {
   2150  1.193      haad 			config_cfdriver_detach(&vnd_cd);
   2151  1.259  pgoyette #ifdef DIAGNOSTIC
   2152  1.257  pgoyette 			aprint_error("%s: unable to register cfattach for \n"
   2153  1.257  pgoyette 			    "%s, error %d", __func__, vnd_cd.cd_name, error);
   2154  1.259  pgoyette #endif
   2155  1.193      haad 			break;
   2156  1.193      haad 		}
   2157  1.244     prlw1 
   2158  1.257  pgoyette                 /*
   2159  1.257  pgoyette                  * Attach the {b,c}devsw's
   2160  1.257  pgoyette                  */
   2161  1.257  pgoyette 		error = devsw_attach("vnd", &vnd_bdevsw, &vnd_bmajor,
   2162  1.257  pgoyette 		    &vnd_cdevsw, &vnd_cmajor);
   2163  1.257  pgoyette                 /*
   2164  1.257  pgoyette                  * If devsw_attach fails, remove from autoconf database
   2165  1.257  pgoyette                  */
   2166  1.193      haad 		if (error) {
   2167  1.193      haad 			config_cfattach_detach(vnd_cd.cd_name, &vnd_ca);
   2168  1.193      haad 			config_cfdriver_detach(&vnd_cd);
   2169  1.259  pgoyette #ifdef DIAGNOSTIC
   2170  1.257  pgoyette                         aprint_error("%s: unable to attach %s devsw, "
   2171  1.257  pgoyette                             "error %d", __func__, vnd_cd.cd_name, error);
   2172  1.259  pgoyette #endif
   2173  1.193      haad 			break;
   2174  1.193      haad 		}
   2175  1.257  pgoyette #endif
   2176  1.193      haad 		break;
   2177  1.193      haad 
   2178  1.193      haad 	case MODULE_CMD_FINI:
   2179  1.257  pgoyette #ifdef _MODULE
   2180  1.257  pgoyette                 /*
   2181  1.257  pgoyette                  * Remove {b,c}devsw's
   2182  1.257  pgoyette                  */
   2183  1.257  pgoyette 		devsw_detach(&vnd_bdevsw, &vnd_cdevsw);
   2184  1.257  pgoyette 
   2185  1.257  pgoyette                 /*
   2186  1.257  pgoyette                  * Now remove device from autoconf database
   2187  1.257  pgoyette                  */
   2188  1.193      haad 		error = config_cfattach_detach(vnd_cd.cd_name, &vnd_ca);
   2189  1.257  pgoyette                 if (error) {
   2190  1.258  pgoyette                         (void)devsw_attach("vnd", &vnd_bdevsw, &vnd_bmajor,
   2191  1.257  pgoyette                             &vnd_cdevsw, &vnd_cmajor);
   2192  1.259  pgoyette #ifdef DIAGNOSTIC
   2193  1.257  pgoyette                         aprint_error("%s: failed to detach %s cfattach, "
   2194  1.257  pgoyette                             "error %d\n", __func__, vnd_cd.cd_name, error);
   2195  1.259  pgoyette #endif
   2196  1.257  pgoyette                         break;
   2197  1.257  pgoyette                 }
   2198  1.257  pgoyette                 error = config_cfdriver_detach(&vnd_cd);
   2199  1.257  pgoyette                 if (error) {
   2200  1.258  pgoyette                         (void)config_cfattach_attach(vnd_cd.cd_name, &vnd_ca);
   2201  1.258  pgoyette                         (void)devsw_attach("vnd", &vnd_bdevsw, &vnd_bmajor,
   2202  1.257  pgoyette                             &vnd_cdevsw, &vnd_cmajor);
   2203  1.259  pgoyette #ifdef DIAGNOSTIC
   2204  1.257  pgoyette                         aprint_error("%s: failed to detach %s cfdriver, "
   2205  1.257  pgoyette                             "error %d\n", __func__, vnd_cd.cd_name, error);
   2206  1.257  pgoyette                         break;
   2207  1.259  pgoyette #endif
   2208  1.257  pgoyette                 }
   2209  1.257  pgoyette #endif
   2210  1.193      haad 		break;
   2211  1.193      haad 
   2212  1.193      haad 	case MODULE_CMD_STAT:
   2213  1.193      haad 		return ENOTTY;
   2214  1.193      haad 
   2215  1.193      haad 	default:
   2216  1.193      haad 		return ENOTTY;
   2217  1.193      haad 	}
   2218  1.193      haad 
   2219  1.193      haad 	return error;
   2220  1.193      haad }
   2221