Home | History | Annotate | Line # | Download | only in dm
dm_target_stripe.c revision 1.10
      1  1.10     haad /*$NetBSD: dm_target_stripe.c,v 1.10 2010/05/18 15:10:41 haad Exp $*/
      2   1.1     haad 
      3   1.1     haad /*
      4   1.1     haad  * Copyright (c) 2009 The NetBSD Foundation, Inc.
      5   1.1     haad  * All rights reserved.
      6   1.1     haad  *
      7   1.1     haad  * This code is derived from software contributed to The NetBSD Foundation
      8   1.1     haad  * by Adam Hamsik.
      9   1.1     haad  *
     10   1.1     haad  * Redistribution and use in source and binary forms, with or without
     11   1.1     haad  * modification, are permitted provided that the following conditions
     12   1.1     haad  * are met:
     13   1.1     haad  * 1. Redistributions of source code must retain the above copyright
     14   1.1     haad  *    notice, this list of conditions and the following disclaimer.
     15   1.1     haad  * 2. Redistributions in binary form must reproduce the above copyright
     16   1.1     haad  *    notice, this list of conditions and the following disclaimer in the
     17   1.1     haad  *    documentation and/or other materials provided with the distribution.
     18   1.1     haad  *
     19   1.1     haad  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     20   1.1     haad  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     21   1.1     haad  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     22   1.1     haad  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     23   1.1     haad  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     24   1.1     haad  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     25   1.1     haad  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     26   1.1     haad  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     27   1.1     haad  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     28   1.1     haad  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     29   1.1     haad  * POSSIBILITY OF SUCH DAMAGE.
     30   1.1     haad  */
     31   1.1     haad 
     32   1.1     haad /*
     33   1.1     haad  * This file implements initial version of device-mapper stripe target.
     34   1.1     haad  */
     35   1.1     haad #include <sys/types.h>
     36   1.1     haad #include <sys/param.h>
     37   1.1     haad 
     38   1.1     haad #include <sys/buf.h>
     39   1.3     haad #include <sys/kmem.h>
     40   1.3     haad #include <sys/vnode.h>
     41   1.1     haad 
     42   1.1     haad #include "dm.h"
     43   1.1     haad 
     44   1.1     haad #ifdef DM_TARGET_MODULE
     45   1.1     haad /*
     46   1.1     haad  * Every target can be compiled directly to dm driver or as a
     47   1.1     haad  * separate module this part of target is used for loading targets
     48   1.1     haad  * to dm driver.
     49   1.1     haad  * Target can be unloaded from kernel only if there are no users of
     50   1.1     haad  * it e.g. there are no devices which uses that target.
     51   1.1     haad  */
     52   1.1     haad #include <sys/kernel.h>
     53   1.1     haad #include <sys/module.h>
     54   1.1     haad 
     55   1.1     haad MODULE(MODULE_CLASS_MISC, dm_target_stripe, NULL);
     56   1.1     haad 
     57   1.1     haad static int
     58   1.1     haad dm_target_stripe_modcmd(modcmd_t cmd, void *arg)
     59   1.1     haad {
     60   1.1     haad 	dm_target_t *dmt;
     61   1.1     haad 	int r;
     62   1.1     haad 	dmt = NULL;
     63   1.9     haad 
     64   1.1     haad 	switch (cmd) {
     65   1.1     haad 	case MODULE_CMD_INIT:
     66   1.3     haad 		if ((dmt = dm_target_lookup("stripe")) != NULL) {
     67   1.3     haad 			dm_target_unbusy(dmt);
     68   1.1     haad 			return EEXIST;
     69   1.3     haad 		}
     70   1.1     haad 		dmt = dm_target_alloc("stripe");
     71   1.9     haad 
     72   1.1     haad 		dmt->version[0] = 1;
     73   1.1     haad 		dmt->version[1] = 0;
     74   1.1     haad 		dmt->version[2] = 0;
     75   1.1     haad 		strlcpy(dmt->name, "stripe", DM_MAX_TYPE_NAME);
     76   1.1     haad 		dmt->init = &dm_target_stripe_init;
     77   1.1     haad 		dmt->status = &dm_target_stripe_status;
     78   1.1     haad 		dmt->strategy = &dm_target_stripe_strategy;
     79  1.10     haad 		dmt->sync = &dm_target_stripe_sync;
     80   1.1     haad 		dmt->deps = &dm_target_stripe_deps;
     81   1.1     haad 		dmt->destroy = &dm_target_stripe_destroy;
     82   1.1     haad 		dmt->upcall = &dm_target_stripe_upcall;
     83   1.1     haad 
     84   1.1     haad 		r = dm_target_insert(dmt);
     85   1.9     haad 
     86   1.1     haad 		break;
     87   1.1     haad 
     88   1.1     haad 	case MODULE_CMD_FINI:
     89   1.1     haad 		r = dm_target_rem("stripe");
     90   1.1     haad 		break;
     91   1.1     haad 
     92   1.1     haad 	case MODULE_CMD_STAT:
     93   1.1     haad 		return ENOTTY;
     94   1.1     haad 
     95   1.1     haad 	default:
     96   1.1     haad 		return ENOTTY;
     97   1.1     haad 	}
     98   1.1     haad 
     99   1.1     haad 	return r;
    100   1.1     haad }
    101   1.1     haad #endif
    102   1.1     haad 
    103   1.3     haad /*
    104   1.3     haad  * Init function called from dm_table_load_ioctl.
    105   1.3     haad  * Example line sent to dm from lvm tools when using striped target.
    106   1.3     haad  * start length striped #stripes chunk_size device1 offset1 ... deviceN offsetN
    107   1.3     haad  * 0 65536 striped 2 512 /dev/hda 0 /dev/hdb 0
    108   1.3     haad  */
    109   1.1     haad int
    110   1.9     haad dm_target_stripe_init(dm_dev_t * dmv, void **target_config, char *params)
    111   1.1     haad {
    112   1.3     haad 	dm_target_stripe_config_t *tsc;
    113   1.8     haad 	size_t len;
    114   1.8     haad 	char **ap, *argv[10];
    115   1.8     haad 
    116   1.9     haad 	if (params == NULL)
    117   1.3     haad 		return EINVAL;
    118   1.8     haad 
    119   1.8     haad 	len = strlen(params) + 1;
    120   1.9     haad 
    121   1.8     haad 	/*
    122   1.8     haad 	 * Parse a string, containing tokens delimited by white space,
    123   1.8     haad 	 * into an argument vector
    124   1.8     haad 	 */
    125   1.8     haad 	for (ap = argv; ap < &argv[9] &&
    126   1.9     haad 	    (*ap = strsep(&params, " \t")) != NULL;) {
    127   1.8     haad 		if (**ap != '\0')
    128   1.8     haad 			ap++;
    129   1.8     haad 	}
    130   1.9     haad 
    131   1.8     haad 	printf("Stripe target init function called!!\n");
    132   1.1     haad 
    133   1.8     haad 	printf("Stripe target chunk size %s number of stripes %s\n", argv[1], argv[0]);
    134   1.8     haad 	printf("Stripe target device name %s -- offset %s\n", argv[2], argv[3]);
    135   1.8     haad 	printf("Stripe target device name %s -- offset %s\n", argv[4], argv[5]);
    136   1.3     haad 
    137   1.8     haad 	if (atoi(argv[0]) > MAX_STRIPES)
    138   1.3     haad 		return ENOTSUP;
    139   1.3     haad 
    140   1.3     haad 	if ((tsc = kmem_alloc(sizeof(dm_target_stripe_config_t), KM_NOSLEEP))
    141   1.3     haad 	    == NULL)
    142   1.3     haad 		return ENOMEM;
    143   1.9     haad 
    144   1.3     haad 	/* Insert dmp to global pdev list */
    145   1.8     haad 	if ((tsc->stripe_devs[0].pdev = dm_pdev_insert(argv[2])) == NULL)
    146   1.3     haad 		return ENOENT;
    147   1.3     haad 
    148   1.3     haad 	/* Insert dmp to global pdev list */
    149   1.8     haad 	if ((tsc->stripe_devs[1].pdev = dm_pdev_insert(argv[4])) == NULL)
    150   1.3     haad 		return ENOENT;
    151   1.3     haad 
    152   1.8     haad 	tsc->stripe_devs[0].offset = atoi(argv[3]);
    153   1.8     haad 	tsc->stripe_devs[1].offset = atoi(argv[5]);
    154   1.3     haad 
    155   1.8     haad 	/* Save length of param string */
    156   1.8     haad 	tsc->params_len = len;
    157   1.8     haad 	tsc->stripe_chunksize = atoi(argv[1]);
    158   1.9     haad 	tsc->stripe_num = (uint8_t) atoi(argv[0]);
    159   1.9     haad 
    160   1.3     haad 	*target_config = tsc;
    161   1.1     haad 
    162   1.1     haad 	dmv->dev_type = DM_STRIPE_DEV;
    163   1.9     haad 
    164   1.3     haad 	return 0;
    165   1.1     haad }
    166   1.1     haad /* Status routine called to get params string. */
    167   1.1     haad char *
    168   1.1     haad dm_target_stripe_status(void *target_config)
    169   1.1     haad {
    170   1.3     haad 	dm_target_stripe_config_t *tsc;
    171   1.3     haad 	char *params;
    172   1.3     haad 
    173   1.3     haad 	tsc = target_config;
    174   1.9     haad 
    175   1.7     haad 	if ((params = kmem_alloc(DM_MAX_PARAMS_SIZE, KM_SLEEP)) == NULL)
    176   1.3     haad 		return NULL;
    177   1.3     haad 
    178   1.9     haad 	snprintf(params, DM_MAX_PARAMS_SIZE, "%d %" PRIu64 " %s %" PRIu64 " %s %" PRIu64,
    179   1.5     haad 	    tsc->stripe_num, tsc->stripe_chunksize,
    180   1.3     haad 	    tsc->stripe_devs[0].pdev->name, tsc->stripe_devs[0].offset,
    181   1.3     haad 	    tsc->stripe_devs[1].pdev->name, tsc->stripe_devs[1].offset);
    182   1.9     haad 
    183   1.3     haad 	return params;
    184   1.9     haad }
    185   1.1     haad /* Strategy routine called from dm_strategy. */
    186   1.1     haad int
    187   1.9     haad dm_target_stripe_strategy(dm_table_entry_t * table_en, struct buf * bp)
    188   1.1     haad {
    189   1.4  reinoud 	dm_target_stripe_config_t *tsc;
    190   1.4  reinoud 	struct buf *nestbuf;
    191   1.4  reinoud 	uint64_t blkno, blkoff;
    192   1.4  reinoud 	uint64_t stripe, stripe_blknr;
    193   1.4  reinoud 	uint32_t stripe_off, stripe_rest, num_blks, issue_blks;
    194   1.4  reinoud 	int stripe_devnr;
    195   1.4  reinoud 
    196   1.4  reinoud 	tsc = table_en->target_config;
    197   1.4  reinoud 	if (tsc == NULL)
    198   1.4  reinoud 		return 0;
    199   1.4  reinoud 
    200   1.8     haad /*	printf("Stripe target read function called %" PRIu64 "!!\n",
    201   1.4  reinoud 	tlc->offset);*/
    202   1.4  reinoud 
    203   1.4  reinoud 	/* calculate extent of request */
    204   1.4  reinoud 	KASSERT(bp->b_resid % DEV_BSIZE == 0);
    205   1.4  reinoud 
    206   1.9     haad 	blkno = bp->b_blkno;
    207   1.4  reinoud 	blkoff = 0;
    208   1.4  reinoud 	num_blks = bp->b_resid / DEV_BSIZE;
    209   1.4  reinoud 	for (;;) {
    210   1.4  reinoud 		/* blockno to strip piece nr */
    211   1.9     haad 		stripe = blkno / tsc->stripe_chunksize;
    212   1.4  reinoud 		stripe_off = blkno % tsc->stripe_chunksize;
    213   1.4  reinoud 
    214   1.4  reinoud 		/* where we are inside the strip */
    215   1.4  reinoud 		stripe_devnr = stripe % tsc->stripe_num;
    216   1.4  reinoud 		stripe_blknr = stripe / tsc->stripe_num;
    217   1.4  reinoud 
    218   1.4  reinoud 		/* how much is left before we hit a boundary */
    219   1.4  reinoud 		stripe_rest = tsc->stripe_chunksize - stripe_off;
    220   1.4  reinoud 
    221   1.4  reinoud 		/* issue this piece on stripe `stripe' */
    222   1.4  reinoud 		issue_blks = MIN(stripe_rest, num_blks);
    223   1.4  reinoud 		nestbuf = getiobuf(NULL, true);
    224   1.4  reinoud 
    225   1.4  reinoud 		nestiobuf_setup(bp, nestbuf, blkoff, issue_blks * DEV_BSIZE);
    226   1.4  reinoud 		nestbuf->b_blkno = stripe_blknr * tsc->stripe_chunksize + stripe_off;
    227   1.4  reinoud 		nestbuf->b_blkno += tsc->stripe_devs[stripe_devnr].offset;
    228   1.4  reinoud 
    229   1.4  reinoud 		VOP_STRATEGY(tsc->stripe_devs[stripe_devnr].pdev->pdev_vnode, nestbuf);
    230   1.4  reinoud 
    231   1.9     haad 		blkno += issue_blks;
    232   1.9     haad 		blkoff += issue_blks * DEV_BSIZE;
    233   1.4  reinoud 		num_blks -= issue_blks;
    234   1.4  reinoud 
    235   1.4  reinoud 		if (num_blks <= 0)
    236   1.4  reinoud 			break;
    237   1.4  reinoud 	}
    238   1.1     haad 
    239   1.1     haad 	return 0;
    240   1.1     haad }
    241  1.10     haad /* Sync underlying disk caches. */
    242  1.10     haad int
    243  1.10     haad dm_target_stripe_sync(dm_table_entry_t * table_en)
    244  1.10     haad {
    245  1.10     haad 	int cmd, err, i;
    246  1.10     haad 	dm_target_stripe_config_t *tsc;
    247  1.10     haad 
    248  1.10     haad 	tsc = table_en->target_config;
    249  1.10     haad 
    250  1.10     haad 	err = 0;
    251  1.10     haad 	cmd = 1;
    252  1.10     haad 
    253  1.10     haad 	for (i = 0; i < tsc->stripe_num; i++) {
    254  1.10     haad 		if ((err = VOP_IOCTL(tsc->stripe_devs[i].pdev->pdev_vnode, DIOCCACHESYNC,
    255  1.10     haad 			    &cmd, FREAD|FWRITE, kauth_cred_get())) != 0)
    256  1.10     haad 			return err;
    257  1.10     haad 	}
    258  1.10     haad 
    259  1.10     haad 	return err;
    260  1.10     haad 
    261  1.10     haad }
    262  1.10     haad /* Destroy target specific data. */
    263   1.1     haad int
    264   1.9     haad dm_target_stripe_destroy(dm_table_entry_t * table_en)
    265   1.1     haad {
    266   1.3     haad 	dm_target_stripe_config_t *tsc;
    267   1.9     haad 
    268   1.3     haad 	tsc = table_en->target_config;
    269   1.3     haad 
    270   1.3     haad 	if (tsc == NULL)
    271   1.3     haad 		return 0;
    272   1.9     haad 
    273   1.3     haad 	dm_pdev_decr(tsc->stripe_devs[0].pdev);
    274   1.3     haad 	dm_pdev_decr(tsc->stripe_devs[1].pdev);
    275   1.1     haad 
    276   1.1     haad 	/* Unbusy target so we can unload it */
    277   1.1     haad 	dm_target_unbusy(table_en->target);
    278   1.9     haad 
    279   1.3     haad 	kmem_free(tsc, sizeof(dm_target_stripe_config_t));
    280   1.9     haad 
    281   1.3     haad 	table_en->target_config = NULL;
    282   1.3     haad 
    283   1.1     haad 	return 0;
    284   1.1     haad }
    285   1.1     haad /* Doesn't not need to do anything here. */
    286   1.1     haad int
    287   1.9     haad dm_target_stripe_deps(dm_table_entry_t * table_en, prop_array_t prop_array)
    288   1.9     haad {
    289   1.3     haad 	dm_target_stripe_config_t *tsc;
    290   1.3     haad 	struct vattr va;
    291   1.9     haad 
    292   1.3     haad 	int error;
    293   1.9     haad 
    294   1.3     haad 	if (table_en->target_config == NULL)
    295   1.3     haad 		return ENOENT;
    296   1.9     haad 
    297   1.3     haad 	tsc = table_en->target_config;
    298   1.9     haad 
    299   1.3     haad 	if ((error = VOP_GETATTR(tsc->stripe_devs[0].pdev->pdev_vnode, &va, curlwp->l_cred)) != 0)
    300   1.3     haad 		return error;
    301   1.3     haad 
    302   1.9     haad 	prop_array_add_uint64(prop_array, (uint64_t) va.va_rdev);
    303   1.9     haad 
    304   1.3     haad 	if ((error = VOP_GETATTR(tsc->stripe_devs[1].pdev->pdev_vnode, &va, curlwp->l_cred)) != 0)
    305   1.3     haad 		return error;
    306   1.9     haad 
    307   1.9     haad 	prop_array_add_uint64(prop_array, (uint64_t) va.va_rdev);
    308   1.9     haad 
    309   1.1     haad 	return 0;
    310   1.1     haad }
    311   1.1     haad /* Unsupported for this target. */
    312   1.1     haad int
    313   1.9     haad dm_target_stripe_upcall(dm_table_entry_t * table_en, struct buf * bp)
    314   1.1     haad {
    315   1.1     haad 	return 0;
    316   1.1     haad }
    317