[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.83 and 1.84

version 1.83, 2013/09/26 15:38:38 version 1.84, 2013/09/27 10:41:47
Line 850  instruction_read(struct_processus *s_eta Line 850  instruction_read(struct_processus *s_eta
   
     int                             c;      int                             c;
     int                             ios;      int                             ios;
       int                             timeout;
   
     integer8                        element;      integer8                        element;
     integer8                        i;      integer8                        i;
     integer8                        id;      integer8                        id;
     integer8                        position_clef;      integer8                        index;
     integer8                        longueur;      integer8                        longueur;
       integer8                        position_clef;
   
     integer8                        longueur_effective;      integer8                        longueur_effective;
     integer8                        longueur_enregistrement;      integer8                        longueur_enregistrement;
Line 878  instruction_read(struct_processus *s_eta Line 880  instruction_read(struct_processus *s_eta
   
     struct flock                    lock;      struct flock                    lock;
   
       struct pollfd                   fds[1];
   
     struct sockaddr_un              adresse_unix;      struct sockaddr_un              adresse_unix;
     struct sockaddr_in              adresse_ipv4;      struct sockaddr_in              adresse_ipv4;
 #   ifdef IPV6  #   ifdef IPV6
     struct sockaddr_in6             adresse_ipv6;      struct sockaddr_in6             adresse_ipv6;
 #   endif  #   endif
   
       struct termios                  tc;
   
     struct timespec                 attente;      struct timespec                 attente;
   
     struct_descripteur_fichier      *descripteur;      struct_descripteur_fichier      *descripteur;
Line 906  instruction_read(struct_processus *s_eta Line 912  instruction_read(struct_processus *s_eta
     unsigned char                   *tampon_lecture;      unsigned char                   *tampon_lecture;
     unsigned char                   *tampon;      unsigned char                   *tampon;
     unsigned char                   *tampon2;      unsigned char                   *tampon2;
       unsigned char                   *tampon3;
   
       int                             vitesses[] =
                           {
                               50, 75, 110, 134, 150, 200, 300, 600,
                               1200, 1800, 2400, 4800, 9600, 19200, 38400,
   #ifdef B57600
                               57600,
   #endif
   #ifdef B115200
                               115200,
   #endif
   #ifdef B230400
                               230400,
   #endif
                               0
                           };
   
       tcflag_t                        vitesses_constantes[] =
                           {
                               B50, B75, B110, B134, B150, B200, B300, B600,
                               B1200, B1800, B2400, B4800, B9600, B19200, B38400,
   #ifdef B57600
                               B57600,
   #endif
   #ifdef B115200
                               B115200,
   #endif
   #ifdef B230400
                               B230400,
   #endif
                               0
                           };
   
     (*s_etat_processus).erreur_execution = d_ex;      (*s_etat_processus).erreur_execution = d_ex;
   
Line 1974  instruction_read(struct_processus *s_eta Line 2013  instruction_read(struct_processus *s_eta
   
                 BUG(((*descripteur).type != 'C'), uprintf("Bad filtype !\n"));                  BUG(((*descripteur).type != 'C'), uprintf("Bad filtype !\n"));
                 longueur_enregistrement = 0;                  longueur_enregistrement = 0;
   
                 device = d_faux;                  device = d_faux;
   
                 if ((position_initiale = ftell((*descripteur).descripteur_c))                  if ((position_initiale = ftell((*descripteur).descripteur_c))
Line 2073  instruction_read(struct_processus *s_eta Line 2113  instruction_read(struct_processus *s_eta
                     }                      }
   
                     free(format_chaine);                      free(format_chaine);
                       tampon3 = NULL;
   
                     if (format_degenere == d_vrai)                      if (format_degenere == d_vrai)
                     {                      {
                           if (device == d_vrai)
                           {
                               longueur_questure = 4096;
                               index = 0;
   
                               if ((tampon3 = malloc(((size_t) longueur_questure) *
                                       sizeof(unsigned char))) == NULL)
                               {
                                   (*s_etat_processus).erreur_systeme =
                                           d_es_allocation_memoire;
                                   return;
                               }
   
                               tampon3[index] = d_code_fin_chaine;
   
                               fds[0].fd = fileno((*descripteur).descripteur_c);
                               fds[0].events = POLLIN;
                               fds[0].revents = 0;
   
                               tcgetattr(fileno((*descripteur).descripteur_c),
                                       &tc);
                               timeout = 0;
   
                               for(i = 0; vitesses[i] != 0; i++)
                               {
                                   if (cfgetispeed(&tc) == vitesses_constantes[i])
                                   {
                                       // La durée entre deux caractères sur le
                                       // périphérique série ne doit pas dépasser
                                       // la moitié de la durée de transmission
                                       // d'un caractère complet.
   
                                       timeout = (int) (((double) 1000) /
                                               (((double) vitesses_constantes[i]) /
                                               4));
                                       break;
                                   }
                               }
                           }
   
                         do                          do
                         {                          {
                               if (device == d_vrai)
                               {
                                   if (poll(fds, 1, timeout) == 0)
                                   {
                                       break;
                                   }
                               }
   
                             c = getc((*descripteur).descripteur_c);                              c = getc((*descripteur).descripteur_c);
                             longueur_enregistrement++;                              longueur_enregistrement++;
                         } while((c != '\n') && (c != EOF));  
                               if (device == d_vrai)
                               {
                                   if (longueur_enregistrement >=
                                           longueur_questure)
                                   {
                                       if ((tampon3 = realloc(tampon3,
                                               (size_t) (longueur_questure *= 2)))
                                               == NULL)
                                       {
                                           (*s_etat_processus).erreur_systeme =
                                                   d_es_allocation_memoire;
                                           return;
                                       }
                                   }
   
                                   tampon3[index++] = (unsigned char) c;
                               }
                           } while(c != EOF);
   
                         if (device == d_faux)                          if (device == d_faux)
                         {                          {
Line 2102  instruction_read(struct_processus *s_eta Line 2209  instruction_read(struct_processus *s_eta
                         longueur_enregistrement = longueur;                          longueur_enregistrement = longueur;
                     }                      }
   
                     if ((tampon_lecture = malloc(((size_t)                      if ((device == d_vrai) && (format_degenere == d_vrai))
                             longueur_enregistrement) * sizeof(unsigned char)))  
                             == NULL)  
                     {                      {
                         (*s_etat_processus).erreur_systeme =                          longueur_effective = longueur_enregistrement;
                                 d_es_allocation_memoire;                          tampon_lecture = tampon3;
                         return;  
                     }                      }
                       else
                       {
                           if ((tampon_lecture = malloc(((size_t)
                                   longueur_enregistrement) *
                                   sizeof(unsigned char))) == NULL)
                           {
                               (*s_etat_processus).erreur_systeme =
                                       d_es_allocation_memoire;
                               return;
                           }
   
                     longueur_effective = (integer8) fread(tampon_lecture,                          longueur_effective = (integer8) fread(tampon_lecture,
                             sizeof(unsigned char),                                  sizeof(unsigned char),
                             (size_t) longueur_enregistrement,                                  (size_t) longueur_enregistrement,
                             (*descripteur).descripteur_c);                                  (*descripteur).descripteur_c);
                       }
   
                     if (l_element_courant == NULL)                      if (l_element_courant == NULL)
                     {                      {
Line 2154  instruction_read(struct_processus *s_eta Line 2269  instruction_read(struct_processus *s_eta
   
                     if (format_degenere == d_vrai)                      if (format_degenere == d_vrai)
                     {                      {
                         if (((*(*l_element_courant).donnee).objet =                          if (device == d_faux)
                             analyse_flux(s_etat_processus, tampon_lecture,  
                             longueur_enregistrement - 1)) == NULL)  
                         {                          {
                             return;                              if (((*(*l_element_courant).donnee).objet =
                                   analyse_flux(s_etat_processus, tampon_lecture,
                                   longueur_enregistrement - 1)) == NULL)
                               {
                                   return;
                               }
                           }
                           else
                           {
                               if (((*(*l_element_courant).donnee).objet =
                                   analyse_flux(s_etat_processus, tampon_lecture,
                                   longueur_enregistrement)) == NULL)
                               {
                                   return;
                               }
                         }                          }
                     }                      }
                     else                      else
Removed from v.1.83  
changed lines
  Added in v.1.84

CVSweb interface <joel.bertrand@systella.fr>