久久中文视频-久久中文网-久久中文亚洲国产-久久中文字幕久久久久-亚洲狠狠成人综合网-亚洲狠狠婷婷综合久久久久


曙海教育集團(tuán)論壇Linux專(zhuān)區(qū)Linux驅(qū)動(dòng)開(kāi)發(fā) → 深入淺出Linux設(shè)備驅(qū)動(dòng)之并發(fā)控制(2)


  共有9572人關(guān)注過(guò)本帖樹(shù)形打印

主題:深入淺出Linux設(shè)備驅(qū)動(dòng)之并發(fā)控制(2)

美女呀,離線,留言給我吧!
wangxinxin
  1樓 個(gè)性首頁(yè) | 博客 | 信息 | 搜索 | 郵箱 | 主頁(yè) | UC


加好友 發(fā)短信
等級(jí):青蜂俠 帖子:1393 積分:14038 威望:0 精華:0 注冊(cè):2010-11-12 11:08:23
深入淺出Linux設(shè)備驅(qū)動(dòng)之并發(fā)控制(2)  發(fā)帖心情 Post By:2010-11-24 11:46:56

下面進(jìn)入對(duì)并發(fā)控制的實(shí)戰(zhàn)。首先,在globalvar的驅(qū)動(dòng)程序中,我們可以通過(guò)信號(hào)量來(lái)控制對(duì)int global_var的并發(fā)訪問(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)
{
 //獲得信號(hào)量
 if (down_interruptible(&sem))
 {
  return - ERESTARTSYS;
 }

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

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

 return sizeof(int);
}

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

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

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

module_init(globalvar_init);
module_exit(globalvar_exit);

  接下來(lái),我們給globalvar的驅(qū)動(dòng)程序增加open()和release()函數(shù),并在其中借助自旋鎖來(lái)保護(hù)對(duì)全局變量int globalvar_count(記錄打開(kāi)設(shè)備的進(jìn)程數(shù))的訪問(wèn)來(lái)實(shí)現(xiàn)設(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);

 //臨界資源訪問(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);

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

圖片點(diǎn)擊可在新窗口打開(kāi)查看
輸出結(jié)果

支持(0中立(0反對(duì)(0單帖管理 | 引用 | 回復(fù) 回到頂部

返回版面帖子列表

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








簽名
主站蜘蛛池模板: 国产精品国产精品 | a理论片| 国产精品久久人人做人人爽 | 国产精品亚洲专一区二区三区 | 国产高清一区二区三区视频 | 国产精品久久久久久久久久一区 | 国产在线爱做人成小视频 | 乱人伦中文字幕视频 | 久久亚洲私人国产精品va | 美女很黄很黄是免费的·无遮挡网站 | 国产三片高清在线观看 | 欧美在线一级片 | 极品美女一级毛片 | 久草热久草在线 | free性chinese国语对白 | 久久综合九色综合欧洲色 | 在线观看亚洲 | 国产精品久久影院 | 国产成人18黄网站在线观看网站 | 免费特黄 | 国产精品亚洲四区在线观看 | 国产欧美精品一区二区三区 | 最新福利片v国产片 | 在线观看黄网 | 亚洲精品一区二区观看 | 真人一级毛片国产 | 在线国产网站 | 成人毛片免费观看视频 | www国产| 91精品国产综合久久欧美 | 在线视免费频观看韩国aaa | 日韩亚洲一区二区三区 | 亚洲欧美一级久久精品 | 免费 视频 1级 | 欧洲一级毛片免费 | 日韩精品久久久免费观看夜色 | 日韩亚 | 国产成人精品视频在放 | 色九九视频 | 亚洲国产天堂在线网址 | 午夜精品一区二区三区在线观看 |