Probleme de select()

Probleme de select() - C++ - Programmation

Marsh Posté le 20-05-2004 à 16:13:59    

Bonjous,  
ben voila je voudrait utiliser un select avec un recv mais qu'and j'envoi sur mon serveur le select qui gere la reception me renvoi TTT 0.donc po de lecture sur ma socket.  
je voudrais savoir si je m'y prend bien pour mon select:  
 

Code :
  1. SOCKET sockclient;
  2. ioctlsocket(sockclient,FIONBIO,(unsigned long *)1);
  3. for (;;)
  4. {
  5.          FD_ZERO(&fdread);
  6.          FD_SET(sockclient,&fdread);
  8. if (ret =select(0,&fdread,NULL,NULL,&seltimeout)==SOCKET_ERROR)cout<<"select error"<<endl
  9.      
  10.      if (ret!=0)cout  <<"La valeur de ret select :"<<ret<<endl;
  11.    
  12.       if (ret > 0)
  13.         {
  14.                    if (FD_ISSET(sockclient,&fdread))
  15.             {
  17.                if ( recv(sockclient,buf,16,0)==-1)cout <<"reception   ECHEC:!"<<endl;
  18.                  
  19.               }
  21.          }
  22. }


 

Reply

Marsh Posté le 20-05-2004 à 16:13:59   

Reply

Marsh Posté le 20-05-2004 à 16:44:55    

Tu devrais faire un WSAGetLastError() pour vérifier précisement d'ou vient le problème...
 
si le code de retour est 0, c'est ton timeout qui expire et qui n'est sans doute pas correctement defini...
 
Sinon je suis pas sur, mais tu as rendu ta socket non bloquante non ? c'est peut etre ca le problème...


---------------
- Pierre Baudelet -
Reply

Marsh Posté le 20-05-2004 à 18:50:53    

non ya po du tou d'ereur avec getlast error
enfet select renvoi zero , si yavaait erreu y renverer socket error  
sa ve dire qu ya zero socket en reception pourtan quand je conect un client avec le select du conect  renvoit 1 donc sa marche mais quant je fait le send  
via le client le select du recv ne renvoi po de socket en cour de lecture donc 0 tous le temp je compren po....
ps :avec ou sans time out sa marche po  
 bon je lache le code complet:
 

Code :
  1. int main()
  2. {
  3. WSADATA WSAData;
  4. WSAStartup(MAKEWORD(2,0), &WSAData);
  8. int NbrClient = 0 ;
  9. SOCKET sockclient = 0;
  10. SOCKET con;
  11. SOCKADDR_IN client;
  12. SOCKADDR_IN conect;
  14. int ret=0;
  15. unsigned long ul = 1;
  16. int retSelect=0;
  17. int clen =sizeof(client);
  18. int flen =sizeof(conect);
  21. con=socket(AF_INET,SOCK_STREAM,0);
  23. conect.sin_addr.s_addr   = htonl(INADDR_ANY);
  24. conect.sin_family   = AF_INET;
  25. conect.sin_port    = htons(4148);
  26. bind(con, (SOCKADDR *)&conect, sizeof(conect));
  27. //----------------------------------------------------
  29. fd_set fdread;
  30. char *buf=new char [16];
  31. struct timeval seltimeout;
  32. DWORD  RecvSend;
  33. seltimeout.tv_usec= 10;
  34. seltimeout.tv_sec=21;
  43. //--------------ger e les conection sur le acept
  44.   listen(con, 0);
  46.   while (true)
  47.   {
  48.      FD_ZERO(&fdread);                 //met le set a 0
  49.      FD_SET(con, &fdread);
  51.      int ret = select(0, &fdread, 0, 0, 0);
  52.      if (ret >0)
  53.         {
  54.         cout << "valeur du acept :"<< ret<<endl;
  55.   sockclient = accept(con, (SOCKADDR *)&client,&clen ) ;
  56.   ret = ioctlsocket(sockclient,FIONBIO,(unsigned long *)1);
  57.     if (ret == SOCKET_ERROR)cout <<"Impossible de passer en nomblocking mode....!"<<endl;
  58.    else {cout << "NOMBLOCKING ACTIVED SOCKET"<<endl;cout <<"::"<<ret<<endl; }
  59.                    FD_ZERO(&fdread);
  60.           cout << "le socket du client ="<<sockclient<<endl;
  61.           FD_SET(sockclient,&fdread);
  63.           NbrClient++;
  64.            cout <<"Nombre de client:"<<NbrClient<<endl;
  66.          }
  67.    //for nbrc}
  68. //----------------------------rer-re-ere-erere-
  70. //------ gere la reception
  72. if  (NbrClient >0)
  73.   {
  78.      if (ret =select(0,&fdread,NULL,NULL,&seltimeout)==SOCKET_ERROR)cout<<"select error"<<endl;//else cout <<"select ok!!!!!!!"<<endl;
  79.      // cout << GetLastError()<<endl;
  80.      if (ret!=0)cout  <<"La valeur de ret select "<<ret<<endl;
  81.      // Sleep(1000);
  82.       if (ret > 0)
  83.         {
  84.          cout <<" un SOCKETR est en cour de lecture"<<endl;
  85.           if (FD_ISSET(sockclient,&fdread))
  86.             {
  88.                if ( recv(sockclient,buf,16,0)==-1)cout <<"reception du nom ECHEC:!"<<endl;
  89.                  
  90.                                 }
  92.         }
  94.     }
  95. }
  98. // fin du programme


Message édité par tckoullou le 20-05-2004 à 19:09:29
Reply

Marsh Posté le 20-05-2004 à 20:32:08    

Et en Français ??  :o

Reply

Marsh Posté le 20-05-2004 à 21:17:57    

le select renvoi tous le temp 0 sur mon socket client coté serveur....
est ce qui fo faire un send classique coter client ??
 
ben en grod je voudrait un code d'exemple pour faire un select() sur un recv()


Message édité par tckoullou le 20-05-2004 à 21:57:38
Reply

Marsh Posté le 20-05-2004 à 22:10:42    

eh ben voila ya qu'a demander ;)
 
C'est une fonction d'attente d'arrivée de données (pour une reponse à un ping en raw sockets)
 

Code :
  1. int CPing::IsDataAvailable()
  2. {
  3. int iErr = ERR_WSA_OK; // code d'erreur renvoyé, par défaut tout va bien
  4. CNWScanException *e = NULL; // exception au cas ou...
  6. e = new CNWScanException;
  7. if(!e)
  8.  return ERR_EXP_CREATE;
  10. // structure utilisée par select contenant une durée en secondes et en microsecondes
  11. timeval timeout = {m_dwTimeout/1000, (m_dwTimeout % 1000) * 1000};
  14. fd_set fds; // file descriptor qui permet d'associer une socket a des opérations de lecture/ecriture
  16. FD_ZERO(&fds); // macro qui initialise le fds
  17. FD_SET(m_Socket, &fds); // macro qui associe la socket au fds
  19. // On attend avec un timeout sur les opérations de lecture
  20. iErr = select(0, &fds, NULL, NULL, &timeout);
  21. if(iErr == 0 || iErr == SOCKET_ERROR)
  22. {
  23.  // un timeout a eu lieu, le buffer de reception est vide
  24.  e->SetErrorCode(ERR_WSA_TIMEOUT);
  25.  throw e;
  26. }
  28. // tout va bien le buffer contient des données
  29. delete e;
  31. return ERR_WSA_OK;
  32. }


 
et le bloc de code avant réception qui se sert du select:
 

Code :
  1. try
  2. {
  3.  // Attente de réception de données dans le buffer avec timeout
  4.  err = IsDataAvailable();
  5. }
  6. catch (CNWScanException *se)
  7. {
  8.  // rien n'est recu apres timeout
  9.  // on nettoie tout et on sort
  10.  Cleanup(pPacket, pRecvBuf);
  11.  e->SetErrorCode(se->GetLastError());
  12.  throw e;
  13. }
  15. // la réponse est la ...
  16. // on alloue un buffer de réception
  17. pRecvBuf = new char[MAX_PACKET_SIZE];
  18. if(!pRecvBuf)
  19. {
  20.  // erreur, on nettoie ce qui est alloué et on sort...
  21.  e->SetErrorCode(ERR_MEM_ALLOC);
  22.  Cleanup(pPacket);
  23.  throw e;
  24. }
  26. // on lit les données recues, on obtient des infos sur l'emetteur dans from
  27. nRead = recvfrom(m_Socket, pRecvBuf, MAX_PACKET_SIZE, NULL, (sockaddr *)&from, &fromLen);
  28. if(nRead == SOCKET_ERROR)
  29. {
  30.  // impossible de lire sur la socket
  31.  // on nettoie tout et on sort
  32.  e->SetErrorCode(ERR_WSA_NOK);
  33.  Cleanup(pPacket, pRecvBuf);
  34.  throw e;
  35. }


---------------
- Pierre Baudelet -
Reply

Marsh Posté le 21-05-2004 à 09:37:26    

:jap: yes je te remerci pedro je vais tester sa !


Message édité par tckoullou le 21-05-2004 à 09:37:52
Reply

Marsh Posté le 21-05-2004 à 12:10:48    

:jap: ok c'est bouen sa marche enfet javait deja piger le concept et ton code ma permis d'etre sur d'insister dans la bone voi je te remerci


Message édité par tckoullou le 21-05-2004 à 12:12:46
Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed