我试图了解 rcu_read_lock() 同步机制。据我了解,使用了rcu_read_lock(),其中有几个读线程和一个写线程,读/写相同的数据,读取是在rcu_read_lock()下进行的,数据是为每个线程复制的。我编写了一个简单的驱动程序来测试它(read() 和 write() 函数是核心):
#include <linux/module.h> /* Needed by all modules */
#include <linux/kernel.h> /* Needed for KERN_INFO */
#include <linux/init.h> /* Needed for the macros */
#include <linux/rcupdate.h>
#include <linux/preempt.h>
#include <linux/fs.h>
#include <linux/cdev.h>
#define MY_MAJOR 42
#define MY_MAX_MINORS 5
char buf[] = "0";
struct dev_data
{
struct cdev cdev;
};
struct dev_data devs[MY_MAX_MINORS];
static ssize_t read(struct file *file, char __user *buffer, size_t size, loff_t *offset)
{
rcu_read_lock();
while (1)
{
printk(KERN_INFO "%s", buf);
}
rcu_read_unlock();
return 0;
}
static ssize_t write(struct file *file, const char __user *buffer, size_t size, loff_t *offset)
{
buf[0] = '1';
return size;
}
const struct file_operations fops = {
.read = &read,
.write = &write,
};
static int __init foo_start(void)
{
int i, err_code;
err_code = register_chrdev_region(MKDEV(MY_MAJOR, 0), MY_MAX_MINORS, "Test char driver");
if (err_code != 0)
return err_code;
for(i=0; i<MY_MAX_MINORS; ++i)
{
cdev_init(&devs[i].cdev, &fops);
cdev_add(&devs[i].cdev, MKDEV(MY_MAJOR, i), 1);
}
return 0;
}
static void __exit foo_end(void)
{
int i;
for(i=0; i<MY_MAX_MINORS; ++i)
{
cdev_del(&devs[i].cdev);
}
unregister_chrdev_region(MKDEV(MY_MAJOR, 0), MY_MAX_MINORS);
}
module_init(foo_start);
module_exit(foo_end);
但是当我在读取过程中调用 write 函数时,数据也在 rcu_read_lock() 下发生变化。我的错误在哪里?
PS 驱动程序本身很糟糕,但我的目标只是测试 rcu_read_lock()。