深入淺出Linux設備驅動(dòng)之并發(fā)控制

深入淺出Linux設備驅動(dòng)之并發(fā)控制

在驅動(dòng)程序中，當多個(gè)線(xiàn)程同時(shí)訪(fǎng)問(wèn)相同的資源時(shí)（驅動(dòng)程序中的全局變量是一種典型的共享資源），可能會(huì )引發(fā)"競態(tài)"，因此我們必須對共享資源進(jìn)行并發(fā)控制。Linux內核中解決并發(fā)控制的最常用方法是自旋鎖與信號量（絕大多數時(shí)候作為互斥鎖使用）。

　　自旋鎖與信號量"類(lèi)似而不類(lèi)"，類(lèi)似說(shuō)的是它們功能上的相似性，"不類(lèi)"指代它們在本質(zhì)和實(shí)現機理上完全不一樣，不屬于一類(lèi)。

　　自旋鎖不會(huì )引起調用者睡眠，如果自旋鎖已經(jīng)被別的執行單元保持，調用者就一直循環(huán)查看是否該自旋鎖的保持者已經(jīng)釋放了鎖，"自旋"就是"在原地打轉"。而信號量則引起調用者睡眠，它把進(jìn)程從運行隊列上拖出去，除非獲得鎖。這就是它們的"不類(lèi)"。

　　但是，無(wú)論是信號量，還是自旋鎖，在任何時(shí)刻，最多只能有一個(gè)保持者，即在任何時(shí)刻最多只能有一個(gè)執行單元獲得鎖。這就是它們的"類(lèi)似"。

　　鑒于自旋鎖與信號量的上述特點(diǎn)，一般而言，自旋鎖適合于保持時(shí)間非常短的情況，它可以在任何上下文使用；信號量適合于保持時(shí)間較長(cháng)的情況，會(huì )只能在進(jìn)程上下文使用。如果被保護的共享資源只在進(jìn)程上下文訪(fǎng)問(wèn)，則可以以信號量來(lái)保護該共享資源，如果對共享資源的訪(fǎng)問(wèn)時(shí)間非常短，自旋鎖也是好的選擇。但是，如果被保護的共享資源需要在中斷上下文訪(fǎng)問(wèn)（包括底半部即中斷處理句柄和頂半部即軟中斷），就必須使用自旋鎖。

　　與信號量相關(guān)的API主要有：

　　定義信號量

struct semaphore sem;　

　　初始化信號量

void sema_init (struct semaphore *sem, int val);

　　該函數初始化信號量，并設置信號量sem的值為val

void init_MUTEX (struct semaphore *sem);

　　該函數用于初始化一個(gè)互斥鎖，即它把信號量sem的值設置為1，等同于sema_init (struct semaphore *sem, 1)；

void init_MUTEX_LOCKED (struct semaphore *sem);

　　該函數也用于初始化一個(gè)互斥鎖，但它把信號量sem的值設置為0，等同于sema_init (struct semaphore *sem, 0)；

　　獲得信號量

void down(struct semaphore * sem);

　　該函數用于獲得信號量sem，它會(huì )導致睡眠，因此不能在中斷上下文使用；

int down_interruptible(struct semaphore * sem);　

　　該函數功能與down類(lèi)似，不同之處為，down不能被信號打斷，但down_interruptible能被信號打斷；

int down_trylock(struct semaphore * sem);

　　該函數嘗試獲得信號量sem，如果能夠立刻獲得，它就獲得該信號量并返回0，否則，返回非0值。它不會(huì )導致調用者睡眠，可以在中斷上下文使用。

　　釋放信號量

void up(struct semaphore * sem);

　　該函數釋放信號量sem，喚醒等待者。

　　與自旋鎖相關(guān)的API主要有：

　　定義自旋鎖

spinlock_t spin;

　　初始化自旋鎖

spin_lock_init(lock)

　　該宏用于動(dòng)態(tài)初始化自旋鎖lock

　　獲得自旋鎖

spin_lock(lock)

　　該宏用于獲得自旋鎖lock，如果能夠立即獲得鎖，它就馬上返回，否則，它將自旋在那里，直到該自旋鎖的保持者釋放；

spin_trylock(lock)

　　該宏嘗試獲得自旋鎖lock，如果能立即獲得鎖，它獲得鎖并返回真，否則立即返回假，實(shí)際上不再"在原地打轉"；

　　釋放自旋鎖

spin_unlock(lock)

　　該宏釋放自旋鎖lock，它與spin_trylock或spin_lock配對使用；

　　除此之外，還有一組自旋鎖使用于中斷情況下的API。

下面進(jìn)入對并發(fā)控制的實(shí)戰。首先，在globalvar的驅動(dòng)程序中，我們可以通過(guò)信號量來(lái)控制對int global_var的并發(fā)訪(fǎng)問(wèn)，下面給出源代碼：

#include <linux/module.h>
#include <linux/init.h>
#include <linux/fs.h>
#include <asm/uaccess.h>
#include <asm/semaphore.h>
MODULE_LICENSE("GPL");

#define MAJOR_NUM 254

static ssize_t globalvar_read(struct file *, char *, size_t, loff_t*);
static ssize_t globalvar_write(struct file *, const char *, size_t, loff_t*);

