[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.103 and 1.124

version 1.103, 2017/06/28 09:20:35 version 1.124, 2025/04/15 10:17:55
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.27    RPL/2 (R) version 4.1.36
   Copyright (C) 1989-2017 Dr. BERTRAND Joël    Copyright (C) 1989-2025 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 869  instruction_read(struct_processus *s_eta Line 869  instruction_read(struct_processus *s_eta
   
     logical1                        device;      logical1                        device;
     logical1                        format_degenere;      logical1                        format_degenere;
       logical1                        format_oriente_ligne;
     logical1                        indicateur_48;      logical1                        indicateur_48;
     logical1                        presence_chaine;      logical1                        presence_chaine;
     logical1                        presence_indicateur;      logical1                        presence_indicateur;
Line 961  instruction_read(struct_processus *s_eta Line 962  instruction_read(struct_processus *s_eta
             printf("(read a record of a file)\n\n");              printf("(read a record of a file)\n\n");
         }          }
   
         printf("    1: %s, %s\n\n", d_FCH, d_SCK);          printf("    1: %s, %s\n", d_FCH, d_SCK);
           printf("->  1: %s\n\n", d_LST);
   
         printf("    2: %s, %s\n", d_INT, d_CHN);          printf("    2: %s, %s\n", d_INT, d_CHN);
         printf("    1: %s\n", d_FCH);          printf("    1: %s\n", d_FCH);
           printf("->  1: %s\n\n", d_LST);
         return;          return;
     }      }
     else if ((*s_etat_processus).test_instruction == 'Y')      else if ((*s_etat_processus).test_instruction == 'Y')
Line 2072  instruction_read(struct_processus *s_eta Line 2075  instruction_read(struct_processus *s_eta
                         return;                          return;
                     }                      }
   
                     if (strncmp("LENGTH*(", format_chaine, 8) != 0)                      if (strcmp("LINE*(*)", format_chaine) == 0)
                     {                      {
                         liberation(s_etat_processus, s_objet_argument_1);                          format_degenere = d_vrai;
                         liberation(s_etat_processus, s_objet_resultat);                          format_oriente_ligne = d_vrai;
                         free(format_chaine);  
   
                         (*s_etat_processus).erreur_execution =  
                                 d_ex_erreur_format_fichier;  
                         return;  
                     }                      }
                       else
                     longueur = (integer8) strlen(format_chaine);  
   
                     if (format_chaine[longueur - 1] != ')')  
                     {                      {
                         liberation(s_etat_processus, s_objet_argument_1);                          format_oriente_ligne = d_faux;
                         liberation(s_etat_processus, s_objet_resultat);  
                         free(format_chaine);  
   
                         (*s_etat_processus).erreur_execution =                          if (strncmp("LENGTH*(", format_chaine, 8) != 0)
                                 d_ex_erreur_format_fichier;                          {
                         return;                              liberation(s_etat_processus, s_objet_argument_1);
                     }                              liberation(s_etat_processus, s_objet_resultat);
                               free(format_chaine);
   
                     format_chaine[longueur] = d_code_fin_chaine;                              (*s_etat_processus).erreur_execution =
                                       d_ex_erreur_format_fichier;
                               return;
                           }
   
                     if (format_chaine[8] == '*')                          longueur = (integer8) strlen(format_chaine);
                     {  
                         format_degenere = d_vrai;  
                     }  
                     else  
                     {  
                         // Détermination de la longueur  
                         format_degenere = d_faux;  
   
                         if (sscanf(&(format_chaine[8]), "%lld", &longueur) != 1)                          if (format_chaine[longueur - 1] != ')')
                         {                          {
                             liberation(s_etat_processus, s_objet_argument_1);                              liberation(s_etat_processus, s_objet_argument_1);
                             liberation(s_etat_processus, s_objet_resultat);                              liberation(s_etat_processus, s_objet_resultat);
Line 2117  instruction_read(struct_processus *s_eta Line 2107  instruction_read(struct_processus *s_eta
                                     d_ex_erreur_format_fichier;                                      d_ex_erreur_format_fichier;
                             return;                              return;
                         }                          }
   
                           format_chaine[longueur] = d_code_fin_chaine;
   
                           if (format_chaine[8] == '*')
                           {
                               format_degenere = d_vrai;
                           }
                           else
                           {
                               // Détermination de la longueur
                               format_degenere = d_faux;
   
                               if (sscanf(&(format_chaine[8]), "%lld", &longueur)
                                       != 1)
                               {
                                   liberation(s_etat_processus,
                                           s_objet_argument_1);
                                   liberation(s_etat_processus, s_objet_resultat);
                                   free(format_chaine);
   
                                   (*s_etat_processus).erreur_execution =
                                           d_ex_erreur_format_fichier;
                                   return;
                               }
                           }
                     }                      }
   
                     free(format_chaine);                      free(format_chaine);
Line 2201  instruction_read(struct_processus *s_eta Line 2216  instruction_read(struct_processus *s_eta
   
                                 tampon3[index++] = (unsigned char) c;                                  tampon3[index++] = (unsigned char) c;
                             }                              }
   
                               if (format_oriente_ligne == d_vrai)
                               {
                                   if (c == '\n')
                                   {
                                       break;
                                   }
                               }
                         } while(c != EOF);                          } while(c != EOF);
   
                         if (device == d_faux)                          if (device == d_faux)
Line 2513  instruction_read(struct_processus *s_eta Line 2536  instruction_read(struct_processus *s_eta
                 }                  }
   
                 // Une donnée a été reçue.                  // Une donnée a été reçue.
                   // Attention : on peut TOUJOURS recevoir 0
                   // indiquant que la socket est close.
   
                 if (ios >= 0)                  if (ios >= 0)
                 {                  {
Line 2520  instruction_read(struct_processus *s_eta Line 2545  instruction_read(struct_processus *s_eta
                     position_initiale = 0;                      position_initiale = 0;
                     presence_indicateur = d_faux;                      presence_indicateur = d_faux;
   
                     do                      if (ios > 0)
                     {                      {
                         if (tampon_lecture[position_initiale] == '{')                          do
                         {                          {
                             presence_indicateur = d_vrai;                              if (tampon_lecture[position_initiale] == '{')
                             break;                              {
                         }                                  presence_indicateur = d_vrai;
                                   break;
                               }
   
                         position_initiale++;                              position_initiale++;
                     } while(position_initiale < longueur_effective);                          } while(position_initiale < longueur_effective);
                       }
                       else
                       {
                           presence_indicateur = d_vrai;
                       }
   
                     if (presence_indicateur == d_vrai)                      if (presence_indicateur == d_vrai)
                     {                      {
                         position_finale = position_initiale + 1;                          position_finale = position_initiale + 1;
                         presence_chaine = d_faux;                          presence_chaine = d_faux;
                         presence_indicateur = d_faux;                          presence_indicateur = d_faux;
                         niveau = 1;                          niveau = 0;
   
                         while(position_finale < longueur_effective)                          while(position_finale < longueur_effective)
                         {                          {
Line 2544  instruction_read(struct_processus *s_eta Line 2576  instruction_read(struct_processus *s_eta
   
                             if (caractere == '"')                              if (caractere == '"')
                             {                              {
                                 if (position_finale > 0)                                  if (tampon_lecture[position_finale - 1]
                                           != '\\')
                                 {                                  {
                                     if (tampon_lecture[position_finale - 1]                                      presence_chaine = (presence_chaine ==
                                             != '\\')                                              d_vrai) ? d_faux : d_vrai;
                                     {  
                                         presence_chaine = (presence_chaine ==  
                                                 d_vrai) ? d_faux : d_vrai;  
                                     }  
                                 }  
                                 else  
                                 {  
                                     presence_chaine =  
                                             (presence_chaine == d_vrai)  
                                             ? d_faux : d_vrai;  
                                 }                                  }
                             }                              }
                             else                              else
Line 2762  instruction_read(struct_processus *s_eta Line 2785  instruction_read(struct_processus *s_eta
                 }                  }
             } while(trame_complete == d_faux);              } while(trame_complete == d_faux);
   
             tampon_lecture[++position_finale] = d_code_fin_chaine;  
             tampon = (*s_etat_processus).instruction_courante;              tampon = (*s_etat_processus).instruction_courante;
             (*s_etat_processus).instruction_courante = tampon_lecture;              (*s_etat_processus).instruction_courante = tampon_lecture;
   
Line 3156  instruction_read(struct_processus *s_eta Line 3178  instruction_read(struct_processus *s_eta
                     return;                      return;
                 }                  }
   
                 if (ios <= 0)                  if (ios < 0)
                 {                  {
                     nanosleep(&attente, NULL);                      nanosleep(&attente, NULL);
                     INCR_GRANULARITE(attente.tv_nsec);                      INCR_GRANULARITE(attente.tv_nsec);
Line 3187  instruction_read(struct_processus *s_eta Line 3209  instruction_read(struct_processus *s_eta
                     position_initiale = 0;                      position_initiale = 0;
                     presence_indicateur = d_faux;                      presence_indicateur = d_faux;
                 }                  }
                 else if (ios > 0)                  else if (ios >= 0)
                 {                  {
                     // On retire une trame du buffer.                      // On retire une trame du buffer.
   
Line 3526  instruction_read(struct_processus *s_eta Line 3548  instruction_read(struct_processus *s_eta
   
             do              do
             {              {
                 if ((tampon_lecture = malloc((((long long unsigned int)                  if ((tampon_lecture = malloc((((size_t) longueur_questure) + 1)
                         longueur_questure) + 1) *                          * sizeof(unsigned char))) == NULL)
                         sizeof(unsigned char))) == NULL)  
                 {                  {
                     (*s_etat_processus).erreur_systeme =                      (*s_etat_processus).erreur_systeme =
                             d_es_allocation_memoire;                              d_es_allocation_memoire;
Line 3679  instruction_read(struct_processus *s_eta Line 3700  instruction_read(struct_processus *s_eta
   
                 if (longueur_effective == longueur_questure)                  if (longueur_effective == longueur_questure)
                 {                  {
                       trame_complete = d_faux;
                     free(tampon_lecture);                      free(tampon_lecture);
                     longueur_questure *= 2;  
                       // Taille standard des jumbo frames
                       if (longueur_questure <= 9000)
                       {
                           longueur_questure *= 2;
                       }
                       else
                       {
                           longueur_questure += 9000;
                       }
                   }
                   else
                   {
                       trame_complete = d_vrai;
                 }                  }
             } while(longueur_effective == longueur_questure);              } while(trame_complete == d_faux);
   
             longueur_enregistrement = 1;              longueur_enregistrement = 1;
   
             for(i = 0; i < longueur_effective; i++)              for(i = 0; i < longueur_effective; i++)
             {              {
                 if (isprint(tampon_lecture[i]) != 0)                  if (isprint(tampon_lecture[i]) == 0)
                 {                  {
                     longueur_enregistrement += 4;                      longueur_enregistrement += 4;
                 }                  }
                 else                  else
                 {                  {
                     longueur_enregistrement++;                      if ((tampon_lecture[i] == '"') ||
                               (tampon_lecture[i] == '\\'))
                       {
                           longueur_enregistrement += 2;
                       }
                       else
                       {
                           longueur_enregistrement++;
                       }
                 }                  }
             }              }
   
Line 3708  instruction_read(struct_processus *s_eta Line 3751  instruction_read(struct_processus *s_eta
                 return;                  return;
             }              }
   
             if (((*s_objet_type).objet = malloc((long long unsigned int)              if (((*s_objet_type).objet = malloc((size_t) longueur_enregistrement
                     longueur_enregistrement *                      * sizeof(unsigned char))) == NULL)
                     sizeof(unsigned char))) == NULL)  
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;                  (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 return;                  return;
Line 3722  instruction_read(struct_processus *s_eta Line 3764  instruction_read(struct_processus *s_eta
             {              {
                 if (isprint(tampon_lecture[i]) != 0)                  if (isprint(tampon_lecture[i]) != 0)
                 {                  {
                     (*ptr) = tampon_lecture[i];                      if ((tampon_lecture[i] == '"') ||
                     ptr++;                              (tampon_lecture[i] == '\\'))
                       {
                           (*ptr) = '\\';
                           ptr++;
                           (*ptr) = tampon_lecture[i];
                           ptr++;
                       }
                       else
                       {
                           (*ptr) = tampon_lecture[i];
                           ptr++;
                       }
                 }                  }
                 else                  else
                 {                  {
Removed from v.1.103  
changed lines
  Added in v.1.124

CVSweb interface <joel.bertrand@systella.fr>