Socket, process et autre avec c++

Socket, process et autre avec c++ - C++ - Programmation

Marsh Posté le 27-08-2004 à 18:19:01    

Bonjour à tous,
 
Le c++, c'est bien mais ça devient vite compliqué quand on touche des domaines assez techniques (TCP-IP) et aussi quaud ce n'est pas nous qui avons écrit le programme  :pt1cable:  
 
Bref ! Voici un petit bout de code que je m'empresse de vous expliquez.
On a un systeme qui reçoit des messages ou des demandes de connexion qui viennent de plusieurs entrés, en l'occurence "de gescom" et d'une socket lsock. En gros, on lit sur ces deux sockets. Si un événement arrive (sur l'un ou l'autre), on lit en priorité sur Gescom puis sur lsock. S'il une connexion s'établit sur lsock, il construit un message et le renvoie à un autre systeme illico.
 

Code :
  1. lsock = bindandlisten();
  3.     signal(SIGHUP, trait_sighup);
  4.     signal(SIGINT, trait_sighup);
  5.     signal(SIGQUIT, trait_sighup);
  6.     signal(SIGILL, trait_sighup);
  7.     signal(SIGTRAP, trait_sighup);
  8.     signal(SIGABRT, trait_sighup);
  9. #ifndef LINUX
  10.     signal(SIGEMT, trait_sighup);
  11. #endif
  12.     signal(SIGFPE, trait_sighup);
  13.     signal(SIGBUS, trait_sighup);
  14.     signal(SIGSEGV, trait_sighup);
  15.     signal(SIGSYS, trait_sighup);
  16.     signal(SIGPIPE, trait_sighup);
  17.     signal(SIGXCPU, trait_sighup);
  18.     signal(SIGXFSZ, trait_sighup);
  19.     signal(SIGCHLD,trait_child);
  20.     signal(SIGALRM, SIG_IGN);
  22.     signal(SIGUSR1,trait_sig_usr1_accueil);
  24. struct pollfd pollfds[2];
  25. const int delai1 = 500;
  26. const int POLLGESCOMNUM = 0;
  27. const int POLLSOCKETNUM = 1;
  29. boucler = TRUE;
  30. for (;boucler;)
  31. {
  32.  testModifEnv_accueil(pmqgescom);
  33.  /* attendre les connections */
  34.  // Attendre soit un accès pipe soit une connexion sur le socket
  35.  // si connexion sur le socket détectée accept ne bloquera pas
  36.  pollfds[POLLGESCOMNUM].fd = pipe_accu2gescom[0];  // lecture sur pipe gescom
  37.  pollfds[POLLGESCOMNUM].events = POLLIN;
  38.  pollfds[POLLSOCKETNUM].fd = lsock;      // lecture sur le socket
  39.  pollfds[POLLSOCKETNUM].events = POLLIN;
  40.  int tmp_timer = delai1;
  41.  switch (poll(pollfds,(accept_connexion==TRUE)?2:1,tmp_timer))
  42.  {
  43.  case 0:
  44.   // timeout
  45.   // rien de particulier à faire a priori : boucler
  46.   // si code retour EINTR il y a eu un traitement de signal
  47.   break;
  48.  case 1: case 2:;
  49.   // POLLIN (1 ou 2 evt pollés)
  50.   // soit message de gescom soit connexion
  51.   // pollin sur message
  52.   // on traite en priorité les messages des sessions
  53.   // puis ceux du controleur de session
  54.   // et enfin ceux de l'accueil
  56.   if (pollfds[POLLGESCOMNUM].revents)
  57.   {
  58.    if (pollfds[POLLGESCOMNUM].revents & POLLIN)
  59.    {
  60.     // réception d'un message
  61.     if (pmqgescom.receive(msg1))
  62.     {
  63.      // si c'est le cas traiter le message
  64.      AccueilMessageRecu(msg1,pmqgescom,tsi,lsock);
  65.     }
  66.     else
  67.     {
  68.      klog.trace(9,"A116",ACCUEIL,'E',"AL_CANT_CONNECT_GESCOM : fin de l'accueil" );
  69.      boucler = FALSE;
  70.     }
  71.    }
  72.    else if (pollfds[POLLGESCOMNUM].revents & (POLLHUP|POLLNVAL|POLLERR))
  73.    {
  74.     klog.trace(9,"A117",ACCUEIL,'E',"AL_CANT_CONNECT_GESCOM : fin de l'accueil (probleme de communication avec Gescom)" );
  75.     boucler = FALSE;
  76.    }
  77.    else
  78.    {
  79.     // etat du polling inattendu
  80.    }
  81.   }
  83.   if (pollfds[POLLSOCKETNUM].revents)
  84.   {
  85.    if ((accept_connexion==TRUE) && (pollfds[POLLSOCKETNUM].revents & POLLIN))
  86.    {
  87.     klog.trace(300,"A118",ACCUEIL,'L',"Connexion Tcp/IP en cours" );
  88.     // connection sur le socket
  89.     caddrlen = sizeof(caddr);
  90.     memset(&caddr, '\0', sizeof(caddr));
  91. #ifndef LINUX
  92.     csock = accept(lsock,&caddr, &caddrlen);
  93. #else
  94.     csock = accept(lsock,&caddr, (unsigned int *)&caddrlen);
  95. #endif
  96.     
  97.                     if (csock < 0 SOCKET_ERROR  )
  98.     {
  99.      if (errno != EINTR)
  100.      {
  101.       // erreur sur le accept, tracer l'erreur
  102.       klog.trace(29,"A119",ACCUEIL,'W',"LOG_SESSION_REFUSED_SOCKET_ERROR ",errno);
  103.      }
  104.     }
  105.     else
  106.     {
  107.      // signaler la connection a Gescom
  108.      Framed_Ip_Address = (int)ntohl(((struct sockaddr_in*)&caddr)->sin_addr.s_addr);
  109.      msg1.mkTCP_SESSION_REQUEST(Framed_Ip_Address );
  110.      pmqgescom.send(msg1);
  111.      // sauvegarder le socket de connection (temporairement)
  112.      tsi.addSockInfo(Framed_Ip_Address,csock,&caddr,caddrlen);
  113.     }
  114.    }
  115.   }
  116.   break;


ça c'était avant!
 
Le problème maintenant, c'est qu'une fois qu'on a une connexion sur lsock, on doit recevoir des données avant de construire un message et de le renvoyer ( avant on servait juste de relai )et là ça devient plus compliqué sachant qu'on veut éviter au maximum les temps morts (ce qui était le cas avant). En gros, une fois la connexion établie avec csock, il faut écouter sur csock or si on le fait dans la foulée, ça risque de créer des temps morts.
 
 :ange:  
Bon je suis conscient de ne pas être très clair...
C'est pourquoi je me tiens à votre disposition s'il y a des bonnes âmes fan d'informatique qui veulent bien m'aider pour répondre à leur questions.


Message édité par cakeman le 30-08-2004 à 14:18:44
Reply

Marsh Posté le 27-08-2004 à 18:19:01   

Reply

Marsh Posté le 30-08-2004 à 10:48:28    

Est ce que qqun au moins pourrait me dire où trouver les infos concernant la librairie poll.h et signal.h ?

Reply

Marsh Posté le 30-08-2004 à 13:41:55    

Utilise les balises [cpp] pour ton code. Après, pour ton problème, c'est quoi un temps mort ? Explique en 2 lignes ton problème.


---------------
FAQ fclc++ - FAQ C++ - C++ FAQ Lite
Reply

Marsh Posté le 30-08-2004 à 14:42:55    

Dsl pour les balises, je n'avais pas vu que ça existait.
 
En gros, on écoute deux systèmes (qu'on appellera système 1 et système 2 alias gescom)à la fois.
Le principe de base: on reçoit une demande du système 1 qu'on retransmets immédiatement au système 2.
Actuellement, on se met en écoute sur tous les ports et dès qu'on reçoit un signal (poll(pollfds,(accept_connexion==TRUE)?2:1,tmp_timer)), on traite en priorité les messages proveant de système 2. Si le signal arrive du système 1, on construit immédiatement le message à envoyer au système 2.
 

Code :
  1. pollfds[POLLGESCOMNUM].fd = pipe_accu2gescom[0];  // lecture sur pipe gescom
  2. pollfds[POLLGESCOMNUM].events = POLLIN;
  3. pollfds[POLLSOCKETNUM].fd = lsock;      // lecture sur le socket
  4. pollfds[POLLSOCKETNUM].events = POLLIN;


 
Seulement maintenant il y a une variante. A partir du moment où on reçoit un signal du sytème 1, il faut se mettre attente pour recevoir  d'autres données avant de faire suivre au système 2.
Avant on n'écoutait que sur deux canals (celui du système 1 et celui du système 2. Or maintenant, on devra écouter sur d'autres ports (n sur le système 1 et un sur le système 2). On met donc un timeout de 5 s sur les ports en écoute sur le système 1.
 
J'avoue que c'est assez délicat à expliquer donc n'hésitez pas à demander des précisions.
 

Reply

Marsh Posté le 31-08-2004 à 15:14:55    

Personne ne sait où je peux trouver  des renseigner sur la librairie "poll.h" et en particulier sur la fonction "poll" ?

Reply

Marsh Posté le 31-08-2004 à 16:16:55    

va voir dans le site www.guill.net

Reply

Sujets relatifs:

Leave a Replay

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