struct file_operations globalvar_fops =
{
　read: globalvar_read, write: globalvar_write,
};
static int global_var = 0;
static struct semaphore sem;

static int __init globalvar_init(void)
{
　int ret;
　ret = register_chrdev(MAJOR_NUM, "globalvar", &globalvar_fops);
　if (ret)
　{
　　printk("globalvar register failure");
　}
　else
　{
　　printk("globalvar register success");
　　init_MUTEX(&sem);
　}
　return ret;
}

static void __exit globalvar_exit(void)
{
　int ret;
　ret = unregister_chrdev(MAJOR_NUM, "globalvar");
　if (ret)
　{
　　printk("globalvar unregister failure");
　}
　else
　{
　　printk("globalvar unregister success");
　}
}

static ssize_t globalvar_read(struct file *filp, char *buf, size_t len, loff_t *off)
{
　//獲得信號量
　if (down_interruptible(&sem))
　{
　　return - ERESTARTSYS;
　}

　//將global_var從內核空間復制到用戶(hù)空間
　if (copy_to_user(buf, &global_var, sizeof(int)))
　{
　　up(&sem);
　　return - EFAULT;
　}

　//釋放信號量
　up(&sem);

　return sizeof(int);
}

ssize_t globalvar_write(struct file *filp, const char *buf, size_t len, loff_t *off)
{
　//獲得信號量
　if (down_interruptible(&sem))
　{
　　return - ERESTARTSYS;
　}

　//將用戶(hù)空間的數據復制到內核空間的global_var
　if (copy_from_user(&global_var, buf, sizeof(int)))
　{
　　up(&sem);
　　return - EFAULT;
　}

　//釋放信號量
　up(&sem);
　return sizeof(int);
}

module_init(globalvar_init);
module_exit(globalvar_exit);

　　接下來(lái)，我們給globalvar的驅動(dòng)程序增加open()和release()函數，并在其中借助自旋鎖來(lái)保護對全局變量int globalvar_count（記錄打開(kāi)設備的進(jìn)程數）的訪(fǎng)問(wèn)來(lái)實(shí)現設備只能被一個(gè)進(jìn)程打開(kāi)（必須確保globalvar_count最多只能為1）：

#include <linux/module.h>
#include <linux/init.h>
#include <linux/fs.h>
#include <asm/uaccess.h>
#include <asm/semaphore.h>

MODULE_LICENSE("GPL");

#define MAJOR_NUM 254

static ssize_t globalvar_read(struct file *, char *, size_t, loff_t*);
static ssize_t globalvar_write(struct file *, const char *, size_t, loff_t*);
static int globalvar_open(struct inode *inode, struct file *filp);
static int globalvar_release(struct inode *inode, struct file *filp);

struct file_operations globalvar_fops =
{
　read: globalvar_read, write: globalvar_write, open: globalvar_open, release:
globalvar_release,
};

static int global_var = 0;
static int globalvar_count = 0;
static struct semaphore sem;
static spinlock_t spin = SPIN_LOCK_UNLOCKED;

static int __init globalvar_init(void)
{
　int ret;
　ret = register_chrdev(MAJOR_NUM, "globalvar", &globalvar_fops);
　if (ret)
　{
　　printk("globalvar register failure");
　}
　else
　{
　　printk("globalvar register success");
　　init_MUTEX(&sem);
　}
　return ret;
}

static void __exit globalvar_exit(void)
{
　int ret;
　ret = unregister_chrdev(MAJOR_NUM, "globalvar");
　if (ret)
　{
　　printk("globalvar unregister failure");
　}
　else
　{
　　printk("globalvar unregister success");
　}
}

static int globalvar_open(struct inode *inode, struct file *filp)
{
　//獲得自選鎖
　spin_lock(&spin);

　//臨界資源訪(fǎng)問(wèn)
　if (globalvar_count)
　{
　　spin_unlock(&spin);
　　return - EBUSY;
　}
　globalvar_count++;

　//釋放自選鎖
　spin_unlock(&spin);
　return 0;
}

static int globalvar_release(struct inode *inode, struct file *filp)
{
　globalvar_count--;
　return 0;
}

static ssize_t globalvar_read(struct file *filp, char *buf, size_t len, loff_t
*off)
{
　if (down_interruptible(&sem))
　{
　　return - ERESTARTSYS;
　}
　if (copy_to_user(buf, &global_var, sizeof(int)))
　{
　　up(&sem);
　　return - EFAULT;
　}
　up(&sem);
　return sizeof(int);
}

static ssize_t globalvar_write(struct file *filp, const char *buf, size_t len,
loff_t *off)
{
　if (down_interruptible(&sem))
　{
　　return - ERESTARTSYS;
　}
　if (copy_from_user(&global_var, buf, sizeof(int)))
　{
　　up(&sem);
　　return - EFAULT;
　}
　up(&sem);
　return sizeof(int);
}

module_init(globalvar_init);
module_exit(globalvar_exit);

　　為了上述驅動(dòng)程序的效果，我們啟動(dòng)兩個(gè)進(jìn)程分別打開(kāi)/dev/globalvar。在兩個(gè)終端中調用./globalvartest.o測試程序，當一個(gè)進(jìn)程打開(kāi)/dev/globalvar后，另外一個(gè)進(jìn)程將打開(kāi)失敗，輸出"device open failure".