简体中文

English

简体中文

English

外观

那么如何用工作队列给中断下文传参呢？

一、工作队列传参 ​

在 Linux 系统中，工作队列可以像这样传递参数：

1、定义数据结构 ​

c
struct work_data {
    struct work_struct test_work;   // 内置的工作项结构
    int a;
    int b;
};
struct work_data test_workqueue_work;

2、初始化工作队列和参数 ​

在模块加载函数里：

c
// 创建名为 "test_workqueue" 的工作队列
test_workqueue = create_workqueue("test_workqueue");

// 初始化工作项，指定处理函数为 test_work
INIT_WORK(&test_workqueue_work.test_work, test_work);

// 给参数赋初始值
test_workqueue_work.a = 1;
test_workqueue_work.b = 2;

3、触发工作队列 ​

当发生中断时：

c
// 将工作项加入队列等待执行
queue_work(test_workqueue, &test_workqueue_work.test_work);

4、处理函数实现 ​

c
void test_work(struct work_struct *work)
{
    struct work_data *pdata;

    // 通过指针找到包含 work_struct 的整个结构体
    pdata = container_of(work, struct work_data, test_work);

    // 输出参数值
    printk("a 的值是: %d\n", pdata->a);
    printk("b 的值是: %d\n", pdata->b);
}

工作原理说明

  • 我们把需要传递的参数（a 和 b）和工作项结构体打包成一个结构体 work_data
  • 当中断发生时，把工作项加入队列
  • 系统执行时，通过 container_of 宏找到原始结构体，就能访问到参数 a 和 b 的值

二、驱动案例 ​

源代码下载

bash
git clone git@gitee.com:yangxuesong314/linux-driver.git
  • 若之前已 git 拉取代码可以忽略
  • 代码位于：linux-driver/04.中断及异常/05.工作队列传参实验

实验说明

  • GPIO1_A4 → 1 * 32 + 0 * 8 + 4 = 36

Makefile：

makefile
export ARCH=arm64
export CROSS_COMPILE=/home/book/rk/tspi/prebuilts/gcc/linux-x86/aarch64/gcc-linaro-6.3.1-2017.05-x86_64_aarch64-linux-gnu/bin/aarch64-linux-gnu-
obj-m += interrupt.o
KDIR := /home/book/rk/tspi/kernel
PWD ?= $(shell pwd)
all:
	make -C $(KDIR) M=$(PWD) modules
clean:
	make -C $(KDIR) M=$(PWD) clean

驱动代码：

c
#include <linux/module.h>
#include <linux/init.h>
#include <linux/interrupt.h>
#include <linux/gpio.h>
#include <linux/delay.h>
#include <linux/workqueue.h>

int irq;

struct work_data {
    struct work_struct test_work;
    int a;
    int b;
};

struct work_data test_workqueue_work;
struct workqueue_struct *test_workqueue;

void test_work(struct work_struct *work)
{
    struct work_data *pdata;
    pdata = container_of(work, struct work_data, test_work);

    printk("a is %d", pdata->a);
    printk("b is %d", pdata->b);
}

irqreturn_t test_interrupt(int irq, void *args)
{
  printk("This is test_interrupt\n");
    queue_work(test_workqueue, &test_workqueue_work.test_work);
    return IRQ_RETVAL(IRQ_HANDLED);
}

static int interrupt_irq_init(void)
{
    int ret;
    irq = gpio_to_irq(36);
  printk("irq is %d\n", irq);

    ret = request_irq(irq, test_interrupt, IRQF_TRIGGER_RISING, "test", NULL);
    if (ret < 0) {
    printk("request_irq is error\n");
        return -1;
    }

    test_workqueue = create_workqueue("test_workqueue");
    INIT_WORK(&test_workqueue_work.test_work, test_work);

    test_workqueue_work.a = 1;
    test_workqueue_work.b = 2;

    return 0;
}

static void interrupt_irq_exit(void)
{
    free_irq(irq, NULL);
    cancel_work_sync(&test_workqueue_work.test_work);
    flush_workqueue(test_workqueue);
    destroy_workqueue(test_workqueue);
  printk("bye bye\n");
}

module_init(interrupt_irq_init);
module_exit(interrupt_irq_exit);
MODULE_LICENSE("GPL");

驱动加载：insmod interrupt.ko

image

拉高 GPIO：

image