Home | History | Annotate | Line # | Download | only in kern
subr_disk.c revision 1.130
      1  1.130   mlelstv /*	$NetBSD: subr_disk.c,v 1.130 2020/03/27 11:13:57 mlelstv Exp $	*/
      2   1.22   thorpej 
      3   1.22   thorpej /*-
      4   1.95        ad  * Copyright (c) 1996, 1997, 1999, 2000, 2009 The NetBSD Foundation, Inc.
      5   1.22   thorpej  * All rights reserved.
      6   1.22   thorpej  *
      7   1.22   thorpej  * This code is derived from software contributed to The NetBSD Foundation
      8   1.22   thorpej  * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
      9   1.22   thorpej  * NASA Ames Research Center.
     10   1.22   thorpej  *
     11   1.22   thorpej  * Redistribution and use in source and binary forms, with or without
     12   1.22   thorpej  * modification, are permitted provided that the following conditions
     13   1.22   thorpej  * are met:
     14   1.22   thorpej  * 1. Redistributions of source code must retain the above copyright
     15   1.22   thorpej  *    notice, this list of conditions and the following disclaimer.
     16   1.22   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     17   1.22   thorpej  *    notice, this list of conditions and the following disclaimer in the
     18   1.22   thorpej  *    documentation and/or other materials provided with the distribution.
     19   1.22   thorpej  *
     20   1.22   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21   1.22   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22   1.22   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23   1.22   thorpej  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24   1.22   thorpej  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25   1.22   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26   1.22   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27   1.22   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28   1.22   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29   1.22   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30   1.22   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     31   1.22   thorpej  */
     32   1.12       cgd 
     33   1.11   mycroft /*
     34   1.11   mycroft  * Copyright (c) 1982, 1986, 1988, 1993
     35   1.11   mycroft  *	The Regents of the University of California.  All rights reserved.
     36   1.11   mycroft  * (c) UNIX System Laboratories, Inc.
     37   1.11   mycroft  * All or some portions of this file are derived from material licensed
     38   1.11   mycroft  * to the University of California by American Telephone and Telegraph
     39   1.11   mycroft  * Co. or Unix System Laboratories, Inc. and are reproduced herein with
     40   1.11   mycroft  * the permission of UNIX System Laboratories, Inc.
     41   1.11   mycroft  *
     42   1.11   mycroft  * Redistribution and use in source and binary forms, with or without
     43   1.11   mycroft  * modification, are permitted provided that the following conditions
     44   1.11   mycroft  * are met:
     45   1.11   mycroft  * 1. Redistributions of source code must retain the above copyright
     46   1.11   mycroft  *    notice, this list of conditions and the following disclaimer.
     47   1.11   mycroft  * 2. Redistributions in binary form must reproduce the above copyright
     48   1.11   mycroft  *    notice, this list of conditions and the following disclaimer in the
     49   1.11   mycroft  *    documentation and/or other materials provided with the distribution.
     50   1.53       agc  * 3. Neither the name of the University nor the names of its contributors
     51   1.11   mycroft  *    may be used to endorse or promote products derived from this software
     52   1.11   mycroft  *    without specific prior written permission.
     53   1.11   mycroft  *
     54   1.11   mycroft  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     55   1.11   mycroft  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     56   1.11   mycroft  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     57   1.11   mycroft  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     58   1.11   mycroft  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     59   1.11   mycroft  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     60   1.11   mycroft  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     61   1.11   mycroft  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     62   1.11   mycroft  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     63   1.11   mycroft  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     64   1.11   mycroft  * SUCH DAMAGE.
     65   1.11   mycroft  *
     66   1.12       cgd  *	@(#)ufs_disksubr.c	8.5 (Berkeley) 1/21/94
     67   1.11   mycroft  */
     68   1.31     lukem 
     69   1.31     lukem #include <sys/cdefs.h>
     70  1.130   mlelstv __KERNEL_RCSID(0, "$NetBSD: subr_disk.c,v 1.130 2020/03/27 11:13:57 mlelstv Exp $");
     71   1.48       mrg 
     72   1.11   mycroft #include <sys/param.h>
     73   1.15   thorpej #include <sys/kernel.h>
     74   1.94      yamt #include <sys/kmem.h>
     75   1.11   mycroft #include <sys/buf.h>
     76  1.107  christos #include <sys/fcntl.h>
     77   1.15   thorpej #include <sys/syslog.h>
     78   1.11   mycroft #include <sys/disklabel.h>
     79   1.15   thorpej #include <sys/disk.h>
     80   1.33    simonb #include <sys/sysctl.h>
     81   1.47       mrg #include <lib/libkern/libkern.h>
     82   1.14   thorpej 
     83   1.14   thorpej /*
     84   1.11   mycroft  * Compute checksum for disk label.
     85   1.11   mycroft  */
     86   1.11   mycroft u_int
     87   1.30    simonb dkcksum(struct disklabel *lp)
     88   1.11   mycroft {
     89   1.98   tsutsui 
     90   1.84    martin 	return dkcksum_sized(lp, lp->d_npartitions);
     91   1.84    martin }
     92   1.84    martin 
     93   1.84    martin u_int
     94   1.84    martin dkcksum_sized(struct disklabel *lp, size_t npartitions)
     95   1.84    martin {
     96   1.98   tsutsui 	uint16_t *start, *end;
     97   1.98   tsutsui 	uint16_t sum = 0;
     98   1.11   mycroft 
     99   1.98   tsutsui 	start = (uint16_t *)lp;
    100   1.98   tsutsui 	end = (uint16_t *)&lp->d_partitions[npartitions];
    101   1.11   mycroft 	while (start < end)
    102   1.11   mycroft 		sum ^= *start++;
    103   1.98   tsutsui 	return sum;
    104   1.11   mycroft }
    105   1.11   mycroft 
    106   1.11   mycroft /*
    107   1.11   mycroft  * Disk error is the preface to plaintive error messages
    108   1.11   mycroft  * about failing disk transfers.  It prints messages of the form
    109   1.11   mycroft 
    110   1.11   mycroft hp0g: hard error reading fsbn 12345 of 12344-12347 (hp0 bn %d cn %d tn %d sn %d)
    111   1.11   mycroft 
    112   1.11   mycroft  * if the offset of the error in the transfer and a disk label
    113   1.11   mycroft  * are both available.  blkdone should be -1 if the position of the error
    114   1.11   mycroft  * is unknown; the disklabel pointer may be null from drivers that have not
    115   1.20  christos  * been converted to use them.  The message is printed with printf
    116   1.11   mycroft  * if pri is LOG_PRINTF, otherwise it uses log at the specified priority.
    117   1.20  christos  * The message should be completed (with at least a newline) with printf
    118   1.11   mycroft  * or addlog, respectively.  There is no trailing space.
    119   1.11   mycroft  */
    120   1.51       dsl #ifndef PRIdaddr
    121   1.51       dsl #define PRIdaddr PRId64
    122   1.51       dsl #endif
    123   1.11   mycroft void
    124   1.38      yamt diskerr(const struct buf *bp, const char *dname, const char *what, int pri,
    125   1.38      yamt     int blkdone, const struct disklabel *lp)
    126   1.11   mycroft {
    127   1.25  drochner 	int unit = DISKUNIT(bp->b_dev), part = DISKPART(bp->b_dev);
    128  1.101  christos 	void (*pr)(const char *, ...) __printflike(1, 2);
    129   1.11   mycroft 	char partname = 'a' + part;
    130   1.51       dsl 	daddr_t sn;
    131   1.51       dsl 
    132   1.52       dsl 	if (/*CONSTCOND*/0)
    133  1.122       kre 		/* Compiler will error this if the format is wrong... */
    134   1.51       dsl 		printf("%" PRIdaddr, bp->b_blkno);
    135   1.11   mycroft 
    136   1.11   mycroft 	if (pri != LOG_PRINTF) {
    137   1.17  christos 		static const char fmt[] = "";
    138   1.17  christos 		log(pri, fmt);
    139   1.11   mycroft 		pr = addlog;
    140   1.11   mycroft 	} else
    141  1.121     joerg 		pr = printf;
    142   1.11   mycroft 	(*pr)("%s%d%c: %s %sing fsbn ", dname, unit, partname, what,
    143   1.11   mycroft 	    bp->b_flags & B_READ ? "read" : "writ");
    144   1.11   mycroft 	sn = bp->b_blkno;
    145   1.11   mycroft 	if (bp->b_bcount <= DEV_BSIZE)
    146   1.51       dsl 		(*pr)("%" PRIdaddr, sn);
    147   1.11   mycroft 	else {
    148   1.11   mycroft 		if (blkdone >= 0) {
    149   1.11   mycroft 			sn += blkdone;
    150   1.51       dsl 			(*pr)("%" PRIdaddr " of ", sn);
    151   1.11   mycroft 		}
    152   1.51       dsl 		(*pr)("%" PRIdaddr "-%" PRIdaddr "", bp->b_blkno,
    153   1.11   mycroft 		    bp->b_blkno + (bp->b_bcount - 1) / DEV_BSIZE);
    154   1.11   mycroft 	}
    155   1.11   mycroft 	if (lp && (blkdone >= 0 || bp->b_bcount <= lp->d_secsize)) {
    156   1.11   mycroft 		sn += lp->d_partitions[part].p_offset;
    157   1.51       dsl 		(*pr)(" (%s%d bn %" PRIdaddr "; cn %" PRIdaddr "",
    158   1.51       dsl 		    dname, unit, sn, sn / lp->d_secpercyl);
    159   1.11   mycroft 		sn %= lp->d_secpercyl;
    160   1.51       dsl 		(*pr)(" tn %" PRIdaddr " sn %" PRIdaddr ")",
    161   1.51       dsl 		    sn / lp->d_nsectors, sn % lp->d_nsectors);
    162   1.11   mycroft 	}
    163   1.15   thorpej }
    164   1.15   thorpej 
    165   1.15   thorpej /*
    166   1.74     blymn  * Searches the iostatlist for the disk corresponding to the
    167   1.15   thorpej  * name provided.
    168   1.15   thorpej  */
    169   1.15   thorpej struct disk *
    170   1.78      yamt disk_find(const char *name)
    171   1.15   thorpej {
    172   1.74     blymn 	struct io_stats *stat;
    173   1.15   thorpej 
    174   1.74     blymn 	stat = iostat_find(name);
    175   1.15   thorpej 
    176   1.75     blymn 	if ((stat != NULL) && (stat->io_type == IOSTAT_DISK))
    177   1.75     blymn 		return stat->io_parent;
    178   1.15   thorpej 
    179   1.76      yamt 	return (NULL);
    180   1.15   thorpej }
    181   1.15   thorpej 
    182   1.89        ad void
    183   1.92      matt disk_init(struct disk *diskp, const char *name, const struct dkdriver *driver)
    184   1.70      yamt {
    185  1.106   mlelstv 	u_int blocksize = DEV_BSIZE;
    186   1.70      yamt 
    187   1.70      yamt 	/*
    188   1.70      yamt 	 * Initialize the wedge-related locks and other fields.
    189   1.70      yamt 	 */
    190   1.87        ad 	mutex_init(&diskp->dk_rawlock, MUTEX_DEFAULT, IPL_NONE);
    191   1.87        ad 	mutex_init(&diskp->dk_openlock, MUTEX_DEFAULT, IPL_NONE);
    192   1.70      yamt 	LIST_INIT(&diskp->dk_wedges);
    193   1.70      yamt 	diskp->dk_nwedges = 0;
    194   1.83       scw 	diskp->dk_labelsector = LABELSECTOR;
    195  1.106   mlelstv 	diskp->dk_blkshift = DK_BSIZE2BLKSHIFT(blocksize);
    196  1.106   mlelstv 	diskp->dk_byteshift = DK_BSIZE2BYTESHIFT(blocksize);
    197   1.89        ad 	diskp->dk_name = name;
    198   1.89        ad 	diskp->dk_driver = driver;
    199   1.70      yamt }
    200   1.70      yamt 
    201   1.89        ad /*
    202  1.128   hannken  * Rename a disk.
    203  1.128   hannken  */
    204  1.128   hannken void
    205  1.128   hannken disk_rename(struct disk *diskp, const char *name)
    206  1.128   hannken {
    207  1.128   hannken 
    208  1.128   hannken 	diskp->dk_name = name;
    209  1.128   hannken 	iostat_rename(diskp->dk_stats, diskp->dk_name);
    210  1.128   hannken }
    211  1.128   hannken 
    212  1.128   hannken /*
    213   1.89        ad  * Attach a disk.
    214   1.89        ad  */
    215   1.89        ad void
    216   1.89        ad disk_attach(struct disk *diskp)
    217   1.15   thorpej {
    218   1.79    kardel 
    219   1.15   thorpej 	/*
    220   1.94      yamt 	 * Allocate and initialize the disklabel structures.
    221   1.15   thorpej 	 */
    222   1.94      yamt 	diskp->dk_label = kmem_zalloc(sizeof(struct disklabel), KM_SLEEP);
    223   1.94      yamt 	diskp->dk_cpulabel = kmem_zalloc(sizeof(struct cpu_disklabel),
    224   1.94      yamt 	    KM_SLEEP);
    225   1.15   thorpej 
    226   1.15   thorpej 	/*
    227   1.74     blymn 	 * Set up the stats collection.
    228   1.15   thorpej 	 */
    229   1.80  christos 	diskp->dk_stats = iostat_alloc(IOSTAT_DISK, diskp, diskp->dk_name);
    230   1.15   thorpej }
    231   1.15   thorpej 
    232   1.96    dyoung int
    233   1.97    dyoung disk_begindetach(struct disk *dk, int (*lastclose)(device_t),
    234   1.96    dyoung     device_t self, int flags)
    235   1.96    dyoung {
    236   1.96    dyoung 	int rc;
    237   1.96    dyoung 
    238   1.96    dyoung 	rc = 0;
    239   1.96    dyoung 	mutex_enter(&dk->dk_openlock);
    240   1.96    dyoung 	if (dk->dk_openmask == 0)
    241   1.96    dyoung 		;	/* nothing to do */
    242   1.96    dyoung 	else if ((flags & DETACH_FORCE) == 0)
    243   1.96    dyoung 		rc = EBUSY;
    244   1.96    dyoung 	else if (lastclose != NULL)
    245   1.96    dyoung 		rc = (*lastclose)(self);
    246   1.96    dyoung 	mutex_exit(&dk->dk_openlock);
    247   1.96    dyoung 
    248   1.96    dyoung 	return rc;
    249   1.96    dyoung }
    250   1.96    dyoung 
    251   1.89        ad /*
    252   1.89        ad  * Detach a disk.
    253   1.89        ad  */
    254   1.89        ad void
    255   1.89        ad disk_detach(struct disk *diskp)
    256   1.15   thorpej {
    257   1.15   thorpej 
    258   1.15   thorpej 	/*
    259   1.74     blymn 	 * Remove from the drivelist.
    260   1.23   thorpej 	 */
    261   1.76      yamt 	iostat_free(diskp->dk_stats);
    262   1.23   thorpej 
    263   1.23   thorpej 	/*
    264   1.81   thorpej 	 * Release the disk-info dictionary.
    265   1.81   thorpej 	 */
    266   1.81   thorpej 	if (diskp->dk_info) {
    267   1.81   thorpej 		prop_object_release(diskp->dk_info);
    268   1.81   thorpej 		diskp->dk_info = NULL;
    269   1.81   thorpej 	}
    270   1.81   thorpej 
    271   1.81   thorpej 	/*
    272   1.15   thorpej 	 * Free the space used by the disklabel structures.
    273   1.15   thorpej 	 */
    274   1.94      yamt 	kmem_free(diskp->dk_label, sizeof(*diskp->dk_label));
    275   1.94      yamt 	kmem_free(diskp->dk_cpulabel, sizeof(*diskp->dk_cpulabel));
    276   1.15   thorpej }
    277   1.15   thorpej 
    278   1.70      yamt void
    279   1.89        ad disk_destroy(struct disk *diskp)
    280   1.70      yamt {
    281   1.70      yamt 
    282   1.87        ad 	mutex_destroy(&diskp->dk_openlock);
    283   1.87        ad 	mutex_destroy(&diskp->dk_rawlock);
    284   1.70      yamt }
    285   1.70      yamt 
    286   1.70      yamt /*
    287  1.118   mlelstv  * Mark the disk as having work queued for metrics collection.
    288  1.118   mlelstv  */
    289  1.118   mlelstv void
    290  1.118   mlelstv disk_wait(struct disk *diskp)
    291  1.118   mlelstv {
    292  1.118   mlelstv 
    293  1.118   mlelstv 	iostat_wait(diskp->dk_stats);
    294  1.118   mlelstv }
    295  1.118   mlelstv 
    296  1.118   mlelstv /*
    297   1.74     blymn  * Mark the disk as busy for metrics collection.
    298   1.15   thorpej  */
    299   1.15   thorpej void
    300   1.30    simonb disk_busy(struct disk *diskp)
    301   1.15   thorpej {
    302   1.76      yamt 
    303   1.74     blymn 	iostat_busy(diskp->dk_stats);
    304   1.15   thorpej }
    305   1.15   thorpej 
    306   1.15   thorpej /*
    307   1.74     blymn  * Finished disk operations, gather metrics.
    308   1.15   thorpej  */
    309   1.15   thorpej void
    310   1.45       mrg disk_unbusy(struct disk *diskp, long bcount, int read)
    311   1.15   thorpej {
    312   1.76      yamt 
    313   1.74     blymn 	iostat_unbusy(diskp->dk_stats, bcount, read);
    314   1.39   hannken }
    315   1.39   hannken 
    316   1.40   hannken /*
    317   1.95        ad  * Return true if disk has an I/O operation in flight.
    318   1.95        ad  */
    319   1.95        ad bool
    320   1.95        ad disk_isbusy(struct disk *diskp)
    321   1.95        ad {
    322   1.95        ad 
    323   1.95        ad 	return iostat_isbusy(diskp->dk_stats);
    324   1.95        ad }
    325   1.95        ad 
    326   1.95        ad /*
    327   1.50      fvdl  * Bounds checking against the media size, used for the raw partition.
    328   1.99       dsl  * secsize, mediasize and b_blkno must all be the same units.
    329   1.99       dsl  * Possibly this has to be DEV_BSIZE (512).
    330   1.50      fvdl  */
    331   1.50      fvdl int
    332   1.73     perry bounds_check_with_mediasize(struct buf *bp, int secsize, uint64_t mediasize)
    333   1.50      fvdl {
    334   1.67      fvdl 	int64_t sz;
    335   1.50      fvdl 
    336  1.113       chs 	if (bp->b_blkno < 0) {
    337  1.113       chs 		/* Reject negative offsets immediately. */
    338  1.113       chs 		bp->b_error = EINVAL;
    339  1.113       chs 		return 0;
    340  1.113       chs 	}
    341  1.113       chs 
    342  1.113       chs 	sz = howmany((int64_t)bp->b_bcount, secsize);
    343  1.113       chs 
    344  1.113       chs 	/*
    345  1.113       chs 	 * bp->b_bcount is a 32-bit value, and we rejected a negative
    346  1.113       chs 	 * bp->b_blkno already, so "bp->b_blkno + sz" cannot overflow.
    347  1.113       chs 	 */
    348   1.50      fvdl 
    349   1.50      fvdl 	if (bp->b_blkno + sz > mediasize) {
    350   1.50      fvdl 		sz = mediasize - bp->b_blkno;
    351   1.50      fvdl 		if (sz == 0) {
    352   1.50      fvdl 			/* If exactly at end of disk, return EOF. */
    353   1.50      fvdl 			bp->b_resid = bp->b_bcount;
    354   1.88        ad 			return 0;
    355   1.50      fvdl 		}
    356   1.50      fvdl 		if (sz < 0) {
    357   1.50      fvdl 			/* If past end of disk, return EINVAL. */
    358   1.50      fvdl 			bp->b_error = EINVAL;
    359   1.88        ad 			return 0;
    360   1.50      fvdl 		}
    361   1.50      fvdl 		/* Otherwise, truncate request. */
    362   1.99       dsl 		bp->b_bcount = sz * secsize;
    363   1.50      fvdl 	}
    364   1.50      fvdl 
    365   1.50      fvdl 	return 1;
    366   1.11   mycroft }
    367   1.82   thorpej 
    368   1.82   thorpej /*
    369   1.83       scw  * Determine the size of the transfer, and make sure it is
    370   1.83       scw  * within the boundaries of the partition. Adjust transfer
    371   1.83       scw  * if needed, and signal errors or early completion.
    372   1.83       scw  */
    373   1.83       scw int
    374   1.83       scw bounds_check_with_label(struct disk *dk, struct buf *bp, int wlabel)
    375   1.83       scw {
    376   1.83       scw 	struct disklabel *lp = dk->dk_label;
    377   1.83       scw 	struct partition *p = lp->d_partitions + DISKPART(bp->b_dev);
    378   1.83       scw 	uint64_t p_size, p_offset, labelsector;
    379   1.83       scw 	int64_t sz;
    380   1.83       scw 
    381  1.113       chs 	if (bp->b_blkno < 0) {
    382  1.113       chs 		/* Reject negative offsets immediately. */
    383  1.113       chs 		bp->b_error = EINVAL;
    384  1.113       chs 		return -1;
    385  1.113       chs 	}
    386  1.113       chs 
    387   1.83       scw 	/* Protect against division by zero. XXX: Should never happen?!?! */
    388  1.129      cnst 	if ((lp->d_secsize / DEV_BSIZE) == 0 || lp->d_secpercyl == 0) {
    389   1.83       scw 		bp->b_error = EINVAL;
    390   1.88        ad 		return -1;
    391   1.83       scw 	}
    392   1.83       scw 
    393  1.100       mrg 	p_size = (uint64_t)p->p_size << dk->dk_blkshift;
    394  1.100       mrg 	p_offset = (uint64_t)p->p_offset << dk->dk_blkshift;
    395   1.83       scw #if RAW_PART == 3
    396   1.83       scw 	labelsector = lp->d_partitions[2].p_offset;
    397   1.83       scw #else
    398   1.83       scw 	labelsector = lp->d_partitions[RAW_PART].p_offset;
    399   1.83       scw #endif
    400   1.83       scw 	labelsector = (labelsector + dk->dk_labelsector) << dk->dk_blkshift;
    401   1.83       scw 
    402  1.113       chs 	sz = howmany((int64_t)bp->b_bcount, DEV_BSIZE);
    403  1.113       chs 
    404  1.113       chs 	/*
    405  1.113       chs 	 * bp->b_bcount is a 32-bit value, and we rejected a negative
    406  1.113       chs 	 * bp->b_blkno already, so "bp->b_blkno + sz" cannot overflow.
    407  1.113       chs 	 */
    408  1.113       chs 
    409  1.113       chs 	if (bp->b_blkno + sz > p_size) {
    410   1.83       scw 		sz = p_size - bp->b_blkno;
    411   1.83       scw 		if (sz == 0) {
    412   1.83       scw 			/* If exactly at end of disk, return EOF. */
    413   1.83       scw 			bp->b_resid = bp->b_bcount;
    414   1.88        ad 			return 0;
    415   1.83       scw 		}
    416   1.83       scw 		if (sz < 0) {
    417   1.83       scw 			/* If past end of disk, return EINVAL. */
    418   1.83       scw 			bp->b_error = EINVAL;
    419   1.88        ad 			return -1;
    420   1.83       scw 		}
    421   1.83       scw 		/* Otherwise, truncate request. */
    422   1.83       scw 		bp->b_bcount = sz << DEV_BSHIFT;
    423   1.83       scw 	}
    424   1.83       scw 
    425   1.83       scw 	/* Overwriting disk label? */
    426   1.83       scw 	if (bp->b_blkno + p_offset <= labelsector &&
    427   1.83       scw 	    bp->b_blkno + p_offset + sz > labelsector &&
    428   1.83       scw 	    (bp->b_flags & B_READ) == 0 && !wlabel) {
    429   1.83       scw 		bp->b_error = EROFS;
    430   1.88        ad 		return -1;
    431   1.83       scw 	}
    432   1.83       scw 
    433   1.83       scw 	/* calculate cylinder for disksort to order transfers with */
    434   1.83       scw 	bp->b_cylinder = (bp->b_blkno + p->p_offset) /
    435   1.83       scw 	    (lp->d_secsize / DEV_BSIZE) / lp->d_secpercyl;
    436   1.88        ad 	return 1;
    437   1.83       scw }
    438   1.83       scw 
    439   1.86    dyoung int
    440   1.86    dyoung disk_read_sectors(void (*strat)(struct buf *), const struct disklabel *lp,
    441   1.86    dyoung     struct buf *bp, unsigned int sector, int count)
    442   1.86    dyoung {
    443  1.130   mlelstv 
    444  1.130   mlelstv 	if ((lp->d_secsize / DEV_BSIZE) == 0 || lp->d_secpercyl == 0)
    445  1.130   mlelstv 		return EINVAL;
    446  1.130   mlelstv 
    447  1.114   mlelstv 	bp->b_blkno = btodb((off_t)sector * lp->d_secsize);
    448   1.86    dyoung 	bp->b_bcount = count * lp->d_secsize;
    449   1.90        ad 	bp->b_flags = (bp->b_flags & ~B_WRITE) | B_READ;
    450   1.90        ad 	bp->b_oflags &= ~BO_DONE;
    451   1.86    dyoung 	bp->b_cylinder = sector / lp->d_secpercyl;
    452   1.86    dyoung 	(*strat)(bp);
    453   1.86    dyoung 	return biowait(bp);
    454   1.86    dyoung }
    455   1.86    dyoung 
    456   1.86    dyoung const char *
    457   1.86    dyoung convertdisklabel(struct disklabel *lp, void (*strat)(struct buf *),
    458   1.86    dyoung     struct buf *bp, uint32_t secperunit)
    459   1.86    dyoung {
    460   1.86    dyoung 	struct partition rp, *altp, *p;
    461   1.86    dyoung 	int geom_ok;
    462  1.116  christos 	const char *str;
    463   1.86    dyoung 
    464   1.86    dyoung 	memset(&rp, 0, sizeof(rp));
    465   1.86    dyoung 	rp.p_size = secperunit;
    466   1.86    dyoung 	rp.p_fstype = FS_UNUSED;
    467   1.86    dyoung 
    468   1.86    dyoung 	/* If we can seek to d_secperunit - 1, believe the disk geometry. */
    469   1.86    dyoung 	if (secperunit != 0 &&
    470   1.86    dyoung 	    disk_read_sectors(strat, lp, bp, secperunit - 1, 1) == 0)
    471   1.86    dyoung 		geom_ok = 1;
    472   1.86    dyoung 	else
    473   1.86    dyoung 		geom_ok = 0;
    474   1.86    dyoung 
    475   1.86    dyoung #if 0
    476   1.86    dyoung 	printf("%s: secperunit (%" PRIu32 ") %s\n", __func__,
    477   1.86    dyoung 	    secperunit, geom_ok ? "ok" : "not ok");
    478   1.86    dyoung #endif
    479   1.86    dyoung 
    480   1.86    dyoung 	p = &lp->d_partitions[RAW_PART];
    481   1.86    dyoung 	if (RAW_PART == 'c' - 'a')
    482   1.86    dyoung 		altp = &lp->d_partitions['d' - 'a'];
    483   1.86    dyoung 	else
    484   1.86    dyoung 		altp = &lp->d_partitions['c' - 'a'];
    485   1.86    dyoung 
    486   1.86    dyoung 	if (lp->d_npartitions > RAW_PART && p->p_offset == 0 && p->p_size != 0)
    487  1.116  christos 		return NULL;	/* already a raw partition */
    488   1.86    dyoung 	else if (lp->d_npartitions > MAX('c', 'd') - 'a' &&
    489   1.86    dyoung 		 altp->p_offset == 0 && altp->p_size != 0) {
    490   1.86    dyoung 		/* alternate partition ('c' or 'd') is suitable for raw slot,
    491   1.86    dyoung 		 * swap with 'd' or 'c'.
    492   1.86    dyoung 		 */
    493   1.86    dyoung 		rp = *p;
    494   1.86    dyoung 		*p = *altp;
    495   1.86    dyoung 		*altp = rp;
    496  1.116  christos 		return NULL;
    497   1.86    dyoung 	} else if (lp->d_npartitions <= RAW_PART &&
    498   1.86    dyoung 	           lp->d_npartitions > 'c' - 'a') {
    499   1.86    dyoung 		/* No raw partition is present, but the alternate is present.
    500   1.86    dyoung 		 * Copy alternate to raw partition.
    501   1.86    dyoung 		 */
    502   1.86    dyoung 		lp->d_npartitions = RAW_PART + 1;
    503   1.86    dyoung 		*p = *altp;
    504  1.116  christos 		return NULL;
    505   1.86    dyoung 	} else if (!geom_ok)
    506  1.116  christos 		str = "no raw partition and disk reports bad geometry";
    507   1.86    dyoung 	else if (lp->d_npartitions <= RAW_PART) {
    508   1.86    dyoung 		memset(&lp->d_partitions[lp->d_npartitions], 0,
    509   1.86    dyoung 		    sizeof(struct partition) * (RAW_PART - lp->d_npartitions));
    510   1.86    dyoung 		*p = rp;
    511   1.86    dyoung 		lp->d_npartitions = RAW_PART + 1;
    512  1.116  christos 		return NULL;
    513   1.86    dyoung 	} else if (lp->d_npartitions < MAXPARTITIONS) {
    514   1.86    dyoung 		memmove(p + 1, p,
    515   1.86    dyoung 		    sizeof(struct partition) * (lp->d_npartitions - RAW_PART));
    516   1.86    dyoung 		*p = rp;
    517   1.86    dyoung 		lp->d_npartitions++;
    518  1.116  christos 		return NULL;
    519   1.86    dyoung 	} else
    520  1.116  christos 		str = "no raw partition and partition table is full";
    521  1.116  christos #ifdef DIAGNOSTIC
    522  1.116  christos 	printf("Bad partition: %s\n", str);
    523  1.116  christos 	printf("type = %u, subtype = %u, typename = %s\n",
    524  1.116  christos 	    lp->d_type, lp->d_subtype, lp->d_typename);
    525  1.116  christos 	printf("secsize = %u, nsectors = %u, ntracks = %u\n",
    526  1.116  christos 	    lp->d_secsize, lp->d_nsectors, lp->d_ntracks);
    527  1.116  christos 	printf("ncylinders = %u, secpercyl = %u, secperunit = %u\n",
    528  1.116  christos 	    lp->d_ncylinders, lp->d_secpercyl, lp->d_secperunit);
    529  1.116  christos 	printf("npartitions = %u\n", lp->d_npartitions);
    530  1.116  christos 
    531  1.116  christos 	for (size_t i = 0; i < MIN(lp->d_npartitions, MAXPARTITIONS); i++) {
    532  1.116  christos 		p = &lp->d_partitions[i];
    533  1.116  christos 		printf("\t%c: offset = %u size = %u fstype = %u\n",
    534  1.116  christos 		    (char)(i + 'a'), p->p_offset, p->p_size, p->p_fstype);
    535  1.116  christos 	}
    536  1.116  christos #endif
    537  1.116  christos 	return str;
    538   1.86    dyoung }
    539   1.86    dyoung 
    540   1.83       scw /*
    541   1.82   thorpej  * disk_ioctl --
    542   1.82   thorpej  *	Generic disk ioctl handling.
    543   1.82   thorpej  */
    544   1.82   thorpej int
    545  1.108  christos disk_ioctl(struct disk *dk, dev_t dev, u_long cmd, void *data, int flag,
    546  1.108  christos     struct lwp *l)
    547   1.82   thorpej {
    548  1.107  christos 	struct dkwedge_info *dkw;
    549  1.115  christos 	struct partinfo *pi;
    550  1.115  christos 	struct partition *dp;
    551  1.108  christos #ifdef __HAVE_OLD_DISKLABEL
    552  1.108  christos 	struct disklabel newlabel;
    553  1.108  christos #endif
    554   1.82   thorpej 
    555   1.82   thorpej 	switch (cmd) {
    556  1.109  christos 	case DIOCGDISKINFO:
    557  1.109  christos 		if (dk->dk_info == NULL)
    558  1.109  christos 			return ENOTSUP;
    559  1.109  christos 		return prop_dictionary_copyout_ioctl(data, cmd, dk->dk_info);
    560  1.109  christos 
    561  1.109  christos 	case DIOCGSECTORSIZE:
    562  1.109  christos 		*(u_int *)data = dk->dk_geom.dg_secsize;
    563  1.109  christos 		return 0;
    564  1.109  christos 
    565  1.109  christos 	case DIOCGMEDIASIZE:
    566  1.109  christos 		*(off_t *)data = (off_t)dk->dk_geom.dg_secsize *
    567  1.109  christos 		    dk->dk_geom.dg_secperunit;
    568  1.109  christos 		return 0;
    569  1.109  christos 	default:
    570  1.109  christos 		break;
    571  1.109  christos 	}
    572  1.109  christos 
    573  1.111  christos 	if (dev == NODEV)
    574  1.109  christos 		return EPASSTHROUGH;
    575  1.109  christos 
    576  1.109  christos 	/* The following should be moved to dk_ioctl */
    577  1.109  christos 	switch (cmd) {
    578  1.108  christos 	case DIOCGDINFO:
    579  1.115  christos 		if (dk->dk_label == NULL)
    580  1.115  christos 			return EBUSY;
    581  1.108  christos 		memcpy(data, dk->dk_label, sizeof (*dk->dk_label));
    582  1.108  christos 		return 0;
    583  1.108  christos 
    584  1.108  christos #ifdef __HAVE_OLD_DISKLABEL
    585  1.108  christos 	case ODIOCGDINFO:
    586  1.115  christos 		if (dk->dk_label == NULL)
    587  1.115  christos 			return EBUSY;
    588  1.108  christos 		memcpy(&newlabel, dk->dk_label, sizeof(newlabel));
    589  1.108  christos 		if (newlabel.d_npartitions > OLDMAXPARTITIONS)
    590  1.108  christos 			return ENOTTY;
    591  1.108  christos 		memcpy(data, &newlabel, sizeof(struct olddisklabel));
    592  1.108  christos 		return 0;
    593  1.108  christos #endif
    594  1.108  christos 
    595  1.115  christos 	case DIOCGPARTINFO:
    596  1.115  christos 		pi = data;
    597  1.115  christos 		memset(pi, 0, sizeof(*pi));
    598  1.115  christos 		pi->pi_secsize = dk->dk_geom.dg_secsize;
    599  1.117  jakllsch 		pi->pi_bsize = MAX(BLKDEV_IOSIZE, pi->pi_secsize);
    600  1.115  christos 
    601  1.115  christos 		if (DISKPART(dev) == RAW_PART) {
    602  1.115  christos 			pi->pi_size = dk->dk_geom.dg_secperunit;
    603  1.115  christos 			return 0;
    604  1.115  christos 		}
    605  1.115  christos 
    606  1.111  christos 		if (dk->dk_label == NULL)
    607  1.111  christos 			return EBUSY;
    608  1.115  christos 
    609  1.115  christos 		dp = &dk->dk_label->d_partitions[DISKPART(dev)];
    610  1.115  christos 		pi->pi_offset = dp->p_offset;
    611  1.115  christos 		pi->pi_size = dp->p_size;
    612  1.115  christos 
    613  1.115  christos 		pi->pi_fstype = dp->p_fstype;
    614  1.115  christos 		pi->pi_frag = dp->p_frag;
    615  1.115  christos 		pi->pi_fsize = dp->p_fsize;
    616  1.115  christos 		pi->pi_cpg = dp->p_cpg;
    617  1.115  christos 
    618  1.115  christos 		/*
    619  1.115  christos 		 * dholland 20130616: XXX this logic should not be
    620  1.115  christos 		 * here. It is here because the old buffer cache
    621  1.115  christos 		 * demands that all accesses to the same blocks need
    622  1.115  christos 		 * to be the same size; but it only works for FFS and
    623  1.115  christos 		 * nowadays I think it'll fail silently if the size
    624  1.115  christos 		 * info in the disklabel is wrong. (Or missing.) The
    625  1.115  christos 		 * buffer cache needs to be smarter; or failing that
    626  1.115  christos 		 * we need a reliable way here to get the right block
    627  1.115  christos 		 * size; or a reliable way to guarantee that (a) the
    628  1.115  christos 		 * fs is not mounted when we get here and (b) any
    629  1.115  christos 		 * buffers generated here will get purged when the fs
    630  1.115  christos 		 * does get mounted.
    631  1.115  christos 		 */
    632  1.115  christos 		if (dp->p_fstype == FS_BSDFFS &&
    633  1.115  christos 		    dp->p_frag != 0 && dp->p_fsize != 0)
    634  1.115  christos 			pi->pi_bsize = dp->p_frag * dp->p_fsize;
    635  1.108  christos 		return 0;
    636  1.108  christos 
    637  1.107  christos 	case DIOCAWEDGE:
    638  1.107  christos 		if ((flag & FWRITE) == 0)
    639  1.107  christos 			return EBADF;
    640  1.107  christos 
    641  1.107  christos 		dkw = data;
    642  1.107  christos 		strlcpy(dkw->dkw_parent, dk->dk_name, sizeof(dkw->dkw_parent));
    643  1.107  christos 		return dkwedge_add(dkw);
    644  1.107  christos 
    645  1.107  christos 	case DIOCDWEDGE:
    646  1.107  christos 		if ((flag & FWRITE) == 0)
    647  1.107  christos 			return EBADF;
    648  1.107  christos 
    649  1.107  christos 		dkw = data;
    650  1.107  christos 		strlcpy(dkw->dkw_parent, dk->dk_name, sizeof(dkw->dkw_parent));
    651  1.107  christos 		return dkwedge_del(dkw);
    652  1.107  christos 
    653  1.107  christos 	case DIOCLWEDGES:
    654  1.107  christos 		return dkwedge_list(dk, data, l);
    655  1.107  christos 
    656  1.107  christos 	case DIOCMWEDGES:
    657  1.107  christos 		if ((flag & FWRITE) == 0)
    658  1.107  christos 			return EBADF;
    659  1.107  christos 
    660  1.107  christos 		dkwedge_discover(dk);
    661  1.107  christos 		return 0;
    662  1.107  christos 
    663  1.123    martin 	case DIOCRMWEDGES:
    664  1.123    martin 		if ((flag & FWRITE) == 0)
    665  1.123    martin 			return EBADF;
    666  1.123    martin 
    667  1.123    martin 		dkwedge_delall(dk);
    668  1.123    martin 		return 0;
    669  1.123    martin 
    670   1.82   thorpej 	default:
    671  1.107  christos 		return EPASSTHROUGH;
    672   1.82   thorpej 	}
    673   1.82   thorpej }
    674  1.102  christos 
    675  1.102  christos void
    676  1.102  christos disk_set_info(device_t dev, struct disk *dk, const char *type)
    677  1.102  christos {
    678  1.102  christos 	struct disk_geom *dg = &dk->dk_geom;
    679  1.102  christos 
    680  1.112   mlelstv 	if (dg->dg_secsize == 0) {
    681  1.112   mlelstv #ifdef DIAGNOSTIC
    682  1.112   mlelstv 		printf("%s: fixing 0 sector size\n", dk->dk_name);
    683  1.112   mlelstv #endif
    684  1.112   mlelstv 		dg->dg_secsize = DEV_BSIZE;
    685  1.112   mlelstv 	}
    686  1.112   mlelstv 
    687  1.112   mlelstv 	dk->dk_blkshift = DK_BSIZE2BLKSHIFT(dg->dg_secsize);
    688  1.112   mlelstv 	dk->dk_byteshift = DK_BSIZE2BYTESHIFT(dg->dg_secsize);
    689  1.112   mlelstv 
    690  1.102  christos 	if (dg->dg_secperunit == 0 && dg->dg_ncylinders == 0) {
    691  1.102  christos #ifdef DIAGNOSTIC
    692  1.102  christos 		printf("%s: secperunit and ncylinders are zero\n", dk->dk_name);
    693  1.102  christos #endif
    694  1.102  christos 		return;
    695  1.102  christos 	}
    696  1.102  christos 
    697  1.102  christos 	if (dg->dg_secperunit == 0) {
    698  1.102  christos 		if (dg->dg_nsectors == 0 || dg->dg_ntracks == 0) {
    699  1.102  christos #ifdef DIAGNOSTIC
    700  1.102  christos 			printf("%s: secperunit and (sectors or tracks) "
    701  1.102  christos 			    "are zero\n", dk->dk_name);
    702  1.102  christos #endif
    703  1.102  christos 			return;
    704  1.102  christos 		}
    705  1.103   mlelstv 		dg->dg_secperunit = (int64_t) dg->dg_nsectors *
    706  1.102  christos 		    dg->dg_ntracks * dg->dg_ncylinders;
    707  1.102  christos 	}
    708  1.102  christos 
    709  1.102  christos 	if (dg->dg_ncylinders == 0) {
    710  1.102  christos 		if (dg->dg_ntracks && dg->dg_nsectors)
    711  1.102  christos 			dg->dg_ncylinders = dg->dg_secperunit /
    712  1.102  christos 			    (dg->dg_ntracks * dg->dg_nsectors);
    713  1.102  christos 	}
    714  1.102  christos 
    715  1.102  christos 	prop_dictionary_t disk_info, odisk_info, geom;
    716  1.102  christos 
    717  1.102  christos 	disk_info = prop_dictionary_create();
    718  1.102  christos 	geom = prop_dictionary_create();
    719  1.102  christos 
    720  1.102  christos 	prop_dictionary_set_uint64(geom, "sectors-per-unit",
    721  1.102  christos 	    dg->dg_secperunit);
    722  1.102  christos 
    723  1.102  christos 	prop_dictionary_set_uint32(geom, "sector-size", dg->dg_secsize);
    724  1.102  christos 
    725  1.102  christos 	if (dg->dg_nsectors)
    726  1.102  christos 		prop_dictionary_set_uint16(geom, "sectors-per-track",
    727  1.102  christos 		    dg->dg_nsectors);
    728  1.102  christos 
    729  1.102  christos 	if (dg->dg_ntracks)
    730  1.102  christos 		prop_dictionary_set_uint16(geom, "tracks-per-cylinder",
    731  1.102  christos 		    dg->dg_ntracks);
    732  1.102  christos 
    733  1.102  christos 	if (dg->dg_ncylinders)
    734  1.102  christos 		prop_dictionary_set_uint64(geom, "cylinders-per-unit",
    735  1.102  christos 		    dg->dg_ncylinders);
    736  1.102  christos 
    737  1.102  christos 	prop_dictionary_set(disk_info, "geometry", geom);
    738  1.102  christos 
    739  1.102  christos 	if (type)
    740  1.102  christos 		prop_dictionary_set_cstring_nocopy(disk_info, "type", type);
    741  1.102  christos 
    742  1.102  christos 	prop_object_release(geom);
    743  1.102  christos 
    744  1.102  christos 	odisk_info = dk->dk_info;
    745  1.102  christos 	dk->dk_info = disk_info;
    746  1.102  christos 
    747  1.102  christos 	if (dev)
    748  1.102  christos 		prop_dictionary_set(device_properties(dev), "disk-info",
    749  1.102  christos 		    disk_info);
    750  1.102  christos 
    751  1.102  christos 	/*
    752  1.102  christos 	 * Don't release disk_info here; we keep a reference to it.
    753  1.102  christos 	 * disk_detach() will release it when we go away.
    754  1.102  christos 	 */
    755  1.102  christos 	if (odisk_info)
    756  1.102  christos 		prop_object_release(odisk_info);
    757  1.102  christos }
    758