Home | History | Annotate | Line # | Download | only in udf
udf_strat_sequential.c revision 1.1.8.2
      1  1.1.8.2   simonb /* $NetBSD: udf_strat_sequential.c,v 1.1.8.2 2008/07/31 04:51:02 simonb Exp $ */
      2      1.1  reinoud 
      3      1.1  reinoud /*
      4      1.1  reinoud  * Copyright (c) 2006, 2008 Reinoud Zandijk
      5      1.1  reinoud  * All rights reserved.
      6      1.1  reinoud  *
      7      1.1  reinoud  * Redistribution and use in source and binary forms, with or without
      8      1.1  reinoud  * modification, are permitted provided that the following conditions
      9      1.1  reinoud  * are met:
     10      1.1  reinoud  * 1. Redistributions of source code must retain the above copyright
     11      1.1  reinoud  *    notice, this list of conditions and the following disclaimer.
     12      1.1  reinoud  * 2. Redistributions in binary form must reproduce the above copyright
     13      1.1  reinoud  *    notice, this list of conditions and the following disclaimer in the
     14      1.1  reinoud  *    documentation and/or other materials provided with the distribution.
     15      1.1  reinoud  *
     16      1.1  reinoud  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     17      1.1  reinoud  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     18      1.1  reinoud  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     19      1.1  reinoud  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     20      1.1  reinoud  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
     21      1.1  reinoud  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
     22      1.1  reinoud  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
     23      1.1  reinoud  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     24      1.1  reinoud  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     25      1.1  reinoud  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     26      1.1  reinoud  *
     27      1.1  reinoud  */
     28      1.1  reinoud 
     29      1.1  reinoud #include <sys/cdefs.h>
     30      1.1  reinoud #ifndef lint
     31  1.1.8.2   simonb __KERNEL_RCSID(0, "$NetBSD: udf_strat_sequential.c,v 1.1.8.2 2008/07/31 04:51:02 simonb Exp $");
     32      1.1  reinoud #endif /* not lint */
     33      1.1  reinoud 
     34      1.1  reinoud 
     35      1.1  reinoud #if defined(_KERNEL_OPT)
     36      1.1  reinoud #include "opt_quota.h"
     37      1.1  reinoud #include "opt_compat_netbsd.h"
     38      1.1  reinoud #endif
     39      1.1  reinoud 
     40      1.1  reinoud #include <sys/param.h>
     41      1.1  reinoud #include <sys/systm.h>
     42      1.1  reinoud #include <sys/sysctl.h>
     43      1.1  reinoud #include <sys/namei.h>
     44      1.1  reinoud #include <sys/proc.h>
     45      1.1  reinoud #include <sys/kernel.h>
     46      1.1  reinoud #include <sys/vnode.h>
     47      1.1  reinoud #include <miscfs/genfs/genfs_node.h>
     48      1.1  reinoud #include <sys/mount.h>
     49      1.1  reinoud #include <sys/buf.h>
     50      1.1  reinoud #include <sys/file.h>
     51      1.1  reinoud #include <sys/device.h>
     52      1.1  reinoud #include <sys/disklabel.h>
     53      1.1  reinoud #include <sys/ioctl.h>
     54      1.1  reinoud #include <sys/malloc.h>
     55      1.1  reinoud #include <sys/dirent.h>
     56      1.1  reinoud #include <sys/stat.h>
     57      1.1  reinoud #include <sys/conf.h>
     58      1.1  reinoud #include <sys/kauth.h>
     59      1.1  reinoud #include <sys/kthread.h>
     60      1.1  reinoud #include <dev/clock_subr.h>
     61      1.1  reinoud 
     62      1.1  reinoud #include <fs/udf/ecma167-udf.h>
     63      1.1  reinoud #include <fs/udf/udf_mount.h>
     64      1.1  reinoud 
     65      1.1  reinoud #if defined(_KERNEL_OPT)
     66      1.1  reinoud #include "opt_udf.h"
     67      1.1  reinoud #endif
     68      1.1  reinoud 
     69      1.1  reinoud #include "udf.h"
     70      1.1  reinoud #include "udf_subr.h"
     71      1.1  reinoud #include "udf_bswap.h"
     72      1.1  reinoud 
     73      1.1  reinoud 
     74      1.1  reinoud #define VTOI(vnode) ((struct udf_node *) vnode->v_data)
     75      1.1  reinoud #define PRIV(ump) ((struct strat_private *) ump->strategy_private)
     76      1.1  reinoud 
     77      1.1  reinoud /* --------------------------------------------------------------------- */
     78      1.1  reinoud 
     79      1.1  reinoud /* BUFQ's */
     80      1.1  reinoud #define UDF_SHED_MAX 3
     81      1.1  reinoud 
     82      1.1  reinoud #define UDF_SHED_READING	0
     83      1.1  reinoud #define UDF_SHED_WRITING	1
     84      1.1  reinoud #define UDF_SHED_SEQWRITING	2
     85      1.1  reinoud 
     86      1.1  reinoud struct strat_private {
     87      1.1  reinoud 	struct pool		 desc_pool;	 	/* node descriptors */
     88      1.1  reinoud 
     89      1.1  reinoud 	lwp_t			*queue_lwp;
     90      1.1  reinoud 	kcondvar_t		 discstrat_cv;		/* to wait on       */
     91      1.1  reinoud 	kmutex_t		 discstrat_mutex;	/* disc strategy    */
     92      1.1  reinoud 
     93      1.1  reinoud 	int			 run_thread;		/* thread control */
     94      1.1  reinoud 	int			 cur_queue;
     95      1.1  reinoud 
     96      1.1  reinoud 	struct disk_strategy	 old_strategy_setting;
     97      1.1  reinoud 	struct bufq_state	*queues[UDF_SHED_MAX];
     98      1.1  reinoud 	struct timespec		 last_queued[UDF_SHED_MAX];
     99      1.1  reinoud };
    100      1.1  reinoud 
    101      1.1  reinoud 
    102      1.1  reinoud /* --------------------------------------------------------------------- */
    103      1.1  reinoud 
    104      1.1  reinoud static void
    105      1.1  reinoud udf_wr_nodedscr_callback(struct buf *buf)
    106      1.1  reinoud {
    107      1.1  reinoud 	struct udf_node *udf_node;
    108      1.1  reinoud 
    109      1.1  reinoud 	KASSERT(buf);
    110      1.1  reinoud 	KASSERT(buf->b_data);
    111      1.1  reinoud 
    112      1.1  reinoud 	/* called when write action is done */
    113      1.1  reinoud 	DPRINTF(WRITE, ("udf_wr_nodedscr_callback(): node written out\n"));
    114      1.1  reinoud 
    115      1.1  reinoud 	udf_node = VTOI(buf->b_vp);
    116      1.1  reinoud 	if (udf_node == NULL) {
    117      1.1  reinoud 		putiobuf(buf);
    118      1.1  reinoud 		printf("udf_wr_node_callback: NULL node?\n");
    119      1.1  reinoud 		return;
    120      1.1  reinoud 	}
    121      1.1  reinoud 
    122      1.1  reinoud 	/* XXX right flags to mark dirty again on error? */
    123      1.1  reinoud 	if (buf->b_error) {
    124      1.1  reinoud 		udf_node->i_flags |= IN_MODIFIED | IN_ACCESSED;
    125      1.1  reinoud 		/* XXX TODO reshedule on error */
    126      1.1  reinoud 	}
    127      1.1  reinoud 
    128  1.1.8.1   simonb 	/* decrement outstanding_nodedscr */
    129  1.1.8.1   simonb 	KASSERT(udf_node->outstanding_nodedscr >= 1);
    130  1.1.8.1   simonb 	udf_node->outstanding_nodedscr--;
    131  1.1.8.1   simonb 	if (udf_node->outstanding_nodedscr == 0) {
    132  1.1.8.1   simonb 		/* first unlock the node */
    133  1.1.8.1   simonb 		KASSERT(udf_node->i_flags & IN_CALLBACK_ULK);
    134  1.1.8.1   simonb 		UDF_UNLOCK_NODE(udf_node, IN_CALLBACK_ULK);
    135  1.1.8.1   simonb 
    136  1.1.8.1   simonb 		wakeup(&udf_node->outstanding_nodedscr);
    137  1.1.8.1   simonb 	}
    138      1.1  reinoud 
    139      1.1  reinoud 	/* unreference the vnode so it can be recycled */
    140      1.1  reinoud 	holdrele(udf_node->vnode);
    141      1.1  reinoud 
    142      1.1  reinoud 	putiobuf(buf);
    143      1.1  reinoud }
    144      1.1  reinoud 
    145      1.1  reinoud /* --------------------------------------------------------------------- */
    146      1.1  reinoud 
    147      1.1  reinoud static int
    148      1.1  reinoud udf_create_logvol_dscr_seq(struct udf_strat_args *args)
    149      1.1  reinoud {
    150      1.1  reinoud 	union dscrptr   **dscrptr = &args->dscr;
    151      1.1  reinoud 	struct udf_mount *ump = args->ump;
    152      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    153      1.1  reinoud 	uint32_t lb_size;
    154      1.1  reinoud 
    155      1.1  reinoud 	lb_size = udf_rw32(ump->logical_vol->lb_size);
    156      1.1  reinoud 	*dscrptr = pool_get(&priv->desc_pool, PR_WAITOK);
    157      1.1  reinoud 	memset(*dscrptr, 0, lb_size);
    158      1.1  reinoud 
    159      1.1  reinoud 	return 0;
    160      1.1  reinoud }
    161      1.1  reinoud 
    162      1.1  reinoud 
    163      1.1  reinoud static void
    164      1.1  reinoud udf_free_logvol_dscr_seq(struct udf_strat_args *args)
    165      1.1  reinoud {
    166      1.1  reinoud 	union dscrptr    *dscr = args->dscr;
    167      1.1  reinoud 	struct udf_mount *ump  = args->ump;
    168      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    169      1.1  reinoud 
    170      1.1  reinoud 	pool_put(&priv->desc_pool, dscr);
    171      1.1  reinoud }
    172      1.1  reinoud 
    173      1.1  reinoud 
    174      1.1  reinoud static int
    175      1.1  reinoud udf_read_logvol_dscr_seq(struct udf_strat_args *args)
    176      1.1  reinoud {
    177      1.1  reinoud 	union dscrptr   **dscrptr = &args->dscr;
    178      1.1  reinoud 	union dscrptr    *tmpdscr;
    179      1.1  reinoud 	struct udf_mount *ump = args->ump;
    180      1.1  reinoud 	struct long_ad   *icb = args->icb;
    181      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    182      1.1  reinoud 	uint32_t lb_size;
    183      1.1  reinoud 	uint32_t sector, dummy;
    184      1.1  reinoud 	int error;
    185      1.1  reinoud 
    186      1.1  reinoud 	lb_size = udf_rw32(ump->logical_vol->lb_size);
    187      1.1  reinoud 
    188      1.1  reinoud 	error = udf_translate_vtop(ump, icb, &sector, &dummy);
    189      1.1  reinoud 	if (error)
    190      1.1  reinoud 		return error;
    191      1.1  reinoud 
    192      1.1  reinoud 	/* try to read in fe/efe */
    193      1.1  reinoud 	error = udf_read_phys_dscr(ump, sector, M_UDFTEMP, &tmpdscr);
    194      1.1  reinoud 	if (error)
    195      1.1  reinoud 		return error;
    196      1.1  reinoud 
    197      1.1  reinoud 	*dscrptr = pool_get(&priv->desc_pool, PR_WAITOK);
    198      1.1  reinoud 	memcpy(*dscrptr, tmpdscr, lb_size);
    199      1.1  reinoud 	free(tmpdscr, M_UDFTEMP);
    200      1.1  reinoud 
    201      1.1  reinoud 	return 0;
    202      1.1  reinoud }
    203      1.1  reinoud 
    204      1.1  reinoud 
    205      1.1  reinoud static int
    206      1.1  reinoud udf_write_logvol_dscr_seq(struct udf_strat_args *args)
    207      1.1  reinoud {
    208      1.1  reinoud 	union dscrptr    *dscr     = args->dscr;
    209      1.1  reinoud 	struct udf_mount *ump      = args->ump;
    210      1.1  reinoud 	struct udf_node  *udf_node = args->udf_node;
    211      1.1  reinoud 	struct long_ad   *icb      = args->icb;
    212      1.1  reinoud 	int               waitfor  = args->waitfor;
    213      1.1  reinoud 	uint32_t logsectornr, sectornr, dummy;
    214      1.1  reinoud 	int error, vpart;
    215      1.1  reinoud 
    216      1.1  reinoud 	/*
    217      1.1  reinoud 	 * we have to decide if we write it out sequential or at its fixed
    218      1.1  reinoud 	 * position by examining the partition its (to be) written on.
    219      1.1  reinoud 	 */
    220      1.1  reinoud 	vpart       = udf_rw16(udf_node->loc.loc.part_num);
    221      1.1  reinoud 	logsectornr = udf_rw32(icb->loc.lb_num);
    222      1.1  reinoud 	sectornr    = 0;
    223      1.1  reinoud 	if (ump->vtop_tp[vpart] != UDF_VTOP_TYPE_VIRT) {
    224      1.1  reinoud 		error = udf_translate_vtop(ump, icb, &sectornr, &dummy);
    225      1.1  reinoud 		if (error)
    226  1.1.8.1   simonb 			goto out;
    227      1.1  reinoud 	}
    228      1.1  reinoud 
    229  1.1.8.1   simonb 	/* add reference to the vnode to prevent recycling */
    230  1.1.8.1   simonb 	vhold(udf_node->vnode);
    231      1.1  reinoud 
    232      1.1  reinoud 	if (waitfor) {
    233      1.1  reinoud 		DPRINTF(WRITE, ("udf_write_logvol_dscr: sync write\n"));
    234      1.1  reinoud 
    235      1.1  reinoud 		error = udf_write_phys_dscr_sync(ump, udf_node, UDF_C_NODE,
    236      1.1  reinoud 			dscr, sectornr, logsectornr);
    237      1.1  reinoud 	} else {
    238      1.1  reinoud 		DPRINTF(WRITE, ("udf_write_logvol_dscr: no wait, async write\n"));
    239      1.1  reinoud 
    240      1.1  reinoud 		error = udf_write_phys_dscr_async(ump, udf_node, UDF_C_NODE,
    241      1.1  reinoud 			dscr, sectornr, logsectornr, udf_wr_nodedscr_callback);
    242      1.1  reinoud 		/* will be UNLOCKED in call back */
    243  1.1.8.1   simonb 		return error;
    244  1.1.8.1   simonb 	}
    245  1.1.8.1   simonb 
    246  1.1.8.1   simonb 	holdrele(udf_node->vnode);
    247  1.1.8.1   simonb out:
    248  1.1.8.1   simonb 	udf_node->outstanding_nodedscr--;
    249  1.1.8.1   simonb 	if (udf_node->outstanding_nodedscr == 0) {
    250  1.1.8.1   simonb 		UDF_UNLOCK_NODE(udf_node, 0);
    251  1.1.8.1   simonb 		wakeup(&udf_node->outstanding_nodedscr);
    252      1.1  reinoud 	}
    253      1.1  reinoud 
    254      1.1  reinoud 	return error;
    255      1.1  reinoud }
    256      1.1  reinoud 
    257      1.1  reinoud /* --------------------------------------------------------------------- */
    258      1.1  reinoud 
    259      1.1  reinoud /*
    260      1.1  reinoud  * Main file-system specific sheduler. Due to the nature of optical media
    261      1.1  reinoud  * sheduling can't be performed in the traditional way. Most OS
    262      1.1  reinoud  * implementations i've seen thus read or write a file atomically giving all
    263      1.1  reinoud  * kinds of side effects.
    264      1.1  reinoud  *
    265      1.1  reinoud  * This implementation uses a kernel thread to shedule the queued requests in
    266      1.1  reinoud  * such a way that is semi-optimal for optical media; this means aproximately
    267      1.1  reinoud  * (R*|(Wr*|Ws*))* since switching between reading and writing is expensive in
    268      1.1  reinoud  * time.
    269      1.1  reinoud  */
    270      1.1  reinoud 
    271      1.1  reinoud static void
    272      1.1  reinoud udf_queuebuf_seq(struct udf_strat_args *args)
    273      1.1  reinoud {
    274      1.1  reinoud 	struct udf_mount *ump = args->ump;
    275      1.1  reinoud 	struct buf *nestbuf = args->nestbuf;
    276      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    277      1.1  reinoud 	int queue;
    278      1.1  reinoud 	int what;
    279      1.1  reinoud 
    280      1.1  reinoud 	KASSERT(ump);
    281      1.1  reinoud 	KASSERT(nestbuf);
    282      1.1  reinoud 	KASSERT(nestbuf->b_iodone == nestiobuf_iodone);
    283      1.1  reinoud 
    284      1.1  reinoud 	what = nestbuf->b_udf_c_type;
    285      1.1  reinoud 	queue = UDF_SHED_READING;
    286      1.1  reinoud 	if ((nestbuf->b_flags & B_READ) == 0) {
    287      1.1  reinoud 		/* writing */
    288      1.1  reinoud 		queue = UDF_SHED_SEQWRITING;
    289      1.1  reinoud 		if (what == UDF_C_DSCR)
    290      1.1  reinoud 			queue = UDF_SHED_WRITING;
    291      1.1  reinoud 		if (what == UDF_C_NODE) {
    292      1.1  reinoud 			if (ump->meta_alloc != UDF_ALLOC_VAT)
    293      1.1  reinoud 				queue = UDF_SHED_WRITING;
    294      1.1  reinoud 		}
    295      1.1  reinoud #if 0
    296      1.1  reinoud 		if (queue == UDF_SHED_SEQWRITING) {
    297      1.1  reinoud 			/* TODO do add sector to uncommitted space */
    298      1.1  reinoud 		}
    299      1.1  reinoud #endif
    300      1.1  reinoud 	}
    301      1.1  reinoud 
    302      1.1  reinoud 	/* use our own sheduler lists for more complex sheduling */
    303      1.1  reinoud 	mutex_enter(&priv->discstrat_mutex);
    304      1.1  reinoud 		BUFQ_PUT(priv->queues[queue], nestbuf);
    305      1.1  reinoud 		vfs_timestamp(&priv->last_queued[queue]);
    306      1.1  reinoud 	mutex_exit(&priv->discstrat_mutex);
    307      1.1  reinoud 
    308      1.1  reinoud 	/* signal our thread that there might be something to do */
    309      1.1  reinoud 	cv_signal(&priv->discstrat_cv);
    310      1.1  reinoud }
    311      1.1  reinoud 
    312      1.1  reinoud /* --------------------------------------------------------------------- */
    313      1.1  reinoud 
    314      1.1  reinoud /* TODO convert to lb_size */
    315      1.1  reinoud static void
    316  1.1.8.2   simonb udf_VAT_mapping_update(struct udf_mount *ump, struct buf *buf, uint32_t lb_map)
    317      1.1  reinoud {
    318      1.1  reinoud 	union dscrptr    *fdscr = (union dscrptr *) buf->b_data;
    319      1.1  reinoud 	struct vnode     *vp = buf->b_vp;
    320      1.1  reinoud 	struct udf_node  *udf_node = VTOI(vp);
    321      1.1  reinoud 	uint32_t lb_size, blks;
    322  1.1.8.2   simonb 	uint32_t lb_num;
    323      1.1  reinoud 	uint32_t udf_rw32_lbmap;
    324      1.1  reinoud 	int c_type = buf->b_udf_c_type;
    325      1.1  reinoud 	int error;
    326      1.1  reinoud 
    327      1.1  reinoud 	/* only interested when we're using a VAT */
    328      1.1  reinoud 	if (ump->meta_alloc != UDF_ALLOC_VAT)
    329      1.1  reinoud 		return;
    330      1.1  reinoud 	KASSERT(ump->vat_node);
    331      1.1  reinoud 
    332      1.1  reinoud 	/* only nodes are recorded in the VAT */
    333      1.1  reinoud 	/* NOTE: and the fileset descriptor (FIXME ?) */
    334      1.1  reinoud 	if (c_type != UDF_C_NODE)
    335      1.1  reinoud 		return;
    336      1.1  reinoud 
    337      1.1  reinoud 	/* we now have an UDF FE/EFE node on media with VAT (or VAT itself) */
    338      1.1  reinoud 	lb_size = udf_rw32(ump->logical_vol->lb_size);
    339      1.1  reinoud 	blks = lb_size / DEV_BSIZE;
    340      1.1  reinoud 
    341      1.1  reinoud 	udf_rw32_lbmap = udf_rw32(lb_map);
    342      1.1  reinoud 
    343      1.1  reinoud 	/* if we're the VAT itself, only update our assigned sector number */
    344      1.1  reinoud 	if (udf_node == ump->vat_node) {
    345      1.1  reinoud 		fdscr->tag.tag_loc = udf_rw32_lbmap;
    346      1.1  reinoud 		udf_validate_tag_sum(fdscr);
    347      1.1  reinoud 		DPRINTF(TRANSLATE, ("VAT assigned to sector %u\n",
    348      1.1  reinoud 			udf_rw32(udf_rw32_lbmap)));
    349      1.1  reinoud 		/* no use mapping the VAT node in the VAT */
    350      1.1  reinoud 		return;
    351      1.1  reinoud 	}
    352      1.1  reinoud 
    353      1.1  reinoud 	/* record new position in VAT file */
    354  1.1.8.1   simonb 	lb_num = udf_rw32(fdscr->tag.tag_loc);
    355  1.1.8.1   simonb 
    356  1.1.8.1   simonb 	/* lb_num = udf_rw32(udf_node->write_loc.loc.lb_num); */
    357      1.1  reinoud 
    358      1.1  reinoud 	DPRINTF(TRANSLATE, ("VAT entry change (log %u -> phys %u)\n",
    359      1.1  reinoud 			lb_num, lb_map));
    360      1.1  reinoud 
    361      1.1  reinoud 	/* VAT should be the longer than this write, can't go wrong */
    362      1.1  reinoud 	KASSERT(lb_num <= ump->vat_entries);
    363      1.1  reinoud 
    364      1.1  reinoud 	mutex_enter(&ump->allocate_mutex);
    365      1.1  reinoud 	error = udf_vat_write(ump->vat_node,
    366      1.1  reinoud 			(uint8_t *) &udf_rw32_lbmap, 4,
    367      1.1  reinoud 			ump->vat_offset + lb_num * 4);
    368      1.1  reinoud 	mutex_exit(&ump->allocate_mutex);
    369      1.1  reinoud 
    370      1.1  reinoud 	if (error)
    371      1.1  reinoud 		panic( "udf_VAT_mapping_update: HELP! i couldn't "
    372      1.1  reinoud 			"write in the VAT file ?\n");
    373      1.1  reinoud }
    374      1.1  reinoud 
    375      1.1  reinoud 
    376      1.1  reinoud static void
    377      1.1  reinoud udf_issue_buf(struct udf_mount *ump, int queue, struct buf *buf)
    378      1.1  reinoud {
    379      1.1  reinoud 	struct long_ad *node_ad_cpy;
    380  1.1.8.2   simonb 	struct part_desc *pdesc;
    381  1.1.8.2   simonb 	uint64_t *lmapping, *lmappos, blknr;
    382      1.1  reinoud 	uint32_t our_sectornr, sectornr, bpos;
    383  1.1.8.2   simonb 	uint32_t ptov;
    384  1.1.8.2   simonb 	uint16_t vpart_num;
    385      1.1  reinoud 	uint8_t *fidblk;
    386      1.1  reinoud 	int sector_size = ump->discinfo.sector_size;
    387      1.1  reinoud 	int blks = sector_size / DEV_BSIZE;
    388      1.1  reinoud 	int len, buf_len;
    389      1.1  reinoud 
    390      1.1  reinoud 	/* if reading, just pass to the device's STRATEGY */
    391      1.1  reinoud 	if (queue == UDF_SHED_READING) {
    392      1.1  reinoud 		DPRINTF(SHEDULE, ("\nudf_issue_buf READ %p : sector %d type %d,"
    393      1.1  reinoud 			"b_resid %d, b_bcount %d, b_bufsize %d\n",
    394      1.1  reinoud 			buf, (uint32_t) buf->b_blkno / blks, buf->b_udf_c_type,
    395      1.1  reinoud 			buf->b_resid, buf->b_bcount, buf->b_bufsize));
    396      1.1  reinoud 		VOP_STRATEGY(ump->devvp, buf);
    397      1.1  reinoud 		return;
    398      1.1  reinoud 	}
    399      1.1  reinoud 
    400      1.1  reinoud 	blknr        = buf->b_blkno;
    401      1.1  reinoud 	our_sectornr = blknr / blks;
    402      1.1  reinoud 
    403      1.1  reinoud 	if (queue == UDF_SHED_WRITING) {
    404      1.1  reinoud 		DPRINTF(SHEDULE, ("\nudf_issue_buf WRITE %p : sector %d "
    405      1.1  reinoud 			"type %d, b_resid %d, b_bcount %d, b_bufsize %d\n",
    406      1.1  reinoud 			buf, (uint32_t) buf->b_blkno / blks, buf->b_udf_c_type,
    407      1.1  reinoud 			buf->b_resid, buf->b_bcount, buf->b_bufsize));
    408      1.1  reinoud 		/* if we have FIDs fixup using buffer's sector number(s) */
    409      1.1  reinoud 		if (buf->b_udf_c_type == UDF_C_FIDS) {
    410      1.1  reinoud 			panic("UDF_C_FIDS in SHED_WRITING!\n");
    411      1.1  reinoud 			buf_len = buf->b_bcount;
    412      1.1  reinoud 			sectornr = our_sectornr;
    413      1.1  reinoud 			bpos = 0;
    414      1.1  reinoud 			while (buf_len) {
    415      1.1  reinoud 				len = MIN(buf_len, sector_size);
    416      1.1  reinoud 				fidblk = (uint8_t *) buf->b_data + bpos;
    417      1.1  reinoud 				udf_fixup_fid_block(fidblk, sector_size,
    418      1.1  reinoud 					0, len, sectornr);
    419      1.1  reinoud 				sectornr++;
    420      1.1  reinoud 				bpos += len;
    421      1.1  reinoud 				buf_len -= len;
    422      1.1  reinoud 			}
    423      1.1  reinoud 		}
    424      1.1  reinoud 		udf_fixup_node_internals(ump, buf->b_data, buf->b_udf_c_type);
    425      1.1  reinoud 		VOP_STRATEGY(ump->devvp, buf);
    426      1.1  reinoud 		return;
    427      1.1  reinoud 	}
    428      1.1  reinoud 
    429      1.1  reinoud 	KASSERT(queue == UDF_SHED_SEQWRITING);
    430      1.1  reinoud 	DPRINTF(SHEDULE, ("\nudf_issue_buf SEQWRITE %p : sector XXXX "
    431      1.1  reinoud 		"type %d, b_resid %d, b_bcount %d, b_bufsize %d\n",
    432      1.1  reinoud 		buf, buf->b_udf_c_type, buf->b_resid, buf->b_bcount,
    433      1.1  reinoud 		buf->b_bufsize));
    434      1.1  reinoud 
    435      1.1  reinoud 	/*
    436      1.1  reinoud 	 * Buffers should not have been allocated to disc addresses yet on
    437      1.1  reinoud 	 * this queue. Note that a buffer can get multiple extents allocated.
    438      1.1  reinoud 	 *
    439      1.1  reinoud 	 * lmapping contains lb_num relative to base partition.
    440      1.1  reinoud 	 */
    441      1.1  reinoud 	lmapping    = ump->la_lmapping;
    442      1.1  reinoud 	node_ad_cpy = ump->la_node_ad_cpy;
    443      1.1  reinoud 
    444  1.1.8.2   simonb 	/* logically allocate buf and map it in the file */
    445  1.1.8.2   simonb 	udf_late_allocate_buf(ump, buf, lmapping, node_ad_cpy, &vpart_num);
    446  1.1.8.2   simonb 
    447  1.1.8.2   simonb 	/* update mapping in the VAT */
    448  1.1.8.2   simonb 	udf_VAT_mapping_update(ump, buf, *lmapping);
    449  1.1.8.2   simonb 
    450  1.1.8.2   simonb 	/*
    451  1.1.8.2   simonb 	 * NOTE We are using the knowledge here that sequential media will
    452  1.1.8.2   simonb 	 * always be mapped linearly. Thus no use to explicitly translate the
    453  1.1.8.2   simonb 	 * lmapping list.
    454  1.1.8.2   simonb 	 */
    455  1.1.8.2   simonb 
    456  1.1.8.2   simonb 	/* calculate offset from physical base partition */
    457  1.1.8.2   simonb 	pdesc = ump->partitions[ump->vtop[vpart_num]];
    458  1.1.8.2   simonb 	ptov  = udf_rw32(pdesc->start_loc);
    459  1.1.8.2   simonb 
    460  1.1.8.2   simonb 	/* set buffers blkno to the physical block number */
    461  1.1.8.2   simonb 	buf->b_blkno = (*lmapping + ptov) * blks;
    462      1.1  reinoud 
    463      1.1  reinoud 	/* if we have FIDs, fixup using the new allocation table */
    464      1.1  reinoud 	if (buf->b_udf_c_type == UDF_C_FIDS) {
    465      1.1  reinoud 		buf_len = buf->b_bcount;
    466      1.1  reinoud 		bpos = 0;
    467      1.1  reinoud 		lmappos = lmapping;
    468      1.1  reinoud 		while (buf_len) {
    469      1.1  reinoud 			sectornr = *lmappos++;
    470      1.1  reinoud 			len = MIN(buf_len, sector_size);
    471      1.1  reinoud 			fidblk = (uint8_t *) buf->b_data + bpos;
    472      1.1  reinoud 			udf_fixup_fid_block(fidblk, sector_size,
    473      1.1  reinoud 				0, len, sectornr);
    474      1.1  reinoud 			bpos += len;
    475      1.1  reinoud 			buf_len -= len;
    476      1.1  reinoud 		}
    477      1.1  reinoud 	}
    478      1.1  reinoud 	udf_fixup_node_internals(ump, buf->b_data, buf->b_udf_c_type);
    479      1.1  reinoud 	VOP_STRATEGY(ump->devvp, buf);
    480      1.1  reinoud }
    481      1.1  reinoud 
    482      1.1  reinoud 
    483      1.1  reinoud static void
    484      1.1  reinoud udf_doshedule(struct udf_mount *ump)
    485      1.1  reinoud {
    486      1.1  reinoud 	struct buf *buf;
    487      1.1  reinoud 	struct timespec now, *last;
    488      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    489      1.1  reinoud 	void (*b_callback)(struct buf *);
    490      1.1  reinoud 	int new_queue;
    491      1.1  reinoud 	int error;
    492      1.1  reinoud 
    493      1.1  reinoud 	buf = BUFQ_GET(priv->queues[priv->cur_queue]);
    494      1.1  reinoud 	if (buf) {
    495      1.1  reinoud 		/* transfer from the current queue to the device queue */
    496      1.1  reinoud 		mutex_exit(&priv->discstrat_mutex);
    497      1.1  reinoud 
    498      1.1  reinoud 		/* transform buffer to synchronous; XXX needed? */
    499      1.1  reinoud 		b_callback = buf->b_iodone;
    500      1.1  reinoud 		buf->b_iodone = NULL;
    501      1.1  reinoud 		CLR(buf->b_flags, B_ASYNC);
    502      1.1  reinoud 
    503      1.1  reinoud 		/* issue and wait on completion */
    504      1.1  reinoud 		udf_issue_buf(ump, priv->cur_queue, buf);
    505      1.1  reinoud 		biowait(buf);
    506      1.1  reinoud 
    507      1.1  reinoud 		mutex_enter(&priv->discstrat_mutex);
    508      1.1  reinoud 
    509      1.1  reinoud 		/* if there is an error, repair this error, otherwise propagate */
    510      1.1  reinoud 		if (buf->b_error && ((buf->b_flags & B_READ) == 0)) {
    511      1.1  reinoud 			/* check what we need to do */
    512      1.1  reinoud 			panic("UDF write error, can't handle yet!\n");
    513      1.1  reinoud 		}
    514      1.1  reinoud 
    515      1.1  reinoud 		/* propagate result to higher layers */
    516      1.1  reinoud 		if (b_callback) {
    517      1.1  reinoud 			buf->b_iodone = b_callback;
    518      1.1  reinoud 			(*buf->b_iodone)(buf);
    519      1.1  reinoud 		}
    520      1.1  reinoud 
    521      1.1  reinoud 		return;
    522      1.1  reinoud 	}
    523      1.1  reinoud 
    524      1.1  reinoud 	/* Check if we're idling in this state */
    525      1.1  reinoud 	vfs_timestamp(&now);
    526      1.1  reinoud 	last = &priv->last_queued[priv->cur_queue];
    527      1.1  reinoud 	if (ump->discinfo.mmc_class == MMC_CLASS_CD) {
    528      1.1  reinoud 		/* dont switch too fast for CD media; its expensive in time */
    529      1.1  reinoud 		if (now.tv_sec - last->tv_sec < 3)
    530      1.1  reinoud 			return;
    531      1.1  reinoud 	}
    532      1.1  reinoud 
    533      1.1  reinoud 	/* check if we can/should switch */
    534      1.1  reinoud 	new_queue = priv->cur_queue;
    535      1.1  reinoud 
    536      1.1  reinoud 	if (BUFQ_PEEK(priv->queues[UDF_SHED_READING]))
    537      1.1  reinoud 		new_queue = UDF_SHED_READING;
    538      1.1  reinoud 	if (BUFQ_PEEK(priv->queues[UDF_SHED_SEQWRITING]))
    539      1.1  reinoud 		new_queue = UDF_SHED_SEQWRITING;
    540      1.1  reinoud 	if (BUFQ_PEEK(priv->queues[UDF_SHED_WRITING]))		/* only for unmount */
    541      1.1  reinoud 		new_queue = UDF_SHED_WRITING;
    542      1.1  reinoud 	if (priv->cur_queue == UDF_SHED_READING) {
    543      1.1  reinoud 		if (new_queue == UDF_SHED_SEQWRITING) {
    544      1.1  reinoud 			/* TODO use flag to signal if this is needed */
    545      1.1  reinoud 			mutex_exit(&priv->discstrat_mutex);
    546      1.1  reinoud 
    547      1.1  reinoud 			/* update trackinfo for data and metadata */
    548      1.1  reinoud 			error = udf_update_trackinfo(ump,
    549      1.1  reinoud 					&ump->data_track);
    550      1.1  reinoud 			assert(error == 0);
    551      1.1  reinoud 			error = udf_update_trackinfo(ump,
    552      1.1  reinoud 					&ump->metadata_track);
    553      1.1  reinoud 			assert(error == 0);
    554      1.1  reinoud 			mutex_enter(&priv->discstrat_mutex);
    555      1.1  reinoud 		}
    556      1.1  reinoud 	}
    557      1.1  reinoud 
    558      1.1  reinoud 	if (new_queue != priv->cur_queue) {
    559      1.1  reinoud 		DPRINTF(SHEDULE, ("switching from %d to %d\n",
    560      1.1  reinoud 			priv->cur_queue, new_queue));
    561      1.1  reinoud 	}
    562      1.1  reinoud 
    563      1.1  reinoud 	priv->cur_queue = new_queue;
    564      1.1  reinoud }
    565      1.1  reinoud 
    566      1.1  reinoud 
    567      1.1  reinoud static void
    568      1.1  reinoud udf_discstrat_thread(void *arg)
    569      1.1  reinoud {
    570      1.1  reinoud 	struct udf_mount *ump = (struct udf_mount *) arg;
    571      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    572      1.1  reinoud 	int empty;
    573      1.1  reinoud 
    574      1.1  reinoud 	empty = 1;
    575      1.1  reinoud 	mutex_enter(&priv->discstrat_mutex);
    576      1.1  reinoud 	while (priv->run_thread || !empty) {
    577      1.1  reinoud 		/* process the current selected queue */
    578      1.1  reinoud 		udf_doshedule(ump);
    579      1.1  reinoud 		empty  = (BUFQ_PEEK(priv->queues[UDF_SHED_READING]) == NULL);
    580      1.1  reinoud 		empty &= (BUFQ_PEEK(priv->queues[UDF_SHED_WRITING]) == NULL);
    581      1.1  reinoud 		empty &= (BUFQ_PEEK(priv->queues[UDF_SHED_SEQWRITING]) == NULL);
    582      1.1  reinoud 
    583      1.1  reinoud 		/* wait for more if needed */
    584      1.1  reinoud 		if (empty)
    585      1.1  reinoud 			cv_timedwait(&priv->discstrat_cv,
    586      1.1  reinoud 				&priv->discstrat_mutex, hz/8);
    587      1.1  reinoud 	}
    588      1.1  reinoud 	mutex_exit(&priv->discstrat_mutex);
    589      1.1  reinoud 
    590      1.1  reinoud 	wakeup(&priv->run_thread);
    591      1.1  reinoud 	kthread_exit(0);
    592      1.1  reinoud 	/* not reached */
    593      1.1  reinoud }
    594      1.1  reinoud 
    595      1.1  reinoud /* --------------------------------------------------------------------- */
    596      1.1  reinoud 
    597      1.1  reinoud static void
    598      1.1  reinoud udf_discstrat_init_seq(struct udf_strat_args *args)
    599      1.1  reinoud {
    600      1.1  reinoud 	struct udf_mount *ump = args->ump;
    601      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    602      1.1  reinoud 	struct disk_strategy dkstrat;
    603      1.1  reinoud 	uint32_t lb_size;
    604      1.1  reinoud 
    605      1.1  reinoud 	KASSERT(ump);
    606      1.1  reinoud 	KASSERT(ump->logical_vol);
    607      1.1  reinoud 	KASSERT(priv == NULL);
    608      1.1  reinoud 
    609      1.1  reinoud 	lb_size = udf_rw32(ump->logical_vol->lb_size);
    610      1.1  reinoud 	KASSERT(lb_size > 0);
    611      1.1  reinoud 
    612      1.1  reinoud 	/* initialise our memory space */
    613      1.1  reinoud 	ump->strategy_private = malloc(sizeof(struct strat_private),
    614      1.1  reinoud 		M_UDFTEMP, M_WAITOK);
    615      1.1  reinoud 	priv = ump->strategy_private;
    616      1.1  reinoud 	memset(priv, 0 , sizeof(struct strat_private));
    617      1.1  reinoud 
    618      1.1  reinoud 	/* initialise locks */
    619      1.1  reinoud 	cv_init(&priv->discstrat_cv, "udfstrat");
    620      1.1  reinoud 	mutex_init(&priv->discstrat_mutex, MUTEX_DEFAULT, IPL_NONE);
    621      1.1  reinoud 
    622      1.1  reinoud 	/*
    623      1.1  reinoud 	 * Initialise pool for descriptors associated with nodes. This is done
    624      1.1  reinoud 	 * in lb_size units though currently lb_size is dictated to be
    625      1.1  reinoud 	 * sector_size.
    626      1.1  reinoud 	 */
    627      1.1  reinoud 	pool_init(&priv->desc_pool, lb_size, 0, 0, 0, "udf_desc_pool", NULL,
    628      1.1  reinoud 	    IPL_NONE);
    629      1.1  reinoud 
    630      1.1  reinoud 	/*
    631      1.1  reinoud 	 * remember old device strategy method and explicit set method
    632      1.1  reinoud 	 * `discsort' since we have our own more complex strategy that is not
    633      1.1  reinoud 	 * implementable on the CD device and other strategies will get in the
    634      1.1  reinoud 	 * way.
    635      1.1  reinoud 	 */
    636      1.1  reinoud 	memset(&priv->old_strategy_setting, 0,
    637      1.1  reinoud 		sizeof(struct disk_strategy));
    638      1.1  reinoud 	VOP_IOCTL(ump->devvp, DIOCGSTRATEGY, &priv->old_strategy_setting,
    639      1.1  reinoud 		FREAD | FKIOCTL, NOCRED);
    640      1.1  reinoud 	memset(&dkstrat, 0, sizeof(struct disk_strategy));
    641      1.1  reinoud 	strcpy(dkstrat.dks_name, "discsort");
    642      1.1  reinoud 	VOP_IOCTL(ump->devvp, DIOCSSTRATEGY, &dkstrat, FWRITE | FKIOCTL,
    643      1.1  reinoud 		NOCRED);
    644      1.1  reinoud 
    645      1.1  reinoud 	/* initialise our internal sheduler */
    646      1.1  reinoud 	priv->cur_queue = UDF_SHED_READING;
    647      1.1  reinoud 	bufq_alloc(&priv->queues[UDF_SHED_READING], "disksort",
    648      1.1  reinoud 		BUFQ_SORT_RAWBLOCK);
    649      1.1  reinoud 	bufq_alloc(&priv->queues[UDF_SHED_WRITING], "disksort",
    650      1.1  reinoud 		BUFQ_SORT_RAWBLOCK);
    651      1.1  reinoud 	bufq_alloc(&priv->queues[UDF_SHED_SEQWRITING], "fcfs", 0);
    652      1.1  reinoud 	vfs_timestamp(&priv->last_queued[UDF_SHED_READING]);
    653      1.1  reinoud 	vfs_timestamp(&priv->last_queued[UDF_SHED_WRITING]);
    654      1.1  reinoud 	vfs_timestamp(&priv->last_queued[UDF_SHED_SEQWRITING]);
    655      1.1  reinoud 
    656      1.1  reinoud 	/* create our disk strategy thread */
    657      1.1  reinoud 	priv->run_thread = 1;
    658      1.1  reinoud 	if (kthread_create(PRI_NONE, 0 /* KTHREAD_MPSAFE*/, NULL /* cpu_info*/,
    659      1.1  reinoud 		udf_discstrat_thread, ump, &priv->queue_lwp,
    660      1.1  reinoud 		"%s", "udf_rw")) {
    661      1.1  reinoud 		panic("fork udf_rw");
    662      1.1  reinoud 	}
    663      1.1  reinoud }
    664      1.1  reinoud 
    665      1.1  reinoud 
    666      1.1  reinoud static void
    667      1.1  reinoud udf_discstrat_finish_seq(struct udf_strat_args *args)
    668      1.1  reinoud {
    669      1.1  reinoud 	struct udf_mount *ump = args->ump;
    670      1.1  reinoud 	struct strat_private *priv = PRIV(ump);
    671      1.1  reinoud 	int error;
    672      1.1  reinoud 
    673      1.1  reinoud 	if (ump == NULL)
    674      1.1  reinoud 		return;
    675      1.1  reinoud 
    676      1.1  reinoud 	/* stop our sheduling thread */
    677      1.1  reinoud 	KASSERT(priv->run_thread == 1);
    678      1.1  reinoud 	priv->run_thread = 0;
    679      1.1  reinoud 	wakeup(priv->queue_lwp);
    680      1.1  reinoud 	do {
    681      1.1  reinoud 		error = tsleep(&priv->run_thread, PRIBIO+1,
    682      1.1  reinoud 			"udfshedfin", hz);
    683      1.1  reinoud 	} while (error);
    684      1.1  reinoud 	/* kthread should be finished now */
    685      1.1  reinoud 
    686      1.1  reinoud 	/* set back old device strategy method */
    687      1.1  reinoud 	VOP_IOCTL(ump->devvp, DIOCSSTRATEGY, &priv->old_strategy_setting,
    688      1.1  reinoud 			FWRITE, NOCRED);
    689      1.1  reinoud 
    690      1.1  reinoud 	/* destroy our pool */
    691      1.1  reinoud 	pool_destroy(&priv->desc_pool);
    692      1.1  reinoud 
    693      1.1  reinoud 	/* free our private space */
    694      1.1  reinoud 	free(ump->strategy_private, M_UDFTEMP);
    695      1.1  reinoud 	ump->strategy_private = NULL;
    696      1.1  reinoud }
    697      1.1  reinoud 
    698      1.1  reinoud /* --------------------------------------------------------------------- */
    699      1.1  reinoud 
    700      1.1  reinoud struct udf_strategy udf_strat_sequential =
    701      1.1  reinoud {
    702      1.1  reinoud 	udf_create_logvol_dscr_seq,
    703      1.1  reinoud 	udf_free_logvol_dscr_seq,
    704      1.1  reinoud 	udf_read_logvol_dscr_seq,
    705      1.1  reinoud 	udf_write_logvol_dscr_seq,
    706      1.1  reinoud 	udf_queuebuf_seq,
    707      1.1  reinoud 	udf_discstrat_init_seq,
    708      1.1  reinoud 	udf_discstrat_finish_seq
    709      1.1  reinoud };
    710      1.1  reinoud 
    711      1.1  reinoud 
    712