Einstellung Timeout zu recv-Funktion

Question

Ich lese vom Sockel mit recv Funktion. Ich habe ein Problem, wenn keine Daten zum Lesen verfügbar sind. Mein Programm hört einfach auf. Ich habe festgestellt, dass ich Timeout mit select Funktion einstellen kann. Aber sieht aus, dass das Timeout sich auf die select Funktion selbst auswirkt und recv das nach dem select immer noch unstetig wartet.

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) 
     { 
     ... 
     } 

Wie recv Funktion Rückkehr nach einigen timout fragen?

Answer 1

Sie sollten Rückgabewert von select überprüfen. select wird 0 bei Timeout Rückkehr abgelaufen ist, so sollten Sie sich für Fehler überprüfen und recv rufen nur, wenn select positiver Wert zurückgegeben:

Bei Erfolg select() und pselect() geben die Anzahl der Datei-Deskriptoren in der enthaltenen drei zurückgegebene Deskriptorsätze (dh die Gesamtzahl der Bits, die in readfds, writefds, exceptfds gesetzt sind), die Null sein können, wenn das Zeitlimit abläuft, bevor etwas Interessantes passiert.

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

Mit dem Makro FD_ISSET() testen, ob Daten zu lesen sind. Wenn sie false zurückgibt, lese nicht.

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

Answer 3

Eine weitere Möglichkeit, einen Timeout auf recv() selbst ohne setzen select() Verwendung ist setsockopt() zu verwenden, um die SO_RCVTIMEO Option der Buchse (auf Plattformen, die es unterstützen) einzustellen.

Unter Windows wird der Code würde wie folgt aussehen:

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) 
     //... 
} 

Auf anderen Plattformen aussehen würde der Code wie diese statt:

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)) 
     //... 
}