Ustawianie limitu czasu na funkcję recv

Question

Odczytuję z gniazda przy użyciu funkcji recv. Mam problem, gdy brak danych do czytania. Mój program się zatrzymuje. Zauważyłem, że mogę ustawić limit czasu przy użyciu funkcji select. Ale wygląda na to, że timeout wpływa na samą funkcję wyboru, a recv, która przechodzi po wybraniu, wciąż czeka w trybie ciągłym.

fd_set set; 
struct timeval timeout; 
FD_ZERO(&set); /* clear the set */ 
FD_SET(s, &set); /* add our file descriptor to the set */ 
timeout.tv_sec = SOCKET_READ_TIMEOUT_SEC; 
timeout.tv_usec = 0; 
int rv = select(s, &set, NULL, NULL, &timeout); 
if((recv_size = recv(s , rx_tmp , bufSize ,0)) == SOCKET_ERROR) 
     { 
     ... 
     } 

Jak poprosić o powrót funkcji po pewnym czasie oczekiwania?

Answer 1

Należy sprawdzić wartość zwracaną select. select powróci 0 wyciszony przypadku wygasł, więc należy sprawdzić błąd i wywołać recv tylko jeśli select powrócił pozytywną wartość:

Po pomyślnym zakończeniu, select() i pselect() zwracają liczbę deskryptorów w trzy zwrócone zbiory deskryptorów (czyli łączna liczba bitów ustawionych w readfds, writefds, exceptfds), które mogą wynosić zero, jeśli limit czasu upłynie zanim wydarzy się coś ciekawego.

int rv = select(s + 1, &set, NULL, NULL, &timeout); 
if (rv == SOCKET_ERROR) 
{ 
    // select error... 
} 
else if (rv == 0) 
{ 
    // timeout, socket does not have anything to read 
} 
else 
{ 
    // socket has something to read 
    recv_size = recv(s, rx_tmp, bufSize, 0); 
    if (recv_size == SOCKET_ERROR) 
    { 
     // read failed... 
    } 
    else if (recv_size == 0) 
    { 
     // peer disconnected... 
    } 
    else 
    { 
     // read successful... 
    } 
} 

Answer 2

użyj makra FD_ISSET(), aby sprawdzić, czy istnieją dane do odczytania. Jeśli zwróci false, nie rób odczytu.

http://linux.die.net/man/3/fd_set

Answer 3

Innym sposobem, aby ustawić limit czasu na samej recv() bez użycia select() jest użycie setsockopt() ustawić SO_RCVTIMEO opcję gniazda za (na platformach, które obsługują).

W Windows, kod wyglądałby następująco:

DWORD timeout = SOCKET_READ_TIMEOUT_SEC * 1000; 
setsockopt(s, SOL_SOCKET, SO_RCVTIMEO, (char*)&timeout, sizeof(timeout)); 

//... 

recv_size = recv(s, rx_tmp, bufSize, 0); 
if (recv_size == SOCKET_ERROR) 
{ 
    if (WSAGetLastError() != WSAETIMEDOUT) 
     //... 
} 

na innych platformach, kod będzie wyglądać tak zamiast:

struct timeval timeout; 
timeout.tv_sec = SOCKET_READ_TIMEOUT_SEC; 
timeout.tv_usec = 0; 
setsockopt(s, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)); 

//... 

recv_size = recv(s, rx_tmp, bufSize, 0); 
if (recv_size == -1) 
{ 
    if ((errno != EAGAIN) && (errno != EWOULDBLOCK)) 
     //... 
}