36 static inline sector_t __sector_to_block(struct ebs_c *ec, sector_t sector)  in __sector_to_block()  argument
38 	return sector >> ec->block_shift;  in __sector_to_block()
47 static inline unsigned int __nr_blocks(struct ebs_c *ec, struct bio *bio)  in __nr_blocks()  argument
49 	sector_t end_sector = __block_mod(bio->bi_iter.bi_sector, ec->u_bs) + bio_sectors(bio);  in __nr_blocks()
51 	return __sector_to_block(ec, end_sector) + (__block_mod(end_sector, ec->u_bs) ? 1 : 0);  in __nr_blocks()
64 static int __ebs_rw_bvec(struct ebs_c *ec, enum req_op op, struct bio_vec *bv,  in __ebs_rw_bvec()  argument
71 	unsigned int buf_off = to_bytes(__block_mod(iter->bi_sector, ec->u_bs));  in __ebs_rw_bvec()
72 	sector_t block = __sector_to_block(ec, iter->bi_sector);  in __ebs_rw_bvec()
82 		cur_len = min(dm_bufio_get_block_size(ec->bufio) - buf_off, bv_len);  in __ebs_rw_bvec()
85 		if (op == REQ_OP_READ || buf_off || bv_len < dm_bufio_get_block_size(ec->bufio))  in __ebs_rw_bvec()
86 			ba = dm_bufio_read(ec->bufio, block, &b);  in __ebs_rw_bvec()
88 			ba = dm_bufio_new(ec->bufio, block, &b);  in __ebs_rw_bvec()
121 static int __ebs_rw_bio(struct ebs_c *ec, enum req_op op, struct bio *bio)  in __ebs_rw_bio()  argument
128 		rr = __ebs_rw_bvec(ec, op, &bv, &iter);  in __ebs_rw_bio()
142 static int __ebs_discard_bio(struct ebs_c *ec, struct bio *bio)  in __ebs_discard_bio()  argument
146 	block = __sector_to_block(ec, sector);  in __ebs_discard_bio()
147 	blocks = __nr_blocks(ec, bio);  in __ebs_discard_bio()
153 	if (__block_mod(sector, ec->u_bs)) {  in __ebs_discard_bio()
159 	if (blocks && __block_mod(bio_end_sector(bio), ec->u_bs))  in __ebs_discard_bio()
162 	return blocks ? dm_bufio_issue_discard(ec->bufio, block, blocks) : 0;  in __ebs_discard_bio()
166 static void __ebs_forget_bio(struct ebs_c *ec, struct bio *bio)  in __ebs_forget_bio()  argument
170 	blocks = __nr_blocks(ec, bio);  in __ebs_forget_bio()
172 	dm_bufio_forget_buffers(ec->bufio, __sector_to_block(ec, sector), blocks);  in __ebs_forget_bio()
181 	struct ebs_c *ec = container_of(ws, struct ebs_c, ws);  in __ebs_process_bios()  local
187 	spin_lock_irq(&ec->lock);  in __ebs_process_bios()
188 	bios = ec->bios_in;  in __ebs_process_bios()
189 	bio_list_init(&ec->bios_in);  in __ebs_process_bios()
190 	spin_unlock_irq(&ec->lock);  in __ebs_process_bios()
194 		block1 = __sector_to_block(ec, bio->bi_iter.bi_sector);  in __ebs_process_bios()
196 			dm_bufio_prefetch(ec->bufio, block1, __nr_blocks(ec, bio));  in __ebs_process_bios()
198 			block2 = __sector_to_block(ec, bio_end_sector(bio));  in __ebs_process_bios()
199 			if (__block_mod(bio->bi_iter.bi_sector, ec->u_bs))  in __ebs_process_bios()
200 				dm_bufio_prefetch(ec->bufio, block1, 1);  in __ebs_process_bios()
201 			if (__block_mod(bio_end_sector(bio), ec->u_bs) && block2 != block1)  in __ebs_process_bios()
202 				dm_bufio_prefetch(ec->bufio, block2, 1);  in __ebs_process_bios()
209 			r = __ebs_rw_bio(ec, REQ_OP_READ, bio);  in __ebs_process_bios()
212 			r = __ebs_rw_bio(ec, REQ_OP_WRITE, bio);  in __ebs_process_bios()
214 			__ebs_forget_bio(ec, bio);  in __ebs_process_bios()
215 			r = __ebs_discard_bio(ec, bio);  in __ebs_process_bios()
226 	r = write ? dm_bufio_write_dirty_buffers(ec->bufio) : 0;  in __ebs_process_bios()
252 	struct ebs_c *ec;  in ebs_ctr()  local
259 	ec = ti->private = kzalloc(sizeof(*ec), GFP_KERNEL);  in ebs_ctr()
260 	if (!ec) {  in ebs_ctr()
272 	ec->start = tmp;  in ebs_ctr()
280 	ec->e_bs = tmp1;  in ebs_ctr()
287 		ec->u_bs = tmp1;  in ebs_ctr()
288 		ec->u_bs_set = true;  in ebs_ctr()
290 		ec->u_bs_set = false;  in ebs_ctr()
292 	r = dm_get_device(ti, argv[0], dm_table_get_mode(ti->table), &ec->dev);  in ebs_ctr()
295 		ec->dev = NULL;  in ebs_ctr()
300 	if (!ec->u_bs_set) {  in ebs_ctr()
301 		ec->u_bs = to_sector(bdev_logical_block_size(ec->dev->bdev));  in ebs_ctr()
302 		if (!__ebs_check_bs(ec->u_bs)) {  in ebs_ctr()
308 	if (!ec->u_bs_set && ec->e_bs == ec->u_bs)  in ebs_ctr()
311 	if (__block_mod(ec->start, ec->u_bs)) {  in ebs_ctr()
316 	ec->bufio = dm_bufio_client_create(ec->dev->bdev, to_bytes(ec->u_bs), 1,  in ebs_ctr()
318 	if (IS_ERR(ec->bufio)) {  in ebs_ctr()
320 		r = PTR_ERR(ec->bufio);  in ebs_ctr()
321 		ec->bufio = NULL;  in ebs_ctr()
325 	ec->wq = alloc_ordered_workqueue("dm-" DM_MSG_PREFIX, WQ_MEM_RECLAIM);  in ebs_ctr()
326 	if (!ec->wq) {  in ebs_ctr()
332 	ec->block_shift = __ffs(ec->u_bs);  in ebs_ctr()
333 	INIT_WORK(&ec->ws, &__ebs_process_bios);  in ebs_ctr()
334 	bio_list_init(&ec->bios_in);  in ebs_ctr()
335 	spin_lock_init(&ec->lock);  in ebs_ctr()
349 	struct ebs_c *ec = ti->private;  in ebs_dtr()  local
351 	if (ec->wq)  in ebs_dtr()
352 		destroy_workqueue(ec->wq);  in ebs_dtr()
353 	if (ec->bufio)  in ebs_dtr()
354 		dm_bufio_client_destroy(ec->bufio);  in ebs_dtr()
355 	if (ec->dev)  in ebs_dtr()
356 		dm_put_device(ti, ec->dev);  in ebs_dtr()
357 	kfree(ec);  in ebs_dtr()
362 	struct ebs_c *ec = ti->private;  in ebs_map()  local
364 	bio_set_dev(bio, ec->dev->bdev);  in ebs_map()
365 	bio->bi_iter.bi_sector = ec->start + dm_target_offset(ti, bio->bi_iter.bi_sector);  in ebs_map()
374 	if (likely(__block_mod(bio->bi_iter.bi_sector, ec->u_bs) ||  in ebs_map()
375 		   __block_mod(bio_end_sector(bio), ec->u_bs) ||  in ebs_map()
376 		   ec->e_bs == ec->u_bs)) {  in ebs_map()
377 		spin_lock_irq(&ec->lock);  in ebs_map()
378 		bio_list_add(&ec->bios_in, bio);  in ebs_map()
379 		spin_unlock_irq(&ec->lock);  in ebs_map()
381 		queue_work(ec->wq, &ec->ws);  in ebs_map()
387 	__ebs_forget_bio(ec, bio);  in ebs_map()
395 	struct ebs_c *ec = ti->private;  in ebs_status()  local
402 		snprintf(result, maxlen, ec->u_bs_set ? "%s %llu %u %u" : "%s %llu %u",  in ebs_status()
403 			 ec->dev->name, (unsigned long long) ec->start, ec->e_bs, ec->u_bs);  in ebs_status()
413 	struct ebs_c *ec = ti->private;  in ebs_prepare_ioctl()  local
414 	struct dm_dev *dev = ec->dev;  in ebs_prepare_ioctl()
420 	return !!(ec->start || ti->len != bdev_nr_sectors(dev->bdev));  in ebs_prepare_ioctl()
425 	struct ebs_c *ec = ti->private;  in ebs_io_hints()  local
427 	limits->logical_block_size = to_bytes(ec->e_bs);  in ebs_io_hints()
428 	limits->physical_block_size = to_bytes(ec->u_bs);  in ebs_io_hints()
436 	struct ebs_c *ec = ti->private;  in ebs_iterate_devices()  local
438 	return fn(ti, ec->dev, ec->start, ti->len, data);  in ebs_iterate_devices()