Linux內核開(kāi)發(fā)之異步通知與異步I/O(二)

　　“曾經(jīng)有一份真摯的愛(ài)情擺在面前，我卻不懂珍惜;曾經(jīng)有一個(gè)承諾，我卻倍感珍惜，今天一定要好好講講..”

　　講講啥，講講上節說(shuō)的那個(gè)異步通知的例子唄，大家喜歡看代碼，咋們就先上代碼:

　　struct globalfifo_dev

　　{

　　struct cdev cdev; /*cdev結構體*/

　　unsigned int current_len; /*fifo有效數據長(cháng)度*/

　　unsigned char mem[GLOBALFIFO_SIZE]; /*全局內存*/

　　struct semaphore sem; /*并發(fā)控制用的信號量*/

　　wait_queue_head_t r_wait; /*阻塞讀用的等待隊列頭*/

　　wait_queue_head_t w_wait; /*阻塞寫(xiě)用的等待隊列頭*/

　　struct fasync_struct *async_queue; /* 異步結構體指針，用于讀 */

　　};

　　/*文件釋放函數*/

　　int globalfifo_release(struct inode *inode, struct file *filp)

　　{

　　/* 將文件從異步通知列表中刪除 */

　　globalmem_fasync( - 1, filp, 0);

　　return 0;

　　}

　　static int globalfifo_fasync(int fd, struct file *filp, int mode)

　　{

　　struct globalfifo_dev *dev = filp->private_data;

　　return fasync_helper(fd, filp, mode, &dev->async_queue);

　　}

　　/*globalfifo寫(xiě)操作*/

　　static ssize_t globalfifo_write(struct file *filp, const char __user *buf,

　　size_t count, loff_t *ppos)

　　{

　　struct globalfifo_dev *dev = filp->private_data; //獲得設備結構體指針

　　int ret;

　　DECLARE_WAITQUEUE(wait, current); //定義等待隊列

　　down(&dev->sem); //獲取信號量

　　add_wait_queue(&dev->w_wait, &wait); //進(jìn)入寫(xiě)等待隊列頭

　　/* 等待FIFO非滿(mǎn) */

　　if (dev->current_len == GLOBALFIFO_SIZE)

　　{

　　if (filp->f_flags &O_NONBLOCK)

　　//如果是非阻塞訪(fǎng)問(wèn)

　　{

　　ret = - EAGAIN;

　　goto out;

　　}

　　__set_current_state(TASK_INTERRUPTIBLE); //改變進(jìn)程狀態(tài)為睡眠

　　up(&dev->sem);

　　schedule(); //調度其他進(jìn)程執行

　　if (signal_pending(current))

　　//如果是因為信號喚醒

　　{

　　ret = - ERESTARTSYS;

　　goto out2;

　　}

　　down(&dev->sem); //獲得信號量

　　}

　　/*從用戶(hù)空間拷貝到內核空間*/

　　if (count > GLOBALFIFO_SIZE - dev->current_len)

　　count = GLOBALFIFO_SIZE - dev->current_len;

　　if (copy_from_user(dev->mem + dev->current_len, buf, count))

　　{

　　ret = - EFAULT;

　　goto out;

　　}

　　else

　　{

　　dev->current_len += count;

　　printk(KERN_INFO "written %d bytes(s),current_len:%dn", count, dev

　　->current_len);

　　wake_up_interruptible(&dev->r_wait); //喚醒讀等待隊列

　　/* 產(chǎn)生異步讀信號 */

　　if (dev->async_queue)

　　kill_fasync(&dev->async_queue, SIGIO, POLL_IN);

　　ret = count;

　　}

　　out: up(&dev->sem); //釋放信號量

　　out2:remove_wait_queue(&dev->w_wait, &wait); //從附屬的等待隊列頭移除

　　set_current_state(TASK_RUNNING);

　　return ret;

　　}

　　下面再給出測試程序：

　　#include ...

　　//接收到異步讀信號的動(dòng)作

　　void input_handler(int signum)

　　{

　　printf("Receive a signal from globalfifo,signalnum:%dn",signum);

　　}

　　int main()

　　{

　　int fd, oflags;

　　fd = open("/dev/globalfifo", O_RDWR, S_IRUSR | S_IWUSR);

　　if (fd != - 1)

　　{

　　//啟動(dòng)信號驅動(dòng)機制

　　signal(SIGIO, input_handler); //讓input_handler()處理SIGIO信號

　　fcntl(fd, F_SETOWN, getpid());

　　oflags = fcntl(fd, F_GETFL);

　　fcntl(fd, F_SETFL, oflags | FASYNC);

　　while(1)

　　{

　　sleep(100);

　　}

　　}

　　else

　　{

　　printf("device open failuren");

　　}

　　}

　　當我們加載完驅動(dòng)并創(chuàng )建完設備節點(diǎn)后，運行上述程序，每當通過(guò)echo向/dev/globalfilfo寫(xiě)入新的數據后，input_handler將會(huì )被調用。如下所示：

　　echo 0>/dev/globalfifo

　　receive a signal from globalfifo ,signalnum:29

　　echo 0>/dev/globalfifo

　　receive a signal from globalfifo ,signalnum:29

　　echo 0>/dev/globalfifo

　　receive a signal from globalfifo ,signalnum:29

　　通過(guò)上邊實(shí)際的例子，小王，明白了吧，我的承諾也兌現了，下次咱們可要開(kāi)始更高級的東西了..