[C] Sockets et appel système "select()"

Sockets et appel système "select()" [C] - C - Programmation

Marsh Posté le 16-04-2004 à 22:03:01    

Bonjour tout le monde,
 
Je suis en train de coder une application client/serveur se basant sur l'appel système select(). Le problème est que le FD_ISSET() (macro détectant qu'un descripteur de fichiers a été utilisé) est vrai, même si le client n'a rien envoyé !
 
Note importante : vous trouverez dans la première réponse à ce message juste les parties du code "intéressantes". Dans ce message, j'ai volontairement mis l'intégralité (enfin, c'est pas non plus monstreux !) des deux codes source (client/serveur).
 
Voici le code du serveur :

Code :
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <unistd.h>
  5. #include <netdb.h>
  6. #include <errno.h>
  7. #include <sys/socket.h>
  8. #include <sys/types.h>
  9. #include <sys/time.h>
  10. #include <sys/types.h>
  11. #include <sys/select.h>
  12. #include <netinet/in.h>
  13. #include <arpa/inet.h>
  15. #define MAX_PENDING_CONNECT (5U)
  16. #define PORT (5000U)
  17. #define BUFSIZE (1024)
  19. /****************************************************************************
  20. * Macro that allow to save and load the descriptors sets. Indeed, when  
  21. * select is called, it removed all descriptors that have not been modified
  22. * since last call. So, we must have an "history" of the initial set and we
  23. * must load it before each select call in order to consider all  
  24. * descriptors.
  25. ****************************************************************************/
  27. #define SAVE_SETS                                                 \
  28. {                                                                 \
  29.    memcpy(&fds_read_copy, &fds_read, sizeof(fds_read));           \
  30. }
  32. #define LOAD_SETS                                                 \
  33. {                                                                 \
  34.    memcpy(&fds_read, &fds_read_copy, sizeof(fds_read_copy));      \
  35. }
  37. /****************************************************************************
  38. *
  39. * Description : Create a socket, disable its TIME_WAIT option, bind the
  40. * port and listen for connections.
  41. *
  42. * Return
  43. *    - '-1' if the creation failed.
  44. *    - the new file descriptor if the creation succeed.
  45. *
  46. ****************************************************************************/
  48. int create_socket(unsigned int port, unsigned int max_pending_connections)
  49. {
  50.    struct sockaddr_in server_info;     /* Information of the server */
  51.    int server_fd;                      /* The file descriptor that will be
  52.                                           returned */
  53.    int flag;                           /* Flag for the setsockopt func. */
  55.    /* Note : htons() is used to convert the port value in the Network Byte  
  56.     * Order (NBO). This order is the one used in the TCP/IP packets. */
  58.    server_info.sin_family = AF_INET;    /* We treats with IPv4 address */
  59.    server_info.sin_port = htons(port);
  60.    server_info.sin_addr.s_addr = INADDR_ANY;   /* My IP address :) */
  61.    memset(&(server_info.sin_zero), '\0', (size_t)8);
  63.    /* Creation of the socket */
  64.    if((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
  65.       return -1;
  67.    /* Disable TIME_WAIT */
  68.    flag=1;
  69.    if(setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag)) == -1
  70. )
  71.       fprintf(stderr, "Error while using setsockopt()\n" );
  73.    /* Binding the port */
  74.    if(bind(server_fd, (struct sockaddr*)&server_info, sizeof(struct sockaddr)) =
  75. = -1)
  76.       return -1;
  79.    /* Listenning connections */
  80.    if(listen(server_fd, max_pending_connections) == -1)
  81.       return -1;
  83.    return (server_fd);
  84. }
  87. int main()
  88. {
  89.    fd_set fds_read;              /* Set of file descriptors for reading */
  90.    fd_set fds_read_copy;         /* Copy of fds_read not to lose info */
  91.    fd_set fds_write_copy;        /* Copy of fds_write not to lose info */
  93.    /* List of the file descriptors of each client. The file descriptor
  94.     * list_file_descriptors[0] is this of the server. */
  96.    int server_fd, new_fd, sin_size, nb_bytes;
  97.    int max_fd;
  98.    char buffer[BUFSIZE];
  99.    struct sockaddr_in client_info;  /* Store the client information */
  101.    FD_ZERO(&fds_read);
  102.    FD_ZERO(&fds_read_copy);
  104.    if((server_fd = create_socket(PORT, MAX_PENDING_CONNECT)) == -1)
  105.    {
  106.       fprintf(stderr, "Error while creating the socket.\n" );
  107.       return (EXIT_FAILURE);
  108.    }
  110.    FD_SET(server_fd, &fds_read);
  111.    SAVE_SETS;
  113.    max_fd = server_fd;
  115.    while(1)
  116.    {
  117.       LOAD_SETS;
  119.       if(select(max_fd + 1, &fds_read, NULL, NULL, NULL)  == -1)
  120.          fprintf(stderr, "select error !\n" );
  122.       /* Après un select, les "sets" peuvent être modifié. */
  124.       if(FD_ISSET(server_fd, &fds_read))
  125.       {
  126.          /* Accepting connections :) */
  127.          printf("Un client s'est connecté, je l'ajoute dans le set\n" );
  128.          sin_size = sizeof(struct sockaddr_in);
  129.          if((new_fd = accept(server_fd, (struct sockaddr*)&client_info, &sin_siz
  130. e)) == -1)
  131.             fprintf(stderr, "Error while accepting connection...\n" );
  133.          if(new_fd > max_fd)
  134.             max_fd = new_fd;
  136.          FD_SET(new_fd, &fds_read);
  137.          SAVE_SETS;
  138.       }
  140.       if(FD_ISSET(new_fd, &fds_read))
  141.       {
  142.          if ((nb_bytes = recv(new_fd, buffer, 50, 0)) == -1)
  143.          {
  144.             fprintf(stderr, "Probleme avec la fonction recv()\n" );
  145.             exit(EXIT_FAILURE);
  146.          }
  147.          else
  148.             printf("." );
  149.       }
  150.    }
  152.    printf("JE QUITTE\n" );
  153.    return EXIT_SUCCESS;
  154. }


 
Vous remarquez donc que dès que le serveur reçoit un message du client, il affiche un point ("." ). Or, avec le client ci-dessous (qui n'envoie que deux messages), le serveur affiche une infinité de points !
 
Le code du client :

Code :
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <sys/socket.h>
  5. #include <sys/types.h>
  6. #include <netinet/in.h>
  7. #include <arpa/inet.h>
  8. #include <netdb.h>
  9. #include <errno.h>
  10. #include <unistd.h>
  12. #define MAX_PENDING_CONNECT (5)
  13. #define PORT (5000)
  14. #define BUFSIZE (1024)
  16. int main(int argc, char **argv)
  17. {
  18.    struct sockaddr_in server_info;
  19.    struct hostent *hostinfo;
  20.    int fd, nb_bytes;
  21.    const char msg[] = "CS 'lockness";
  22.    char buffer[BUFSIZE];
  24.    if(argc < 2)
  25.    {
  26.       fprintf(stderr, "Hostname or IP in argument please !\n" );
  27.       return (EXIT_FAILURE);
  28.    }
  30.    /*************************
  31.     * CREATION DE LA SOCKET *
  32.     *************************/
  33.    if((hostinfo = gethostbyname(argv[1])) == NULL)
  34.       fprintf(stderr, "Et là... c'est le drame !\n" );
  36.    server_info.sin_family = AF_INET;    /* We treats with IPv4 address */
  37.    server_info.sin_port = htons(5000);
  38.    server_info.sin_addr = *((struct in_addr*)hostinfo->h_addr);
  39.    memset(&(server_info.sin_zero), '\0', (size_t)8);
  41.    if((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
  42.       fprintf(stderr, "Error in the socket creation\n" );
  44.    printf("ip = %s\n", inet_ntoa(server_info.sin_addr));
  47.    /************************
  48.     * CONNEXION AU SERVEUR *
  49.     ************************/
  50.    if (connect(fd, (struct sockaddr *)&server_info, sizeof(struct sockaddr)) ==
  51. -1)
  52.    {
  53.       fprintf(stderr, "Impossible de se connecter au serveur\n" );
  54.       exit(EXIT_FAILURE);
  55.    }
  57.    /**************
  58.     * TRANSFERTS *
  59.     **************/
  61.    /* Envoie d'un msg au serveur */
  62.    if (send(fd, msg, strlen(msg), 0) == -1)
  63.       fprintf(stderr, "Error while using send()\n" );
  64.    printf("Message sent by the client : %s\n", msg);
  66.    sleep(2);
  68.    if (send(fd, msg, strlen(msg), 0) == -1)
  69.       fprintf(stderr, "Error while using send()\n" );
  70.    printf("Message sent by the client : %s\n", msg);
  72.    close(fd);
  74.    return EXIT_SUCCESS;
  75. }


 
Quelqu'un pourrait-il m'aider à résoudre ce problème (tout bete en plus) ?


Message édité par Lockness le 16-04-2004 à 22:10:39
Reply

Marsh Posté le 16-04-2004 à 22:03:01   

Reply

Marsh Posté le 16-04-2004 à 22:08:47    

Chose promie, chose due, voici juste les parties "intéressantes" du serveur et du client :
 
Le serveur :  

Code :
  1. FD_SET(server_fd, &fds_read);
  2.    SAVE_SETS;
  4.    max_fd = server_fd;
  6.    while(1)
  7.    {
  8.       LOAD_SETS;
  10.       if(select(max_fd + 1, &fds_read, NULL, NULL, NULL)  == -1)
  11.          fprintf(stderr, "select error !\n" );
  13.       /* Après un select, les "sets" peuvent être modifié. */
  15.       if(FD_ISSET(server_fd, &fds_read))
  16.       {
  17.          /* Accepting connections :) */
  18.          printf("Un client s'est connecté, je l'ajoute dans le set\n" );
  19.          sin_size = sizeof(struct sockaddr_in);
  20.          if((new_fd = accept(server_fd, (struct sockaddr*)&client_info, &sin_siz
  21. e)) == -1)
  22.             fprintf(stderr, "Error while accepting connection...\n" );
  24.          if(new_fd > max_fd)
  25.             max_fd = new_fd;
  27.          FD_SET(new_fd, &fds_read);
  28.          SAVE_SETS;
  29.       }
  31.       if(FD_ISSET(new_fd, &fds_read))
  32.       {
  33.          if ((nb_bytes = recv(new_fd, buffer, 50, 0)) == -1)
  34.          {
  35.             fprintf(stderr, "Probleme avec la fonction recv()\n" );
  36.             exit(EXIT_FAILURE);
  37.          }
  38.          else
  39.             printf("." );
  40.       }
  41.    }


 
Le client :

Code :
  1. int main(int argc, char **argv)
  2. {
  3.    struct sockaddr_in server_info;
  4.    struct hostent *hostinfo;
  5.    int fd, nb_bytes;
  6.    const char msg[] = "CS 'lockness";
  7.    char buffer[BUFSIZE];
  9.    if(argc < 2)
  10.       return (EXIT_FAILURE);
  12.    /*************************
  13.     * CREATION DE LA SOCKET *
  14.     *************************/
  15.    if((hostinfo = gethostbyname(argv[1])) == NULL)
  16.       fprintf(stderr, "Et là... c'est le drame !\n" );
  18.    server_info.sin_family = AF_INET;    /* We treats with IPv4 address */
  19.    server_info.sin_port = htons(5000);
  20.    server_info.sin_addr = *((struct in_addr*)hostinfo->h_addr);
  21.    memset(&(server_info.sin_zero), '\0', (size_t)8);
  23.    if((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
  24.       fprintf(stderr, "Error in the socket creation\n" );
  26.    if (connect(fd, (struct sockaddr *)&server_info, sizeof(struct sockaddr)) ==
  27. -1)
  28.       exit(EXIT_FAILURE);
  30.    /**************
  31.     * TRANSFERTS *
  32.     **************/
  34.    /* Envoie d'un msg au serveur */
  35.    if (send(fd, msg, strlen(msg), 0) == -1)
  36.       fprintf(stderr, "Error while using send()\n" );
  37.    printf("Message sent by the client : %s\n", msg);
  39.    sleep(2);
  41.    if (send(fd, msg, strlen(msg), 0) == -1)
  42.       fprintf(stderr, "Error while using send()\n" );
  43.    printf("Message sent by the client : %s\n", msg);
  45.    close(fd);
  47.    return EXIT_SUCCESS;
  48. }

Reply

Marsh Posté le 16-04-2004 à 22:09:25    

c'est à toi de faire un FD_SET au début je pense pour les initialiser


Message édité par antsite le 16-04-2004 à 22:10:04
Reply

Marsh Posté le 16-04-2004 à 22:12:47    

C'est ce que j'ai fait : juste après les deux FD_ZERO.

Reply

Marsh Posté le 17-04-2004 à 16:25:49    

Lockness a écrit :

Bonjour tout le monde,
 
Je suis en train de coder une application client/serveur se basant sur l'appel système select(). Le problème est que le FD_ISSET() (macro détectant qu'un descripteur de fichiers a été utilisé) est vrai, même si le client n'a rien envoyé !
 


 
Au pif-ô-mètre, le problème me semble venir du code retour du select qui n'est pas testé. A savoir si select retourne 0, votre code effectue quand même le FD_ISSET or, pour peu que le set retourné par le select soit vide dans ce cas, il est fort possible que ça chie un max.

Reply

Sujets relatifs:

Leave a Replay

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