1. 程式人生 > >字元裝置驅動同步之互斥阻塞

字元裝置驅動同步之互斥阻塞

先了解幾個概念:
臨界資源:一次只允許一個執行單元使用的資源稱為臨界資源。比如多臺電腦都可以使用同一臺印表機,但是,一個時刻只能有一臺電腦來控制他進行列印,所以印表機在這裡就是臨界資源。
臨界區:訪問共享資源的程式碼區域。就是執行單元訪問共享資源的那段程式碼就對啦。
併發:就是幾個程序一起執行。
競態:幾個程序同時訪問共享資源時發生
(上面之所以說是執行單元,不說程序是因為還有執行緒的存在)
什麼叫程序的同步?
百度一下:我們把非同步環境下的一組併發程序因直接制約而互相傳送訊息、進行互相合作、互相等待,使得各程序按一定的速度執行的過程稱為程序間的同步。
我的理解就是:程序之間步伐一致,他們之間能夠有配合的工作。

程序之間同步的實現需要一些規則來協調,通常比如:互斥、阻塞。
一、互斥:同一時刻只能有一個App開啟某個裝置或訪問某個資源
實現互斥的技巧:
(1)原子操作
驅動程式的任務:
①設定原子變數的值
atomic_t v = ATOMIC_INIT(1);//定義原子變數v初始化為1
②在即將訪問臨界資源前設定“使用中”標記,通常是:
if (!atomic_dec_and_test(&canopen))
{
atomic_inc(&canopen);
printk("Using now!\n");
return -EBUSY;
}
③在不使用資源時要將標記改成“未使用”
atomic_inc(&canopen);//釋放原子變數
程式碼實現:

atomic.c檔案

#include <linux/delay.h>
#include <linux/irq.h>
#include <asm/uaccess.h>
#include <asm/irq.h>
#include <asm/io.h>
#include <linux/module.h>
#include <linux/device.h> 		//class_create
#include <mach/regs-gpio.h>		//S3C2410_GPF1 
#include <mach/hardware.h>
#include <linux/interrupt.h>  //wait_event_interruptible
#include <linux/fs.h>
#include <arch/arm/include/asm/atomic.h>

/* 定義並初始化等待佇列頭 */
static DECLARE_WAIT_QUEUE_HEAD(button_waitq);

////////////////////////////////////////////////////////////////////////
static atomic_t canopen = ATOMIC_INIT(1);     //定義原子變數並初始化為1
////////////////////////////////////////////////////////////////////////

static struct class *buttondev_class;
static struct device *buttons_device;

static struct pin_desc{
	unsigned int pin;
	unsigned int key_val;
};

static struct pin_desc pins_desc[4] = {
		{S3C2410_GPF1,0x01}, //S3C2410_GPF1是對GPF1引腳這種“裝置”的編號dev_id
		{S3C2410_GPF4,0x02},
		{S3C2410_GPF2,0x03},
		{S3C2410_GPF0,0x04},
}; 
static int ev_press = 0;
static unsigned char key_val;
int major;

/* 中斷處理函式 */
static irqreturn_t handle_irq(int irq, void *dev_id)
{
	struct pin_desc *irq_pindesc = (struct pin_desc *)dev_id;//
	unsigned int pinval;
		
	pinval = s3c2410_gpio_getpin(irq_pindesc->pin);//獲取按鍵值:有按鍵按下返回按鍵值0
	/* 鍵值: 按下時, 0x01, 0x02, 0x03, 0x04 */
	/* 鍵值: 鬆開時, 0x81, 0x82, 0x83, 0x84 */
	if(pinval)
	{
		/* 鬆開 */
		key_val = 0x80 | (irq_pindesc->key_val);
	}
	else
	{
		/* 按下 */
		key_val = irq_pindesc->key_val;
	}

	ev_press = 1;							/* 表示中斷已經發生 */
	wake_up_interruptible(&button_waitq);   /* 喚醒休眠的程序 */
	return IRQ_HANDLED;
}

