Home | History | Annotate | Line # | Download | only in dev
md.c revision 1.57.2.2
      1  1.57.2.2       jym /*	$NetBSD: md.c,v 1.57.2.2 2009/07/23 23:31:45 jym Exp $	*/
      2       1.1       gwr 
      3       1.1       gwr /*
      4       1.1       gwr  * Copyright (c) 1995 Gordon W. Ross, Leo Weppelman.
      5       1.1       gwr  * All rights reserved.
      6       1.1       gwr  *
      7       1.1       gwr  * Redistribution and use in source and binary forms, with or without
      8       1.1       gwr  * modification, are permitted provided that the following conditions
      9       1.1       gwr  * are met:
     10       1.1       gwr  * 1. Redistributions of source code must retain the above copyright
     11       1.1       gwr  *    notice, this list of conditions and the following disclaimer.
     12       1.1       gwr  * 2. Redistributions in binary form must reproduce the above copyright
     13       1.1       gwr  *    notice, this list of conditions and the following disclaimer in the
     14       1.1       gwr  *    documentation and/or other materials provided with the distribution.
     15       1.1       gwr  * 3. The name of the author may not be used to endorse or promote products
     16       1.1       gwr  *    derived from this software without specific prior written permission.
     17       1.1       gwr  * 4. All advertising materials mentioning features or use of this software
     18       1.1       gwr  *    must display the following acknowledgement:
     19       1.1       gwr  *      This product includes software developed by
     20       1.1       gwr  *			Gordon W. Ross and Leo Weppelman.
     21       1.1       gwr  *
     22       1.1       gwr  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     23       1.1       gwr  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     24       1.1       gwr  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     25       1.1       gwr  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     26       1.1       gwr  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
     27       1.1       gwr  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
     28       1.1       gwr  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
     29       1.1       gwr  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     30       1.1       gwr  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     31       1.1       gwr  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     32       1.1       gwr  */
     33       1.1       gwr 
     34       1.1       gwr /*
     35      1.11        pk  * This implements a general-purpose memory-disk.
     36      1.13    jeremy  * See md.h for notes on the config types.
     37       1.1       gwr  *
     38       1.1       gwr  * Note that this driver provides the same functionality
     39       1.1       gwr  * as the MFS filesystem hack, but this is better because
     40       1.1       gwr  * you can use this for any filesystem type you'd like!
     41       1.1       gwr  *
     42       1.1       gwr  * Credit for most of the kmem ramdisk code goes to:
     43       1.1       gwr  *   Leo Weppelman (atari) and Phil Nelson (pc532)
     44      1.11        pk  * Credit for the ideas behind the "user space memory" code goes
     45       1.1       gwr  * to the authors of the MFS implementation.
     46       1.1       gwr  */
     47      1.27     lukem 
     48      1.27     lukem #include <sys/cdefs.h>
     49  1.57.2.2       jym __KERNEL_RCSID(0, "$NetBSD: md.c,v 1.57.2.2 2009/07/23 23:31:45 jym Exp $");
     50      1.16       mrg 
     51      1.19  jonathan #include "opt_md.h"
     52  1.57.2.1       jym #include "opt_tftproot.h"
     53       1.1       gwr 
     54       1.1       gwr #include <sys/param.h>
     55       1.7       gwr #include <sys/kernel.h>
     56       1.7       gwr #include <sys/malloc.h>
     57       1.1       gwr #include <sys/systm.h>
     58       1.1       gwr #include <sys/buf.h>
     59      1.39      yamt #include <sys/bufq.h>
     60       1.1       gwr #include <sys/device.h>
     61       1.4   thorpej #include <sys/disk.h>
     62       1.8       leo #include <sys/proc.h>
     63       1.8       leo #include <sys/conf.h>
     64      1.14       leo #include <sys/disklabel.h>
     65      1.23       mrg 
     66      1.23       mrg #include <uvm/uvm_extern.h>
     67       1.1       gwr 
     68      1.11        pk #include <dev/md.h>
     69       1.1       gwr 
     70       1.1       gwr /*
     71      1.49       dsl  * The user-space functionality is included by default.
     72      1.11        pk  * Use  `options MEMORY_DISK_SERVER=0' to turn it off.
     73       1.1       gwr  */
     74      1.11        pk #ifndef MEMORY_DISK_SERVER
     75      1.49       dsl #error MEMORY_DISK_SERVER should be defined by opt_md.h
     76      1.33    atatat #endif	/* MEMORY_DISK_SERVER */
     77       1.1       gwr 
     78       1.1       gwr /*
     79      1.21   tsutsui  * We should use the raw partition for ioctl.
     80       1.1       gwr  */
     81      1.21   tsutsui #define MD_UNIT(unit)	DISKUNIT(unit)
     82       1.1       gwr 
     83       1.1       gwr /* autoconfig stuff... */
     84       1.1       gwr 
     85      1.11        pk struct md_softc {
     86       1.4   thorpej 	struct disk sc_dkdev;	/* hook for generic disk handling */
     87      1.11        pk 	struct md_conf sc_md;
     88      1.42      yamt 	struct bufq_state *sc_buflist;
     89       1.1       gwr };
     90      1.11        pk /* shorthand for fields in sc_md: */
     91      1.11        pk #define sc_addr sc_md.md_addr
     92      1.11        pk #define sc_size sc_md.md_size
     93      1.11        pk #define sc_type sc_md.md_type
     94       1.1       gwr 
     95      1.38   thorpej void	mdattach(int);
     96       1.6   thorpej 
     97      1.54    cegger static void	md_attach(device_t, device_t, void *);
     98  1.57.2.2       jym static int	md_detach(device_t, int);
     99      1.38   thorpej 
    100      1.38   thorpej static dev_type_open(mdopen);
    101      1.38   thorpej static dev_type_close(mdclose);
    102      1.38   thorpej static dev_type_read(mdread);
    103      1.38   thorpej static dev_type_write(mdwrite);
    104      1.38   thorpej static dev_type_ioctl(mdioctl);
    105      1.38   thorpej static dev_type_strategy(mdstrategy);
    106      1.38   thorpej static dev_type_size(mdsize);
    107      1.31   gehenna 
    108      1.31   gehenna const struct bdevsw md_bdevsw = {
    109      1.31   gehenna 	mdopen, mdclose, mdstrategy, mdioctl, nodump, mdsize, D_DISK
    110      1.31   gehenna };
    111      1.31   gehenna 
    112      1.31   gehenna const struct cdevsw md_cdevsw = {
    113      1.31   gehenna 	mdopen, mdclose, mdread, mdwrite, mdioctl,
    114      1.32  jdolecek 	nostop, notty, nopoll, nommap, nokqfilter, D_DISK
    115      1.31   gehenna };
    116      1.31   gehenna 
    117      1.45  christos static struct dkdriver mddkdriver = { mdstrategy, NULL };
    118       1.4   thorpej 
    119      1.53  drochner extern struct cfdriver md_cd;
    120  1.57.2.2       jym CFATTACH_DECL3_NEW(md, sizeof(struct md_softc),
    121  1.57.2.2       jym 	0, md_attach, md_detach, NULL, NULL, NULL, DVF_DETACH_SHUTDOWN);
    122       1.4   thorpej 
    123  1.57.2.1       jym extern size_t md_root_size;
    124  1.57.2.1       jym 
    125       1.7       gwr /*
    126       1.7       gwr  * This is called if we are configured as a pseudo-device
    127       1.7       gwr  */
    128       1.7       gwr void
    129      1.38   thorpej mdattach(int n)
    130       1.1       gwr {
    131       1.7       gwr 	int i;
    132      1.54    cegger 	cfdata_t cf;
    133       1.7       gwr 
    134  1.57.2.1       jym #ifdef TFTPROOT
    135  1.57.2.1       jym 	/*
    136  1.57.2.1       jym 	 * Attachement of md0 must be done after md_root_setconf(),
    137  1.57.2.1       jym 	 * because the RAMdisk is not loaded yet.
    138  1.57.2.1       jym 	 */
    139  1.57.2.1       jym 	if (md_root_size == 0)
    140  1.57.2.1       jym 		return;
    141  1.57.2.1       jym #endif
    142      1.53  drochner 	if (config_cfattach_attach("md", &md_ca)) {
    143      1.53  drochner 		printf("md: cfattach_attach failed\n");
    144       1.7       gwr 		return;
    145       1.7       gwr 	}
    146       1.7       gwr 
    147       1.7       gwr 	/* XXX:  Are we supposed to provide a default? */
    148       1.7       gwr 	if (n <= 1)
    149       1.7       gwr 		n = 1;
    150       1.7       gwr 
    151       1.7       gwr 	/* Attach as if by autoconfig. */
    152       1.7       gwr 	for (i = 0; i < n; i++) {
    153      1.53  drochner 		cf = malloc(sizeof(*cf), M_DEVBUF, M_WAITOK);
    154      1.53  drochner 		cf->cf_name = "md";
    155      1.53  drochner 		cf->cf_atname = "md";
    156      1.53  drochner 		cf->cf_unit = i;
    157      1.53  drochner 		cf->cf_fstate = FSTATE_NOTFOUND;
    158      1.54    cegger 		(void)config_attach_pseudo(cf);
    159       1.7       gwr 	}
    160       1.1       gwr }
    161       1.1       gwr 
    162       1.1       gwr static void
    163  1.57.2.2       jym md_attach(device_t parent, device_t self, void *aux)
    164       1.1       gwr {
    165      1.54    cegger 	struct md_softc *sc = device_private(self);
    166       1.1       gwr 
    167      1.42      yamt 	bufq_alloc(&sc->sc_buflist, "fcfs", 0);
    168      1.22   thorpej 
    169       1.1       gwr 	/* XXX - Could accept aux info here to set the config. */
    170      1.11        pk #ifdef	MEMORY_DISK_HOOKS
    171       1.1       gwr 	/*
    172       1.1       gwr 	 * This external function might setup a pre-loaded disk.
    173      1.11        pk 	 * All it would need to do is setup the md_conf struct.
    174      1.25   tsutsui 	 * See sys/dev/md_root.c for an example.
    175       1.1       gwr 	 */
    176      1.54    cegger 	md_attach_hook(device_unit(self), &sc->sc_md);
    177       1.1       gwr #endif
    178       1.4   thorpej 
    179       1.4   thorpej 	/*
    180       1.4   thorpej 	 * Initialize and attach the disk structure.
    181       1.4   thorpej 	 */
    182      1.54    cegger 	disk_init(&sc->sc_dkdev, device_xname(self), &mddkdriver);
    183       1.4   thorpej 	disk_attach(&sc->sc_dkdev);
    184      1.55    cegger 
    185      1.55    cegger 	if (!pmf_device_register(self, NULL, NULL))
    186      1.55    cegger 		aprint_error_dev(self, "couldn't establish power handler\n");
    187       1.1       gwr }
    188       1.1       gwr 
    189  1.57.2.2       jym static int
    190  1.57.2.2       jym md_detach(device_t self, int flags)
    191  1.57.2.2       jym {
    192  1.57.2.2       jym 	struct md_softc *sc = device_private(self);
    193  1.57.2.2       jym 	int rc;
    194  1.57.2.2       jym 
    195  1.57.2.2       jym 	rc = 0;
    196  1.57.2.2       jym 	mutex_enter(&sc->sc_dkdev.dk_openlock);
    197  1.57.2.2       jym 	if (sc->sc_dkdev.dk_openmask == 0)
    198  1.57.2.2       jym 		;	/* nothing to do */
    199  1.57.2.2       jym 	else if ((flags & DETACH_FORCE) == 0)
    200  1.57.2.2       jym 		rc = EBUSY;
    201  1.57.2.2       jym 	mutex_exit(&sc->sc_dkdev.dk_openlock);
    202  1.57.2.2       jym 
    203  1.57.2.2       jym 	if (rc != 0)
    204  1.57.2.2       jym 		return rc;
    205  1.57.2.2       jym 
    206  1.57.2.2       jym 	pmf_device_deregister(self);
    207  1.57.2.2       jym 	disk_detach(&sc->sc_dkdev);
    208  1.57.2.2       jym 	disk_destroy(&sc->sc_dkdev);
    209  1.57.2.2       jym 	bufq_free(sc->sc_buflist);
    210  1.57.2.2       jym 	return 0;
    211  1.57.2.2       jym }
    212  1.57.2.2       jym 
    213       1.1       gwr /*
    214       1.1       gwr  * operational routines:
    215       1.1       gwr  * open, close, read, write, strategy,
    216       1.1       gwr  * ioctl, dump, size
    217       1.1       gwr  */
    218       1.1       gwr 
    219      1.11        pk #if MEMORY_DISK_SERVER
    220      1.38   thorpej static int	md_server_loop(struct md_softc *sc);
    221      1.38   thorpej static int	md_ioctl_server(struct md_softc *sc, struct md_conf *umd,
    222      1.43  christos 		    struct lwp *l);
    223      1.33    atatat #endif	/* MEMORY_DISK_SERVER */
    224      1.38   thorpej static int	md_ioctl_kalloc(struct md_softc *sc, struct md_conf *umd,
    225      1.43  christos 		    struct lwp *l);
    226       1.1       gwr 
    227      1.38   thorpej static int
    228      1.21   tsutsui mdsize(dev_t dev)
    229       1.1       gwr {
    230      1.11        pk 	struct md_softc *sc;
    231       1.1       gwr 
    232      1.54    cegger 	sc = device_lookup_private(&md_cd, MD_UNIT(dev));
    233       1.1       gwr 	if (sc == NULL)
    234       1.1       gwr 		return 0;
    235       1.1       gwr 
    236      1.11        pk 	if (sc->sc_type == MD_UNCONFIGURED)
    237       1.1       gwr 		return 0;
    238       1.1       gwr 
    239       1.1       gwr 	return (sc->sc_size >> DEV_BSHIFT);
    240       1.1       gwr }
    241       1.1       gwr 
    242      1.38   thorpej static int
    243      1.47  christos mdopen(dev_t dev, int flag, int fmt, struct lwp *l)
    244       1.1       gwr {
    245      1.21   tsutsui 	int unit;
    246      1.11        pk 	struct md_softc *sc;
    247       1.1       gwr 
    248      1.21   tsutsui 	unit = MD_UNIT(dev);
    249      1.53  drochner 	sc = device_lookup_private(&md_cd, unit);
    250       1.1       gwr 	if (sc == NULL)
    251       1.1       gwr 		return ENXIO;
    252       1.1       gwr 
    253       1.1       gwr 	/*
    254      1.21   tsutsui 	 * The raw partition is used for ioctl to configure.
    255       1.1       gwr 	 */
    256      1.21   tsutsui 	if (DISKPART(dev) == RAW_PART)
    257       1.1       gwr 		return 0;
    258       1.1       gwr 
    259      1.11        pk #ifdef	MEMORY_DISK_HOOKS
    260       1.1       gwr 	/* Call the open hook to allow loading the device. */
    261      1.11        pk 	md_open_hook(unit, &sc->sc_md);
    262       1.1       gwr #endif
    263       1.1       gwr 
    264       1.1       gwr 	/*
    265       1.1       gwr 	 * This is a normal, "slave" device, so
    266      1.21   tsutsui 	 * enforce initialized.
    267       1.1       gwr 	 */
    268      1.11        pk 	if (sc->sc_type == MD_UNCONFIGURED)
    269       1.1       gwr 		return ENXIO;
    270       1.1       gwr 
    271       1.1       gwr 	return 0;
    272       1.1       gwr }
    273       1.1       gwr 
    274      1.38   thorpej static int
    275      1.47  christos mdclose(dev_t dev, int flag, int fmt, struct lwp *l)
    276       1.1       gwr {
    277       1.1       gwr 
    278       1.1       gwr 	return 0;
    279       1.1       gwr }
    280       1.1       gwr 
    281      1.38   thorpej static int
    282      1.47  christos mdread(dev_t dev, struct uio *uio, int flags)
    283       1.1       gwr {
    284      1.21   tsutsui 	struct md_softc *sc;
    285      1.21   tsutsui 
    286      1.54    cegger 	sc = device_lookup_private(&md_cd, MD_UNIT(dev));
    287      1.21   tsutsui 
    288      1.21   tsutsui 	if (sc->sc_type == MD_UNCONFIGURED)
    289      1.21   tsutsui 		return ENXIO;
    290      1.21   tsutsui 
    291      1.11        pk 	return (physio(mdstrategy, NULL, dev, B_READ, minphys, uio));
    292       1.1       gwr }
    293       1.1       gwr 
    294      1.38   thorpej static int
    295      1.47  christos mdwrite(dev_t dev, struct uio *uio, int flags)
    296       1.1       gwr {
    297      1.21   tsutsui 	struct md_softc *sc;
    298      1.21   tsutsui 
    299      1.54    cegger 	sc = device_lookup_private(&md_cd, MD_UNIT(dev));
    300      1.21   tsutsui 
    301      1.21   tsutsui 	if (sc->sc_type == MD_UNCONFIGURED)
    302      1.21   tsutsui 		return ENXIO;
    303      1.21   tsutsui 
    304      1.11        pk 	return (physio(mdstrategy, NULL, dev, B_WRITE, minphys, uio));
    305       1.1       gwr }
    306       1.1       gwr 
    307       1.1       gwr /*
    308       1.1       gwr  * Handle I/O requests, either directly, or
    309       1.1       gwr  * by passing them to the server process.
    310       1.1       gwr  */
    311      1.38   thorpej static void
    312      1.38   thorpej mdstrategy(struct buf *bp)
    313       1.1       gwr {
    314      1.11        pk 	struct md_softc	*sc;
    315      1.48  christos 	void *	addr;
    316      1.21   tsutsui 	size_t off, xfer;
    317       1.1       gwr 
    318      1.54    cegger 	sc = device_lookup_private(&md_cd, MD_UNIT(bp->b_dev));
    319       1.1       gwr 
    320      1.21   tsutsui 	if (sc->sc_type == MD_UNCONFIGURED) {
    321      1.21   tsutsui 		bp->b_error = ENXIO;
    322      1.21   tsutsui 		goto done;
    323      1.21   tsutsui 	}
    324      1.21   tsutsui 
    325       1.1       gwr 	switch (sc->sc_type) {
    326      1.11        pk #if MEMORY_DISK_SERVER
    327      1.11        pk 	case MD_UMEM_SERVER:
    328       1.1       gwr 		/* Just add this job to the server's queue. */
    329      1.57      yamt 		bufq_put(sc->sc_buflist, bp);
    330      1.48  christos 		wakeup((void *)sc);
    331      1.29   hannken 		/* see md_server_loop() */
    332       1.1       gwr 		/* no biodone in this case */
    333       1.1       gwr 		return;
    334      1.11        pk #endif	/* MEMORY_DISK_SERVER */
    335       1.1       gwr 
    336      1.11        pk 	case MD_KMEM_FIXED:
    337      1.11        pk 	case MD_KMEM_ALLOCATED:
    338       1.1       gwr 		/* These are in kernel space.  Access directly. */
    339       1.1       gwr 		bp->b_resid = bp->b_bcount;
    340       1.1       gwr 		off = (bp->b_blkno << DEV_BSHIFT);
    341       1.1       gwr 		if (off >= sc->sc_size) {
    342       1.1       gwr 			if (bp->b_flags & B_READ)
    343       1.1       gwr 				break;	/* EOF */
    344       1.1       gwr 			goto set_eio;
    345       1.1       gwr 		}
    346       1.1       gwr 		xfer = bp->b_resid;
    347       1.1       gwr 		if (xfer > (sc->sc_size - off))
    348       1.1       gwr 			xfer = (sc->sc_size - off);
    349      1.48  christos 		addr = (char *)sc->sc_addr + off;
    350       1.1       gwr 		if (bp->b_flags & B_READ)
    351      1.26   thorpej 			memcpy(bp->b_data, addr, xfer);
    352       1.1       gwr 		else
    353      1.26   thorpej 			memcpy(addr, bp->b_data, xfer);
    354       1.1       gwr 		bp->b_resid -= xfer;
    355       1.1       gwr 		break;
    356       1.1       gwr 
    357       1.1       gwr 	default:
    358       1.1       gwr 		bp->b_resid = bp->b_bcount;
    359       1.1       gwr 	set_eio:
    360       1.1       gwr 		bp->b_error = EIO;
    361       1.1       gwr 		break;
    362       1.1       gwr 	}
    363      1.21   tsutsui  done:
    364       1.1       gwr 	biodone(bp);
    365       1.1       gwr }
    366       1.1       gwr 
    367      1.38   thorpej static int
    368      1.48  christos mdioctl(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
    369       1.1       gwr {
    370      1.21   tsutsui 	struct md_softc *sc;
    371      1.21   tsutsui 	struct md_conf *umd;
    372       1.1       gwr 
    373      1.54    cegger 	sc = device_lookup_private(&md_cd, MD_UNIT(dev));
    374       1.1       gwr 
    375      1.21   tsutsui 	/* If this is not the raw partition, punt! */
    376      1.21   tsutsui 	if (DISKPART(dev) != RAW_PART)
    377       1.1       gwr 		return ENOTTY;
    378       1.1       gwr 
    379      1.11        pk 	umd = (struct md_conf *)data;
    380       1.1       gwr 	switch (cmd) {
    381      1.11        pk 	case MD_GETCONF:
    382      1.11        pk 		*umd = sc->sc_md;
    383       1.1       gwr 		return 0;
    384       1.1       gwr 
    385      1.11        pk 	case MD_SETCONF:
    386       1.1       gwr 		/* Can only set it once. */
    387      1.11        pk 		if (sc->sc_type != MD_UNCONFIGURED)
    388       1.1       gwr 			break;
    389      1.11        pk 		switch (umd->md_type) {
    390      1.11        pk 		case MD_KMEM_ALLOCATED:
    391      1.43  christos 			return md_ioctl_kalloc(sc, umd, l);
    392      1.11        pk #if MEMORY_DISK_SERVER
    393      1.11        pk 		case MD_UMEM_SERVER:
    394      1.43  christos 			return md_ioctl_server(sc, umd, l);
    395      1.33    atatat #endif	/* MEMORY_DISK_SERVER */
    396       1.1       gwr 		default:
    397       1.1       gwr 			break;
    398       1.1       gwr 		}
    399       1.1       gwr 		break;
    400       1.1       gwr 	}
    401       1.1       gwr 	return EINVAL;
    402       1.1       gwr }
    403       1.1       gwr 
    404       1.1       gwr /*
    405      1.11        pk  * Handle ioctl MD_SETCONF for (sc_type == MD_KMEM_ALLOCATED)
    406       1.1       gwr  * Just allocate some kernel memory and return.
    407       1.1       gwr  */
    408       1.8       leo static int
    409      1.46  christos md_ioctl_kalloc(struct md_softc *sc, struct md_conf *umd,
    410      1.47  christos     struct lwp *l)
    411       1.1       gwr {
    412      1.17       eeh 	vaddr_t addr;
    413      1.21   tsutsui 	vsize_t size;
    414       1.1       gwr 
    415       1.1       gwr 	/* Sanity check the size. */
    416      1.11        pk 	size = umd->md_size;
    417      1.41      yamt 	addr = uvm_km_alloc(kernel_map, size, 0, UVM_KMF_WIRED|UVM_KMF_ZERO);
    418       1.1       gwr 	if (!addr)
    419       1.1       gwr 		return ENOMEM;
    420       1.1       gwr 
    421       1.1       gwr 	/* This unit is now configured. */
    422      1.48  christos 	sc->sc_addr = (void *)addr; 	/* kernel space */
    423       1.1       gwr 	sc->sc_size = (size_t)size;
    424      1.11        pk 	sc->sc_type = MD_KMEM_ALLOCATED;
    425       1.1       gwr 	return 0;
    426      1.40     perry }
    427       1.1       gwr 
    428      1.11        pk #if MEMORY_DISK_SERVER
    429       1.1       gwr 
    430       1.1       gwr /*
    431      1.11        pk  * Handle ioctl MD_SETCONF for (sc_type == MD_UMEM_SERVER)
    432       1.1       gwr  * Set config, then become the I/O server for this unit.
    433       1.1       gwr  */
    434       1.8       leo static int
    435      1.46  christos md_ioctl_server(struct md_softc *sc, struct md_conf *umd,
    436      1.47  christos     struct lwp *l)
    437       1.1       gwr {
    438      1.17       eeh 	vaddr_t end;
    439       1.1       gwr 	int error;
    440       1.1       gwr 
    441       1.1       gwr 	/* Sanity check addr, size. */
    442      1.48  christos 	end = (vaddr_t) ((char *)umd->md_addr + umd->md_size);
    443       1.1       gwr 
    444       1.1       gwr 	if ((end >= VM_MAXUSER_ADDRESS) ||
    445      1.17       eeh 		(end < ((vaddr_t) umd->md_addr)) )
    446       1.1       gwr 		return EINVAL;
    447       1.1       gwr 
    448       1.1       gwr 	/* This unit is now configured. */
    449      1.11        pk 	sc->sc_addr = umd->md_addr; 	/* user space */
    450      1.11        pk 	sc->sc_size = umd->md_size;
    451      1.11        pk 	sc->sc_type = MD_UMEM_SERVER;
    452       1.1       gwr 
    453       1.1       gwr 	/* Become the server daemon */
    454      1.11        pk 	error = md_server_loop(sc);
    455       1.1       gwr 
    456       1.1       gwr 	/* This server is now going away! */
    457      1.11        pk 	sc->sc_type = MD_UNCONFIGURED;
    458       1.1       gwr 	sc->sc_addr = 0;
    459       1.1       gwr 	sc->sc_size = 0;
    460       1.1       gwr 
    461       1.1       gwr 	return (error);
    462      1.40     perry }
    463       1.1       gwr 
    464      1.38   thorpej static int md_sleep_pri = PWAIT | PCATCH;
    465       1.1       gwr 
    466       1.1       gwr static int
    467      1.38   thorpej md_server_loop(struct md_softc *sc)
    468       1.1       gwr {
    469       1.1       gwr 	struct buf *bp;
    470      1.48  christos 	void *addr;	/* user space address */
    471      1.21   tsutsui 	size_t off;	/* offset into "device" */
    472      1.21   tsutsui 	size_t xfer;	/* amount to transfer */
    473       1.1       gwr 	int error;
    474       1.1       gwr 
    475       1.1       gwr 	for (;;) {
    476       1.1       gwr 		/* Wait for some work to arrive. */
    477      1.57      yamt 		while ((bp = bufq_get(sc->sc_buflist)) == NULL) {
    478      1.48  christos 			error = tsleep((void *)sc, md_sleep_pri, "md_idle", 0);
    479       1.1       gwr 			if (error)
    480       1.1       gwr 				return error;
    481       1.1       gwr 		}
    482       1.1       gwr 
    483       1.1       gwr 		/* Do the transfer to/from user space. */
    484       1.1       gwr 		error = 0;
    485       1.1       gwr 		bp->b_resid = bp->b_bcount;
    486       1.1       gwr 		off = (bp->b_blkno << DEV_BSHIFT);
    487       1.1       gwr 		if (off >= sc->sc_size) {
    488       1.1       gwr 			if (bp->b_flags & B_READ)
    489       1.1       gwr 				goto done;	/* EOF (not an error) */
    490       1.1       gwr 			error = EIO;
    491       1.1       gwr 			goto done;
    492       1.1       gwr 		}
    493       1.1       gwr 		xfer = bp->b_resid;
    494       1.1       gwr 		if (xfer > (sc->sc_size - off))
    495       1.1       gwr 			xfer = (sc->sc_size - off);
    496      1.48  christos 		addr = (char *)sc->sc_addr + off;
    497       1.1       gwr 		if (bp->b_flags & B_READ)
    498       1.1       gwr 			error = copyin(addr, bp->b_data, xfer);
    499       1.1       gwr 		else
    500       1.1       gwr 			error = copyout(bp->b_data, addr, xfer);
    501       1.1       gwr 		if (!error)
    502       1.1       gwr 			bp->b_resid -= xfer;
    503       1.1       gwr 
    504       1.1       gwr 	done:
    505       1.1       gwr 		if (error) {
    506       1.1       gwr 			bp->b_error = error;
    507       1.1       gwr 		}
    508       1.1       gwr 		biodone(bp);
    509       1.1       gwr 	}
    510       1.1       gwr }
    511      1.11        pk #endif	/* MEMORY_DISK_SERVER */
    512