LXR linux/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
   8DECLARE_WAIT_QUEUE_HEAD(speakup_event);
   9EXPORT_SYMBOL_GPL(speakup_event);
  10
  11int 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                         */
  53                        synth->catch_up(synth);
  54                }
  55
  56                speakup_start_ttys();
  57        }
  58        mutex_unlock(&spk_mutex);
  59        return 0;
  60}
  61