socket编程中的EINTR是什么?

socket编程中的EINTR是什么?

在socket编程中，我们时常在accept/read/write等接口调用的异常处理的部分看到对于EINTR的处理，例如下面这样的语句：

repeat:
if(read(fd, buff, size) < 0)
{if(errno == EINTR)goto repeat;elseprintf("read failed");
}

那么EINTR是什么呢？为什么要对它进行处理呢？ 本文将对EINTR做一些讨论。

慢系统调用

如果想要解释EINTR，首先得对慢系统调用有个了解。

慢系统调用(slow system call)指不会立即返回的系统调用, 可能永远阻塞而无法返回。 例如支持网络的调用, 包括read/write, connect, accept等, 都属于这一类。

慢系统调用, 主要分为以下类别:

  • 读写"慢"设备。 包括pipe, fifo, 终端设备, 网络连接等. 读时, 数据不存在, 需要等待缓冲区有数据输入; 写时, 缓冲区满, 需要等待缓冲区有空闲位置。注意: 读写磁盘文件一般不会阻塞， 网络磁盘除外。
  • 打开某些特殊文件时, 需要等待某些条件才能打开。如打开终端设备, 需要等待连接设备的modern响应, 才能打开
  • pause和wait系统调用。
    • pause阻塞进程, 直到收到信号唤醒;
    • wait等待任意子进程终止;
  • 某些ioctl操作
  • 某些IPC操作。如pipe, fifo, 没有指定NON_BLOCKING选项时的写操作, 如果管道缓冲区满, write阻塞;互斥锁, 条件变量, 信号量, 记录锁等等.

慢系统调用与EINTR

如果进程在一个慢系统调用(slow system call)中阻塞时，当捕获到某个信号且相应信号处理函数返回时，这个系统调用被中断，调用返回错误，设置errno为EINTR（相应的错误描述为"Interrupted system call"）。

因此EINTR错误的产生是慢系统调用和信号处理函数组合使用会产生的问题。

回过头来再看开头所提到的这一段的代码，其含义是当程序通过read读取数据，当目前fd对应的缓冲区没有数据可读时，进程将被阻塞。此时如果向该进程发送了信号，那么read函数将会返回-1，并且此时errno为EINTR，代表read方法被中断了。对于这样的情况，我们就需要人为的对read进行"重启"， 即重新的进行read。

repeat:
if(read(fd, buff, size) < 0)
{if(errno == EINTR)goto repeat;elseprintf("read failed");
}

到此，我们了解到了EINTR的产生原因，下面将介绍如何处理EINTR，以避免一些不必要的系统问题。

如何避免EINTR带来的问题。

既然系统调用会被中断，那么就需要处理被中断的系统调用。

  • 人为重启被中断的系统调用
  • 安装信号时设置 SA_RESTART属性（该方法对有的系统调用无效）

其实人为重启被中断的系统调用，上面已经提到过了

repeat:
if(read(fd, buff, size) < 0)
{if(errno == EINTR)goto repeat;elseprintf("read failed");
}

这里着重来看一下第二种方法，为信号处理函数设置SA_RESTART。

下面是一个使用socket编程所建立的一个TCP server，进程在没有连接进入的时候将会卡在accept调用上。 同时，对于该进程，安装了SIGINT的信号处理函数，并且为该信号设置了SA_RESTART的属性。

