From b6510fe5d778b91c3476c6ca8fd0b05f9770d321 Mon Sep 17 00:00:00 2001 From: Thadeu Lima de Souza Cascardo Date: Tue, 10 Feb 2009 16:11:15 -0200 Subject: [PATCH] A first test of workqueues. They've changed significantly since LDDv3. --- workqueue/Makefile | 12 ++++++++++++ workqueue/wq.c | 49 ++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 61 insertions(+) create mode 100644 workqueue/Makefile create mode 100644 workqueue/wq.c diff --git a/workqueue/Makefile b/workqueue/Makefile new file mode 100644 index 0000000..f2266eb --- /dev/null +++ b/workqueue/Makefile @@ -0,0 +1,12 @@ +ifneq ($(KERNELRELEASE),) + obj-m := wq.o +else + KERNELDIR ?= /lib/modules/$(shell uname -r)/build + PWD := $(shell pwd) + +default: + $(MAKE) -C $(KERNELDIR) M=$(PWD) modules + +clean: + $(MAKE) -C $(KERNELDIR) M=$(PWD) clean +endif diff --git a/workqueue/wq.c b/workqueue/wq.c new file mode 100644 index 0000000..1d5fe38 --- /dev/null +++ b/workqueue/wq.c @@ -0,0 +1,49 @@ +/* + * Copyright (C) 2009 Thadeu Lima de Souza Cascardo + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + */ + + +#include +#include +#include + +MODULE_LICENSE("GPL"); + +static void do_mywork(struct work_struct *data) +{ + printk(KERN_INFO "I've been scheduled.\n"); +} + +DECLARE_DELAYED_WORK(mywork, do_mywork); +static struct workqueue_struct *mywq; + +static int mywq_init(void) +{ + mywq = create_workqueue("mywq"); + printk(KERN_INFO "Here I am, this is me.\n"); + queue_delayed_work(mywq, &mywork, 8 * HZ); + return 0; +} + +static void mywq_exit(void) +{ + flush_workqueue(mywq); + destroy_workqueue(mywq); +} + +module_init(mywq_init); +module_exit(mywq_exit); -- 2.20.1