cregit-Linux how code gets into the kernel

Release 4.14 drivers/md/linear.c

Directory: drivers/md
/*
   linear.c : Multiple Devices driver for Linux
              Copyright (C) 1994-96 Marc ZYNGIER
              <zyngier@ufr-info-p7.ibp.fr> or
              <maz@gloups.fdn.fr>

   Linear mode management functions.

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License as published by
   the Free Software Foundation; either version 2, or (at your option)
   any later version.

   You should have received a copy of the GNU General Public License
   (for example /usr/src/linux/COPYING); if not, write to the Free
   Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/

#include <linux/blkdev.h>
#include <linux/raid/md_u.h>
#include <linux/seq_file.h>
#include <linux/module.h>
#include <linux/slab.h>
#include <trace/events/block.h>
#include "md.h"
#include "linear.h"

/*
 * find which device holds a particular offset
 */

static inline struct dev_info *which_dev(struct mddev *mddev, sector_t sector) { int lo, mid, hi; struct linear_conf *conf; lo = 0; hi = mddev->raid_disks - 1; conf = mddev->private; /* * Binary Search */ while (hi > lo) { mid = (hi + lo) / 2; if (sector < conf->disks[mid].end_sector) hi = mid; else lo = mid + 1; } return conf->disks + lo; }

Contributors

PersonTokensPropCommitsCommitProp
Sandeep K Sinha6364.95%333.33%
Neil Brown3435.05%666.67%
Total97100.00%9100.00%

/* * In linear_congested() conf->raid_disks is used as a copy of * mddev->raid_disks to iterate conf->disks[], because conf->raid_disks * and conf->disks[] are created in linear_conf(), they are always * consitent with each other, but mddev->raid_disks does not. */
static int linear_congested(struct mddev *mddev, int bits) { struct linear_conf *conf; int i, ret = 0; rcu_read_lock(); conf = rcu_dereference(mddev->private); for (i = 0; i < conf->raid_disks && !ret ; i++) { struct request_queue *q = bdev_get_queue(conf->disks[i].rdev->bdev); ret |= bdi_congested(q->backing_dev_info, bits); } rcu_read_unlock(); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Neil Brown7680.85%457.14%
Coly Li1010.64%114.29%
Sandeep K Sinha66.38%114.29%
Jens Axboe22.13%114.29%
Total94100.00%7100.00%


static sector_t linear_size(struct mddev *mddev, sector_t sectors, int raid_disks) { struct linear_conf *conf; sector_t array_sectors; conf = mddev->private; WARN_ONCE(sectors || raid_disks, "%s does not support generic reshape\n", __func__); array_sectors = conf->array_sectors; return array_sectors; }

Contributors

PersonTokensPropCommitsCommitProp
Dan J Williams3364.71%120.00%
Sandeep K Sinha1223.53%120.00%
Neil Brown611.76%360.00%
Total51100.00%5100.00%


static struct linear_conf *linear_conf(struct mddev *mddev, int raid_disks) { struct linear_conf *conf; struct md_rdev *rdev; int i, cnt; bool discard_supported = false; conf = kzalloc (sizeof (*conf) + raid_disks*sizeof(struct dev_info), GFP_KERNEL); if (!conf) return NULL; cnt = 0; conf->array_sectors = 0; rdev_for_each(rdev, mddev) { int j = rdev->raid_disk; struct dev_info *disk = conf->disks + j; sector_t sectors; if (j < 0 || j >= raid_disks || disk->rdev) { pr_warn("md/linear:%s: disk numbering problem. Aborting!\n", mdname(mddev)); goto out; } disk->rdev = rdev; if (mddev->chunk_sectors) { sectors = rdev->sectors; sector_div(sectors, mddev->chunk_sectors); rdev->sectors = sectors * mddev->chunk_sectors; } disk_stack_limits(mddev->gendisk, rdev->bdev, rdev->data_offset << 9); conf->array_sectors += rdev->sectors; cnt++; if (blk_queue_discard(bdev_get_queue(rdev->bdev))) discard_supported = true; } if (cnt != raid_disks) { pr_warn("md/linear:%s: not enough drives present. Aborting!\n", mdname(mddev)); goto out; } if (!discard_supported) queue_flag_clear_unlocked(QUEUE_FLAG_DISCARD, mddev->queue); else queue_flag_set_unlocked(QUEUE_FLAG_DISCARD, mddev->queue); /* * Here we calculate the device offsets. */ conf->disks[0].end_sector = conf->disks[0].rdev->sectors; for (i = 1; i < raid_disks; i++) conf->disks[i].end_sector = conf->disks[i-1].end_sector + conf->disks[i].rdev->sectors; /* * conf->raid_disks is copy of mddev->raid_disks. The reason to * keep a copy of mddev->raid_disks in struct linear_conf is, * mddev->raid_disks may not be consistent with pointers number of * conf->disks[] when it is updated in linear_add() and used to * iterate old conf->disks[] earray in linear_congested(). * Here conf->raid_disks is always consitent with number of * pointers in conf->disks[] array, and mddev->private is updated * with rcu_assign_pointer() in linear_addr(), such race can be * avoided. */ conf->raid_disks = raid_disks; return conf; out: kfree(conf); return NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Neil Brown18352.89%1655.17%
Linus Torvalds (pre-git)7120.52%310.34%
Shaohua Li4513.01%13.45%
Sandeep K Sinha164.62%26.90%
Andrew Morton102.89%13.45%
Coly Li72.02%13.45%
Martin K. Petersen72.02%13.45%
Andre Noll30.87%26.90%
Al Viro30.87%13.45%
Nikanth Karthikesan10.29%13.45%
Total346100.00%29100.00%


static int linear_run (struct mddev *mddev) { struct linear_conf *conf; int ret; if (md_check_no_bitmap(mddev)) return -EINVAL; conf = linear_conf(mddev, mddev->raid_disks); if (!conf) return 1; mddev->private = conf; md_set_array_sectors(mddev, linear_size(mddev, 0, 0)); ret = md_integrity_register(mddev); if (ret) { kfree(conf); mddev->private = NULL; } return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Neil Brown4344.79%333.33%
Jianpeng Ma (马建朋)2526.04%111.11%
Andre Noll1515.62%222.22%
Dan J Williams1212.50%222.22%
Linus Torvalds (pre-git)11.04%111.11%
Total96100.00%9100.00%


static int linear_add(struct mddev *mddev, struct md_rdev *rdev) { /* Adding a drive to a linear array allows the array to grow. * It is permitted if the new drive has a matching superblock * already on it, with raid_disk equal to raid_disks. * It is achieved by creating a new linear_private_data structure * and swapping it in in-place of the current one. * The current one is never freed until the array is stopped. * This avoids races. */ struct linear_conf *newconf, *oldconf; if (rdev->saved_raid_disk != mddev->raid_disks) return -EINVAL; rdev->raid_disk = rdev->saved_raid_disk; rdev->saved_raid_disk = -1; newconf = linear_conf(mddev,mddev->raid_disks+1); if (!newconf) return -ENOMEM; /* newconf->raid_disks already keeps a copy of * the increased * value of mddev->raid_disks, WARN_ONCE() is just used to make * sure of this. It is possible that oldconf is still referenced * in linear_congested(), therefore kfree_rcu() is used to free * oldconf until no one uses it anymore. */ mddev_suspend(mddev); oldconf = rcu_dereference_protected(mddev->private, lockdep_is_held(&mddev->reconfig_mutex)); mddev->raid_disks++; WARN_ONCE(mddev->raid_disks != newconf->raid_disks, "copied raid_disks doesn't match mddev->raid_disks"); rcu_assign_pointer(mddev->private, newconf); md_set_array_sectors(mddev, linear_size(mddev, 0, 0)); set_capacity(mddev->gendisk, mddev->array_sectors); mddev_resume(mddev); revalidate_disk(mddev->gendisk); kfree_rcu(oldconf, rcu); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Neil Brown11868.21%1055.56%
Coly Li2313.29%15.56%
Dan J Williams126.94%211.11%
Shaohua Li95.20%15.56%
Linus Torvalds (pre-git)63.47%211.11%
Sandeep K Sinha42.31%15.56%
Andre Noll10.58%15.56%
Total173100.00%18100.00%


static void linear_free(struct mddev *mddev, void *priv) { struct linear_conf *conf = priv; kfree(conf); }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)1659.26%240.00%
Neil Brown1140.74%360.00%
Total27100.00%5100.00%


static bool linear_make_request(struct mddev *mddev, struct bio *bio) { char b[BDEVNAME_SIZE]; struct dev_info *tmp_dev; sector_t start_sector, end_sector, data_offset; sector_t bio_sector = bio->bi_iter.bi_sector; if (unlikely(bio->bi_opf & REQ_PREFLUSH)) { md_flush_request(mddev, bio); return true; } tmp_dev = which_dev(mddev, bio_sector); start_sector = tmp_dev->end_sector - tmp_dev->rdev->sectors; end_sector = tmp_dev->end_sector; data_offset = tmp_dev->rdev->data_offset; if (unlikely(bio_sector >= end_sector || bio_sector < start_sector)) goto out_of_bounds; if (unlikely(bio_end_sector(bio) > end_sector)) { /* This bio crosses a device boundary, so we have to split it */ struct bio *split = bio_split(bio, end_sector - bio_sector, GFP_NOIO, mddev->bio_set); bio_chain(split, bio); generic_make_request(bio); bio = split; } bio_set_dev(bio, tmp_dev->rdev->bdev); bio->bi_iter.bi_sector = bio->bi_iter.bi_sector - start_sector + data_offset; if (unlikely((bio_op(bio) == REQ_OP_DISCARD) && !blk_queue_discard(bio->bi_disk->queue))) { /* Just ignore it */ bio_endio(bio); } else { if (mddev->gendisk) trace_block_bio_remap(bio->bi_disk->queue, bio, disk_devt(mddev->gendisk), bio_sector); mddev_check_writesame(mddev, bio); mddev_check_write_zeroes(mddev, bio); generic_make_request(bio); } return true; out_of_bounds: pr_err("md/linear:%s: make_request: Sector %llu out of bounds on dev %s: %llu sectors, offset %llu\n", mdname(mddev), (unsigned long long)bio->bi_iter.bi_sector, bdevname(tmp_dev->rdev->bdev, b), (unsigned long long)tmp_dev->rdev->sectors, (unsigned long long)start_sector); bio_io_error(bio); return true; }

Contributors

PersonTokensPropCommitsCommitProp
Neil Brown12737.57%1337.14%
Kent Overstreet9929.29%38.57%
Shaohua Li288.28%38.57%
Linus Torvalds (pre-git)267.69%411.43%
Christoph Hellwig236.80%411.43%
Sandeep K Sinha185.33%12.86%
Michael Christie61.78%25.71%
Linus Torvalds51.48%12.86%
Andre Noll20.59%12.86%
Andrew Morton20.59%12.86%
Tejun Heo10.30%12.86%
Jens Axboe10.30%12.86%
Total338100.00%35100.00%


static void linear_status (struct seq_file *seq, struct mddev *mddev) { seq_printf(seq, " %dk rounding", mddev->chunk_sectors / 2); }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)1965.52%350.00%
Neil Brown827.59%233.33%
Andre Noll26.90%116.67%
Total29100.00%6100.00%


static void linear_quiesce(struct mddev *mddev, int state) { }

Contributors

PersonTokensPropCommitsCommitProp
Neil Brown13100.00%1100.00%
Total13100.00%1100.00%

static struct md_personality linear_personality = { .name = "linear", .level = LEVEL_LINEAR, .owner = THIS_MODULE, .make_request = linear_make_request, .run = linear_run, .free = linear_free, .status = linear_status, .hot_add_disk = linear_add, .size = linear_size, .quiesce = linear_quiesce, .congested = linear_congested, };
static int __init linear_init (void) { return register_md_personality (&linear_personality); }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)1593.75%375.00%
Linus Torvalds16.25%125.00%
Total16100.00%4100.00%


static void linear_exit (void) { unregister_md_personality (&linear_personality); }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)1285.71%266.67%
Neil Brown214.29%133.33%
Total14100.00%3100.00%