//g++ main.cpp -o main
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>
#include <sys/socket.h>
#include <unistd.h>
#define PORT 8080
void  handler_func(int sig){printf("test\n");
}
int main(int argc, char const* argv[])
{int server_fd, new_socket;ssize_t valread;struct sockaddr_in address;int opt = 1;socklen_t addrlen = sizeof(address);char buffer[1024] = { 0 };char* hello = "Hello from server";struct sigaction action;action.sa_handler = handler_func;sigemptyset(&action.sa_mask);action.sa_flags = 0;/* 设置SA_RESTART属性 */action.sa_flags |= SA_RESTART;sigaction(SIGINT, &action, NULL);// Creating socket file descriptorif ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {perror("socket failed");exit(EXIT_FAILURE);}// Forcefully attaching socket to the port 8080if (setsockopt(server_fd, SOL_SOCKET,SO_REUSEADDR | SO_REUSEPORT, &opt,sizeof(opt))) {perror("setsockopt");exit(EXIT_FAILURE);}address.sin_family = AF_INET;address.sin_addr.s_addr = INADDR_ANY;address.sin_port = htons(PORT);// Forcefully attaching socket to the port 8080if (bind(server_fd, (struct sockaddr*)&address,sizeof(address))< 0) {perror("bind failed");exit(EXIT_FAILURE);}if (listen(server_fd, 3) < 0) {perror("listen");exit(EXIT_FAILURE);}if ((new_socket= accept(server_fd, (struct sockaddr*)&address,&addrlen))< 0) {perror("accept");exit(EXIT_FAILURE);}valread = read(new_socket, buffer,1024 - 1); // subtract 1 for the null// terminator at the endprintf("%s\n", buffer);send(new_socket, hello, strlen(hello), 0);printf("Hello message sent\n");// closing the connected socketclose(new_socket);// closing the listening socketclose(server_fd);return 0;
}

程序运行后，使用ctrl+c 向进程发送SIGINT信号，可以看到程序输出了test的打印，但是程序仍然阻塞在了accept的系统调用上，等待客户端连接。

[root@localhost test1]# ./main
^Ctest
^Ctest
^Ctest
^Ctest
^Ctest

如果没有添加SA_RESTART这样的flag， 那么发送SIGINT给进程的话，accept就会报这样的错误，就需要手动进行处理。

[root@localhost test1]# ./main
^Ctest
accept: Interrupted system call

但是要注意的是SA_RESTART并不能解决所有的问题。

下面的这些场景当设置了SA_RESTART后，如果信号处理函数返回之后，系统调用可以自行恢复：

  • read/readv/write/writev/ioctl在"慢设备"上的调用。所谓慢设备，就是在该设备上执行I/O调用时可能会造成无限时间的阻塞的一类设备， 例如管道，socket,终端。 需要注意的是，本地磁盘不属于慢设备，但是网络磁盘属于慢设备。
  • open， 例如open一个FIFO。
  • wait系列的方法，例如：wait(2), wait3(2), wait4(2), waitid(2), and waitpid(2).
  • 没有设置超时参数的socket的操作接口。 accept(2), connect(2), recv(2), recvfrom(2), recvmmsg(2), recvmsg(2), send(2), sendto(2), and sendmsg(2).
  • 文件锁接口： flock(2)， fcntl(2)进行F_OFD_SETLKW F_SETLKW操作。
  • POSIX消息队列: mq_receive(3), mq_timedreceive(3), mq_send(3), mq_timedsend(3).
  • futex(2) FUTEX_WAIT。 2.6.22版本之前， 信号处理函数返回时，futex总是返回EINTR，SA_RESTART无效。
  • getrandom(2).
  • pthread_mutex_lock(3), pthread_cond_wait(3)
  • futex(2) FUTEX_WAIT_BITSET.
  • POSIX 信号量的接口 sem_wait(3) and sem_timedwait(3)。 2.6.22版本之前， 信号处理函数返回时，信号量的接口总是返回EINTR，SA_RESTART无效。
  • read(2) 方法操作由 inotify(7)方法返回的文件描述符 (3.8版本之前， 信号处理函数返回时，总是返回EINTR，SA_RESTART无效。).

下面这些场景，即使使用了SA_RESTART，当系统调用被信号处理函数中断后，仍然会返回EINTR：

  • 设置了超过时间的socket的输入接口。使用setsockopt方法的SO_RCVTIMEO参数可以设置timeout时间。accept(2), recv(2), recvfrom(2)，recvmmsg(2) recvmsg(2).
  • 设置了超过时间的socket的输出接口。使用setsockopt方法的SO_SNDTIMEO参数可以设置timeout时间。connect(2), send(2), sendto(2), sendmsg(2).
  • 等待信号的接口，例如: pause(2), sigsuspend(2), sigtimedwait(2), and sigwaitinfo(2).
  • 多路复用的接口，例如： epoll_wait(2), epoll_pwait(2), poll(2), ppoll(2), select(2), and pselect(2).
  • System V的IPC interface， 例如：msgrcv(2), msgsnd(2), semop(2), 和semtimedop(2).
  • sleep的接口， 例如: clock_nanosleep(2), nanosleep(2), and usleep(3).
  • io_getevents(2).

