[BACK]Return to instructions_r4.c CVS log [TXT] [DIR] Up to [local] / rpl / src

Diff for /rpl/src/instructions_r4.c between versions 1.78 and 1.79

version 1.78, 2013/04/01 15:29:37 version 1.79, 2013/04/04 07:51:56
Line 883  instruction_read(struct_processus *s_eta Line 883  instruction_read(struct_processus *s_eta
     struct sockaddr_in6             adresse_ipv6;      struct sockaddr_in6             adresse_ipv6;
 #   endif  #   endif
   
     struct pollfd                   poll_fd;  
   
     struct timespec                 attente;      struct timespec                 attente;
   
     struct_descripteur_fichier      *descripteur;      struct_descripteur_fichier      *descripteur;
Line 2498  instruction_read(struct_processus *s_eta Line 2496  instruction_read(struct_processus *s_eta
                     }                      }
                     else                      else
                     {                      {
                         // Installation d'un timeout pour sortir de                          // Si on a lu toute une trame et qu'on n'a pas
                         // l'instruction dans le cas où la transmission serait                          // réussi à en trouver la structure, on remonte
                         // invalide et que la trame reçue serait erronée.                          // une erreur de syntaxe.
   
                         poll_fd.fd = (*((struct_socket *)  
                                 (*s_objet_argument_1).objet)).socket;  
                         poll_fd.events = POLLIN;  
   
                         while((ios = poll(&poll_fd, 1, 10000)) <= 0)                          if (longueur_effective == ios)
                         {                          {
                             // La fin de la trame n'est pas atteinte.                              if ((*((struct_socket *) (*s_objet_argument_1)
                                       .objet)).domaine == PF_UNIX)
                             switch(ios)  
                             {                              {
                                 case EINTR:                                  do
                                 {                                  {
                                     if ((*s_etat_processus)                                      longueur_adresse = sizeof(adresse_unix);
                                             .var_volatile_requete_arret == -1)                                      recvfrom((*((struct_socket *)
                                     {                                              (*s_objet_argument_1).objet))
                                         liberation(s_etat_processus,                                              .socket, tampon_lecture,
                                                 s_objet_argument_1);                                              (size_t) longueur_effective,
                                         free(tampon_lecture);                                              0, (struct sockaddr *)
                                         return;                                              &adresse_unix, &longueur_adresse);
                                     }                                  } while((ios == -1) && (errno == EINTR));
                               }
                                     break;                              else if ((*((struct_socket *) (*s_objet_argument_1)
                                       .objet)).domaine == PF_INET)
                               {
                                   do
                                   {
                                       longueur_adresse = sizeof(adresse_ipv4);
                                       recvfrom((*((struct_socket *)
                                               (*s_objet_argument_1).objet))
                                               .socket, tampon_lecture,
                                               (size_t) longueur_effective,
                                               0, (struct sockaddr *)
                                               &adresse_ipv4, &longueur_adresse);
                                   } while((ios == -1) && (errno == EINTR));
                               }
                               else if ((*((struct_socket *) (*s_objet_argument_1)
                                       .objet)) .domaine == PF_INET6)
                               {
   #                               ifdef IPV6
                                   do
                                   {
                                       longueur_adresse = sizeof(adresse_ipv6);
                                       recvfrom((*((struct_socket *)
                                               (*s_objet_argument_1).objet))
                                               .socket, tampon_lecture,
                                               (size_t) longueur_effective,
                                               0, (struct sockaddr *)
                                               &adresse_ipv6, &longueur_adresse);
                                   } while((ios == -1) && (errno == EINTR));
   #                               else
                                   if ((*s_etat_processus).langue == 'F')
                                   {
                                       printf("+++Attention : Support du protocole"
                                               " IPv6 indisponible\n");
                                 }                                  }
                                   else
                                 case 0:  
                                 {                                  {
                                     liberation(s_etat_processus,                                      printf("+++Warning : IPv6 support "
                                             s_objet_argument_1);                                              "unavailable\n");
                                     free(tampon_lecture);  
   
                                     (*s_etat_processus).erreur_execution =  
                                             d_ex_fin_de_fichier_atteinte;  
                                     return;  
                                 }                                  }
   
   #                               endif
                             }                              }
   
                               liberation(s_etat_processus, s_objet_argument_1);
                               free(tampon_lecture);
   
                               (*s_etat_processus).erreur_execution = d_ex_syntaxe;
                               return;
                         }                          }
                     }                      }
                 }                  }
Removed from v.1.78  
changed lines
  Added in v.1.79

CVSweb interface <joel.bertrand@systella.fr>