A.2  Programmation en mode connecté

A.2.1  Exemple de serveur

• Une fonction d’initialisation générique :

  int initialisationServeur(char *service,int connexions){
  struct addrinfo precisions,*resultat,*origine;
  int statut;
  int s;
  
  /* Construction de la structure adresse */
  memset(&precisions,0,sizeof precisions);
  precisions.ai_family=AF_UNSPEC;
  precisions.ai_socktype=SOCK_STREAM;
  precisions.ai_flags=AI_PASSIVE;
  statut=getaddrinfo(NULL,service,&precisions,&origine);
  if(statut<0){ perror("initialisationServeur.getaddrinfo"); exit(EXIT_FAILURE); }
  struct addrinfo *p;
  for(p=origine,resultat=origine;p!=NULL;p=p->ai_next)
    if(p->ai_family==AF_INET6){ resultat=p; break; }
  
  /* Creation d'une socket */
  s=socket(resultat->ai_family,resultat->ai_socktype,resultat->ai_protocol);
  if(s<0){ perror("initialisationServeur.socket"); exit(EXIT_FAILURE); }
  
  /* Options utiles */
  int vrai=1;
  if(setsockopt(s,SOL_SOCKET,SO_REUSEADDR,&vrai,sizeof(vrai))<0){
    perror("initialisationServeur.setsockopt (REUSEADDR)");
    exit(EXIT_FAILURE);
    }
  if(setsockopt(s,IPPROTO_TCP,TCP_NODELAY,&vrai,sizeof(vrai))<0){
    perror("initialisationServeur.setsockopt (NODELAY)");
    exit(EXIT_FAILURE);
    }
  
  /* Specification de l'adresse de la socket */
  statut=bind(s,resultat->ai_addr,resultat->ai_addrlen);
  if(statut<0) return -1;
  
  /* Liberation de la structure d'informations */
  freeaddrinfo(origine);
  
  /* Taille de la queue d'attente */
  statut=listen(s,connexions);
  if(statut<0) return -1;
  
  return s;
  }
  

• La fonction de gestion des clients :

  int boucleServeur(int ecoute,int (*traitement)(int))
  {
  int dialogue;
  
  while(1){
  
      /* Attente d'une connexion */
      if((dialogue=accept(ecoute,NULL,NULL))<0) return -1;
  
      /* Passage de la socket de dialogue a la fonction de traitement */
      if(traitement(dialogue)<0){ shutdown(ecoute,SHUT_RDWR); return 0;}
  
      }
  }
  

• La fonction principale :

  int gestionClient(int s){
  
  /* Obtient une structure de fichier */
  FILE *dialogue=fdopen(s,"a+");
  if(dialogue==NULL){ perror("gestionClient.fdopen"); exit(EXIT_FAILURE); }
  
  /* Echo */
  char ligne[MAX_LIGNE];
  while(fgets(ligne,MAX_LIGNE,dialogue)!=NULL)
    fprintf(dialogue,"> %s",ligne);
  
  /* Termine la connexion */
  fclose(dialogue);
  return 0;
  }
  
  int main(int argc,char *argv[])
  {
  int s;
   
  /* Lecture des arguments de la commande */
  analyseArguments(argc,argv);
    
  /* Initialisation du serveur */
  s=initialisationServeur(&port,MAX_CONNEXIONS);
     
  /* Lancement de la boucle d'ecoute */
  boucleServeur(s,gestionClient);
  } 
  

A.2.2  Exemple de client

• Une fonction de connexion générique :

  int connexionServeur(char *hote,char *service){
  struct addrinfo precisions,*resultat,*origine;
  int statut;
  int s;
  
  /* Creation de l'adresse de socket */
  memset(&precisions,0,sizeof precisions);
  precisions.ai_family=AF_UNSPEC;
  precisions.ai_socktype=SOCK_STREAM;
  statut=getaddrinfo(hote,service,&precisions,&origine);
  if(statut<0){ perror("connexionServeur.getaddrinfo"); exit(EXIT_FAILURE); }
  struct addrinfo *p;
  for(p=origine,resultat=origine;p!=NULL;p=p->ai_next)
    if(p->ai_family==AF_INET6){ resultat=p; break; }
  
  /* Creation d'une socket */
  s=socket(resultat->ai_family,resultat->ai_socktype,resultat->ai_protocol);
  if(s<0){ perror("connexionServeur.socket"); exit(EXIT_FAILURE); }
  
  /* Connection de la socket a l'hote */
  if(connect(s,resultat->ai_addr,resultat->ai_addrlen)<0) return -1;
  
  /* Liberation de la structure d'informations */
  freeaddrinfo(origine);
  
  return s;
  }
  

• La fonction principale :

  int main(int argc,char *argv[])
  {
  int s;
  
  /* Lecture des arguments de la commande */
  analyseArguments(argc,argv);
  
  /* Connection au serveur */
  s=connexionServeur(machine,port);
  if(s<0){ fprintf(stderr,"Erreur de connexion au serveur\n"); exit(EXIT_FAILURE); }    
  
  /* Boucle de communication avec le serveur */
  struct pollfd descripteurs[2];
  descripteurs[0].fd=s;
  descripteurs[0].events=POLLIN;
  descripteurs[1].fd=0;
  descripteurs[1].events=POLLIN;
  while(1){
    char tampon[MAX_TAMPON];
    int nb=poll(descripteurs,2,-1);
    if(nb<0){ perror("main.poll"); exit(EXIT_FAILURE); }
    if((descripteurs[0].revents&POLLIN)!=0){
      int taille=read(s,tampon,MAX_TAMPON);
      if(taille<=0) break;
      write(1,tampon,taille);
      }
    if((descripteurs[1].revents&POLLIN)!=0){
      int taille=read(0,tampon,MAX_TAMPON);
      if(taille<=0) break;
      write(s,tampon,taille);
      }
    }
  
  /* On termine la connexion */
  shutdown(s,SHUT_RDWR);
  
  return 0;
  }