module_init(linear_init); module_exit(linear_exit); MODULE_LICENSE("GPL"); MODULE_DESCRIPTION("Linear device concatenation personality for MD"); MODULE_ALIAS("md-personality-1"); /* LINEAR - deprecated*/ MODULE_ALIAS("md-linear"); MODULE_ALIAS("md-level--1");

Overall Contributors

PersonTokensPropCommitsCommitProp
Neil Brown69849.19%4848.48%
Linus Torvalds (pre-git)19613.81%99.09%
Sandeep K Sinha1198.39%44.04%
Kent Overstreet996.98%33.03%
Shaohua Li825.78%44.04%
Dan J Williams624.37%22.02%
Coly Li412.89%11.01%
Jianpeng Ma (马建朋)251.76%11.01%
Christoph Hellwig241.69%55.05%
Andre Noll231.62%77.07%
Andrew Morton120.85%22.02%
Linus Torvalds110.78%33.03%
Martin K. Petersen70.49%11.01%
Michael Christie60.42%22.02%
Tejun Heo40.28%22.02%
Paul Gortmaker30.21%11.01%
Jens Axboe30.21%22.02%
Al Viro30.21%11.01%
Nikanth Karthikesan10.07%11.01%
Total1419100.00%99100.00%
Directory: drivers/md
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.