Socket進程處理被中斷的系統調用及Accept函數返回EINTR錯誤處理 （轉）

 

轉自　http://blog.csdn.net/keshacookie/article/details/40717059?utm_source=tuicool

咱們用慢系統調用來描述那些可 能永遠堵塞的系統調用（函數調用），如：accept，read等。永遠堵塞的系統調用是指調用有可能永遠沒法返回，多數網絡支持函數都屬於這一類。例 如，若是沒有客戶鏈接到服務器上，則服務器對accept的調用就沒有返回保證。相似的，若是客戶從未發送過一行要求服務器回射的文本，則服務器對 read的調用將永不返回。其餘慢系統調用的例子是對管道和終端設備的讀寫。有一個例外，就是磁盤IO，他通常都返回調用者。

當一個進程堵塞與慢系統調用時捕獲到一個信號，等到信號處理程序返回時，系統調用可能返回一個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);
    }
}