Linux: est-il lire ou recv de socket par timeout?

Comment puis-je essayer de lire les données de prise par timeout?
Je sais, de sélectionner, de pselect, sondage, a un délai d'attente de champ, mais à l'aide de leur désactive l'option "tcp fast-path" dans tcp reno pile.

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

  • Il existe également une option de l'utilisation de threads 🙂 mais fil des signaux encore nécessaires
InformationsquelleAutor osgx | 2010-05-20
  1. 176

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

    SO_RCVTIMEO

    Définit la valeur de délai d'expiration qui spécifie
    la durée maximale d'une entrée
    la fonction attend jusqu'à la fin. Il
    accepte une structure timeval avec l'
    nombre de secondes et microsecondes
    la spécification de la limite sur combien de temps
    d'attente pour une opération d'entrée à
    complète. Si une opération de réception a
    bloqué pendant autant de temps sans
    la réception de données supplémentaires, il est
    de retour avec un partiel de nombre ou de errno
    réglé sur [EAGAIN] ou [EWOULDBLOCK] si non
    les données sont reçues. La valeur par défaut pour cette
    l'option est égale à zéro, ce qui indique qu'un
    opération de réception ne doit pas le temps.
    Cette option prend une structure timeval.
    Notez que toutes les implémentations
    permettre cette option pour être ensemble.

    //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 l'appel de bind. J'ai vérifier par l'expérience que cela peut être fait avant ou après bind sur Linux et OS X.

    • Oui, il le fera. Merci beaucoup
    • Cette réponse a sauvé mon cul. J'ai été coincé mise en œuvre de cette alambiqué "select" de la merde, sans succès. Cela a fonctionné immédiatement, de manière beaucoup plus simple.
    • Maintenant, c'est pourquoi le délai de windows ne fonctionne pas parce que je suis en utilisant le code pour linux. Merci. Si windows n'est pas à l'aide de struct timeval tv; puis signifie select() ne fonctionnent pas trop? J'ai essayé le portage de mon select() code pour windows et il est juste délais d'attente immédiatement il ressemble à son en ignorant la valeur que je suis en train au timeval.
    • Je définir la valeur du délai de 5 secondes. Pourquoi faut-il toujours prendre 5 secondes pour chaque cycle de lecture quel que soit il y a des données entrantes ou pas?
    • cela fonctionne aussi sur windows, même après l'opération de liaison. essayé sur windows 10
    • cela peut-il conduire à perdre des paquets udp, par exemple, lorsque le délai d'attente juste des coups de pied dans quand un nouveau message est reçu?
    • href="https://stackoverflow.com/a/49776408/1910445">Cette réponse les réclamations, il ne devrait pas.

    InformationsquelleAutor Robert S. Barnes
  2. 20

    Voici un code Simple pour ajouter du temps à votre fonction recv à l'aide de sondage dans 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;
}
    InformationsquelleAutor Abdessamad Doughri
  3. 0

    //fonctionne aussi 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);
    InformationsquelleAutor cahit beyaz
  4. -1

    Installer un gestionnaire pour SIGALRM, puis utilisez alarm() ou ualarm() avant régulière de blocage recv(). Si l'alarme se déclenche, le recv() retournera un message d'erreur avec errno ensemble de EINTR.

    • alarmes et signaux) sont le mauvais sens à cette tâche. Si je veux utiliser le protocole tcp fast path, que j'ai besoin d'une latence minimale. Les signaux sont lents.
    • Le signal se produit uniquement si il y a un délai d'attente.
    InformationsquelleAutor caf
  5. -4

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

    NOTE: Vous avez mis ce paramètre avant de bind() appel de fonction pour la bonne exécution

    • Cette question a déjà été répondu ans. Ce que la nouvelle valeur votre solution apporter?
    • Vous avez mis ce paramètre avant de bind() de l'appel de fonction pour la bonne exécution de la présente partie n'est pas mentionner dans sna
    InformationsquelleAutor vivek