Blame view
block/blk-lib.c
3.81 KB
f31e7e402
|
1 2 3 4 5 6 7 8 9 10 |
/* * 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" |
5dba3089e
|
11 12 13 14 15 16 17 |
struct bio_batch { atomic_t done; unsigned long flags; struct completion *wait; }; static void bio_batch_end_io(struct bio *bio, int err) |
f31e7e402
|
18 |
{ |
5dba3089e
|
19 |
struct bio_batch *bb = bio->bi_private; |
8af1954d1
|
20 |
if (err && (err != -EOPNOTSUPP)) |
5dba3089e
|
21 |
clear_bit(BIO_UPTODATE, &bb->flags); |
5dba3089e
|
22 23 |
if (atomic_dec_and_test(&bb->done)) complete(bb->wait); |
f31e7e402
|
24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 |
bio_put(bio); } /** * 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) { DECLARE_COMPLETION_ONSTACK(wait); struct request_queue *q = bdev_get_queue(bdev); |
8c5553678
|
43 |
int type = REQ_WRITE | REQ_DISCARD; |
10d1f9e2c
|
44 |
unsigned int max_discard_sectors; |
5dba3089e
|
45 |
struct bio_batch bb; |
f31e7e402
|
46 |
struct bio *bio; |
f31e7e402
|
47 48 49 50 51 52 53 |
int ret = 0; if (!q) return -ENXIO; if (!blk_queue_discard(q)) return -EOPNOTSUPP; |
10d1f9e2c
|
54 55 56 57 58 59 60 61 62 63 |
/* * Ensure that max_discard_sectors is of the proper * granularity */ max_discard_sectors = min(q->limits.max_discard_sectors, UINT_MAX >> 9); if (q->limits.discard_granularity) { unsigned int disc_sects = q->limits.discard_granularity >> 9; max_discard_sectors &= ~(disc_sects - 1); } |
f31e7e402
|
64 |
|
dd3932edd
|
65 |
if (flags & BLKDEV_DISCARD_SECURE) { |
8d57a98cc
|
66 67 |
if (!blk_queue_secdiscard(q)) return -EOPNOTSUPP; |
8c5553678
|
68 |
type |= REQ_SECURE; |
8d57a98cc
|
69 |
} |
5dba3089e
|
70 71 72 73 74 |
atomic_set(&bb.done, 1); bb.flags = 1 << BIO_UPTODATE; bb.wait = &wait; while (nr_sects) { |
f31e7e402
|
75 |
bio = bio_alloc(gfp_mask, 1); |
66ac02801
|
76 77 78 79 |
if (!bio) { ret = -ENOMEM; break; } |
f31e7e402
|
80 |
bio->bi_sector = sector; |
5dba3089e
|
81 |
bio->bi_end_io = bio_batch_end_io; |
f31e7e402
|
82 |
bio->bi_bdev = bdev; |
5dba3089e
|
83 |
bio->bi_private = &bb; |
f31e7e402
|
84 |
|
f31e7e402
|
85 86 87 88 89 90 91 92 |
if (nr_sects > max_discard_sectors) { bio->bi_size = max_discard_sectors << 9; nr_sects -= max_discard_sectors; sector += max_discard_sectors; } else { bio->bi_size = nr_sects << 9; nr_sects = 0; } |
5dba3089e
|
93 |
atomic_inc(&bb.done); |
f31e7e402
|
94 |
submit_bio(type, bio); |
5dba3089e
|
95 |
} |
f31e7e402
|
96 |
|
5dba3089e
|
97 98 |
/* Wait for bios in-flight */ if (!atomic_dec_and_test(&bb.done)) |
dd3932edd
|
99 |
wait_for_completion(&wait); |
f31e7e402
|
100 |
|
8af1954d1
|
101 |
if (!test_bit(BIO_UPTODATE, &bb.flags)) |
5dba3089e
|
102 |
ret = -EIO; |
66ac02801
|
103 |
|
f31e7e402
|
104 |
return ret; |
f31e7e402
|
105 106 |
} EXPORT_SYMBOL(blkdev_issue_discard); |
3f14d792f
|
107 |
|
3f14d792f
|
108 |
/** |
291d24f6d
|
109 |
* blkdev_issue_zeroout - generate number of zero filed write bios |
3f14d792f
|
110 111 112 113 |
* @bdev: blockdev to issue * @sector: start sector * @nr_sects: number of sectors to write * @gfp_mask: memory allocation flags (for bio_alloc) |
3f14d792f
|
114 115 116 |
* * Description: * Generate and issue number of bios with zerofiled pages. |
3f14d792f
|
117 118 119 |
*/ int blkdev_issue_zeroout(struct block_device *bdev, sector_t sector, |
dd3932edd
|
120 |
sector_t nr_sects, gfp_t gfp_mask) |
3f14d792f
|
121 |
{ |
18edc8eaa
|
122 |
int ret; |
3f14d792f
|
123 124 |
struct bio *bio; struct bio_batch bb; |
0aeea1896
|
125 |
unsigned int sz; |
3f14d792f
|
126 |
DECLARE_COMPLETION_ONSTACK(wait); |
0aeea1896
|
127 |
atomic_set(&bb.done, 1); |
3f14d792f
|
128 129 |
bb.flags = 1 << BIO_UPTODATE; bb.wait = &wait; |
3f14d792f
|
130 |
|
18edc8eaa
|
131 |
ret = 0; |
3f14d792f
|
132 133 134 |
while (nr_sects != 0) { bio = bio_alloc(gfp_mask, min(nr_sects, (sector_t)BIO_MAX_PAGES)); |
18edc8eaa
|
135 136 |
if (!bio) { ret = -ENOMEM; |
3f14d792f
|
137 |
break; |
18edc8eaa
|
138 |
} |
3f14d792f
|
139 140 141 142 |
bio->bi_sector = sector; bio->bi_bdev = bdev; bio->bi_end_io = bio_batch_end_io; |
dd3932edd
|
143 |
bio->bi_private = &bb; |
3f14d792f
|
144 |
|
0341aafb7
|
145 146 |
while (nr_sects != 0) { sz = min((sector_t) PAGE_SIZE >> 9 , nr_sects); |
3f14d792f
|
147 148 149 150 151 152 |
ret = bio_add_page(bio, ZERO_PAGE(0), sz << 9, 0); nr_sects -= ret >> 9; sector += ret >> 9; if (ret < (sz << 9)) break; } |
18edc8eaa
|
153 |
ret = 0; |
0aeea1896
|
154 |
atomic_inc(&bb.done); |
3f14d792f
|
155 156 |
submit_bio(WRITE, bio); } |
3f14d792f
|
157 |
|
dd3932edd
|
158 |
/* Wait for bios in-flight */ |
0aeea1896
|
159 |
if (!atomic_dec_and_test(&bb.done)) |
dd3932edd
|
160 |
wait_for_completion(&wait); |
3f14d792f
|
161 162 163 164 |
if (!test_bit(BIO_UPTODATE, &bb.flags)) /* One of bios in the batch was completed with error.*/ ret = -EIO; |
3f14d792f
|
165 166 167 |
return ret; } EXPORT_SYMBOL(blkdev_issue_zeroout); |