博客
信号和AIO
|
?? 异步非阻塞IO：即io操作发出后不阻塞IO操作也不阻塞通知，当操作完成后内核通过信号或回调方式主动通知调用进程，而不需要等待调用者主动进行查询。
?? 在异步IO操作中，当IO资源可用时驱动释放相应的信号给调用进程；当调用者捕获到信号后执行相关的信号处理函数；对于应用程序需通过fcntl(fd,F_SETOWN,getpid())将该进程设定为操作资源（文件）的属主以确定信号的接受对象，通过fcntl(fd,F_SETFL,FASYNC)设置FASYNC 调用驱动的fasync函数;待资源可使用时kill_fasync函数释放信号给调用者。
?? AIO 的基本思想是允许进程发起很多 I/O 操作，而不用阻塞或等待任何操作完成。稍后或在接收到 I/O 操作完成的通知时，进程就可以检索 I/O 操作的结果；对于一系列的IO操作是使用lio_list函数发起的，先定义一个aiocb的指针数组后于之即可发起；AIO可以使用信号或回调函数作为资源可用通知。
struct sigaction
??{
??__sighandler_t sa_handler; //信号处理函数地址 *阻塞的意思是延迟相应信号
??unsigned long sa_flags; //信号的处理标志：
??//SA_NODEFER表示内核不阻塞信号，一般为阻塞信号
??//SA_RESETHAND:表示调用信号处理函数重置为缺省态
??//SA_SIGINFO：表示处理函数有三个参数；void (*_sa_sigaction)(int,struct siginfo *,void *)因为对于应用层而言处理函数为 union {__sighandler_t _sa_handler; void (*_sa_sigaction)(int, struct siginfo *, void *);} _u;
??__sigrestore_t sa_restorer; //保存地址
??sigset_t sa_mask; //指定哪些信号被阻塞，一般默认为当前信号被阻塞
};
??
struct aiocb {
?? int aio_fildes; //aio文件描述符
?? int aio_lio_opcode;//进行批量IO操作时有效，读写类型
?? volatile void *aio_buf;//数据缓冲
?? size_t aio_nbytes; //数据缓冲长度
?? int aio_reqprio;//信号优先级
?? struct sigevent aio_sigevent; //aio结束后该执行的操作
?? /* Internal fields */
};
??
struct sigevent {
??union sigev_value{int sival_int;void *sival_ptr;}
??//信号传递值，即信号传递为处理函数的信息；
?? 若函数为独参时为信号值
?? 若为三个参数时则将包含aiocb结构体的siginfo _t传递给函数以完成AIO的异步读写。
??int sigev_signo; //信号值（类型）
??int sigev_notify; //通知模式SIGEV_SIGNAL为信号，SIGEV_THREAD为回调函数
??union {
?? int _pad[SIGEV_PAD_SIZE];
?? int _tid; //使用宏定义sigev_notify_thread_id 线程ID号
?? struct {
?? void (*_function)(sigval_t); //使用宏定义sigev_notify_function为线程回调函数
?? void *_attribute; //使用宏定义sigev_notify_attributes为线程属性
?? } _sigev_thread;
?? } _sigev_un;
};
??
使用范例：
//初始化信号
sig_act.sa_mask=0;
sig_act.sa_flags= SA_SIGINFO; //信号传递aiobc故 //--------------------------------------------------
使用3参数； 无
sig_act. sa_sigaction=fun;//信号处理函数 //---------------------------------------------------
//初始化aiocb结构
my_aiocb. aio_fildes=fd;
my_aiocb. aio_buf=***;
my_aiocb. aio_nbytes=N;
my_aiocb. aio_offset=next_offset;
//表示下一个操作从上一个操作结束处开始
//将AIO请求于与信号处理函数链接 //将AIO请求于与回调线程处理函数链接
my_aiocb. aio_sigevent. sigev_notify=SIGEV_SIGNAL; my_aiocb. aio_sigevent. sigev_notify=SIGEV_THREAD;
//表示以信号作通知 //表示以回调线程作通知
my_aiocb. aio_sigevent. sigev_signo=SIGIO; my_aiocb. aio_sigevent. sigev_notify_function=fun1;//回调函数
my_aiocb. aio_sigevent. sigev_notify_attributes=NULL;//属性不使用
my_aiocb. aio_sigevent. sival_ptr=&my_aiocb; my_aiocb. aio_sigevent. sival_ptr=&my_aiocb;
//捕获信号
sigaction(SIGIO,&sig_act,NULL); //--------------------------------------------------
//信号处理函数 // 回调函数
void fun（int signo,siginfo_t *info,void *context） void fun1（sigval_t sigval）
{-----------------------------p=info->si_value.sival_ptr; {-----------------------------p=sigval.sival_ptr;
//获得aiobc地址 //获得aiobc地址
} ? }
