linux下使用异步通知

时间:2021-06-15 01:53:07

阻塞式I/O是一直等待直到设备可以访问,非阻塞式I/O是定期轮询设备是否可以访问。

异步通知则是当设备可以访问时才主动通知应用程序,有点像设备的硬中断。

并不是所有的设备都支持异步通知,应用程序通常假设只有套接字和终端才有异步通知的能力。

异步通知存在一个问题,当进程收到SIGIO信号时,它并不知道是哪个文件有了新的输入,如果

有多于一个的文件可以异步通知同一个进程,那么应用进程还需要借助于poll或select来确定输入

的来源。

应用层

fcntl - manipulate file descriptor

fcntl(fd, F_SETFL, flags | O_ASYNC);

效果:

If you set the O_ASYNC status flag on a file descriptor by using the F_SETFL command of fcntl(),

a SIGIO signal is sent whenever input or output becomes possible on that file descriptor.

例子

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <signal.h>
#include <fcntl.h> #define MAX_LEN 100 void my_handler(int signum)
{
char data[MAX_LEN];
int len; len = read(STDIN_FILENO, &data, MAX_LEN);
data[len] = 0; printf("Input message: %s\n", data);
exit(0);
} int main(void)
{
int oflags; /* set new SIGIO handler */
signal(SIGIO, my_handler);
/* set fd's owner process */
fcntl(STDIN_FILENO, F_SETOWN, getpid());
/* get old fd flags */
oflags = fcntl(STDIN_FILENO, F_GETFL);
/* set new fd flags */
fcntl(STDIN_FILENO, F_SETFL, oflags | O_ASYNC); /* infinitely wait until recv SIGIO */
while(1);
return 0;
}

为了能处理设备发出的SIGIO信号,用户程序需要做:

1. 设置设备文件的拥有者为本进程,这样一来才能收到设备驱动发出的SIGIO信号。

2. 使设备文件支持异步通知,即设置O_ASYNC标志。

3. 通过signal()指定SIGIO的处理函数。

设备驱动

struct fasync_struct {
spinlock_t fa_lock;
int magic;
int fa_fd; /* 文件描述符 */
struct fasync_struct *fa_next; /* 用于链入单向链表 */
struct file *fa_file; /* fa_file->f_owner记录接收信号的进程 */
struct rcu_head fa_rcu;
};

(1) 设备的异步通知链

struct xxx_dev {
struct cdev cdev;
...
struct fasync_struct *async_queue; /* 异步通知链 */
};

(2) 插入到异步通知链

static int xxx_fasync(int fd, struct file *filp, int on)
{
struct xxx_dev *dev = filp->private_data;
return fasync_helper(fd, filp, on, &dev->async_queue);
}

(3) 发送信号通知进程

设备使用kill_fasync()来发送信号给用户进程,一般sig为SIGIO,可读时band为POLL_IN,

可写时band为POLL_OUT。

static ssize_t xxx_write(struct file *filp, const char __user *buf, size_t count, loff_t *f_ops)
{
struct xxx_dev *dev = filp->private_data;
...
if (dev->async_queue) {
kill_fasync(&dev->async_queue, SIGIO, POLL_IN);
}
...
}

(4) 从异步通知链中删除

在关闭文件时,需要把对应的异步通知结构从链表中删除。

static xxx_release(struct inode *inode, struct file *filp)
{
struct xxx_dev *dev = filp->private_data;
...
fasync_helper(-1, filp, 0, &dev->async_queue);
...
}

内核API

异步通知结构体的插入和删除,失败返回负值,没有变化返回0,有变化返回正值。

/* fasync_helper() is used by almost all character device drivers to set up the
* fasync queue, and for regular files by the file lease code. It returns negative
* on error, 0 if it did no changes and positive if it added/deleted the entry.
*/ int fasync_helper(int fd, struct file *filp, int on, struct fasync_struct **fapp)
{
if (!on) /* 删除 */
return fasync_remove_entry(filp, fapp);
return fasync_add_entry(fd, filp, fapp); /* 插入 */
}

发送信号,通知用户进程,sig一般设为SIGIO,可读时band为POLL_IN,可写时band为POLL_OUT。

void kill_fasync(struct fasync_struct **fp, int sig, int band)
{
/* First a quick test without locking: usually the list is empty. */
if (*fp) {
rcu_read_lock();
kill_fasync_rcu(rcu_dereference(*fp), sig, band);
rcu_read_unlock();
}
}

Reference

[1]. http://www.cnblogs.com/hanyan225/archive/2010/10/20/1857040.html

[2]. 《设备驱动程序》