Socket进程处理被中断的系统调用及Accept函数返回EINTR错误处理
当一个进程堵塞与慢系统调用时捕获到一个信号,等到信号处理程序返回时,系统调用可能返回一个EINTR错误。有些内核自动重启某些被中断的系统调用。为了便于移植,当我们编写一个捕获信号的程序时(多数并发服务器捕获SIGCHLD),我们必须对慢系统调用返回EINTR有所准备。
为了处理一个被中断的accept,我们对accept的调用尽心了处理,其他慢系统调用函数也可以照此思路进行处理:
第一种方法: 用continue进入for的下一次循环,从而重启被中断的系统调用;
for( ; ; ) { clilen = sizeof(cliaddr); if((connfd = accept(listenfd, (SA *)&cliaddr, &clilen)) < 0) { if(errno == EINTR) continue; else err_sys("accept error"); } }
或者 用goto来实现一样的功能,也同样让被中断的系统调用重启;
Again: for( ; ; ) { clilen = sizeof(cliaddr); if((connfd = accept(listenfd, (SA *)&cliaddr, &clilen)) < 0) { if(errno == EINTR) goto Again; else err_sys("accept error"); } }
另外要说明的是:
适用于慢系统调用的基本规则是:当阻塞于某个慢系统调用的一个进程捕获某个信号切相应信号处理函数返回时,该系统调用可能返回一个EINTR错误;而有些系统内核会自动重启某些被中断的系统调用; 这点要注意;
在这段代码中,我们所做的就是自己重启被中断的系统调用,这对于accept以及其他诸如read,write,select和open这样的函数是合适的,但有一个函数我们不能自己重启:connect。如果这个函数返回INTER,我们就不能再调用他,否则返回错误。当connet被一个捕获的信号中断而且不自动重启时,我们必须调用select来等待连接完成。
最后,当我们编写处理accept返回EINTR错误的TCP服务器最终版本的时候,首先要注意幾個問題:
>>> 当fork子进程时,必须捕获SIGCHLD信号(SIGCHLD信号是子进程结束时,向内核发送的信号)
>>> 当捕获信号时,必须处理被中断的系统调用
>>> SIGCHLD的信号处理函数(sig_chld)必须正确编写,应使用waitpid函数杀死僵死进程;
以下就是 “处理accept函数返回EINTR错误的TCP服务器程序最终版本”:
#include <unp.h> int main(int argc, char **argv) { int listenfd, connfd; pid_t child_pid; socklen_t clilen; struct sockaddr_in cliaddr, servaddr; void sig_chld(int); listenfd = Socket(AF_INET, SOCK_STREAM, 0); bzero(&servaddr, sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_addr.s_addr = htonl(INADDR_ANY); servaddr.sin_port = htons(SERV_PORT); Bind(listenfd, (SA *)&servaddr, sizeof(servaddr)); listen(listenfd, LISTENQ); Signal(SIGCHLD, sig_chld); for( ; ; ) { clilen = sizeof(cliaddr); if( (connfd = accept(listenfd, (SA *)&cliaddr, &clilen)) < 0 ) { if(errno == EINTR) continue; else err_sys("accept error"); } if( (child_pid = Fork()) == 0 ) { Close(listenfd); str_cli(connfd); exit(0); } Close(connfd); } }
最近都忙着看书,好少时间写博客和刷题了~~
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。