Add the rt linux 4.1.3-rt3 as base
[kvmfornfv.git] / kernel / drivers / staging / speakup / thread.c
1 #include <linux/kthread.h>
2 #include <linux/wait.h>
3
4 #include "spk_types.h"
5 #include "speakup.h"
6 #include "spk_priv.h"
7
8 DECLARE_WAIT_QUEUE_HEAD(speakup_event);
9 EXPORT_SYMBOL_GPL(speakup_event);
10
11 int speakup_thread(void *data)
12 {
13         unsigned long flags;
14         int should_break;
15         struct bleep our_sound;
16
17         our_sound.active = 0;
18         our_sound.freq = 0;
19         our_sound.jiffies = 0;
20
21         mutex_lock(&spk_mutex);
22         while (1) {
23                 DEFINE_WAIT(wait);
24
25                 while (1) {
26                         spin_lock_irqsave(&speakup_info.spinlock, flags);
27                         our_sound = spk_unprocessed_sound;
28                         spk_unprocessed_sound.active = 0;
29                         prepare_to_wait(&speakup_event, &wait,
30                                 TASK_INTERRUPTIBLE);
31                         should_break = kthread_should_stop() ||
32                                 our_sound.active ||
33                                 (synth && synth->catch_up && synth->alive &&
34                                         (speakup_info.flushing ||
35                                         !synth_buffer_empty()));
36                         spin_unlock_irqrestore(&speakup_info.spinlock, flags);
37                         if (should_break)
38                                 break;
39                         mutex_unlock(&spk_mutex);
40                         schedule();
41                         mutex_lock(&spk_mutex);
42                 }
43                 finish_wait(&speakup_event, &wait);
44                 if (kthread_should_stop())
45                         break;
46
47                 if (our_sound.active)
48                         kd_mksound(our_sound.freq, our_sound.jiffies);
49                 if (synth && synth->catch_up && synth->alive) {
50                         /* It is up to the callee to take the lock, so that it
51                          * can sleep whenever it likes */
52                         synth->catch_up(synth);
53                 }
54
55                 speakup_start_ttys();
56         }
57         mutex_unlock(&spk_mutex);
58         return 0;
59 }