还有一个比较特殊的是sleep(3)方法，其被信号处理函数打断后并不会返回返回EINTR， 而是将剩下需要sleep的时间作为返回值返回。

在整理资料时，我发现Linux man的界面还存在一个描述问题：

EINTR

对于Output socket接口的描述中， when a timeout (SO_RCVTIMEO) has been set on the socket 描述并不正确。此时描述的是output相关的接口，因此应该是when a timeout (SO_SNDTIMEO) has been set on the socket。 下面的if a send timeout (SO_SNDTIMEO) has been set描述正确了，但是感觉又有点重复。

从上面的描述中我们知道， SO_RESTART并不是万能的，对于一些接口而言，仍然需要添加对EINTR的处理。 因此对于EINTR的处理需要组合上面两种方法。

总结

  • EINTR错误的产生是慢系统调用和信号处理函数组合使用会产生的问题。
  • 对于EINTR错误，安装信号处理函数时设置SA_RESTART可以解决很多系统调用被终端的问题。但是对于一些可以设置超时参数的API，即使设置SA_RESTART，仍然有可能收到EINTR错误。因此组合使用SA_RESTART和人为重启系统调用。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/136960.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

三菱FX3U系列-定位指令

三菱FX3U系列-定位指令

目录 一、简介 二、指令形式 1、相对定位[DRVI、DDRVI] 2、绝对定位[DRVA、DDRVA] 三、总结 一、简介 定位指令用于控制伺服电机或步进电机的位置移动。可以通过改变脉冲频率和脉冲数量来控制电机的移动速度和移动距离&#xff0c;同时还可以指定移动的方向。 二、指令形…
阅读更多...
Linux下的环境变量【详解】

Linux下的环境变量【详解】

Linux下的环境变量 一&#xff0c;环境变量的概念1 概述2 环境变量的分类3 常见的环境变量4 查看环境变量4.1 shell变量4.2 查看环境变量 5 添加和删除环境变量5.1 添加环境变量5.2 删除环境变量 6. 通过代码如何获取环境变量6.1 命令行的第三个参数6.2 通过第三方变量environ获…
阅读更多...
Linux 的热插拔机制通过 Udev(用户空间设备)实现、守护进程

Linux 的热插拔机制通过 Udev(用户空间设备)实现、守护进程

一、Udev作用概述 udev机制简介udev工作流程图 二、Linux的热拔插UDEV机制 三、守护进程 守护进程概念守护进程在后台运行基本特点 四、守护进程和后台进程的区别 一、Udev作用概述 udev机制简介 Udev&#xff08;用户空间设备&#xff09;是一个 Linux 系统中用于动态管…
阅读更多...
微信号绑定50个开发者小程序以后超额如何删除不用的

微信号绑定50个开发者小程序以后超额如何删除不用的

我们在开发微信小程序的时候&#xff0c;当前开发者工具登录的必须是该小程序的开发者才能进行小程序的开发&#xff0c;添加开发者的步骤是&#xff1a; 添加开发者 1、进入微信开放平台&#xff0c;然后扫码进入管理平台 2、找到下图所示位置 3:、输入要添加的微信账号&am…
阅读更多...
LCD英文字模库（16x8）模拟测试程序

LCD英文字模库（16x8）模拟测试程序

字模 字模&#xff0c;就是把文字符号转换为LCD能识别的像素点阵信息。 电子发烧友可能都熟悉字模的用途。就是调用者通过向LCD模块发送字模数据&#xff0c;LCD根据字模数据在LCD面板上相应的像素描绘出图形或文字。 现在&#xff0c;大部分的LCD都内置了字模库&#xff0c…
阅读更多...
11-09 周四 CNN 卷积神经网络基础知识

11-09 周四 CNN 卷积神经网络基础知识

11-09 周四 CNN 卷积神经网络 时间版本修改人描述2023年11月9日09:38:12V0.1宋全恒新建文档 简介 学习一下CNN&#xff0c;卷积神经网络。使用的视频课程。视觉相关的任务&#xff1a; 人脸识别 卷积网络与传统网络的区别&#xff1a; <img altimage-20231109094400591 s…
阅读更多...
电脑怎么录制视频，录制的视频怎么剪辑？

电脑怎么录制视频，录制的视频怎么剪辑？

在现今数字化的时代&#xff0c;视频成为了人们日常生活中不可或缺的一部分。因此&#xff0c;对于一些需要制作视频教程、录制游戏或者是进行视频演示的人来说&#xff0c;电脑录屏已经成为了一个必不可少的工具。那么&#xff0c;对于这些人来说&#xff0c;如何选择一个好用…
阅读更多...
Zigbee—网络层地址分配机制

Zigbee—网络层地址分配机制

&#x1f3ac;慕斯主页&#xff1a;修仙—别有洞天 ♈️今日夜电波&#xff1a;孤雏 0:21━━━━━━️&#x1f49f;──────── 4:14 &#x1f504; ◀️ ⏸ ▶️ ☰ &#x1f497;关注…
阅读更多...
大厂面试题-MySQL中的RR隔离级别，到底有没有解决幻读问题？

大厂面试题-MySQL中的RR隔离级别，到底有没有解决幻读问题？

就MySQL中的RR(Repeatable Reads)事务隔离级别&#xff0c;到底有没有解决幻读问题发起了激烈的讨论。 一部分人说有&#xff0c;一部分人说没有。 结论&#xff0c;MySQL中的RR事务隔离级别&#xff0c;在特定的情况下会出现幻读的问题。 所谓的幻读&#xff0c;表示在同一…
阅读更多...
景联文科技加入中国人工智能产业发展联盟（AIIA），与行业各方共促AI产业发展

景联文科技加入中国人工智能产业发展联盟（AIIA），与行业各方共促AI产业发展

近日&#xff0c;景联文科技加入中国人工智能产业发展联盟&#xff08;AIIA&#xff09;&#xff0c;与行业各方共同挖掘人工智能数据的更多价值&#xff0c;破解中国人工智能AI数据短缺难题。 中国人工智能产业发展联盟&#xff08;简称AIIA&#xff09;是在国家发改委、科技部…
阅读更多...
GIS入门，xyz地图瓦片是什么，xyz数据格式详解，如何发布离线XYZ瓦片到nginx或者tomcat中

GIS入门，xyz地图瓦片是什么，xyz数据格式详解，如何发布离线XYZ瓦片到nginx或者tomcat中

XYZ介绍 XYZ瓦片是一种在线地图数据格式，由goole公司开发。 与其他瓦片地图类似，XYZ瓦片将地图数据分解为一系列小的图像块，以提高地图显示效率和性能。 XYZ瓦片提供了一种开放的地图平台，使开发者可以轻松地将地图集成到自己的应用程序中。同时，它还提供了高分辨率图像和…
阅读更多...
红海云签约和兆服饰，科技引领服饰行业人力资源数字化转型

红海云签约和兆服饰，科技引领服饰行业人力资源数字化转型

和兆服饰从事多品牌多品类经营管理&#xff0c;旗下拥有POLOSPORT、POLOKIDS、CARTELO等国际品牌。作为一个主打POLO文化的服饰品牌&#xff0c;诞生于美国的POLOSPORT拥有现代感的产品设计、系列化的产品搭配、全方位的服务&#xff0c;是最具美国马球精神的休闲时尚服饰品牌之…
阅读更多...
攻防世界题目练习——Web引导模式（四）（持续更新）

攻防世界题目练习——Web引导模式（四）（持续更新）

