当前位置：文江博客话题详情

不间断的读/写调用

发布于 2024-09-11 19:29:42 字数 237 浏览 12 评论 0原文

在 Linux 上的 C 编程冒险过程中的某个时刻，我遇到了一些标志（可能是 ioctl/fcntl？），这些标志使文件描述符上的读写操作不间断。

不幸的是，我不记得如何做到这一点，也不记得我在哪里读过它。任何人都可以透露一些信息吗？

Update0

为了优化我的查询，我追求相同的阻塞并保证 fwrite() 和 fread() 提供，无用户空间缓冲。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

把梦留给海 2024-09-18 19:29:42

您可以通过确保所有信号处理程序都使用 SA_RESTART 安装来避免来自 read() 和 write() 的 EINTR > sigaction() 的标志。

然而，这并不能保护您免受短读/写的影响。这只能通过将 read() / write() 放入循环中来实现（除了必须已提供给 的缓冲区之外，它不需要额外的缓冲区） code>read() / write() 调用。）

这样的循环如下所示：

/* If return value is less than `count', then errno == 0 indicates end of file,
 * otherwise errno indicates the error that occurred. */
ssize_t hard_read(int fd, void *buf, size_t count)
{
    ssize_t rv;
    ssize_t total_read = 0;

    while (total_read < count)
    {
        rv = read(fd, (char *)buf + total_read, count - total_read);

        if (rv == 0)
            errno = 0;

        if (rv < 1)
            if (errno == EINTR)
                continue;
            else
                break;

        total_read += rv;
    }

    return rv;
}

You can avoid EINTR from read() and write() by ensuring all your signal handlers are installed with the SA_RESTART flag of sigaction().

However this does not protect you from short reads / writes. This is only possible by putting the read() / write() into a loop (it does not require an additional buffer beyond the one that must already be supplied to the read() / write() call.)

Such a loop would look like:

/* If return value is less than `count', then errno == 0 indicates end of file,
 * otherwise errno indicates the error that occurred. */
ssize_t hard_read(int fd, void *buf, size_t count)
{
    ssize_t rv;
    ssize_t total_read = 0;

    while (total_read < count)
    {
        rv = read(fd, (char *)buf + total_read, count - total_read);

        if (rv == 0)
            errno = 0;

        if (rv < 1)
            if (errno == EINTR)
                continue;
            else
                break;

        total_read += rv;
    }

    return rv;
}

回复收藏 0 原文