Linux: czy istnieje odczyt lub odzyskanie z gniazda z przekroczeniem limitu czasu?

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

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.

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;
}

// 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