Diff for /rpl/src/instructions_r4.c between versions 1.75 and 1.76

version 1.75, 2013/03/18 10:32:41 version 1.76, 2013/03/20 22:24:37
Line 96  instruction_r_vers_b(struct_processus *s Line 96  instruction_r_vers_b(struct_processus *s
         }          }
         else          else
         {          {
             (*((logical8 *) (*s_objet_resultat).objet)) = (*((integer8 *)              (*((logical8 *) (*s_objet_resultat).objet)) = (logical8)
                     (*s_objet_argument).objet));                      (*((integer8 *) (*s_objet_argument).objet));
         }          }
     }      }
     else      else
Line 1053  instruction_read(struct_processus *s_eta Line 1053  instruction_read(struct_processus *s_eta
   
                 longueur_questure = 4096;                  longueur_questure = 4096;
   
                 if ((tampon_lecture = malloc(longueur_questure *                  if ((tampon_lecture = malloc(((size_t) longueur_questure) *
                         sizeof(unsigned char))) == NULL)                          sizeof(unsigned char))) == NULL)
                 {                  {
                     (*s_etat_processus).erreur_systeme =                      (*s_etat_processus).erreur_systeme =
Line 1072  instruction_read(struct_processus *s_eta Line 1072  instruction_read(struct_processus *s_eta
   
                 do                  do
                 {                  {
                     longueur_effective = fread(tampon_lecture,                      longueur_effective = (integer8) fread(tampon_lecture,
                             (size_t) sizeof(unsigned char), longueur_questure,                              sizeof(unsigned char), (size_t) longueur_questure,
                             (*descripteur).descripteur_c);                              (*descripteur).descripteur_c);
   
                     pointeur = 0;                      pointeur = 0;
Line 1123  instruction_read(struct_processus *s_eta Line 1123  instruction_read(struct_processus *s_eta
   
                 do                  do
                 {                  {
                     longueur_effective = fread(tampon_lecture,                      longueur_effective = (integer8) fread(tampon_lecture,
                             (size_t) sizeof(unsigned char), longueur_questure,                              sizeof(unsigned char), (size_t) longueur_questure,
                             (*descripteur).descripteur_c);                              (*descripteur).descripteur_c);
   
                     pointeur = 0;                      pointeur = 0;
Line 1192  instruction_read(struct_processus *s_eta Line 1192  instruction_read(struct_processus *s_eta
                 free(tampon_lecture);                  free(tampon_lecture);
                 longueur_enregistrement = position_finale - position_initiale;                  longueur_enregistrement = position_finale - position_initiale;
   
                 if ((tampon_lecture = malloc((longueur_enregistrement + 1) *                  if ((tampon_lecture = malloc(((size_t)
                           (longueur_enregistrement + 1)) *
                         sizeof(unsigned char))) == NULL)                          sizeof(unsigned char))) == NULL)
                 {                  {
                     (*s_etat_processus).erreur_systeme =                      (*s_etat_processus).erreur_systeme =
Line 1210  instruction_read(struct_processus *s_eta Line 1211  instruction_read(struct_processus *s_eta
                     return;                      return;
                 }                  }
   
                 longueur_effective = fread(tampon_lecture,                  longueur_effective = (integer8) fread(tampon_lecture,
                         (size_t) sizeof(unsigned char),                          sizeof(unsigned char), (size_t) longueur_enregistrement,
                         (size_t) longueur_enregistrement,  
                         (*descripteur).descripteur_c);                          (*descripteur).descripteur_c);
   
                 if (longueur_effective != longueur_enregistrement)                  if (longueur_effective != longueur_enregistrement)
Line 1302  instruction_read(struct_processus *s_eta Line 1302  instruction_read(struct_processus *s_eta
                 }                  }
   
                 if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,                  if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
                         commande, strlen(commande), &ppStmt, &queue)                          commande, (int) strlen(commande), &ppStmt, &queue)
                         != SQLITE_OK)                          != SQLITE_OK)
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;                      (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
Line 1473  instruction_read(struct_processus *s_eta Line 1473  instruction_read(struct_processus *s_eta
                 }                  }
   
                 if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,                  if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
                         commande, strlen(commande), &ppStmt, &queue)                          commande, (int) strlen(commande), &ppStmt, &queue)
                         != SQLITE_OK)                          != SQLITE_OK)
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;                      (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
Line 1547  instruction_read(struct_processus *s_eta Line 1547  instruction_read(struct_processus *s_eta
                 }                  }
   
                 if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,                  if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
                         commande, strlen(commande), &ppStmt, &queue)                          commande, (int) strlen(commande), &ppStmt, &queue)
                         != SQLITE_OK)                          != SQLITE_OK)
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;                      (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
Line 1640  instruction_read(struct_processus *s_eta Line 1640  instruction_read(struct_processus *s_eta
                 }                  }
   
                 if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,                  if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
                         commande, strlen(commande), &ppStmt, &queue)                          commande, (int) strlen(commande), &ppStmt, &queue)
                         != SQLITE_OK)                          != SQLITE_OK)
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;                      (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
Line 2028  instruction_read(struct_processus *s_eta Line 2028  instruction_read(struct_processus *s_eta
                         return;                          return;
                     }                      }
   
                     longueur = strlen(format_chaine);                      longueur = (integer8) strlen(format_chaine);
   
                     if (format_chaine[longueur - 1] != ')')                      if (format_chaine[longueur - 1] != ')')
                     {                      {
Line 2090  instruction_read(struct_processus *s_eta Line 2090  instruction_read(struct_processus *s_eta
                         longueur_enregistrement = longueur;                          longueur_enregistrement = longueur;
                     }                      }
   
                     if ((tampon_lecture = malloc((longueur_enregistrement)                      if ((tampon_lecture = malloc(((size_t)
                             * sizeof(unsigned char))) == NULL)                              longueur_enregistrement) * sizeof(unsigned char)))
                               == NULL)
                     {                      {
                         (*s_etat_processus).erreur_systeme =                          (*s_etat_processus).erreur_systeme =
                                 d_es_allocation_memoire;                                  d_es_allocation_memoire;
                         return;                          return;
                     }                      }
   
                     longueur_effective = fread(tampon_lecture,                      longueur_effective = (integer8) fread(tampon_lecture,
                             (size_t) sizeof(unsigned char),                              sizeof(unsigned char),
                             (size_t) longueur_enregistrement,                              (size_t) longueur_enregistrement,
                             (*descripteur).descripteur_c);                              (*descripteur).descripteur_c);
   
Line 2233  instruction_read(struct_processus *s_eta Line 2234  instruction_read(struct_processus *s_eta
                 presence_indicateur = d_faux;                  presence_indicateur = d_faux;
   
                 if ((tampon_lecture = realloc(tampon_lecture,                  if ((tampon_lecture = realloc(tampon_lecture,
                         (longueur_effective + longueur_questure + 1)                          ((size_t) (longueur_effective + longueur_questure + 1))
                         * sizeof(unsigned char))) == NULL)                          * sizeof(unsigned char))) == NULL)
                 {                  {
                     (*s_etat_processus).erreur_systeme =                      (*s_etat_processus).erreur_systeme =
Line 2258  instruction_read(struct_processus *s_eta Line 2259  instruction_read(struct_processus *s_eta
   
                     do                      do
                     {                      {
                         ios = recvfrom((*((struct_socket *)                          ios = (int) recvfrom((*((struct_socket *)
                                 (*s_objet_argument_1).objet)).socket,                                  (*s_objet_argument_1).objet)).socket,
                                 tampon_lecture,                                  tampon_lecture, (size_t) (longueur_effective +
                                 longueur_effective + longueur_questure,                                  longueur_questure),
                                 MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)                                  MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
                                 &adresse_unix, &longueur_adresse);                                  &adresse_unix, &longueur_adresse);
                     } while((ios == -1) && (errno == EINTR));                      } while((ios == -1) && (errno == EINTR));
Line 2273  instruction_read(struct_processus *s_eta Line 2274  instruction_read(struct_processus *s_eta
   
                     do                      do
                     {                      {
                         ios = recvfrom((*((struct_socket *)                          ios = (int) recvfrom((*((struct_socket *)
                                 (*s_objet_argument_1).objet)).socket,                                  (*s_objet_argument_1).objet)).socket,
                                 tampon_lecture,                                  tampon_lecture, (size_t) (longueur_effective +
                                 longueur_effective + longueur_questure,                                  longueur_questure),
                                 MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)                                  MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
                                 &adresse_ipv4, &longueur_adresse);                                  &adresse_ipv4, &longueur_adresse);
                     } while((ios == -1) && (errno == EINTR));                      } while((ios == -1) && (errno == EINTR));
Line 2289  instruction_read(struct_processus *s_eta Line 2290  instruction_read(struct_processus *s_eta
                                           
                     do                      do
                     {                      {
                         ios = recvfrom((*((struct_socket *)                          ios = (int) recvfrom((*((struct_socket *)
                                 (*s_objet_argument_1).objet)).socket,                                  (*s_objet_argument_1).objet)).socket,
                                 tampon_lecture,                                  tampon_lecture, (size_t) (longueur_effective +
                                 longueur_effective + longueur_questure,                                  longueur_questure),
                                 MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)                                  MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
                                 &adresse_ipv6, &longueur_adresse);                                  &adresse_ipv6, &longueur_adresse);
                     } while((ios == -1) && (errno == EINTR));                      } while((ios == -1) && (errno == EINTR));
Line 2444  instruction_read(struct_processus *s_eta Line 2445  instruction_read(struct_processus *s_eta
                                 longueur_adresse = sizeof(adresse_unix);                                  longueur_adresse = sizeof(adresse_unix);
                                 recvfrom((*((struct_socket *)                                  recvfrom((*((struct_socket *)
                                         (*s_objet_argument_1).objet)).socket,                                          (*s_objet_argument_1).objet)).socket,
                                         tampon_lecture, longueur_effective,                                          tampon_lecture,
                                           (size_t) longueur_effective,
                                         0, (struct sockaddr *)                                          0, (struct sockaddr *)
                                         &adresse_unix, &longueur_adresse);                                          &adresse_unix, &longueur_adresse);
                             } while((ios == -1) && (errno == EINTR));                              } while((ios == -1) && (errno == EINTR));
Line 2457  instruction_read(struct_processus *s_eta Line 2459  instruction_read(struct_processus *s_eta
                                 longueur_adresse = sizeof(adresse_ipv4);                                  longueur_adresse = sizeof(adresse_ipv4);
                                 recvfrom((*((struct_socket *)                                  recvfrom((*((struct_socket *)
                                         (*s_objet_argument_1).objet)).socket,                                          (*s_objet_argument_1).objet)).socket,
                                         tampon_lecture, longueur_effective,                                          tampon_lecture,
                                           (size_t) longueur_effective,
                                         0, (struct sockaddr *)                                          0, (struct sockaddr *)
                                         &adresse_ipv4, &longueur_adresse);                                          &adresse_ipv4, &longueur_adresse);
                             } while((ios == -1) && (errno == EINTR));                              } while((ios == -1) && (errno == EINTR));
Line 2471  instruction_read(struct_processus *s_eta Line 2474  instruction_read(struct_processus *s_eta
                                 longueur_adresse = sizeof(adresse_ipv6);                                  longueur_adresse = sizeof(adresse_ipv6);
                                 recvfrom((*((struct_socket *)                                  recvfrom((*((struct_socket *)
                                         (*s_objet_argument_1).objet)).socket,                                          (*s_objet_argument_1).objet)).socket,
                                         tampon_lecture, longueur_effective,                                          tampon_lecture,
                                           (size_t) longueur_effective,
                                         0, (struct sockaddr *)                                          0, (struct sockaddr *)
                                         &adresse_ipv6, &longueur_adresse);                                          &adresse_ipv6, &longueur_adresse);
                             } while((ios == -1) && (errno == EINTR));                              } while((ios == -1) && (errno == EINTR));
Line 2836  instruction_read(struct_processus *s_eta Line 2840  instruction_read(struct_processus *s_eta
                 longueur_adresse = 0;                  longueur_adresse = 0;
                 recvfrom((*((struct_socket *)                  recvfrom((*((struct_socket *)
                         (*s_objet_argument_1).objet)).socket, tampon_lecture,                          (*s_objet_argument_1).objet)).socket, tampon_lecture,
                         position_finale, MSG_DONTWAIT,                          (size_t) position_finale, MSG_DONTWAIT,
                         NULL, &longueur_adresse);                          NULL, &longueur_adresse);
             }              }
   
Line 2867  instruction_read(struct_processus *s_eta Line 2871  instruction_read(struct_processus *s_eta
                 presence_indicateur = d_faux;                  presence_indicateur = d_faux;
   
                 if ((tampon_lecture = realloc(tampon_lecture,                  if ((tampon_lecture = realloc(tampon_lecture,
                         (longueur_effective + longueur_questure + 1)                          ((size_t) (longueur_effective + longueur_questure) + 1)
                         * sizeof(unsigned char))) == NULL)                          * sizeof(unsigned char))) == NULL)
                 {                  {
                     (*s_etat_processus).erreur_systeme =                      (*s_etat_processus).erreur_systeme =
Line 2892  instruction_read(struct_processus *s_eta Line 2896  instruction_read(struct_processus *s_eta
   
                     do                      do
                     {                      {
                         ios = recvfrom((*((struct_socket *)                          ios = (int) recvfrom((*((struct_socket *)
                                 (*s_objet_argument_1).objet)).socket,                                  (*s_objet_argument_1).objet)).socket,
                                 tampon_lecture,                                  tampon_lecture, (size_t)
                                 longueur_effective + longueur_questure,                                  (longueur_effective + longueur_questure),
                                 MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)                                  MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
                                 &adresse_unix, &longueur_adresse);                                  &adresse_unix, &longueur_adresse);
                     } while((ios == -1) && (errno == EINTR));                      } while((ios == -1) && (errno == EINTR));
Line 2907  instruction_read(struct_processus *s_eta Line 2911  instruction_read(struct_processus *s_eta
   
                     do                      do
                     {                      {
                         ios = recvfrom((*((struct_socket *)                          ios = (int) recvfrom((*((struct_socket *)
                                 (*s_objet_argument_1).objet)).socket,                                  (*s_objet_argument_1).objet)).socket,
                                 tampon_lecture,                                  tampon_lecture, (size_t)
                                 longueur_effective + longueur_questure,                                  (longueur_effective + longueur_questure),
                                 MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)                                  MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
                                 &adresse_ipv4, &longueur_adresse);                                  &adresse_ipv4, &longueur_adresse);
                     } while((ios == -1) && (errno == EINTR));                      } while((ios == -1) && (errno == EINTR));
Line 2923  instruction_read(struct_processus *s_eta Line 2927  instruction_read(struct_processus *s_eta
                                           
                     do                      do
                     {                      {
                         ios = recvfrom((*((struct_socket *)                          ios = (int) recvfrom((*((struct_socket *)
                                 (*s_objet_argument_1).objet)).socket,                                  (*s_objet_argument_1).objet)).socket,
                                 tampon_lecture,                                  tampon_lecture, (size_t)
                                 longueur_effective + longueur_questure,                                  (longueur_effective + longueur_questure),
                                 MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)                                  MSG_PEEK | MSG_DONTWAIT, (struct sockaddr *)
                                 &adresse_ipv6, &longueur_adresse);                                  &adresse_ipv6, &longueur_adresse);
                     } while((ios == -1) && (errno == EINTR));                      } while((ios == -1) && (errno == EINTR));
Line 3012  instruction_read(struct_processus *s_eta Line 3016  instruction_read(struct_processus *s_eta
                             longueur_adresse = sizeof(adresse_unix);                              longueur_adresse = sizeof(adresse_unix);
                             recvfrom((*((struct_socket *)                              recvfrom((*((struct_socket *)
                                     (*s_objet_argument_1).objet)).socket,                                      (*s_objet_argument_1).objet)).socket,
                                     tampon_lecture, longueur_effective,                                      tampon_lecture, (size_t) longueur_effective,
                                     0, (struct sockaddr *)                                      0, (struct sockaddr *)
                                     &adresse_unix, &longueur_adresse);                                      &adresse_unix, &longueur_adresse);
                         } while((ios == -1) && (errno == EINTR));                          } while((ios == -1) && (errno == EINTR));
Line 3025  instruction_read(struct_processus *s_eta Line 3029  instruction_read(struct_processus *s_eta
                             longueur_adresse = sizeof(adresse_ipv4);                              longueur_adresse = sizeof(adresse_ipv4);
                             recvfrom((*((struct_socket *)                              recvfrom((*((struct_socket *)
                                     (*s_objet_argument_1).objet)).socket,                                      (*s_objet_argument_1).objet)).socket,
                                     tampon_lecture, longueur_effective,                                      tampon_lecture, (size_t) longueur_effective,
                                     0, (struct sockaddr *)                                      0, (struct sockaddr *)
                                     &adresse_ipv4, &longueur_adresse);                                      &adresse_ipv4, &longueur_adresse);
                         } while((ios == -1) && (errno == EINTR));                          } while((ios == -1) && (errno == EINTR));
Line 3039  instruction_read(struct_processus *s_eta Line 3043  instruction_read(struct_processus *s_eta
                             longueur_adresse = sizeof(adresse_ipv6);                              longueur_adresse = sizeof(adresse_ipv6);
                             recvfrom((*((struct_socket *)                              recvfrom((*((struct_socket *)
                                     (*s_objet_argument_1).objet)).socket,                                      (*s_objet_argument_1).objet)).socket,
                                     tampon_lecture, longueur_effective,                                      tampon_lecture, (size_t) longueur_effective,
                                     0, (struct sockaddr *)                                      0, (struct sockaddr *)
                                     &adresse_ipv6, &longueur_adresse);                                      &adresse_ipv6, &longueur_adresse);
                         } while((ios == -1) && (errno == EINTR));                          } while((ios == -1) && (errno == EINTR));
Line 3321  instruction_read(struct_processus *s_eta Line 3325  instruction_read(struct_processus *s_eta
                 longueur_adresse = 0;                  longueur_adresse = 0;
                 recvfrom((*((struct_socket *)                  recvfrom((*((struct_socket *)
                         (*s_objet_argument_1).objet)).socket, tampon_lecture,                          (*s_objet_argument_1).objet)).socket, tampon_lecture,
                         position_finale, MSG_DONTWAIT,                          (size_t) position_finale, MSG_DONTWAIT,
                         NULL, &longueur_adresse);                          NULL, &longueur_adresse);
             }              }
   

Removed from v.1.75  
changed lines
  Added in v.1.76


CVSweb interface <joel.bertrand@systella.fr>