cregit-Linux how code gets into the kernel

Release 4.7 block/blk-lib.c

Directory: block
/*
 * Functions related to generic helpers functions
 */
#include <linux/kernel.h>
#include <linux/module.h>
#include <linux/bio.h>
#include <linux/blkdev.h>
#include <linux/scatterlist.h>

#include "blk.h"




static struct bio *next_bio(struct bio *bio, int rw, unsigned int nr_pages,
		gfp_t gfp)
{
	struct bio *new = bio_alloc(gfp, nr_pages);

	if (bio) {
		bio_chain(bio, new);
		submit_bio(rw, bio);
	}

	return new;
}


Contributors
PersonTokensPropCommitsCommitProp
christoph hellwigchristoph hellwig3560.34%250.00%


dmitriy monakhovdmitriy monakhov1932.76%125.00%


lukas czernerlukas czerner46.90%125.00%


Total58100.00%4100.00%






int __blkdev_issue_discard(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp_mask, int type, struct bio **biop)
{
	struct request_queue *q = bdev_get_queue(bdev);
	struct bio *bio = *biop;
	unsigned int granularity;
	int alignment;

	if (!q)
		return -ENXIO;
	if (!blk_queue_discard(q))
		return -EOPNOTSUPP;
	if ((type & REQ_SECURE) && !blk_queue_secdiscard(q))
		return -EOPNOTSUPP;

	/* Zero-sector (unknown) and one-sector granularities are the same.  */
	granularity = max(q->limits.discard_granularity >> 9, 1U);
	alignment = (bdev_discard_alignment(bdev) >> 9) % granularity;

	while (nr_sects) {
		unsigned int req_sects;
		sector_t end_sect, tmp;

		/* Make sure bi_size doesn't overflow */
		req_sects = min_t(sector_t, nr_sects, UINT_MAX >> 9);

		/**
                 * If splitting a request, and the next starting sector would be
                 * misaligned, stop the discard at the previous aligned sector.
                 */
		end_sect = sector + req_sects;
		tmp = end_sect;
		if (req_sects < nr_sects &&
		    sector_div(tmp, granularity) != alignment) {
			end_sect = end_sect - alignment;
			sector_div(end_sect, granularity);
			end_sect = end_sect * granularity + alignment;
			req_sects = end_sect - sector;
		}

		bio = next_bio(bio, type, 1, gfp_mask);
		bio->bi_iter.bi_sector = sector;
		bio->bi_bdev = bdev;

		bio->bi_iter.bi_size = req_sects << 9;
		nr_sects -= req_sects;
		sector = end_sect;

		/*
                 * We can loop for a long time in here, if someone does
                 * full device discards (like mkfs). Be nice and allow
                 * us to schedule out to avoid softlocking if preempt
                 * is disabled.
                 */
		cond_resched();
	}

	*biop = bio;
	return 0;
}

Contributors
PersonTokensPropCommitsCommitProp
ming linming lin8331.68%110.00%


dmitriy monakhovdmitriy monakhov8130.92%110.00%


christoph hellwigchristoph hellwig5721.76%220.00%


paolo bonzinipaolo bonzini269.92%110.00%


jens axboejens axboe93.44%220.00%


kent overstreetkent overstreet41.53%110.00%


shaohua lishaohua li10.38%110.00%


lukas czernerlukas czerner10.38%110.00%


Total262100.00%10100.00%




EXPORT_SYMBOL(__blkdev_issue_discard);

/**
 * blkdev_issue_discard - queue a discard
 * @bdev:       blockdev to issue discard for
 * @sector:     start sector
 * @nr_sects:   number of sectors to discard
 * @gfp_mask:   memory allocation flags (for bio_alloc)
 * @flags:      BLKDEV_IFL_* flags to control behaviour
 *
 * Description:
 *    Issue a discard request for the sectors in question.
 */



