perché select() restituisce sempre 0 dopo il primo timeout

Question

Ho un problema con la funzione select quando ho lavorato su un programma socket Linux. La funzione select ha funzionato bene come dice la pagina man se il client ha collegato il lato server nell'intervallo di tempo configurato dal server. Se si verifica il timeout, la funzione di selezione restituirà 0 per sempre. A quel tempo, eseguo il debug del client e trovo che il client si sia connesso al server. Ma la funzione di selezione restituisce ancora 0. Ho cercato questo problema ma non ne trovai nessuna utile. Qualcuno potrebbe sapere perché selezionare ha fatto così? La mia versione di Linux è RHEL5.4. Grazie per l'aiuto.

Il codice è illustrato di seguito.

static const int maxLog = 10000; 

int main() 
{ 
    int servSock; 
    signal(SIGPIPE, SIG_IGN); 
    if((servSock = socket(AF_INET, SOCK_STREAM, 0)) < 0) 
    { 
     printf("socket create fail\n"); 
     exit(-1); 
    } 
    int val = 1; 
    if(setsockopt(servSock, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val))<0) 
    { 
     DieWithUserMessage("setsockopt error"); 
    } 

    struct sockaddr_in serverAddr; 
    memset(&serverAddr, 0, sizeof(serverAddr)); 
    serverAddr.sin_family = AF_INET; 
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY); 
    serverAddr.sin_port = htons(22000); 

    if(bind(servSock, (struct sockaddr *) &serverAddr, 
       sizeof(serverAddr)) < 0) 
    { 
     printf("socket bind fail\n"); 
     exit(-1); 
    } 

    if(listen(servSock, maxLog) < 0) 
    { 
     printf("listen failed\n"); 
     exit(-1); 
    } 

    fd_set read_set; 
    FD_ZERO(&read_set); 
    FD_SET(servSock, &read_set); 
    int maxfd1 = servSock + 1; 
    std::set<int> fd_readset; 

    for(;;){  
     struct timeval tv; 
     tv.tv_sec = 5; 
     int ret = select(maxfd1, &read_set, NULL, NULL, tv);  
     if(ret == 0) 
      continue; 

     if(ret < 0) 
      DieWithUserMessage("select error"); 

     if(FD_ISSET(servSock, &read_set)) 
     { 
      struct sockaddr_in clntAddr; 
      socklen_t clntAddrlen = sizeof(clntAddr); 
      int clntSock = accept(servSock, (struct sockaddr *) &clntAddr, &clntAddrlen); 
      if(clntSock < 0) 
      { 
       printf("accept failed()"); 
       exit(-1); 
      } 

      maxfd1 = 1 + (servSock>=clntSock? servSock:clntSock); 
      FD_SET(clntSock, &read_set); 
      fd_readset.insert(clntSock); 
     } 

    } 
} 

Answer 1

La funzione 'select()' è frustrante da utilizzare; devi impostare i suoi argomenti ogni volta prima di chiamarlo perché li modifica. Quello che state vedendo è una dimostrazione di cosa succede se non impostate fd_set (s) ogni volta attorno al ciclo.

Answer 2

Devi riempire il tuo FD_SET ad ogni iterazione. Il modo migliore per farlo è mantenere una raccolta dei tuoi FD da qualche parte e mettere quello necessario per la chiamata selezionata in un FD_SET temporaneo.

Se è necessario gestire molti client, potrebbe essere necessario modificare la macro FD_SETSIZE (in /usr/include/sys/select.h).

Felice programmazione di rete :)

Answer 3

Hai già la risposta giusta - ri-init i fd_set s prima di ogni chiamata a select(2).

Vorrei indicarvi un'alternativa migliore: Linux fornisce la funzione epoll(4). Anche se non è standard, è molto più comodo in quanto è necessario configurare gli eventi che si aspettano solo una volta. Il kernel gestisce le tabelle degli eventi descrittori dei file per te, quindi è molto più efficiente. epoll fornisce anche funzionalità edge-triggered, in cui viene segnalato solo un cambiamento di stato su un descrittore.

Per completezza: i BSD forniscono kqueue(2), Solaris dispone di /dev/poll.

Un'altra cosa: il tuo codice ha una ben nota condizione di competizione tra un client e il server. Dai un'occhiata a Stevens UnP: Nonblocking accept.

Answer 4

Lo stesso effetto sembra accadere se non si ripristina la struttura temporale prima di ogni chiamata da selezionare.

Answer 5

Ho lo stesso problema nei miei codici simili. Ho seguito il suggerimento di fare l'inizializzazione ogni volta prima di chiamare select() e funziona. Nei codici in questo caso, il solo fatto di portare le due linee in loop lo farà funzionare.

FD_ZERO(&read_set); 
FD_SET(servSock, &read_set);