broadcast UDP sous linux et UDP + connect

broadcast UDP sous linux et UDP + connect - C - Programmation

Marsh Posté le 04-04-2012 à 21:38:03    

Bonsoir,
 
Je suis en train de coder une application nécessitant d'envoyer et de recevoir des broadcast sous linux et je rencontre quelques difficultés ( ou plutot interrogations ).
 
Je ne trouve pas de littérature sur internet m'expliquant en détail le fonctionnement, les pages man de chaque fonction sont insuffisantes à ce niveau.
 
Voici mon problème :
 
J'ai codé un petit test unitaire sous windows qui crée une socket DGRAM , et qui envoie en broadcast sur un port X des datas bien précis. Une application test ( sous windows egalement et uniquement ) se charge de réceptionner ces datas , et d'en renvoyer d'autre sur le même port X toujours en broadcast.
 
Ce test fonctionne sous windows, pour cela, j'ai juste eu besoin de créer ma socket ( DGRAM / IPPROTO_UDP ) , et de faire un bind sur l'adresse de l'interface sur laquelle je souhaite envoyer le broadcast. J'ai volontairement plusieurs interfaces, et ca envoie bien sur la 2eme ( vérifié sur wireshark des 2 cotés ).
 
Par contre, sous linux, le bind sur l'adresse de l'interface ne fonctionne pas. J'envoie bien mon message en broadcast, je vois bien qu'il part, qu'il est réceptionné par mon application test, celle-ci renvoie bien le message retour sur l'adresse broadcast, mais je ne le recois pas sous linux. Le seul moyen est de ne pas faire de bind sur l'adresse de l'interface comme sous windows, mais de le faire sur l'adresse broadcast.
 
Voici mes questions :  
   - Pourquoi cette différence, et où est-elle documentée ( je n'ai pas trouvé ) ? (je précise, j'ai bien fait le setsockopt qui positionne le broadcast à ACTIVE ).
   - pourquoi quand je fais le bind cette fois-ci sur l'adresse d'interface cela ne fonctionne pas ?
   - pourquoi quand je fais le bind sur la valeur INADDR_BROADCAST, cela ne fonctionne pas non plus ? Quelle différence avec l'adresse broadcast ( je vois bien la différence, INADDR_BROADCAST vaut 0xFFFFFFFF )
   - pourquoi quand je fais le bind sur la valeur INADDR_ANY cela marche bien ?  
 
 
Je ne peux pas poster de code ce soir, je ne suis pas à mon poste :p Je le ferai dès demain.
 
Merci de m'avoir lu :)


Message édité par xilebo le 05-04-2012 à 09:57:54
Reply

Marsh Posté le 04-04-2012 à 21:38:03   

Reply

Marsh Posté le 05-04-2012 à 09:21:41    

J'en profite pour poser une 2ème question : l'UDP unicast ne fonctionne pas sous linux alors que le même code fonctionne sous windows.
 
A priori , c'est l'appel à la fonction connect qui fait échouer.
 
Voici les portions de code ( dialogue entre 2 machines : 172.17.0.163 le test unitaire sous linux , 172.17.0.160 le serveur qui réceptionne le test sous windows )
 
Initialisation de la socket

Code :
  1. int oui = 1;
  4. m_socket = socket( AF_INET , SOCK_DGRAM , IPPROTO_UDP );
  6. if ( m_socket >= 0)
  7. {
  9.  // options de socket devant être paramétrées *avant* le bind() ou connect()
  12. #ifdef SO_NOSIGPIPE
  13.  if (setsockopt( m_socket , SOL_SOCKET, SO_NOSIGPIPE, (char *)&oui, sizeof(oui)) < 0)
  14.  {
  15.   ERROR(("setsockopt(SO_NOSIGPIPE): %s", strerror_socket(errno)));
  16.   CloseSocket( );
  17.   return PRT_FAILED;
  18.  }
  19. #endif
  21.  if (setsockopt( m_socket , SOL_SOCKET, SO_REUSEADDR, (char *)&oui, sizeof(oui)) < 0)
  22.  {
  23.   ERROR((setsockopt(SO_REUSEADDR): %s", strerror_socket(errno)));
  24.   CloseSocket( );
  25.   return PRT_FAILED;
  26.  }
  28. #ifdef SO_REUSEPORT
  29.  if (setsockopt( m_socket , SOL_SOCKET, SO_REUSEPORT, (char *)&oui, sizeof(oui)) < 0)
  30.  {
  31.   ERROR(("setsockopt(SO_REUSEPORT): %s", strerror_socket(errno)));
  32.   CloseSocket( );
  33.   return PRT_FAILED;
  34.  }
  35. #endif
  39.  ULONG hote_l =INADDR_NONE;
  42.  hote_l = inet_addr( m_address_sz );
  45.  ULONG peer_l;
  47.  peer_l = inet_addr( m_pair_address_sz );
  50.  if ( hote_l == INADDR_NONE )
  51.  {
  52.   ERROR(("%s is not a valid IP address", m_address_sz ) );
  53.   CloseSocket( );
  54.   return PRT_FAILED;
  55.  }
  57.  struct sockaddr_in adresse;
  59.  memset ( &adresse , 0 , sizeof( adresse ) );
  61.  adresse.sin_family  = AF_INET;
  63.  adresse.sin_addr.s_addr = hote_l;
  64.  adresse.sin_port  = htons ( (USHORT)m_port_l ); // port stocké dans un long, mais < 65535 donc cast OK
  67.  struct sockaddr_in adresse_peer;
  69.  memset ( &adresse_peer , 0 , sizeof( adresse_peer ) );
  71.  adresse_peer.sin_family  = AF_INET;
  72.  adresse_peer.sin_addr.s_addr = peer_l;
  73.  adresse_peer.sin_port  = htons( (USHORT)m_port_l); // port stocké dans un long, mais < 65535 donc cast OK
  75.  // boucler les tentatives ?
  79.  if ( bind( m_socket , (struct sockaddr *) &adresse , sizeof (adresse ) ) != 0 )
  80.  {
  81.   ERROR(("bind failed %s", strerror_socket(errno) ) );
  82.   CloseSocket( );
  83.   return PRT_FAILED;
  84.  }
  86.  if ( connect( m_socket , (struct sockaddr *) &adresse_peer , sizeof (adresse_peer ) ) != 0 )
  87.  {
  88.   ERROR(("connect failed %s", strerror_socket(errno) ) );
  89.   CloseSocket( );
  90.   return PRT_FAILED;
  91.  }
  93.  // options de socket devant être paramétrées *apres* le bind() ou connect()
  96.  struct timeval timeout;
  97.  timeout.tv_sec  = 0;
  98.  timeout.tv_usec = 100000;
  100.  if (setsockopt( m_socket , SOL_SOCKET, SO_RCVTIMEO, (char *)&timeout, sizeof(timeout)) < 0)
  101.  {
  102.   PGAS_ERROR(("setsockopt(SO_RCVTIMEO): %s", strerror_socket(errno)));
  103.   CloseSocket( );
  104.   return PRT_FAILED;
  105.  }
  108.  // connection is OK
  110.  m_connected_b = TRUE;
  111.  return PRT_SUCCESS;
  112. }
  114. return PRT_FAILED;


 
 
code faisant le send : Pas besoin de sendto, l'adresse par défaut est celle spécifiée dans le connect

Code :
  1. while (tot < nBufferSize)
  2. {
  3. int envoye = 0;
  5. envoye = send( m_socket, retour + tot, nBufferSize - tot, 0 );
  7. if ( envoye < 0)
  8. {
  9.  ERROR(("erreur d'envoi a %s/%d: %s", m_address_sz, m_port_l, strerror_socket(errno)));
  10.  return PRT_FAILED;
  11. }
  12. else
  13. {
  14.  tot += envoye;
  15. }
  16. }


 
 
code du receive :  
 

Code :
  1. fd_set      fdin;
  2. timeval     tv;
  5. FD_ZERO(&fdin);
  6. FD_SET(m_socket, &fdin);
  7. tv.tv_sec = _timeout / 1000 ;
  8. tv.tv_usec = ( _timeout % 1000 ) * 1000 ;
  10. data = select(((int)m_socket)+1, &fdin, NULL, NULL, &tv);
  12. if (data == -1)
  13. {
  14. ERROR(("Erreur select : %s",strerror_socket(errno)));
  15. return PRT_FAILED;
  16. }
  17. else if (FD_ISSET(m_socket, &fdin) != 0)
  18. {
  20. recu = recv(m_socket, entete, BUFFERSIZE, 0 );
  21. }


 
 
Alors , avec ce code ( qui est le même sur les 2 machines ) voici comment sont fait les appels :
 
Sur la machine "test unitaire" je fais Init , puis Send, puis Recv , puis Shut.
 
Sur la machine "serveur pour test" , je fais Init , puis Recv , puis Send,  puis Shut  
 
Jusque là, c'est normal.
 
Avec ce code, si les 2 machines sont sous windows, mon test passe.
 
Avec ce même code, si la machine "test unitaire" est sous linux , et la machine "serveur pour test", le test ne passe pas.
 
Où est l'échec ?  
 - l'init fonctionne bien des 2 cotés ( les appels systèmes retournent tous OK ).
 - le premier envoi sous linux se passe bien car il est bien recu sous windows. L'appel connect sous linux est donc cohérent puisque pour l'envoi, je fais un send, sans préciser le destinaire.
 - suite à la réception sous windows, celui-ci envoie une réponse pour être réceptionné sous linux.
 - c'est la réception sous linux qui pose problème, le select retourne "nodata", par conséquent, je ne peux pas faire le recv.
 
 - A savoir que si je mets ( juste coté linux ) en commentaire l'appel à connect  ( ce qui a pour conséquence de m'obliger à remplacer le send par un sendto vers ma machine "serveur pour test" , je ne change pas le recv , qui revient à faire un recvfrom avec sockaddr_in NULL ) , cela fonctionne bien.
 
Je ne comprends pas quelle erreur j'ai pu faire qui fait que le comportement est différent sous linux.
 
Il y a soit un appel de trop qui gêne ( dans les setsockopt par exemple ), soit il manque quelque chose spécifique à linux.
 
Avez vous une idée car je sèche ?
 
Merci :)

Reply

Sujets relatifs:

Leave a Replay

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