static int buttons_dev_open(struct inode * inode, struct file * filp)
{
	///////////////////////////////////////////////////////////
	//實現互斥:原子操作
	if (!atomic_dec_and_test(&canopen))
	{
		atomic_inc(&canopen);
		printk("dev is using now!\n");
		return -EBUSY;
	}
	///////////////////////////////////////////////////////////
	request_irq(IRQ_EINT1, handle_irq, IRQ_TYPE_EDGE_FALLING, "K1",&pins_desc[0]);
	request_irq(IRQ_EINT4, handle_irq, IRQ_TYPE_EDGE_FALLING, "K2",&pins_desc[1]);
	request_irq(IRQ_EINT2, handle_irq, IRQ_TYPE_EDGE_FALLING, "K3",&pins_desc[2]);
	request_irq(IRQ_EINT0, handle_irq, IRQ_TYPE_EDGE_FALLING, "K4",&pins_desc[3]);
	return 0;
}

static int buttons_dev_close(struct inode *inode, struct file *file)
{
	//////////////////////////////////////////////////////////////
	atomic_inc(&canopen);//釋放原子變數
	//////////////////////////////////////////////////////////////
	free_irq(IRQ_EINT1,&pins_desc[0]);
	free_irq(IRQ_EINT4,&pins_desc[1]);
	free_irq(IRQ_EINT2,&pins_desc[2]);
	free_irq(IRQ_EINT0,&pins_desc[3]);
	
	return 0;
}

static ssize_t buttons_dev_read(struct file *file, char __user *user, size_t size,loff_t *ppos)
{
	if (size != 1)
			return -EINVAL;
	wait_event_interruptible(button_waitq, ev_press);//沒有按鍵就進入休眠
	copy_to_user(user, &key_val, 1);
	/* 將ev_press清零 */
	ev_press = 0;
	return 1;
}

/* File operations struct for character device */
static const struct file_operations buttons_dev_fops = {
	.owner		= THIS_MODULE,
	.open		= buttons_dev_open,
	.read		= buttons_dev_read,
	.release    = buttons_dev_close,
};

/* 驅動入口函式 */
static int buttons_dev_init(void)
{
	/* 主裝置號設定為0表示由系統自動分配主裝置號 */
	major = register_chrdev(0, "buttons_dev", &buttons_dev_fops);

	/* 建立buttondev類 */
	buttondev_class = class_create(THIS_MODULE, "buttondev");

	/* 在buttondev類下建立buttons裝置,供應用程式開啟裝置*/
	buttons_device = device_create(buttondev_class, NULL, MKDEV(major, 0), NULL, "buttons");//

	return 0;
}

/* 驅動出口函式 */
static void buttons_dev_exit(void)
{
	unregister_chrdev(major, "buttons_dev");
	device_unregister(buttons_device);  //解除安裝類下的裝置
	class_destroy(buttondev_class);		//解除安裝類
}

/* 模組載入和解除安裝函式的修飾 */
module_init(buttons_dev_init);  
module_exit(buttons_dev_exit); 

MODULE_AUTHOR("CLBIAO");
MODULE_DESCRIPTION("Just for Demon");
MODULE_LICENSE("GPL");  //遵循GPL協議
測試程式:

app_atomic.c

/* 檔案的編譯指令是arm-linux-gcc -static -o app_irq app_atomic.c */
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>   //sleep 
#include <stdio.h>

int main(int argc, char **argv)
{
	int flag,fd; 
	unsigned char key_val;
	
	fd = open("/dev/buttons", O_RDWR); //申請外部引腳中斷服務
	if (fd < 0)
	{
		printf("can't open!\n");//開啟失敗
		return -1;//返回
	}
	while(1)
	{
		read(fd,&key_val,1); 
   		printf("key_val = 0x%x\n",key_val); 
		sleep(3);
	}
	return 0;
}
執行結果:

(2)訊號量:只有得到訊號量的程序才能執行臨界區的程式碼。得不到的程序進入休眠狀態,直到有條件獲取訊號量,或者被其他程序終止。
驅動程式的任務:
①定義訊號量&初始化,通常使用下面的巨集
DECLARE_MUTEX(name);//定義一個名為name的訊號量,並初始化為1
②獲取訊號量

void down(struct semaphore * sem);//獲得訊號量sem,如果獲取不到,這個函式會導致休眠,休眠 不可以被訊號打斷,即使是“kill -9 pid”也不能將他退出,不要在中斷上下文中使用,因為它太固執了!

void down_interruptible(struct semaphore * sem);//進入睡眠狀態的程序能被訊號打斷
void down_trylock(struct semaphore * sem);//嘗試去獲取訊號量,成功返回0,失敗返回非零,不會導致呼叫程序休眠,可用於中斷上下文
“down”往下,讓我想到:在資源上插一支旗子,獲取他的人就把它拿下來,其他人就呵呵了^_^
③釋放訊號量
int up(struct semaphore * sem);//把訊號插回去,然後喚醒沉睡的人
程式碼實現:
#include <linux/delay.h>
#include <linux/irq.h>
#include <asm/uaccess.h>
#include <asm/irq.h>
#include <asm/io.h>
#include <linux/module.h>
#include <linux/device.h> 		//class_create
#include <mach/regs-gpio.h>		//S3C2410_GPF1 
#include <mach/hardware.h>
#include <linux/interrupt.h>  //wait_event_interruptible
#include <linux/fs.h>
#include <linux/semaphore.h>

/* 定義並初始化等待佇列頭 */
static DECLARE_WAIT_QUEUE_HEAD(button_waitq);

////////////////////////////////////////////////////////////////////////
static DECLARE_MUTEX(button_lock);//(1)獲取訊號量量並初始化為1
////////////////////////////////////////////////////////////////////////

static struct class *buttondev_class;
static struct device *buttons_device;

static struct pin_desc{
	unsigned int pin;
	unsigned int key_val;
};

static struct pin_desc pins_desc[4] = {
		{S3C2410_GPF1,0x01}, //S3C2410_GPF1是對GPF1引腳這種“裝置”的編號dev_id
		{S3C2410_GPF4,0x02},
		{S3C2410_GPF2,0x03},
		{S3C2410_GPF0,0x04},
}; 
static int ev_press = 0;
static unsigned char key_val;
int major;

/* 中斷處理函式 */
static irqreturn_t handle_irq(int irq, void *dev_id)
{
	struct pin_desc *irq_pindesc = (struct pin_desc *)dev_id;//
	unsigned int pinval;
		
	pinval = s3c2410_gpio_getpin(irq_pindesc->pin);//獲取按鍵值:有按鍵按下返回按鍵值0
	/* 鍵值: 按下時, 0x01, 0x02, 0x03, 0x04 */
	/* 鍵值: 鬆開時, 0x81, 0x82, 0x83, 0x84 */
	if(pinval)
	{
		/* 鬆開 */
		key_val = 0x80 | (irq_pindesc->key_val);
	}
	else
	{
		/* 按下 */
		key_val = irq_pindesc->key_val;
	}

	ev_press = 1;							/* 表示中斷已經發生 */
	wake_up_interruptible(&button_waitq);   /* 喚醒休眠的程序 */
	return IRQ_HANDLED;
}

static int buttons_dev_open(struct inode * inode, struct file * filp)
{
	/////////////////////////////////////
	down(&button_lock);//(2)獲取訊號量
	////////////////////////////////////
	request_irq(IRQ_EINT1, handle_irq, IRQ_TYPE_EDGE_FALLING, "K1",&pins_desc[0]);
	request_irq(IRQ_EINT4, handle_irq, IRQ_TYPE_EDGE_FALLING, "K2",&pins_desc[1]);
	request_irq(IRQ_EINT2, handle_irq, IRQ_TYPE_EDGE_FALLING, "K3",&pins_desc[2]);
	request_irq(IRQ_EINT0, handle_irq, IRQ_TYPE_EDGE_FALLING, "K4",&pins_desc[3]);
	return 0;
}

static int buttons_dev_close(struct inode *inode, struct file *file)
{
	/////////////////////////////////////
	up(&button_lock);//(3)釋放訊號量
	////////////////////////////////////
	free_irq(IRQ_EINT1,&pins_desc[0]);
	free_irq(IRQ_EINT4,&pins_desc[1]);
	free_irq(IRQ_EINT2,&pins_desc[2]);
	free_irq(IRQ_EINT0,&pins_desc[3]);
	
	return 0;
}

