有人能给我一个例子,告诉我如何提醒select()fd变为"准备好"

Question

我不知道为什么我很难找到这个,但我正在查看一些linux代码,我们正在使用select()等待文件描述符来报告它已准备就绪.从选择的手册页:

select() and pselect() allow a program to monitor multiple file descriptors,
waiting until one or more of the file descriptors become "ready" for some
class of I/O operation 

所以,这很好......我在一些描述符上调用select,给它一些时间值并开始等待指示去.文件描述符(或描述符的所有者)如何报告它"准备好"以便select()语句返回？

Answer 1

据报道它已经准备就绪了.

select等待通常超出程序控制范围的事件.从本质上讲,通过电话select,你的程序说:"我要做什么,直到......,请暂停我的程序".

您指定的条件是一组事件,其中任何事件都会唤醒您.

例如,如果您正在下载某些内容,则您的循环必须等待新数据到达,如果传输被卡住则发生超时,或者用户要中断,这正是select如此.

当您有多个下载时,到达任何连接的数据会触发程序中的活动(您需要将数据写入磁盘),因此您需要select在文件描述符列表中提供所有下载连接的列表以供监视"读".

当您同时将数据上传到某个地方时,您再次使用select以查看连接当前是否接受数据.如果另一端是拨号,它将只缓慢地确认数据,因此本地发送缓冲区总是满的,任何写入更多数据的尝试都会阻塞,直到缓冲区空间可用或失败.通过将我们发送的文件描述符select作为"写"描述符传递,一旦缓冲区空间可用于发送,我们就会收到通知.

一般的想法是您的程序变为事件驱动,即它对来自公共消息循环的外部事件做出反应,而不是执行顺序操作.你告诉内核"这是我要做的事情的一组事件",内核会给你一组已经发生的事件.两个事件同时发生是相当常见的; 例如,TCP确认包含在数据包中,这可以使相同的fd可读(数据可用)和可写(已确认的数据已从发送缓冲区中删除),因此您应该准备好处理所有事件在select再次打电话之前

其中一个更好的点是,select基本上给你一个一个调用read或write不会阻止的承诺,而不保证调用本身.例如,如果一个字节的缓冲区空间可用,您可以尝试写入10个字节,内核将返回并说"我写了1个字节",因此您应该准备好处理这种情况.一种典型的方法是使缓冲区"要写入此fd的数据",只要它是非空的,就将fd添加到写集中,并通过尝试写入所有来处理"可写"事件当前在缓冲区中的数据.如果缓冲区之后是空的,那么很好,如果没有,只需再次等待"可写".

"异常"集很少使用 - 它用于具有带外数据的协议,其中数据传输可能被阻塞,而其他数据需要通过.如果您的程序当前无法接受来自"可读"文件描述符的数据(例如,您正在下载,并且磁盘已满),则您不希望将描述符包含在"可读"集中,因为您无法处理该事件并select会立即返回,如果再次调用.如果接收器在"例外"集中包含fd,并且发送者要求其IP栈发送具有"紧急"数据的分组,则接收器然后被唤醒,并且可以决定丢弃未处理的数据并与发送器重新同步. .该telnet协议使用这一点,例如,对于Ctrl-C键的处理.除非您正在设计需要此类功能的协议,否则您可以轻松地将其删除.

强制代码示例:

#include <sys/types.h>
#include <sys/select.h>

#include <unistd.h>

#include <stdbool.h>

static inline int max(int lhs, int rhs) {
    if(lhs > rhs)
        return lhs;
    else
        return rhs;
}

void copy(int from, int to) {
    char buffer[10];
    int readp = 0;
    int writep = 0;
    bool eof = false;
    for(;;) {
        fd_set readfds, writefds;
        FD_ZERO(&readfds);
        FD_ZERO(&writefds);

        int ravail, wavail;
        if(readp < writep) {
            ravail = writep - readp - 1;
            wavail = sizeof buffer - writep;
        }
        else {
            ravail = sizeof buffer - readp;
            wavail = readp - writep;
        }

        if(!eof && ravail)
            FD_SET(from, &readfds);
        if(wavail)
            FD_SET(to, &writefds);
        else if(eof)
            break;
        int rc = select(max(from,to)+1, &readfds, &writefds, NULL, NULL);
        if(rc == -1)
            break;
        if(FD_ISSET(from, &readfds))
        {
            ssize_t nread = read(from, &buffer[readp], ravail);
            if(nread < 1)
                eof = true;
            readp = readp + nread;
        }
        if(FD_ISSET(to, &writefds))
        {
            ssize_t nwritten = write(to, &buffer[writep], wavail);
            if(nwritten < 1)
                break;
            writep = writep + nwritten;
        }
        if(readp == sizeof buffer && writep != 0)
            readp = 0;
        if(writep == sizeof buffer)
            writep = 0;
    }
}

我们尝试读取是否有可用的缓冲区空间,并且读取端没有文件结束或错误,如果缓冲区中有数据,我们会尝试写入; 如果达到文件结尾且缓冲区为空,那么我们就完成了.

这段代码的行为显然不是最理想的(它是示例代码),但是您应该能够看到内核可以接受比读取和写入时要求的更少的内容,在这种情况下,我们只需返回并说"每当你准备好了,而且我们从不读或写,而不会问它是否会阻止.

Answer 2

从同一个手册页:

退出时,将对这些集进行修改,以指示哪些文件描述符实际更改了状态.

因此FD_ISSET(),在传递的集合上使用以选择以确定哪些FD已准备就绪.