select是操作系统多路I/O复用技术实现的方式之一。
多路I/O复用技术大致使用场景为:构造一张感兴趣的文件描述符列表,然后调用多路复用的IO接口,在接口中进行阻塞,直到这些描述符中的一个已准备好进行I/O时,该函数才返回。
select在应用中使用的例子如下段代码所示。
#include <sys/select.h>
int main (int argc, char **argv)
{  
    fd_set       fdset;
    struct timeval  timeout;
    timeout.tv_sec  = 10;
    timeout.tv_usec = 0;
    int fd = open("/dev/htm2", O_RDWR, 0666);
    for (;;) {
        FD_ZERO(&fdset);
        FD_SET(fd, &fdset);
        select(fd + 1, &fdset, &fdset, NULL, &timeout);
        sleep(1);
    }
    return  (0);
}
LW_API INT   select(INT                   iWidth, 
                   fd_set               *pfdsetRead,
                   fd_set               *pfdsetWrite,
                   fd_set               *pfdsetExcept,
                   struct timeval        *ptmvalTO);
SylixOS的select接口实现中,系统会调用到每一个fd对应的设备驱动的ioctl接口,并会调用到如下表所示的两个命令。
| 命令 | 说明 | 
|---|---|
| FIOSELECT | 添加SEL_WAKE_NODE节点 | 
| FIOUNSELECT | 移除SEL_WAKE_NODE节点 | 
添加与移除SEL_WAKE_NODE的操作实际都是对SylixOS的select等待链进行操作,
对应调用如SEL_WAKE_NODE_ADD与SEL_WAKE_NODE_DELETE的系统接口。
等待链的作用就是将一堆阻塞待唤醒的线程组成集合,当需要被唤醒时可以通过调用系统的SEL_WAKE_UP系列函数实现对线程的唤醒。
SylixOS提供的唤醒命令如下表所示。
| 命令 | 说明 | 
|---|---|
| SEL_WAKE_UP | 唤醒一个等待线程 | 
| SEL_WAKE_UP_ALL | 唤醒等待某一类型操作的所有线程 | 
| SEL_WAKE_UP_TYPE | 获取节点的等待类型 | 
| SEL_WAKE_UP_ERROR | 由于产生了错误,唤醒一个等待的线程 | 
| SEL_WAKE_UP_TERM | 由于产生了错误,唤醒所有等待某一类型操作的所有线程 | 
需要注意的是:select阻塞操作使用的信号量为select上下文之中的,并不需要在驱动的FIOSELECT里再实现一个信号量。
select的上下文如下段程序所示。
typedef struct {
    LW_OBJECT_HANDLE       SELCTX_hSembWakeup;              /*  唤醒信号量              */
    BOOL                   SELCTX_bPendedOnSelect;          /*  是否阻塞在 select() 上  */
    fd_set                *SELCTX_pfdsetReadFds;            /*  阻塞的读文件集指针       */
    fd_set                *SELCTX_pfdsetWriteFds;           /*  阻塞的写文件集指针       */
    fd_set                *SELCTX_pfdsetExceptFds;          /*  阻塞的异常文件集指针     */
    fd_set                 SELCTX_fdsetOrigReadFds;         /*  原始的读文件集          */
    fd_set                 SELCTX_fdsetOrigWriteFds;        /*  原始的写文件集          */
    fd_set                 SELCTX_fdsetOrigExceptFds;       /*  原始的异常文件集        */
    INT                    SELCTX_iWidth;                   /*  select() 第一个参数    */
} LW_SEL_CONTEXT;
typedef LW_SEL_CONTEXT     *PLW_SEL_CONTEXT;
select的阻塞操作是在其内部调用的pselect函数中调用二进制信号量的pend操作实现的。但是在调用pend之前,pselect会首先调用ioctl,传递FIOSELECT参数,此接口中会判断当前是否满足select的唤醒条件,若满足则先调用post,以使之后调用的pend不会被阻塞。
其流程如下图所示。
在需要进行唤醒的地方调用SEL_WAKE_UP系列接口,如产生中断的地方、检测的线程中。
原文:http://blog.51cto.com/4102785/2073470