aboutsummaryrefslogtreecommitdiffstats
path: root/litmus/norqlock.c
blob: 1a17d6c3ac17f9168de53cbfa4916d0bddd2263f (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
#include <linux/list.h>
#include <linux/bitops.h>
#include <linux/percpu.h>
#include <linux/module.h>
#include <linux/smp.h>

#include <litmus/norqlock.h>

struct worklist {
	struct no_rqlock_work* next;
	int hrtimer_hack;
};

static DEFINE_PER_CPU(struct worklist, norq_worklist) = {NULL, 0};

void init_no_rqlock_work(struct no_rqlock_work* w, work_t work,
			 unsigned long arg)
{
	w->active = 0;
	w->work   = work;
	w->arg    = arg;
	w->next   = NULL;
}

void __do_without_rqlock(struct no_rqlock_work *work)
{
	long flags;
	struct worklist* wl;

	local_irq_save(flags);
	wl = &__get_cpu_var(norq_worklist);
	work->next = wl->next;
	wl->next   = work;
	local_irq_restore(flags);
}

void hrtimer_wakeup_hack(int onoff)
{
	preempt_disable();
	__get_cpu_var(norq_worklist).hrtimer_hack = onoff;
	preempt_enable();
}

void tick_no_rqlock(void)
{
	long flags;
	struct no_rqlock_work *todo, *next;
	struct worklist* wl;


	local_irq_save(flags);

	wl = &__get_cpu_var(norq_worklist);

	if (wl->hrtimer_hack) {
		/* bail out! */
		local_irq_restore(flags);
		return;
	}

	next = wl->next;
	wl->next = NULL;

	local_irq_restore(flags);

	while (next) {
		todo = next;
		next = next->next;
		todo->next = NULL;
		smp_mb__before_clear_bit();
		clear_bit(0, (void*) &todo->active);
		todo->work(todo->arg);
	}


}