欧美日韩一区二区高清,久久视频这里只有精品,超黄网站在线观看,成人av影院在线观看

以文本方式查看主題

-  曙海教育集團(tuán)論壇  (http://www.martymets.com/bbs/index.asp)
--  Linux驅(qū)動開發(fā)  (http://www.martymets.com/bbs/list.asp?boardid=33)
----  深入淺出Linux設(shè)備驅(qū)動之并發(fā)控制(2)  (http://www.martymets.com/bbs/dispbbs.asp?boardid=33&id=1742)

--  作者：wangxinxin
--  發(fā)布時間：2010-11-24 11:46:56
--  深入淺出Linux設(shè)備驅(qū)動之并發(fā)控制(2)
下面進(jìn)入對并發(fā)控制的實戰(zhàn)。首先，在globalvar的驅(qū)動程序中，我們可以通過信號量來控制對int global_var的并發(fā)訪問，下面給出源代碼：

#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從內(nèi)核空間復(fù)制到用戶空間
　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;
　}

　//將用戶空間的數(shù)據(jù)復(fù)制到內(nèi)核空間的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);

　　接下來，我們給globalvar的驅(qū)動程序增加open()和release()函數(shù)，并在其中借助自旋鎖來保護(hù)對全局變量int globalvar_count（記錄打開設(shè)備的進(jìn)程數(shù)）的訪問來實現(xiàn)設(shè)備只能被一個進(jìn)程打開（必須確保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);

　//臨界資源訪問
　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ū)動程序的效果，我們啟動兩個進(jìn)程分別打開/dev/globalvar。在兩個終端中調(diào)用./globalvartest.o測試程序，當(dāng)一個進(jìn)程打開/dev/globalvar后，另外一個進(jìn)程將打開失敗，輸出"device open failure"，如下圖：

輸出結(jié)果

主站蜘蛛池模板：三亚市| 四子王旗| 焦作市| 兴海县| 枞阳县| 河池市| 资溪县| 繁昌县| 阿巴嘎旗| 津南区| 隆林| 青川县| 济阳县| 固原市| 资溪县| 深圳市| 九台市| 谷城县| 福海县| 贡山| 汾西县| 梁河县| 甘肃省| 延长县| 定结县| 城口县| 阳信县| 景东| 双流县| 芮城县| 大渡口区| 壶关县| 永登县| 沂源县| 潍坊市| 雷波县| 北碚区| 定结县| 曲靖市| 石阡县| 宜宾市|