diff options
Diffstat (limited to 'fs/afs/kafstimod.c')
-rw-r--r-- | fs/afs/kafstimod.c | 194 |
1 files changed, 0 insertions, 194 deletions
diff --git a/fs/afs/kafstimod.c b/fs/afs/kafstimod.c deleted file mode 100644 index 3526dcccc163..000000000000 --- a/fs/afs/kafstimod.c +++ /dev/null | |||
@@ -1,194 +0,0 @@ | |||
1 | /* AFS timeout daemon | ||
2 | * | ||
3 | * Copyright (C) 2002 Red Hat, Inc. All Rights Reserved. | ||
4 | * Written by David Howells (dhowells@redhat.com) | ||
5 | * | ||
6 | * This program is free software; you can redistribute it and/or | ||
7 | * modify it under the terms of the GNU General Public License | ||
8 | * as published by the Free Software Foundation; either version | ||
9 | * 2 of the License, or (at your option) any later version. | ||
10 | */ | ||
11 | |||
12 | #include <linux/module.h> | ||
13 | #include <linux/init.h> | ||
14 | #include <linux/sched.h> | ||
15 | #include <linux/completion.h> | ||
16 | #include <linux/freezer.h> | ||
17 | #include "cell.h" | ||
18 | #include "volume.h" | ||
19 | #include "kafstimod.h" | ||
20 | #include <asm/errno.h> | ||
21 | #include "internal.h" | ||
22 | |||
23 | static DECLARE_COMPLETION(kafstimod_alive); | ||
24 | static DECLARE_COMPLETION(kafstimod_dead); | ||
25 | static DECLARE_WAIT_QUEUE_HEAD(kafstimod_sleepq); | ||
26 | static int kafstimod_die; | ||
27 | |||
28 | static LIST_HEAD(kafstimod_list); | ||
29 | static DEFINE_SPINLOCK(kafstimod_lock); | ||
30 | |||
31 | static int kafstimod(void *arg); | ||
32 | |||
33 | /* | ||
34 | * start the timeout daemon | ||
35 | */ | ||
36 | int afs_kafstimod_start(void) | ||
37 | { | ||
38 | int ret; | ||
39 | |||
40 | ret = kernel_thread(kafstimod, NULL, 0); | ||
41 | if (ret < 0) | ||
42 | return ret; | ||
43 | |||
44 | wait_for_completion(&kafstimod_alive); | ||
45 | |||
46 | return ret; | ||
47 | } | ||
48 | |||
49 | /* | ||
50 | * stop the timeout daemon | ||
51 | */ | ||
52 | void afs_kafstimod_stop(void) | ||
53 | { | ||
54 | /* get rid of my daemon */ | ||
55 | kafstimod_die = 1; | ||
56 | wake_up(&kafstimod_sleepq); | ||
57 | wait_for_completion(&kafstimod_dead); | ||
58 | } | ||
59 | |||
60 | /* | ||
61 | * timeout processing daemon | ||
62 | */ | ||
63 | static int kafstimod(void *arg) | ||
64 | { | ||
65 | struct afs_timer *timer; | ||
66 | |||
67 | DECLARE_WAITQUEUE(myself, current); | ||
68 | |||
69 | printk("kAFS: Started kafstimod %d\n", current->pid); | ||
70 | |||
71 | daemonize("kafstimod"); | ||
72 | |||
73 | complete(&kafstimod_alive); | ||
74 | |||
75 | /* loop around looking for things to attend to */ | ||
76 | loop: | ||
77 | set_current_state(TASK_INTERRUPTIBLE); | ||
78 | add_wait_queue(&kafstimod_sleepq, &myself); | ||
79 | |||
80 | for (;;) { | ||
81 | unsigned long jif; | ||
82 | signed long timeout; | ||
83 | |||
84 | /* deal with the server being asked to die */ | ||
85 | if (kafstimod_die) { | ||
86 | remove_wait_queue(&kafstimod_sleepq, &myself); | ||
87 | _leave(""); | ||
88 | complete_and_exit(&kafstimod_dead, 0); | ||
89 | } | ||
90 | |||
91 | try_to_freeze(); | ||
92 | |||
93 | /* discard pending signals */ | ||
94 | afs_discard_my_signals(); | ||
95 | |||
96 | /* work out the time to elapse before the next event */ | ||
97 | spin_lock(&kafstimod_lock); | ||
98 | if (list_empty(&kafstimod_list)) { | ||
99 | timeout = MAX_SCHEDULE_TIMEOUT; | ||
100 | } else { | ||
101 | timer = list_entry(kafstimod_list.next, | ||
102 | struct afs_timer, link); | ||
103 | timeout = timer->timo_jif; | ||
104 | jif = jiffies; | ||
105 | |||
106 | if (time_before_eq((unsigned long) timeout, jif)) | ||
107 | goto immediate; | ||
108 | timeout = (long) timeout - (long) jiffies; | ||
109 | } | ||
110 | spin_unlock(&kafstimod_lock); | ||
111 | |||
112 | schedule_timeout(timeout); | ||
113 | |||
114 | set_current_state(TASK_INTERRUPTIBLE); | ||
115 | } | ||
116 | |||
117 | /* the thing on the front of the queue needs processing | ||
118 | * - we come here with the lock held and timer pointing to the expired | ||
119 | * entry | ||
120 | */ | ||
121 | immediate: | ||
122 | remove_wait_queue(&kafstimod_sleepq, &myself); | ||
123 | set_current_state(TASK_RUNNING); | ||
124 | |||
125 | _debug("@@@ Begin Timeout of %p", timer); | ||
126 | |||
127 | /* dequeue the timer */ | ||
128 | list_del_init(&timer->link); | ||
129 | spin_unlock(&kafstimod_lock); | ||
130 | |||
131 | /* call the timeout function */ | ||
132 | timer->ops->timed_out(timer); | ||
133 | |||
134 | _debug("@@@ End Timeout"); | ||
135 | goto loop; | ||
136 | } | ||
137 | |||
138 | /* | ||
139 | * (re-)queue a timer | ||
140 | */ | ||
141 | void afs_kafstimod_add_timer(struct afs_timer *timer, unsigned long timeout) | ||
142 | { | ||
143 | struct afs_timer *ptimer; | ||
144 | struct list_head *_p; | ||
145 | |||
146 | _enter("%p,%lu", timer, timeout); | ||
147 | |||
148 | spin_lock(&kafstimod_lock); | ||
149 | |||
150 | list_del(&timer->link); | ||
151 | |||
152 | /* the timer was deferred or reset - put it back in the queue at the | ||
153 | * right place */ | ||
154 | timer->timo_jif = jiffies + timeout; | ||
155 | |||
156 | list_for_each(_p, &kafstimod_list) { | ||
157 | ptimer = list_entry(_p, struct afs_timer, link); | ||
158 | if (time_before(timer->timo_jif, ptimer->timo_jif)) | ||
159 | break; | ||
160 | } | ||
161 | |||
162 | list_add_tail(&timer->link, _p); /* insert before stopping point */ | ||
163 | |||
164 | spin_unlock(&kafstimod_lock); | ||
165 | |||
166 | wake_up(&kafstimod_sleepq); | ||
167 | |||
168 | _leave(""); | ||
169 | } | ||
170 | |||
171 | /* | ||
172 | * dequeue a timer | ||
173 | * - returns 0 if the timer was deleted or -ENOENT if it wasn't queued | ||
174 | */ | ||
175 | int afs_kafstimod_del_timer(struct afs_timer *timer) | ||
176 | { | ||
177 | int ret = 0; | ||
178 | |||
179 | _enter("%p", timer); | ||
180 | |||
181 | spin_lock(&kafstimod_lock); | ||
182 | |||
183 | if (list_empty(&timer->link)) | ||
184 | ret = -ENOENT; | ||
185 | else | ||
186 | list_del_init(&timer->link); | ||
187 | |||
188 | spin_unlock(&kafstimod_lock); | ||
189 | |||
190 | wake_up(&kafstimod_sleepq); | ||
191 | |||
192 | _leave(" = %d", ret); | ||
193 | return ret; | ||
194 | } | ||