Linux select() 不阻塞
Linux select() not blocking
我试图更好地理解 select() 和 poll() 之间的区别。为此,我尝试实现一个简单的程序,该程序将以只写方式打开文件,将其文件描述符添加到读取集,然后执行 select 希望该函数将阻塞,直到授予读取权限。
由于这不起作用(据我所知,这是预期的行为),我试图在 select() 执行之前使用 flock 阻止对文件的访问。尽管如此,程序并没有阻止它的执行。
我的示例代码如下:
#include <stdio.h>
#include <poll.h>
#include <sys/file.h>
#include <errno.h>
#include <sys/select.h>
int main(int argc, char **argv)
{
printf("[+] Select minimal example\n");
int max_number_fds = FOPEN_MAX;
int select_return;
int cnt_pollfds;
struct pollfd pfds_array[max_number_fds];
struct pollfd *pfds = pfds_array;
fd_set fds;
int fd_file = open("./poll_text.txt", O_WRONLY);
struct timeval tv;
tv.tv_sec = 10;
tv.tv_usec = 0;
printf("\t[+] Textfile fd: %d\n", fd_file);
//create and set fds set
FD_ZERO(&fds);
FD_SET(fd_file, &fds);
printf("[+] Locking file descriptor!\n");
if(flock(fd_file,LOCK_EX) == -1)
{
int error_nr = errno;
printf("\t[+] Errno: %d\n", error_nr);
}
printf("[+] Executing select()\n");
select_return = select(fd_file+1, &fds, NULL, NULL, &tv);
if(select_return == -1){
int error_nr = errno;
printf("[+] Select Errno: %d\n", error_nr);
}
printf("[+] Select return: %d\n", select_return);
}
任何人都可以看到我在这段代码中的错误吗?另外:我首先尝试在将两个 FD 添加到读取列表的情况下执行此代码。当试图锁定它们时,我不得不使用 flock(fd_file,LOCK_SH) 因为我不能用 LOCK_EX 专门锁定两个 FD。如何锁定同一文件的两个 FD(与仅锁定一个 fd 相比)是否存在差异
我也不确定为什么 select 在添加到读取集的文件以只写方式打开时不会阻塞。该程序永远不能(没有权限更改)从 fd 读取数据,所以根据我的理解 select 应该阻止执行,对吧?
作为澄清:我的 "problem" 我想解决的是我必须检查我是否能够用 poll() 替换现有的 select() 调用(存在于: 我不会重写 select() 调用代码,但可以访问 select.) 的参数。为了检查这一点,我想实施一个强制 select 阻止其执行的测试,这样我可以稍后检查 poll 是否会以相同的方式运行(当给出类似的指令时,即要检查相同的 FD)。
所以我的 "workflow" 将是:为不同的 select 行为(即阻止和不阻止)编写测试,为轮询编写类似的测试(也是阻止,而不是阻止)并检查 if/how poll 可以强制执行 select 正在做的事情。
感谢您的任何提示!
当select
告诉您文件描述符已准备好读取时,这并不一定意味着您可以读取数据。这仅意味着 read
调用不会阻塞。当 return 出现 EOF 或错误情况时,read
调用也不会阻塞。
在你的情况下,我希望 read
将立即 return -1 并将 errno
设置为 EBADF
(fd 不是有效的文件描述符或未打开阅读)或者 EINVAL
(fd 附加到不适合阅读的对象...)
编辑:评论中要求的附加信息:
如果需要花费一些时间的物理操作,例如,文件可以处于阻塞状态。如果读取缓冲区为空并且必须从磁盘读取(新)数据,如果文件连接到终端并且用户尚未输入任何(更多)数据,或者如果文件是套接字或管道并且read
必须等待(新)数据到达...
同样适用于write
:如果发送缓冲区已满,write
将阻塞。如果发送缓冲区中剩余的space小于您的数据量,它可能只写入当前适合缓冲区的部分。
如果您将文件设置为非阻塞模式,read
或 write
不会阻塞,但会告诉您它 会 阻塞。
如果出于测试目的而想要阻塞情况,则需要控制提供或使用数据的进程或硬件。我建议在不输入任何数据时从终端 (stdin
) 使用 read
,或者在写入过程不写入任何数据的管道中使用 read
。您还可以在读取进程不从中读取时填充管道上的写入缓冲区。
我试图更好地理解 select() 和 poll() 之间的区别。为此,我尝试实现一个简单的程序,该程序将以只写方式打开文件,将其文件描述符添加到读取集,然后执行 select 希望该函数将阻塞,直到授予读取权限。 由于这不起作用(据我所知,这是预期的行为),我试图在 select() 执行之前使用 flock 阻止对文件的访问。尽管如此,程序并没有阻止它的执行。
我的示例代码如下:
#include <stdio.h>
#include <poll.h>
#include <sys/file.h>
#include <errno.h>
#include <sys/select.h>
int main(int argc, char **argv)
{
printf("[+] Select minimal example\n");
int max_number_fds = FOPEN_MAX;
int select_return;
int cnt_pollfds;
struct pollfd pfds_array[max_number_fds];
struct pollfd *pfds = pfds_array;
fd_set fds;
int fd_file = open("./poll_text.txt", O_WRONLY);
struct timeval tv;
tv.tv_sec = 10;
tv.tv_usec = 0;
printf("\t[+] Textfile fd: %d\n", fd_file);
//create and set fds set
FD_ZERO(&fds);
FD_SET(fd_file, &fds);
printf("[+] Locking file descriptor!\n");
if(flock(fd_file,LOCK_EX) == -1)
{
int error_nr = errno;
printf("\t[+] Errno: %d\n", error_nr);
}
printf("[+] Executing select()\n");
select_return = select(fd_file+1, &fds, NULL, NULL, &tv);
if(select_return == -1){
int error_nr = errno;
printf("[+] Select Errno: %d\n", error_nr);
}
printf("[+] Select return: %d\n", select_return);
}
任何人都可以看到我在这段代码中的错误吗?另外:我首先尝试在将两个 FD 添加到读取列表的情况下执行此代码。当试图锁定它们时,我不得不使用 flock(fd_file,LOCK_SH) 因为我不能用 LOCK_EX 专门锁定两个 FD。如何锁定同一文件的两个 FD(与仅锁定一个 fd 相比)是否存在差异
我也不确定为什么 select 在添加到读取集的文件以只写方式打开时不会阻塞。该程序永远不能(没有权限更改)从 fd 读取数据,所以根据我的理解 select 应该阻止执行,对吧?
作为澄清:我的 "problem" 我想解决的是我必须检查我是否能够用 poll() 替换现有的 select() 调用(存在于: 我不会重写 select() 调用代码,但可以访问 select.) 的参数。为了检查这一点,我想实施一个强制 select 阻止其执行的测试,这样我可以稍后检查 poll 是否会以相同的方式运行(当给出类似的指令时,即要检查相同的 FD)。
所以我的 "workflow" 将是:为不同的 select 行为(即阻止和不阻止)编写测试,为轮询编写类似的测试(也是阻止,而不是阻止)并检查 if/how poll 可以强制执行 select 正在做的事情。
感谢您的任何提示!
当select
告诉您文件描述符已准备好读取时,这并不一定意味着您可以读取数据。这仅意味着 read
调用不会阻塞。当 return 出现 EOF 或错误情况时,read
调用也不会阻塞。
在你的情况下,我希望 read
将立即 return -1 并将 errno
设置为 EBADF
(fd 不是有效的文件描述符或未打开阅读)或者 EINVAL
(fd 附加到不适合阅读的对象...)
编辑:评论中要求的附加信息:
如果需要花费一些时间的物理操作,例如,文件可以处于阻塞状态。如果读取缓冲区为空并且必须从磁盘读取(新)数据,如果文件连接到终端并且用户尚未输入任何(更多)数据,或者如果文件是套接字或管道并且read
必须等待(新)数据到达...
同样适用于write
:如果发送缓冲区已满,write
将阻塞。如果发送缓冲区中剩余的space小于您的数据量,它可能只写入当前适合缓冲区的部分。
如果您将文件设置为非阻塞模式,read
或 write
不会阻塞,但会告诉您它 会 阻塞。
如果出于测试目的而想要阻塞情况,则需要控制提供或使用数据的进程或硬件。我建议在不输入任何数据时从终端 (stdin
) 使用 read
,或者在写入过程不写入任何数据的管道中使用 read
。您还可以在读取进程不从中读取时填充管道上的写入缓冲区。