Jak mogę spróbować odczytać dane z gniazda z przekroczeniem limitu czasu? Wiem, select, pselect, poll, ma pole limitu czasu, ale ich użycie wyłącza "tcp fast-path" w stosie tcp reno.
Jedyny pomysł, jaki mam, to użycie recv (fd, ..., MSG_DONTWAIT) w pętli
Odpowiedzi:
Możesz użyć funkcji setsockopt, aby ustawić limit czasu dla operacji odbierania:
SO_RCVTIMEO
Ustawia wartość limitu czasu, która określa maksymalny czas, przez jaki funkcja wejściowa oczekuje do zakończenia. Akceptuje strukturę czasu z liczbą sekund i mikrosekund określającą limit czasu oczekiwania na zakończenie operacji wejściowej. Jeśli operacja odbioru została zablokowana przez tak długi czas bez otrzymywania dodatkowych danych, powinna powrócić z częściowym zliczaniem lub errno ustawionym na [EAGAIN] lub [EWOULDBLOCK], jeśli żadne dane nie są odbierane. Wartością domyślną dla tej opcji jest zero, co oznacza, że operacja odbierania nie powinna przekraczać limitu czasu. Ta opcja ma strukturę chronologiczną. Zauważ, że nie wszystkie implementacje pozwalają na ustawienie tej opcji.
// LINUX
struct timeval tv;
tv.tv_sec = timeout_in_seconds;
tv.tv_usec = 0;
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (const char*)&tv, sizeof tv);
// WINDOWS
DWORD timeout = timeout_in_seconds * 1000;
setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof timeout);
// MAC OS X (identical to Linux)
struct timeval tv;
tv.tv_sec = timeout_in_seconds;
tv.tv_usec = 0;
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (const char*)&tv, sizeof tv);
Podobno w systemie Windows należy to zrobić przed wywołaniem bind. Eksperymentalnie potwierdziłem, że można to zrobić przed lub po bindw systemie Linux i OS X.
struct timeval tv;czy oznacza to, że funkcja select () też nie będzie działać? Próbowałem przenieść mój kod select () do systemu Windows i natychmiast przekroczył limit czasu, wygląda na to, że ignoruje wartość, którą ustawiam w timeval.
Oto prosty kod dodający limit czasu do recvfunkcji pollw języku C:
struct pollfd fd;
int ret;
fd.fd = mySocket; // your socket handler
fd.events = POLLIN;
ret = poll(&fd, 1, 1000); // 1 second for timeout
switch (ret) {
case -1:
// Error
break;
case 0:
// Timeout
break;
default:
recv(mySocket,buf,sizeof(buf), 0); // get your data
break;
}
pollbędzie czekał na odebranie co najmniej jednego bajtu lub przekroczenia limitu czasu, podczas gdy podczas wywoływania recvfunkcji będzie czekał na sizeof(buf)bajty, powodując jej ponowne zablokowanie, jeśli ten licznik jeszcze nie nadszedł, ale tym razem bez przekroczenia limitu czasu.
// działa również po operacji wiązania dla WINDOWS
DWORD timeout = timeout_in_seconds * 1000;
setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof timeout);
Zainstaluj moduł obsługi dla SIGALRM, a następnie użyj alarm()lub ualarm()przed zwykłym blokowaniem recv(). Jeśli alarm się recv()włączy, zwróci błąd z errnoustawieniem na EINTR.
LINUX
struct timeval tv;
tv.tv_sec = 30; // 30 Secs Timeout
tv.tv_usec = 0; // Not init'ing this can cause strange errors
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (const char*)&tv,sizeof(struct timeval));WINDOWS
DWORD timeout = SOCKET_READ_TIMEOUT_SEC * 1000;
setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof(timeout));UWAGA : To ustawienie zostało wprowadzone przed bind()wywołaniem funkcji dla prawidłowego uruchomienia