static ssize_t buttons_dev_read(struct file *file, char __user *user, size_t size,loff_t *ppos)
{
	if (size != 1)
			return -EINVAL;
	wait_event_interruptible(button_waitq, ev_press);//沒有按鍵就進入休眠
	copy_to_user(user, &key_val, 1);
	/* 將ev_press清零 */
	ev_press = 0;
	return 1;
}

/* File operations struct for character device */
static const struct file_operations buttons_dev_fops = {
	.owner		= THIS_MODULE,
	.open		= buttons_dev_open,
	.read		= buttons_dev_read,
	.release    = buttons_dev_close,
};

/* 驅動入口函式 */
static int buttons_dev_init(void)
{
	/* 主裝置號設定為0表示由系統自動分配主裝置號 */
	major = register_chrdev(0, "buttons_dev", &buttons_dev_fops);

	/* 建立buttondev類 */
	buttondev_class = class_create(THIS_MODULE, "buttondev");

	/* 在buttondev類下建立buttons裝置,供應用程式開啟裝置*/
	buttons_device = device_create(buttondev_class, NULL, MKDEV(major, 0), NULL, "buttons");//

	return 0;
}

/* 驅動出口函式 */
static void buttons_dev_exit(void)
{
	unregister_chrdev(major, "buttons_dev");
	device_unregister(buttons_device);  //解除安裝類下的裝置
	class_destroy(buttondev_class);		//解除安裝類
}

/* 模組載入和解除安裝函式的修飾 */
module_init(buttons_dev_init);  
module_exit(buttons_dev_exit); 

MODULE_AUTHOR("CLBIAO");
MODULE_DESCRIPTION("Just for Demon");
MODULE_LICENSE("GPL");  //遵循GPL協議

測試程式和前面一個一樣。

執行結果:

      

(3)自旋鎖:就是得不到自旋鎖就“原地打轉”,程序一直跑不過是原地迴圈
使用和訊號量很相似,主要有:定義、初始化、獲得、釋放操作。
(4)中斷遮蔽:讓系統不能進行中斷,這樣就不會切換到其他程序來搶奪資源了。
使用方法:
①遮蔽中斷
local_irq_disable();
②臨界區安安心心地訪問資源
③開中斷
local_irq_enable();
二、阻塞和非阻塞
阻塞:不能獲得資源時掛起程序並進入睡眠狀態,直到資源到來。之前的驅動都是阻塞方式開啟的。這裡不再進行列舉程式。
app:open("...",O_RDWR);//open預設就是阻塞的方式開啟
非阻塞:無資源不掛起程序,之後放棄或不停的查詢。通常和訊號量配合使用。

app:open("...",O_RDWR|O_NONBLOCK);

非阻塞方式例程式

nonblock.c檔案

#include <linux/delay.h>
#include <linux/irq.h>
#include <asm/uaccess.h>
#include <asm/irq.h>
#include <asm/io.h>
#include <linux/module.h>
#include <linux/device.h> 		//class_create
#include <mach/regs-gpio.h>		//S3C2410_GPF1 
#include <mach/hardware.h>
#include <linux/interrupt.h>  //wait_event_interruptible
#include <linux/fs.h>
#include <linux/semaphore.h>

/* 定義並初始化等待佇列頭 */
static DECLARE_WAIT_QUEUE_HEAD(button_waitq);

////////////////////////////////////////////////////////////////////////
static DECLARE_MUTEX(button_lock);//(1)獲取訊號量量並初始化為1
////////////////////////////////////////////////////////////////////////

static struct class *buttondev_class;
static struct device *buttons_device;

static struct pin_desc{
	unsigned int pin;
	unsigned int key_val;
};

static struct pin_desc pins_desc[4] = {
		{S3C2410_GPF1,0x01}, //S3C2410_GPF1是對GPF1引腳這種“裝置”的編號dev_id
		{S3C2410_GPF4,0x02},
		{S3C2410_GPF2,0x03},
		{S3C2410_GPF0,0x04},
}; 
static int ev_press = 0;
static unsigned char key_val;
int major;

/* 中斷處理函式 */
static irqreturn_t handle_irq(int irq, void *dev_id)
{
	struct pin_desc *irq_pindesc = (struct pin_desc *)dev_id;//
	unsigned int pinval;
		
	pinval = s3c2410_gpio_getpin(irq_pindesc->pin);//獲取按鍵值:有按鍵按下返回按鍵值0
	/* 鍵值: 按下時, 0x01, 0x02, 0x03, 0x04 */
	/* 鍵值: 鬆開時, 0x81, 0x82, 0x83, 0x84 */
	if(pinval)
	{
		/* 鬆開 */
		key_val = 0x80 | (irq_pindesc->key_val);
	}
	else
	{
		/* 按下 */
		key_val = irq_pindesc->key_val;
	}

	ev_press = 1;							/* 表示中斷已經發生 */
	wake_up_interruptible(&button_waitq);   /* 喚醒休眠的程序 */
	return IRQ_HANDLED;
}

static int buttons_dev_open(struct inode * inode, struct file * filp)
{
	/////////////////////////////////////
	if (file->f_flags & O_NONBLOCK)//判斷是不是非阻塞方式
	{
		if (down_trylock(&button_lock))//嘗試獲取訊號量,沒有就走人,不等待!
			return -EBUSY;
	}
	else  //是阻塞方式就使用down函式,這樣可以進入睡眠
	{
		/* 獲取訊號量 */
		down(&button_lock);
	}
	////////////////////////////////////
	request_irq(IRQ_EINT1, handle_irq, IRQ_TYPE_EDGE_FALLING, "K1",&pins_desc[0]);
	request_irq(IRQ_EINT4, handle_irq, IRQ_TYPE_EDGE_FALLING, "K2",&pins_desc[1]);
	request_irq(IRQ_EINT2, handle_irq, IRQ_TYPE_EDGE_FALLING, "K3",&pins_desc[2]);
	request_irq(IRQ_EINT0, handle_irq, IRQ_TYPE_EDGE_FALLING, "K4",&pins_desc[3]);
	return 0;
}

static int buttons_dev_close(struct inode *inode, struct file *file)
{
	/////////////////////////////////////
	up(&button_lock);//(3)釋放訊號量
	////////////////////////////////////
	free_irq(IRQ_EINT1,&pins_desc[0]);
	free_irq(IRQ_EINT4,&pins_desc[1]);
	free_irq(IRQ_EINT2,&pins_desc[2]);
	free_irq(IRQ_EINT0,&pins_desc[3]);
	
	return 0;
}

static ssize_t buttons_dev_read(struct file *file, char __user *user, size_t size,loff_t *ppos)
{
	if (size != 1)
			return -EINVAL;
	/////////////////////////////////////////////////////////////////
	if (file->f_flags & O_NONBLOCK) //讀不到按鍵值立馬返回,不睡眠!
	{
		if (!ev_press)
			return -EAGAIN;
	}
	else
		wait_event_interruptible(button_waitq, ev_press);//沒有按鍵就進入休眠
	///////////////////////////////////////////////////////////////////
	copy_to_user(user, &key_val, 1);
	/* 將ev_press清零 */
	ev_press = 0;
	
	return 1;
}

/* File operations struct for character device */
static const struct file_operations buttons_dev_fops = {
	.owner		= THIS_MODULE,
	.open		= buttons_dev_open,
	.read		= buttons_dev_read,
	.release    = buttons_dev_close,
};

/* 驅動入口函式 */
static int buttons_dev_init(void)
{
	/* 主裝置號設定為0表示由系統自動分配主裝置號 */
	major = register_chrdev(0, "buttons_dev", &buttons_dev_fops);

	/* 建立buttondev類 */
	buttondev_class = class_create(THIS_MODULE, "buttondev");

	/* 在buttondev類下建立buttons裝置,供應用程式開啟裝置*/
	buttons_device = device_create(buttondev_class, NULL, MKDEV(major, 0), NULL, "buttons");//

	return 0;
}

/* 驅動出口函式 */
static void buttons_dev_exit(void)
{
	unregister_chrdev(major, "buttons_dev");
	device_unregister(buttons_device);  //解除安裝類下的裝置
	class_destroy(buttondev_class);		//解除安裝類
}

/* 模組載入和解除安裝函式的修飾 */
module_init(buttons_dev_init);  
module_exit(buttons_dev_exit); 

MODULE_AUTHOR("CLBIAO");
MODULE_DESCRIPTION("Just for Demon");
MODULE_LICENSE("GPL");  //遵循GPL協議

加油!更上一層樓!生氣