字元裝置驅動同步之互斥阻塞
阿新 • • 發佈:2019-02-05
先了解幾個概念:
臨界資源:一次只允許一個執行單元使用的資源稱為臨界資源。比如多臺電腦都可以使用同一臺印表機,但是,一個時刻只能有一臺電腦來控制他進行列印,所以印表機在這裡就是臨界資源。
臨界區:訪問共享資源的程式碼區域。就是執行單元訪問共享資源的那段程式碼就對啦。
併發:就是幾個程序一起執行。
競態:幾個程序同時訪問共享資源時發生
(上面之所以說是執行單元,不說程序是因為還有執行緒的存在)
什麼叫程序的同步?
百度一下:我們把非同步環境下的一組併發程序因直接制約而互相傳送訊息、進行互相合作、互相等待,使得各程序按一定的速度執行的過程稱為程序間的同步。
我的理解就是:程序之間步伐一致,他們之間能夠有配合的工作。
程序之間同步的實現需要一些規則來協調,通常比如:互斥、阻塞。
一、互斥:同一時刻只能有一個App開啟某個裝置或訪問某個資源
實現互斥的技巧:
(1)原子操作
驅動程式的任務:
①設定原子變數的值
if (!atomic_dec_and_test(&canopen))
{
③在不使用資源時要將標記改成“未使用”
(2)訊號量:只有得到訊號量的程序才能執行臨界區的程式碼。得不到的程序進入休眠狀態,直到有條件獲取訊號量,或者被其他程序終止。
驅動程式的任務:
①定義訊號量&初始化,通常使用下面的巨集
③釋放訊號量
(3)自旋鎖:就是得不到自旋鎖就“原地打轉”,程序一直跑不過是原地迴圈
使用和訊號量很相似,主要有:定義、初始化、獲得、釋放操作。
(4)中斷遮蔽:讓系統不能進行中斷,這樣就不會切換到其他程序來搶奪資源了。
使用方法:
①遮蔽中斷
③開中斷
阻塞:不能獲得資源時掛起程序並進入睡眠狀態,直到資源到來。之前的驅動都是阻塞方式開啟的。這裡不再進行列舉程式。
app:open("...",O_RDWR);//open預設就是阻塞的方式開啟
非阻塞:無資源不掛起程序,之後放棄或不停的查詢。通常和訊號量配合使用。
加油!更上一層樓!
臨界資源:一次只允許一個執行單元使用的資源稱為臨界資源。比如多臺電腦都可以使用同一臺印表機,但是,一個時刻只能有一臺電腦來控制他進行列印,所以印表機在這裡就是臨界資源。
臨界區:訪問共享資源的程式碼區域。就是執行單元訪問共享資源的那段程式碼就對啦。
併發:就是幾個程序一起執行。
競態:幾個程序同時訪問共享資源時發生
(上面之所以說是執行單元,不說程序是因為還有執行緒的存在)
什麼叫程序的同步?
百度一下:我們把非同步環境下的一組併發程序因直接制約而互相傳送訊息、進行互相合作、互相等待,使得各程序按一定的速度執行的過程稱為程序間的同步。
我的理解就是:程序之間步伐一致,他們之間能夠有配合的工作。
程序之間同步的實現需要一些規則來協調,通常比如:互斥、阻塞。
一、互斥:同一時刻只能有一個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②獲取訊號量
“down”往下,讓我想到:在資源上插一支旗子,獲取他的人就把它拿下來,其他人就呵呵了^_^void down(struct semaphore * sem);//獲得訊號量sem,如果獲取不到,這個函式會導致休眠,休眠 不可以被訊號打斷,即使是“kill -9 pid”也不能將他退出,不要在中斷上下文中使用,因為它太固執了!
void down_interruptible(struct semaphore * sem);//進入睡眠狀態的程序能被訊號打斷
void down_trylock(struct semaphore * sem);//嘗試去獲取訊號量,成功返回0,失敗返回非零,不會導致呼叫程序休眠,可用於中斷上下文
③釋放訊號量
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協議
加油!更上一層樓!