int blkdev_issue_discard(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp_mask, unsigned long flags)
{
	int type = REQ_WRITE | REQ_DISCARD;
	struct bio *bio = NULL;
	struct blk_plug plug;
	int ret;

	if (flags & BLKDEV_DISCARD_SECURE)
		type |= REQ_SECURE;

	blk_start_plug(&plug);
	ret = __blkdev_issue_discard(bdev, sector, nr_sects, gfp_mask, type,
			&bio);
	if (!ret && bio) {
		ret = submit_bio_wait(type, bio);
		if (ret == -EOPNOTSUPP)
			ret = 0;
		bio_put(bio);
	}
	blk_finish_plug(&plug);

	return ret;
}

Contributors
PersonTokensPropCommitsCommitProp
christoph hellwigchristoph hellwig9175.21%233.33%


mike snitzermike snitzer1310.74%116.67%


dmitriy monakhovdmitriy monakhov86.61%116.67%


shaun tancheffshaun tancheff54.13%116.67%


lukas czernerlukas czerner43.31%116.67%


Total121100.00%6100.00%




EXPORT_SYMBOL(blkdev_issue_discard);

/**
 * blkdev_issue_write_same - queue a write same operation
 * @bdev:       target blockdev
 * @sector:     start sector
 * @nr_sects:   number of sectors to write
 * @gfp_mask:   memory allocation flags (for bio_alloc)
 * @page:       page containing data to write
 *
 * Description:
 *    Issue a write same request for the sectors in question.
 */



int blkdev_issue_write_same(struct block_device *bdev, sector_t sector,
			    sector_t nr_sects, gfp_t gfp_mask,
			    struct page *page)
{
	struct request_queue *q = bdev_get_queue(bdev);
	unsigned int max_write_same_sectors;
	struct bio *bio = NULL;
	int ret = 0;

	if (!q)
		return -ENXIO;

	/* Ensure that max_write_same_sectors doesn't overflow bi_size */
	max_write_same_sectors = UINT_MAX >> 9;

	while (nr_sects) {
		bio = next_bio(bio, REQ_WRITE | REQ_WRITE_SAME, 1, gfp_mask);
		bio->bi_iter.bi_sector = sector;
		bio->bi_bdev = bdev;
		bio->bi_vcnt = 1;
		bio->bi_io_vec->bv_page = page;
		bio->bi_io_vec->bv_offset = 0;
		bio->bi_io_vec->bv_len = bdev_logical_block_size(bdev);

		if (nr_sects > max_write_same_sectors) {
			bio->bi_iter.bi_size = max_write_same_sectors << 9;
			nr_sects -= max_write_same_sectors;
			sector += max_write_same_sectors;
		} else {
			bio->bi_iter.bi_size = nr_sects << 9;
			nr_sects = 0;
		}
	}

	if (bio) {
		ret = submit_bio_wait(REQ_WRITE | REQ_WRITE_SAME, bio);
		bio_put(bio);
	}
	return ret != -EOPNOTSUPP ? ret : 0;
}

Contributors
PersonTokensPropCommitsCommitProp
martin k. petersenmartin k. petersen16779.90%120.00%


christoph hellwigchristoph hellwig2511.96%120.00%


shaun tancheffshaun tancheff73.35%120.00%


kent overstreetkent overstreet62.87%120.00%


ming linming lin41.91%120.00%


Total209100.00%5100.00%




EXPORT_SYMBOL(blkdev_issue_write_same);

/**
 * blkdev_issue_zeroout - generate number of zero filed write bios
 * @bdev:       blockdev to issue
 * @sector:     start sector
 * @nr_sects:   number of sectors to write
 * @gfp_mask:   memory allocation flags (for bio_alloc)
 *
 * Description:
 *  Generate and issue number of bios with zerofiled pages.
 */




