Linux: y a-t-il une lecture ou une recv depuis le socket avec timeout?

Comment puis-je essayer de lire les données du socket avec timeout? Je sais, select, pselect, poll, a un champ timeout, mais leur utilisation désactive "tcp fast-path" dans la pile tcp reno.

La seule idée que j'ai est d'utiliser recv (fd, ..., MSG_DONTWAIT) dans une boucle

Vous pouvez utiliser la fonction setsockopt pour définir un délai sur les opérations de réception:

SO_RCVTIMEO

Définit la valeur du délai d'expiration qui spécifie la durée maximale pendant laquelle une fonction d'entrée attend jusqu'à ce qu'elle se termine. Il accepte une structure timeval avec le nombre de secondes et de microsecondes spécifiant la limite de la durée d'attente d'une opération d'entrée pour se terminer. Si une opération de réception s'est bloquée pendant autant de temps sans recevoir de données supplémentaires, elle doit retourner avec un décompte partiel ou un numéro d'erreur mis à [EAGAIN] ou [EWOULDBLOCK] si aucune donnée n'est reçue. La valeur par défaut de cette option est zéro, ce qui indique qu'une opération de réception ne doit pas expirer. Cette option prend une structure timeval. Notez que toutes les implémentations ne permettent pas de définir cette option.

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

Apparemment, sur Windows, cela devrait être fait avant d'appeler bind. J'ai vérifié par expérience que cela pouvait être fait avant ou après bindsous Linux et OS X.

Voici un code simple pour ajouter un délai à votre recvfonction en utilisant pollen 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;
}

// fonctionne également après l'opération de liaison pour WINDOWS

DWORD timeout = timeout_in_seconds * 1000;
setsockopt(socket, SOL_SOCKET, SO_RCVTIMEO, (const char*)&timeout, sizeof timeout);

Installez un gestionnaire pour SIGALRM, puis utilisez alarm()ou ualarm()avant un blocage normal recv(). Si l'alarme se déclenche, le recv()renverra une erreur avec errnola valeur 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));

LES FENÊTRES

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

REMARQUE : vous avez mis ce paramètre avant bind()l'appel de fonction pour une exécution correcte