题目目录 1. shrine2. very_easy_sql3. fakebook 1. shrine 打开网页题目内容如下&#xff1a; 是一段代码&#xff0c;我们把它还原一下&#xff1a; import flask import osapp flask.Flask(__name__) app.config[FLAG] os.environ.pop(FLAG) #这里应该是将config配置里…
阅读更多...
【Docker】设置容器系统字符集zh_CN.UTF-8退出失效：关于Docker容器配置环境变量，再次进入失效问题

【Docker】设置容器系统字符集zh_CN.UTF-8退出失效：关于Docker容器配置环境变量，再次进入失效问题

设置容器系统字符集zh_CN.UTF-8退出失效&#xff1a;关于Docker容器配置环境变量&#xff0c;再次进入失效问题 修改正在运行的Docker容器内的字符集: 先进入Docker容器&#xff1a;docker exec -it 容器ID /bin/bash查看是否支持中文字符集&#xff1a;locale -a | grep zh&a…
阅读更多...
PCIe寄存器之二

PCIe寄存器之二

关键字索引&#xff1a; CAP_PM 对应&#xff1a;Capabilities: [c0] Power Management CAP_MSI 对应&#xff1a;Capabilities: [c8] MSI CAP_MSIX对应&#xff1a;Capabilities: [e0] MSI-X CAP_EXP 对应&#xff1a;Capabilities: [70] Express (v2) Endpoint 以上 [] 内的…
阅读更多...
uni-app前端H5页面底部内容被tabbar遮挡

uni-app前端H5页面底部内容被tabbar遮挡

问题&#xff1a; 在用uniapp写小程序的时候&#xff0c;底部有一部分内容没显示出来&#xff0c;被底部的tabbar遮挡住了 解决&#xff1a; 给最外部的view设置样式padding-bottom: var(--window-bottom)&#xff0c;如下 参考&#xff1a; 参考1 参考2 使用 uni-app 框…
阅读更多...
推送效率低？MobPush带着APP消息推送一站式解决方案来了

推送效率低？MobPush带着APP消息推送一站式解决方案来了

随着移动应用竞争的日趋激烈&#xff0c;如何拉新促活&#xff0c;保持用户粘性成为各大APP的运营的焦点和核心。作为一种有效的营销和用户保留工具。APP消息推送可以有效提高用户参与度&#xff0c;增强用户忠诚度&#xff0c;并最终提高业务效益。然而随着各大APP推送的高度同…
阅读更多...
UML与PlantUML简介

UML与PlantUML简介

UML与PlantUML 1、UML与PlantUML概述2、PlantUML使用 1、UML与PlantUML概述 UML&#xff08;Unified Modeling Language&#xff09;是一种统一建模语言&#xff0c;为面向对象开发系统的产品进行说明、可视化、和编制文档的一种标准语言&#xff0c;独立于任何具体程序设计语言…
阅读更多...
YOLOv8-Seg改进： 分割小目标系列篇 | SPD-Conv，提升分割小目标和弱小分割图精度

YOLOv8-Seg改进： 分割小目标系列篇 | SPD-Conv，提升分割小目标和弱小分割图精度

🚀🚀🚀本文改进：SPD-Conv由一个空间到深度(SPD)层和一个无卷积步长(Conv)层组成，可以应用于大多数CNN体系结构，特别是在处理低分辨率图像和分割小目标等更困难的任务时。 🚀🚀🚀SPD-Conv 分割小目标检测首选，暴力涨点 🚀🚀🚀YOLOv8-seg创新专栏：http:…
阅读更多...
什么是Node.js的NVM（Node Version Manager）？它的作用是什么？

什么是Node.js的NVM（Node Version Manager）？它的作用是什么？

聚沙成塔每天进步一点点 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 欢迎来到前端入门之旅&#xff01;感兴趣的可以订阅本专栏哦&#xff01;这个专栏是为那些对Web开发感兴趣、刚刚踏入前端领域的朋友们量身打造的。无论你是完全的新手还是有一些基础的开发…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023