static int __blkdev_issue_zeroout(struct block_device *bdev, sector_t sector,
				  sector_t nr_sects, gfp_t gfp_mask)
{
	int ret;
	struct bio *bio = NULL;
	unsigned int sz;

	while (nr_sects != 0) {
		bio = next_bio(bio, WRITE,
				min(nr_sects, (sector_t)BIO_MAX_PAGES),
				gfp_mask);
		bio->bi_iter.bi_sector = sector;
		bio->bi_bdev   = bdev;

		while (nr_sects != 0) {
			sz = min((sector_t) PAGE_SIZE >> 9 , nr_sects);
			ret = bio_add_page(bio, ZERO_PAGE(0), sz << 9, 0);
			nr_sects -= ret >> 9;
			sector += ret >> 9;
			if (ret < (sz << 9))
				break;
		}
	}

	if (bio) {
		ret = submit_bio_wait(WRITE, bio);
		bio_put(bio);
		return ret;
	}
	return 0;
}


Contributors
PersonTokensPropCommitsCommitProp
dmitriy monakhovdmitriy monakhov13178.92%111.11%


christoph hellwigchristoph hellwig159.04%222.22%


shaun tancheffshaun tancheff127.23%111.11%


jens axboejens axboe31.81%111.11%


kent overstreetkent overstreet21.20%111.11%


fabian frederickfabian frederick10.60%111.11%


lukas czernerlukas czerner10.60%111.11%


martin k. petersenmartin k. petersen10.60%111.11%


Total166100.00%9100.00%



/**
 * blkdev_issue_zeroout - zero-fill a block range
 * @bdev:       blockdev to write
 * @sector:     start sector
 * @nr_sects:   number of sectors to write
 * @gfp_mask:   memory allocation flags (for bio_alloc)
 * @discard:    whether to discard the block range
 *
 * Description:
 *  Zero-fill a block range.  If the discard flag is set and the block
 *  device guarantees that subsequent READ operations to the block range
 *  in question will return zeroes, the blocks will be discarded. Should
 *  the discard request fail, if the discard flag is not set, or if
 *  discard_zeroes_data is not supported, this function will resort to
 *  zeroing the blocks manually, thus provisioning (allocating,
 *  anchoring) them. If the block device supports the WRITE SAME command
 *  blkdev_issue_zeroout() will use it to optimize the process of
 *  clearing the block range. Otherwise the zeroing will be performed
 *  using regular WRITE calls.
 */




int blkdev_issue_zeroout(struct block_device *bdev, sector_t sector,
			 sector_t nr_sects, gfp_t gfp_mask, bool discard)
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (discard && blk_queue_discard(q) && q->limits.discard_zeroes_data &&
	    blkdev_issue_discard(bdev, sector, nr_sects, gfp_mask, 0) == 0)
		return 0;

	if (bdev_write_same(bdev) &&
	    blkdev_issue_write_same(bdev, sector, nr_sects, gfp_mask,
				    ZERO_PAGE(0)) == 0)
		return 0;

	return __blkdev_issue_zeroout(bdev, sector, nr_sects, gfp_mask);
}

Contributors
PersonTokensPropCommitsCommitProp
martin k. petersenmartin k. petersen105100.00%3100.00%


Total105100.00%3100.00%




EXPORT_SYMBOL(blkdev_issue_zeroout);

Overall Contributors
PersonTokensPropCommitsCommitProp
martin k. petersenmartin k. petersen28029.05%417.39%


dmitriy monakhovdmitriy monakhov26827.80%28.70%


christoph hellwigchristoph hellwig22923.76%313.04%


ming linming lin879.02%28.70%


paolo bonzinipaolo bonzini262.70%14.35%


shaun tancheffshaun tancheff242.49%14.35%


mike snitzermike snitzer131.35%14.35%


kent overstreetkent overstreet121.24%14.35%


jens axboejens axboe121.24%313.04%


lukas czernerlukas czerner101.04%28.70%


fabian frederickfabian frederick10.10%14.35%


tao matao ma10.10%14.35%


shaohua lishaohua li10.10%14.35%


Total964100.00%23100.00%

  
Directory: block



Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
{% endraw %}