socket non bloquant

Version imprimable

socket non bloquant

Tout est dans le titre, j'arrive pas a faire de mon socket, un socket non bloquant, voici le code de la fonction pour recevoir le message du serveur.
La variable readfds etant de type fd_set
La variable socket est de type SOCKET est bien initialisé car j'arrive a recevoir des messages quand j'en envoie
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 int Server::recevoir_message() { message = new char[1024]; int result = 0; FD_ZERO(&readfds); FD_SET(socket,&readfds); select(0,&readfds,0,0,NULL); if(FD_ISSET(socket, &readfds)) { result = recv ( socket, message , 1024 , 0 ) ; } return result; }
Lorsque je lance cette fonction dans une boucle, la boucle se bloque si le serveur aucun message n'est reçu.
Apparemment le bloquage se fait au niveau du select d'apres mes tests.
Si vous pouvez eclairer ma lanterne ca serait sympa ! Merci d'avance.

La socket doit être mis non bloquante après sa déclaration, voici la fonction classique pour le faire qui est utilisé dans beaucoup de tuto et qui a le mérite d'être cross-platform.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
/*----------------------------------------------------------------------
 Portable function to set a socket into nonblocking mode.
 Calling this on a socket causes all future read() and write() calls on
 that socket to do only as much as they can immediately, and return 
 without waiting.
 If no data can be read or written, they return -1 and set errno
 to EAGAIN (or EWOULDBLOCK).
 Thanks to Bjorn Reese for this code.
----------------------------------------------------------------------*/
int setNonblocking(int fd)
{
    int flags;
 
    /* If they have O_NONBLOCK, use the Posix way to do it */
#if defined(O_NONBLOCK)
    /* Fixme: O_NONBLOCK is defined but broken on SunOS 4.1.x and AIX 3.2.5. */
    if (-1 == (flags = fcntl(fd, F_GETFL, 0)))
        flags = 0;
    return fcntl(fd, F_SETFL, flags | O_NONBLOCK);
#else
    /* Otherwise, use the old way of doing it */
    flags = 1;
    return ioctl(fd, FIOBIO, &flags);
#endif
}

12/08/2007, 01h56
loufoque

Normal, la fonction select bloque jusqu'à ce qu'il y ait des données à lire.
12/08/2007, 12h44
albat0r

Oops j'avais même pas lu jusqu'au bout, si tu ne veux pas que select bloc plus d'un certain temps, pour continuer à executer une routine par exemple dans un programme non threadé, tu peux spécifier un timeout à la fonction select.
12/08/2007, 14h00
Mister_Don

Vous auriez un exemple plus au moins complet avec declaration de socket, mise en non bloquant et un timeout pour le select parce que j'ai du mal à visualiser la.

En tout cas merci pour l'aide jusque là.
12/08/2007, 14h40
loufoque

Lis ton manuel unix, ça t'expliquera comment select fonctionne.
12/08/2007, 14h42
Mister_Don

je suis sur windows avec visual C++

Puis j'ai pas besoin qu'on me réponde pour me dire une chose pareil, ca n'a pas d'interet...
12/08/2007, 21h17
albat0r

Les socket du monde windows sont casi identique à celle du monde UNIX, si je me trompe pas windows utiliserai du code BSD pour sa partie réseau ?
J'ai commencé sur les socket avec un exelent tutorial qui est pour moi la référence en la matière, le tutorial de Beej.
12/08/2007, 21h31
millie

Voir également le site d'Emmanuel Delahaye : http://emmanuel-delahaye.developpez.com/reseaux.htm

Je vous remercie pour ces tutoriaux, mais hélas ils ne font que confirmer pourquoi je poste. C'est à dire que je pense que ca devrait marcher mais ca marche pas

