[C/Linux] Probleme de communication UDP

Probleme de communication UDP [C/Linux] - C - Programmation

Marsh Posté le 27-09-2006 à 09:54:23    

Salut !
 
 
J'ai un soucis: J'utilise une red hat enterprise 4 et j'essaye de faire un server/client udp.
Or lorsque j'envoie un tableau de 64Ko, seul 1000 octets sont envoyé (sendto retourne 1000). Si je compile le meme soft sous cygwin, et bien ca envoie bien 64Ko. Derniere étape: client sous cygwin et serveur sous linux => le client cygwin envoie bien 64Ko mais le serveur sous linux recoit 1000 octets (recvfrom retourne 1000).
 
Je ne comprends pas trop...
 
Voici mon code:
 
Serveur:

Code :
  1. /* Socket creation
  2.     * IP protocol family(PF_INET)
  3.     * UDP (SOCK_DGRAM)
  4.     */
  5.     if( (socket_id = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0 ) {
  6.         printf("! Error while creating socket !\n" );
  7.         exit(1);
  8.     }
  10.     memset((char*) &server, sizeof(server), 0 );
  11.     server.sin_family = AF_INET;                        /* Used protocol: INET */
  12.     server.sin_addr.s_addr = INADDR_ANY;                /* Any address can connect to the socket */
  13.     server.sin_port = htons(1234);                      /* setup the probing port*/
  17.     /* Connect to the socket */
  18.     if ( (i = bind(socket_id, (struct sockaddr *)&server, sizeof(server))) < 0 ) {
  19.         perror ("! Error while binding to socket !" );
  20.         exit(3);
  21.     }
  23.     while(1)
  24.     {
  25.         /* wait client connection */
  26.         client_ln = sizeof(client);
  27.         n_read = recvfrom( socket_id, buf, MAX_BUF, 0, (struct sockaddr *)&client, &client_ln);
  29.         //pthread_mutex_lock (&mutex);
  31.     got = n_read;
  33.         if((n_read < 0) ) {
  34.             printf("! Error while receiving data (n_read = %d from %s:%d) !\r", n_read, inet_ntoa(client.sin_addr), ntohs(client.sin_port));
  35.             rerrors++;
  36.             if (n_read < 0)
  37.  exit(4);
  38.         }
  39.         else
  40.         {
  41.    
  42.         received += n_read;
  43.             for(i=0;i<MAX_BUF;i++)
  44.             {
  45.              if (buf[i]!=(i%255))
  46.              {
  47.                 rerrors++;
  48.                 printf("@%d => receieved: %d expected: %d \n", i, buf[i], i%255);
  49.              }
  50.            }
  51.         }
  54.         /* Now, send the answer */
  55.         n_sent = sendto( socket_id, buf, MAX_BUF, 0, (struct sockaddr *)&client, sizeof(client));
  57.         if(n_sent < 0 )
  58.         {
  59.                 printf("! Error while answering to %s", get_ip(client.sin_addr.s_addr));
  60.                 serrors++;
  61.                 if (n_sent < 0)
  62.   exit(5);
  63.         }
  64.         else
  65.         {
  66.             sent += n_sent;
  67.         }
  69.         //pthread_mutex_unlock (&mutex);
  70.   }


 
Client:

Code :
  1. struct sockaddr_in server;
  2.     struct hostent *host;
  3.     unsigned char buf[MAX_BUF];
  4.     int buf_len, socket_id, n_sent, n_read, i;
  5.     u_long address;
  6.     u_long nb_send=0, nb_read=0;
  8.     //if (argc != 2)
  9.     {
  10.         printf("> Usage: %s <server name> <udp port>\n",argv[0]);
  11.     }
  13.    /* Socket Creation
  14.     * IP protocol family(PF_INET)
  15.     * UDP (SOCK_DGRAM)
  16.     */
  17.      if( (socket_id = socket( AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0 ) {
  18.         printf("! Error while creating UDP socket !\n" );
  19.         exit(1);
  20.     }
  22.     /* No need to cal bind() because we are using UDP */
  23.     server.sin_family = AF_INET;
  24.     /* set the connection port */
  25.     server.sin_port = htons(1234);
  26.    
  27.     if (argc > 1)
  28.     {
  29.         if ( (host = (struct hostent*) gethostbyname(argv[1])) == NULL ) {
  30.             printf("! Unkown host name !\n" );
  31.             exit(2);
  32.         }
  33.         else
  34.         {
  35.             /* Get host IP address */
  36.             //address = *((u_long*)host->h_addr_list[0]);
  37.             address = inet_addr("127.0.0.1" );
  38.             server.sin_addr.s_addr = address;
  39.            
  40.         }
  41.     }
  42.     else
  43.     {
  44.         printf("] No host specified, using localhost then...\n" );
  45.         server.sin_addr.s_addr = inet_addr("192.168.1.250" );
  46.     }
  50.     do
  51.     {
  52.         /* On compose le message */
  53.         for(i=0;i<MAX_BUF;i++)
  54.          buf[i]= (i % 255);
  55.         buf_len = MAX_BUF; // remove the return char
  57.         /* Message sent to the remote server */
  58.         n_sent = sendto( socket_id, buf, buf_len, 0, (struct sockaddr *)&server, sizeof(server));
  60.         if( n_sent < 0 )
  61.         {
  62.             printf("! Error while sending the message !\n" );
  63.             exit(3);
  64.         }
  65.         else
  66.         {
  67.             nb_send+=n_sent;
  68.         }
  72.         /* buffer cleanning */
  73.         //memset( buf, 0, MAX_BUF);
  75.         /* wait for the server response */
  76.         n_read = recvfrom(socket_id, buf, MAX_BUF, 0, NULL, NULL);
  78.         if( n_read < 0 || n_read < 1000)
  79.         {
  80.             printf("! Error while retreiving the answer !\n" );
  81.             //exit(4);
  82.         }
  83.         else
  84.         {
  85.             nb_read += n_read;
  86.         }
  88.         if ( (nb_send%(1024*1024/MAX_BUF)) == 0 )
  89.         {
  90.             printf("] Sent %d Mo [%d]", nb_send/(1024*1024), n_sent);
  91.      printf("- Received %d Mo [%d] \r", nb_read/(1024*1024), n_read);
  92.      fflush(stdout);
  93.  }
  96.        
  97.     } while (1);


 
Si quelqu'un peut m'expliquer :jap:

Message cité 1 fois
Reply

Marsh Posté le 27-09-2006 à 09:54:23   

Reply

Marsh Posté le 27-09-2006 à 10:23:50    

farok a écrit :

J'ai un soucis: J'utilise une red hat enterprise 4 et j'essaye de faire un server/client udp.
Or lorsque j'envoie un tableau de 64Ko, seul 1000 octets sont envoyé (sendto retourne 1000).  


Ben oui, c'est à toi de gérer le découpage du bloc. C'est à ça que sert le code retour de sendto()...
 
Idem en réception, il faudra réassembler le bloc. J'espère que tu as prévu de transmettre la taille ou un délimiteur...

Message cité 1 fois
Message édité par Emmanuel Delahaye le 27-09-2006 à 10:25:13

---------------
Des infos sur la programmation et le langage C: http://www.bien-programmer.fr Pas de Wi-Fi à la maison : http://www.cpl-france.org/
Reply

Marsh Posté le 27-09-2006 à 10:39:34    

Emmanuel Delahaye a écrit :

Ben oui, c'est à toi de gérer le découpage du bloc. C'est à ça que sert le code retour de sendto()...
 
Idem en réception, il faudra réassembler le bloc. J'espère que tu as prévu de transmettre la taille ou un délimiteur...


 
Arf zut !
Je pensais que l'on etait limité par la taille d'une trame (64Ko) pas par le systeme !
 
Il n'y a pas moyen de modifier un paramètre quelque part (systeme ou via une fonction ?)
 

Message cité 2 fois
Reply

Marsh Posté le 27-09-2006 à 10:50:08    

farok a écrit :

Il n'y a pas moyen de modifier un paramètre quelque part (systeme ou via une fonction ?)


Mauvais reflexe. Le code doit être indépendant du système...


---------------
Des infos sur la programmation et le langage C: http://www.bien-programmer.fr Pas de Wi-Fi à la maison : http://www.cpl-france.org/
Reply

Marsh Posté le 27-09-2006 à 10:59:43    

farok a écrit :

Arf zut !
Je pensais que l'on etait limité par la taille d'une trame (64Ko) pas par le systeme !


et bien si justement c'est 65.527o la taille maximale de la charge utile d'un paquet UDP. S'il la taille de ton paquet UDP dépasse la MTU, alors il y a de la fragmentation IP.
 
Maintenant si tu dis que sur le linux tu ne reçois que 1000o dans l'application, c'est un problème applicatif. Tu devrais regarde les retour de sendto et bien vérifier tout ça.

Reply

Marsh Posté le 27-09-2006 à 11:01:48    

pour le sendto je veux dire qu'étant donné UDP, si sendto n'a pas envoyé exactement le nombre d'octets demandé, alors il y a un problème. On n'est pas en TCP.

Reply

Marsh Posté le 27-09-2006 à 12:23:38    

Alors je pense avoir (à moitié) élucidé mon soucis
J'ai defini un define MAX_BUF dans mon application qui etait mise à 65000
hors à l'execution, si je faisais un printf("%d\n",MAX_BUF);
ca me sortais des lignes de 1000 :o
 
le define était dans un .h externe mais en le changeant par BIG_BUFFER, ca roule maintenant !
 
Je n'avais aucun warning avec gcc 346 :??:

Message cité 1 fois
Reply

Marsh Posté le 27-09-2006 à 13:46:18    

farok a écrit :

Alors je pense avoir (à moitié) élucidé mon soucis
J'ai defini un define MAX_BUF dans mon application qui etait mise à 65000
hors à l'execution, si je faisais un printf("%d\n",MAX_BUF);
ca me sortais des lignes de 1000 :o
 
le define était dans un .h externe mais en le changeant par BIG_BUFFER, ca roule maintenant !
 
Je n'avais aucun warning avec gcc 346 :??:


Je suis très étonné qu'il faille bricoler comme ça dans les headers... En principe, sauf indication contraire très explicite, on a pas le doit de modifier les headers.


---------------
Des infos sur la programmation et le langage C: http://www.bien-programmer.fr Pas de Wi-Fi à la maison : http://www.cpl-france.org/
Reply

Marsh Posté le 27-09-2006 à 15:40:46    

humm je parlais d'un header a moi, donc pas de soucis ;)

Reply

Sujets relatifs:

Leave a Replay

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