Commit 8376d3c1 authored by Kees Cook's avatar Kees Cook Committed by Jens Axboe
Browse files

md: Convert timers to use timer_setup() 



In preparation for unconditionally passing the struct timer_list pointer to
all timer callbacks, switch to using the new timer_setup() and from_timer()
to pass the timer pointer explicitly.

Cc: Kent Overstreet <kent.overstreet@gmail.com>
Cc: Shaohua Li <shli@kernel.org>
Cc: Alasdair Kergon <agk@redhat.com>
Cc: Mike Snitzer <snitzer@redhat.com>
Cc: dm-devel@redhat.com
Cc: linux-bcache@vger.kernel.org
Cc: linux-raid@vger.kernel.org
Signed-off-by: default avatarKees Cook <keescook@chromium.org>
Reviewed-by: default avatarMichael Lyle <mlyle@lyle.org>
Reviewed-by: default avatarMike Snitzer <snitzer@redhat.com>
Signed-off-by: default avatarJens Axboe <axboe@kernel.dk>
parent b5775a6b

drivers/md/bcache/stats.c

+3 −5
Original line number Diff line number Diff line
@@ -147,9 +147,9 @@ static void scale_stats(struct cache_stats *stats, unsigned long rescale_at) 
	}

}



static void scale_accounting(unsigned long data)

static void scale_accounting(struct timer_list *t)

{

	struct cache_accounting *acc = (struct cache_accounting *) data;

	struct cache_accounting *acc = from_timer(acc, t, timer);



#define move_stat(name) do {						\

	unsigned t = atomic_xchg(&acc->collector.name, 0);		\
@@ -234,9 +234,7 @@ void bch_cache_accounting_init(struct cache_accounting *acc, 
	kobject_init(&acc->day.kobj,		&bch_stats_ktype);



	closure_init(&acc->cl, parent);

	init_timer(&acc->timer);

	timer_setup(&acc->timer, scale_accounting, 0);

	acc->timer.expires	= jiffies + accounting_delay;

	acc->timer.data		= (unsigned long) acc;

	acc->timer.function	= scale_accounting;

	add_timer(&acc->timer);

}

drivers/md/dm-delay.c

+3 −3
Original line number Diff line number Diff line
@@ -44,9 +44,9 @@ struct dm_delay_info { 


static DEFINE_MUTEX(delayed_bios_lock);



static void handle_delayed_timer(unsigned long data)

static void handle_delayed_timer(struct timer_list *t)

{

	struct delay_c *dc = (struct delay_c *)data;

	struct delay_c *dc = from_timer(dc, t, delay_timer);



	queue_work(dc->kdelayd_wq, &dc->flush_expired_bios);

}
@@ -195,7 +195,7 @@ out: 
		goto bad_queue;

	}



	setup_timer(&dc->delay_timer, handle_delayed_timer, (unsigned long)dc);

	timer_setup(&dc->delay_timer, handle_delayed_timer, 0);



	INIT_WORK(&dc->flush_expired_bios, flush_expired_bios);

	INIT_LIST_HEAD(&dc->delayed_bios);

drivers/md/dm-integrity.c

+3 −3
Original line number Diff line number Diff line
@@ -1094,9 +1094,9 @@ static void sleep_on_endio_wait(struct dm_integrity_c *ic) 
	__remove_wait_queue(&ic->endio_wait, &wait);

}



static void autocommit_fn(unsigned long data)

static void autocommit_fn(struct timer_list *t)

{

	struct dm_integrity_c *ic = (struct dm_integrity_c *)data;

	struct dm_integrity_c *ic = from_timer(ic, t, autocommit_timer);



	if (likely(!dm_integrity_failed(ic)))

		queue_work(ic->commit_wq, &ic->commit_work);
@@ -2942,7 +2942,7 @@ static int dm_integrity_ctr(struct dm_target *ti, unsigned argc, char **argv) 


	ic->autocommit_jiffies = msecs_to_jiffies(sync_msec);

	ic->autocommit_msec = sync_msec;

	setup_timer(&ic->autocommit_timer, autocommit_fn, (unsigned long)ic);

	timer_setup(&ic->autocommit_timer, autocommit_fn, 0);



	ic->io = dm_io_client_create();

	if (IS_ERR(ic->io)) {

drivers/md/dm-raid1.c

+3 −5
Original line number Diff line number Diff line
@@ -94,9 +94,9 @@ static void wakeup_mirrord(void *context) 
	queue_work(ms->kmirrord_wq, &ms->kmirrord_work);

}



static void delayed_wake_fn(unsigned long data)

static void delayed_wake_fn(struct timer_list *t)

{

	struct mirror_set *ms = (struct mirror_set *) data;

	struct mirror_set *ms = from_timer(ms, t, timer);



	clear_bit(0, &ms->timer_pending);

	wakeup_mirrord(ms);
@@ -108,8 +108,6 @@ static void delayed_wake(struct mirror_set *ms) 
		return;



	ms->timer.expires = jiffies + HZ / 5;

	ms->timer.data = (unsigned long) ms;

	ms->timer.function = delayed_wake_fn;

	add_timer(&ms->timer);

}
@@ -1133,7 +1131,7 @@ static int mirror_ctr(struct dm_target *ti, unsigned int argc, char **argv) 
		goto err_free_context;

	}

	INIT_WORK(&ms->kmirrord_work, do_mirror);

	init_timer(&ms->timer);

	timer_setup(&ms->timer, delayed_wake_fn, 0);

	ms->timer_pending = 0;

	INIT_WORK(&ms->trigger_event, trigger_event);

drivers/md/md.c

+4 −5
Original line number Diff line number Diff line
@@ -541,7 +541,7 @@ static void mddev_put(struct mddev *mddev) 
		bioset_free(sync_bs);

}



static void md_safemode_timeout(unsigned long data);

static void md_safemode_timeout(struct timer_list *t);



void mddev_init(struct mddev *mddev)

{
@@ -550,8 +550,7 @@ void mddev_init(struct mddev *mddev) 
	mutex_init(&mddev->bitmap_info.mutex);

	INIT_LIST_HEAD(&mddev->disks);

	INIT_LIST_HEAD(&mddev->all_mddevs);

	setup_timer(&mddev->safemode_timer, md_safemode_timeout,

		    (unsigned long) mddev);

	timer_setup(&mddev->safemode_timer, md_safemode_timeout, 0);

	atomic_set(&mddev->active, 1);

	atomic_set(&mddev->openers, 0);

	atomic_set(&mddev->active_io, 0);
@@ -5404,9 +5403,9 @@ static int add_named_array(const char *val, struct kernel_param *kp) 
	return -EINVAL;

}



static void md_safemode_timeout(unsigned long data)

static void md_safemode_timeout(struct timer_list *t)

{

	struct mddev *mddev = (struct mddev *) data;

	struct mddev *mddev = from_timer(mddev, t, safemode_timer);



	mddev->safemode = 1;

	if (mddev->external)

CRA Git | Maintained and supported by SUSTech CRA and CCSE