Lines Matching +full:read +full:- +full:delay
1 // SPDX-License-Identifier: GPL-2.0-only
3 * Copyright (C) 2005-2007 Red Hat GmbH
18 #include <linux/device-mapper.h>
20 #define DM_MSG_PREFIX "delay"
25 unsigned int delay; member
38 struct delay_class read; member
58 queue_work(dc->kdelayd_wq, &dc->flush_expired_bios); in handle_delayed_timer()
63 mutex_lock(&dc->timer_lock); in queue_timeout()
65 if (!timer_pending(&dc->delay_timer) || expires < dc->delay_timer.expires) in queue_timeout()
66 mod_timer(&dc->delay_timer, expires); in queue_timeout()
68 mutex_unlock(&dc->timer_lock); in queue_timeout()
73 return !!dc->worker; in delay_is_fast()
81 n = bio->bi_next; in flush_bios()
82 bio->bi_next = NULL; in flush_bios()
97 list_for_each_entry_safe(delayed, next, &dc->delayed_bios, list) { in flush_delayed_bios()
99 if (flush_all || time_after_eq(jiffies, delayed->expires)) { in flush_delayed_bios()
102 list_del(&delayed->list); in flush_delayed_bios()
104 delayed->class->ops--; in flush_delayed_bios()
111 next_expires = delayed->expires; in flush_delayed_bios()
113 next_expires = min(next_expires, delayed->expires); in flush_delayed_bios()
132 if (unlikely(list_empty(&dc->delayed_bios))) { in flush_worker_fn()
155 struct delay_c *dc = ti->private; in delay_dtr()
157 if (dc->kdelayd_wq) in delay_dtr()
158 destroy_workqueue(dc->kdelayd_wq); in delay_dtr()
160 if (dc->read.dev) in delay_dtr()
161 dm_put_device(ti, dc->read.dev); in delay_dtr()
162 if (dc->write.dev) in delay_dtr()
163 dm_put_device(ti, dc->write.dev); in delay_dtr()
164 if (dc->flush.dev) in delay_dtr()
165 dm_put_device(ti, dc->flush.dev); in delay_dtr()
166 if (dc->worker) in delay_dtr()
167 kthread_stop(dc->worker); in delay_dtr()
169 mutex_destroy(&dc->timer_lock); in delay_dtr()
181 ti->error = "Invalid device sector"; in delay_class_ctr()
182 return -EINVAL; in delay_class_ctr()
184 c->start = tmpll; in delay_class_ctr()
186 if (sscanf(argv[2], "%u%c", &c->delay, &dummy) != 1) { in delay_class_ctr()
187 ti->error = "Invalid delay"; in delay_class_ctr()
188 return -EINVAL; in delay_class_ctr()
191 ret = dm_get_device(ti, argv[0], dm_table_get_mode(ti->table), &c->dev); in delay_class_ctr()
193 ti->error = "Device lookup failed"; in delay_class_ctr()
202 * <device> <offset> <delay> [<write_device> <write_offset> <write_delay>]
215 ti->error = "Requires exactly 3, 6 or 9 arguments"; in delay_ctr()
216 return -EINVAL; in delay_ctr()
221 ti->error = "Cannot allocate context"; in delay_ctr()
222 return -ENOMEM; in delay_ctr()
225 ti->private = dc; in delay_ctr()
226 INIT_LIST_HEAD(&dc->delayed_bios); in delay_ctr()
227 mutex_init(&dc->timer_lock); in delay_ctr()
228 dc->may_delay = true; in delay_ctr()
229 dc->argc = argc; in delay_ctr()
231 ret = delay_class_ctr(ti, &dc->read, argv); in delay_ctr()
234 max_delay = dc->read.delay; in delay_ctr()
237 ret = delay_class_ctr(ti, &dc->write, argv); in delay_ctr()
240 ret = delay_class_ctr(ti, &dc->flush, argv); in delay_ctr()
243 max_delay = max(max_delay, dc->write.delay); in delay_ctr()
244 max_delay = max(max_delay, dc->flush.delay); in delay_ctr()
248 ret = delay_class_ctr(ti, &dc->write, argv + 3); in delay_ctr()
252 ret = delay_class_ctr(ti, &dc->flush, argv + 3); in delay_ctr()
255 max_delay = max(max_delay, dc->flush.delay); in delay_ctr()
259 ret = delay_class_ctr(ti, &dc->flush, argv + 6); in delay_ctr()
262 max_delay = max(max_delay, dc->flush.delay); in delay_ctr()
270 dc->worker = kthread_create(&flush_worker_fn, dc, in delay_ctr()
271 "dm-delay-flush-worker"); in delay_ctr()
272 if (IS_ERR(dc->worker)) { in delay_ctr()
273 ret = PTR_ERR(dc->worker); in delay_ctr()
274 dc->worker = NULL; in delay_ctr()
278 timer_setup(&dc->delay_timer, handle_delayed_timer, 0); in delay_ctr()
279 INIT_WORK(&dc->flush_expired_bios, flush_expired_bios); in delay_ctr()
280 dc->kdelayd_wq = alloc_workqueue("kdelayd", WQ_MEM_RECLAIM, 0); in delay_ctr()
281 if (!dc->kdelayd_wq) { in delay_ctr()
282 ret = -EINVAL; in delay_ctr()
288 ti->num_flush_bios = 1; in delay_ctr()
289 ti->num_discard_bios = 1; in delay_ctr()
290 ti->accounts_remapped_io = true; in delay_ctr()
291 ti->per_io_data_size = sizeof(struct dm_delay_info); in delay_ctr()
304 if (!c->delay) in delay_bio()
309 delayed->context = dc; in delay_bio()
310 delayed->expires = expires = jiffies + msecs_to_jiffies(c->delay); in delay_bio()
313 if (unlikely(!dc->may_delay)) { in delay_bio()
317 c->ops++; in delay_bio()
318 list_add_tail(&delayed->list, &dc->delayed_bios); in delay_bio()
322 wake_up_process(dc->worker); in delay_bio()
331 struct delay_c *dc = ti->private; in delay_presuspend()
334 dc->may_delay = false; in delay_presuspend()
338 del_timer_sync(&dc->delay_timer); in delay_presuspend()
344 struct delay_c *dc = ti->private; in delay_resume()
346 dc->may_delay = true; in delay_resume()
351 struct delay_c *dc = ti->private; in delay_map()
356 if (unlikely(bio->bi_opf & REQ_PREFLUSH)) in delay_map()
357 c = &dc->flush; in delay_map()
359 c = &dc->write; in delay_map()
361 c = &dc->read; in delay_map()
363 delayed->class = c; in delay_map()
364 bio_set_dev(bio, c->dev->bdev); in delay_map()
365 bio->bi_iter.bi_sector = c->start + dm_target_offset(ti, bio->bi_iter.bi_sector); in delay_map()
371 DMEMIT("%s %llu %u", (c)->dev->name, (unsigned long long)(c)->start, (c)->delay)
376 struct delay_c *dc = ti->private; in delay_status()
381 DMEMIT("%u %u %u", dc->read.ops, dc->write.ops, dc->flush.ops); in delay_status()
385 DMEMIT_DELAY_CLASS(&dc->read); in delay_status()
386 if (dc->argc >= 6) { in delay_status()
388 DMEMIT_DELAY_CLASS(&dc->write); in delay_status()
390 if (dc->argc >= 9) { in delay_status()
392 DMEMIT_DELAY_CLASS(&dc->flush); in delay_status()
405 struct delay_c *dc = ti->private; in delay_iterate_devices()
408 ret = fn(ti, dc->read.dev, dc->read.start, ti->len, data); in delay_iterate_devices()
411 ret = fn(ti, dc->write.dev, dc->write.start, ti->len, data); in delay_iterate_devices()
414 ret = fn(ti, dc->flush.dev, dc->flush.start, ti->len, data); in delay_iterate_devices()
423 .name = "delay",
435 module_dm(delay);
437 MODULE_DESCRIPTION(DM_NAME " delay target");