voici le code que j'aie a l'initialisation peut etre que le problème vient de la.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 int Server::connection() { tv.tv_sec = 2; tv.tv_usec = 500000; int nonblocking=0; /* ouverture d'un socket de communication */ if ( ( _socket = socket ( AF_INET , SOCK_STREAM , 0 ) ) == -1 ) { return 0; } printf ( "Socket numero %d cree\n" , _socket ) ; ioctlsocket( _socket, FIONBIO, (unsigned long*) &nonblocking); /* Connexion au Serveur */ if ( connect ( _socket , (struct sockaddr*)&(_sockaddr) , sizeof (struct sockaddr_in) ) ) { return 0; } printf ( "Connect OK\n" ) ; return 1; }
Et comme je l'ai dit précedemment, si je recois des messages tout fonctionne le probleme se situe au niveau du select qui ne veut pas etre non bloquant

C'est normal que ça bloque... Select est bloquant sur ton socket...

Sinon, passes en paramètre à select un struct timeval que tu initialises ainsi :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 /*définition dans winsock2.h*/ struct timeval { long tv_sec; long tv_usec; }; /*initialisation*/ struct timeval t; t.tv_sec = 0; t.tv_usec = 0; select(, ...., &t);

12/08/2007, 22h24
Mister_Don

bon, je tiens a m'excuser pour la perte de temps que j'ai pu faire et remercier les personnes qui m'ont aidé.

Mon problème venait que je definissais mon time out mais je ne le mettais pas dans le select ............. :oops: :oops:

Donc voila encore Merci !!!
17/08/2007, 11h41
untipy

bonjour

je suis entrain de faire la meme chose
comme as tu déclaré readfds, svp?
17/08/2007, 11h43
millie
Citation:

Envoyé par untipy

bonjour

je suis entrain de faire la meme chose
comme as tu déclaré readfds, svp?

Il a écrit que c'était de type fd_set :
Donc quelque chose du genre :
Code:

1 2 3 4 5 6 7 fd_set readfs; FD_ZERO(&readfs); //on ajoute les socket à regarder FD_SET(socket, &readfs); ....

voila ! j'ai un truc comme çà:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
 fd_set rfds;
            struct timeval tv;
            int retval;
            FD_ZERO(&rfds);
            FD_SET(sck, &rfds); /* on ajoute la socket a regarder */
            tv.tv_sec = 2;
            tv.tv_usec = 0;
            retval = select(0, &rfds, NULL, NULL, &tv);
 
            if (retval)
            {
                /* infos reçues sur sck dans les 2 secondes*/
                len = read(sck,msg,4096);
}
else{printf"rienr recu");}

mais il détecte jamais rien en entrée du socket

17/08/2007, 14h04
millie

Il faut utiliser FD_ISSET pour savoir si des données sont arrivés sur le socket.

Il faut aussi tester retval avec des chiffres :
-1 = erreur
0 = timeout dépassé
n = nombre de socket (ou de file descriptor) qui a recu des données
17/08/2007, 14h31
untipy

oui vous avez raison :

Code:

if (FD_ISSET(sck, &rfds))

j'avais bien testé çà

merci pour vos conseils !!

je pense que cela vient de la configuration de mon select

Code:

retval = select(0, &rfds,0, 0, &tv);

Qaund le premier parametre est 0, le timer ne fonctionne pas mais lit le socket
Qaund le premier parametre est 1, le timer ne fonctionne mais ne lit le socket

ou alors c'est :

Code:

FD_SET(me->sock, &rfds);

qui n'ajoute pas le descripteur
:? >>:( >> :bug:
17/08/2007, 16h27
untipy

Voila j'ai trouvé mon buf .... oufff
alors petit retour d'expérience si cela peut être utile a d'autres programmeurs ...

je suis sur linux
donc pour faire une socket non bloquant en lecture, il faut configurer la fonction select

Code:

int select( int nfds,fd_set* readfds,fd_set* writefds,fd_set* exceptfds,const struct timeval* timeout );

sachant que nfds : [doit valoir le plus grand identifiant de socket, plus 1 (non utilisé sous Windows).

Code:

int select( socket+1,...)

Le plus 1 est SUPER important, c'était mon bug.
:D
17/08/2007, 17h57
millie

Citation:

Envoyé par untipy

Le plus 1 est SUPER important, c'était mon bug.
:D

Oui, j'avais oublié de signalé ce détail :roll: