Files
linux-kernel-module-cheat/packages/kernel_modules/wait_queue.c
Ciro Santilli fd55d694c0 lkmc v2-rc
Unsquashed version at v2-rc-unsquashed, but that cannot be merged as it
breaks bisects at several points. All bugs will not bisect to this
humongous change.

It all started with a conversion of the Bash scripts to Python, mainly
because I couldn't stand not being able to properly use --options for
run which has a million options.

Then since that required a full testing, I decided to do all the
refactorings that I had in mind at once, and so I did and it became
v2-rc.

This is the largest patch I have ever done! OMG a few weeks of extra time.
I'm never writing a Bash script for anything that starts getting big again.

Some of the features are:

* separate build-qemu and build-gem5 commands
* common: convert scripts to python. Add --option for everything
* rename build to build-buildroot now that we are splitting all the build
  commands, Linux kernel to follow
* move all git submodules to submodules/ and all buildroot packages to
  packages/
* refactor the out/ structure. Keep projects on toplevel, because guest
  projects separate archs and host ones don't, making a toplevel arch wrong
* do-release: rename to just release
  https://stackoverflow.com/questions/16174992/cant-get-argparse-to-read-quoted-string-with-dashes-in-it
* run: add --terminal and explain gem5 pdb
* just track the lvimrc
* store CLI kernel config fragment inside buildlroot to avoid conflicts
* gem5: document m5 initparam
* readme: make a bunch of things awesomer
* readme: fix broken refs
* parsec-benchmark: update to 75d55ac446a43c47efb1044844a108c6c330184c
  Could not fetch otherwise.
* gem5: M5_OVERRIDE_PY_SOURCE
2018-09-14 07:13:47 +01:00

75 lines
1.7 KiB
C

/* https://github.com/cirosantilli/linux-kernel-module-cheat#wait-queues */
#include <linux/delay.h> /* usleep_range */
#include <linux/kernel.h>
#include <linux/kthread.h>
#include <linux/module.h>
#include <linux/wait.h> /* wait_queue_head_t, wait_event_interruptible, wake_up_interruptible */
static struct task_struct *kthread_wake;
static struct task_struct *kthread_sleep1;
static struct task_struct *kthread_sleep2;
static wait_queue_head_t queue;
static atomic_t awake1 = ATOMIC_INIT(0);
static atomic_t awake2 = ATOMIC_INIT(0);
static int kthread_wake_func(void *data)
{
unsigned int i = 0;
while (!kthread_should_stop()) {
pr_info("0 %u\n", i);
usleep_range(1000000, 1000001);
atomic_set(&awake1, 1);
atomic_set(&awake2, 1);
wake_up(&queue);
i++;
}
return 0;
}
static int kthread_sleep_func_1(void *data)
{
unsigned int i = 0;
while (!kthread_should_stop()) {
pr_info("1 %u\n", i);
i++;
wait_event(queue, atomic_read(&awake1));
atomic_set(&awake1, 0);
schedule();
}
return 0;
}
static int kthread_sleep_func_2(void *data)
{
unsigned int i = 0;
while (!kthread_should_stop()) {
pr_info("2 %u\n", i);
i++;
wait_event(queue, atomic_read(&awake2));
atomic_set(&awake2, 0);
schedule();
}
return 0;
}
int init_module(void)
{
init_waitqueue_head(&queue);
kthread_wake = kthread_create(kthread_wake_func, NULL, "wake");
kthread_sleep1 = kthread_create(kthread_sleep_func_1, NULL, "sleep1");
kthread_sleep2 = kthread_create(kthread_sleep_func_2, NULL, "sleep2");
wake_up_process(kthread_wake);
wake_up_process(kthread_sleep1);
wake_up_process(kthread_sleep2);
return 0;
}
void cleanup_module(void)
{
kthread_stop(kthread_sleep2);
kthread_stop(kthread_sleep1);
kthread_stop(kthread_wake);
}
MODULE_LICENSE("GPL");