Diff for /rpl/src/gestion_processus.c between versions 1.61 and 1.62

version 1.61, 2013/02/27 17:11:40 version 1.62, 2013/03/20 17:11:44
Line 40 Line 40
 void *  void *
 surveillance_processus(void *argument)  surveillance_processus(void *argument)
 {  {
     int                             iostat;  
     int                             status;      int                             status;
   
     integer8                        nombre_donnees;      integer8                        nombre_donnees;
Line 57  surveillance_processus(void *argument) Line 56  surveillance_processus(void *argument)
   
     pthread_t                       tid_candidat;      pthread_t                       tid_candidat;
   
       ssize_t                         iostat;
     ssize_t                         longueur_ecriture;      ssize_t                         longueur_ecriture;
   
     struct_descripteur_thread       *s_argument_thread;      struct_descripteur_thread       *s_argument_thread;
Line 70  surveillance_processus(void *argument) Line 70  surveillance_processus(void *argument)
   
     unsigned char                   caractere;      unsigned char                   caractere;
   
     unsigned int                    tampon_erreur_execution;      int                             tampon_erreur_execution;
     unsigned int                    tampon_erreur_systeme;      int                             tampon_erreur_systeme;
   
     sigset_t                                set;      sigset_t                        set;
   
     sigfillset(&set);      sigfillset(&set);
     pthread_sigmask(SIG_BLOCK, &set, NULL);      pthread_sigmask(SIG_BLOCK, &set, NULL);
Line 1860  ecriture_pipe(struct_processus *s_etat_p Line 1860  ecriture_pipe(struct_processus *s_etat_p
   
     struct timespec                 attente;      struct timespec                 attente;
   
     unsigned long                   i;      integer8                        i;
     unsigned long                   j;      integer8                        j;
   
     size_t                          longueur;      size_t                          longueur;
     ssize_t                         longueur_ecriture;      ssize_t                         longueur_ecriture;
Line 2708  lecture_pipe(struct_processus *s_etat_pr Line 2708  lecture_pipe(struct_processus *s_etat_pr
   
     struct timespec         attente;      struct timespec         attente;
   
     unsigned long           i;      integer8                i;
     unsigned long           j;      integer8                j;
   
     if ((s_objet = allocation(s_etat_processus, NON)) == NULL)      if ((s_objet = allocation(s_etat_processus, NON)) == NULL)
     {      {
Line 2803  lecture_pipe(struct_processus *s_etat_pr Line 2803  lecture_pipe(struct_processus *s_etat_pr
         }          }
   
         if (((*((struct_vecteur *) (*s_objet).objet)).tableau =          if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
                 malloc((*((struct_vecteur *) (*s_objet).objet)).taille *                  malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
                 sizeof(integer8))) == NULL)                  .taille) * sizeof(integer8))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 2847  lecture_pipe(struct_processus *s_etat_pr Line 2847  lecture_pipe(struct_processus *s_etat_pr
         }          }
   
         if (((*((struct_vecteur *) (*s_objet).objet)).tableau =          if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
                 malloc((*((struct_vecteur *) (*s_objet).objet)).taille *                  malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
                 sizeof(real8))) == NULL)                  .taille) * sizeof(real8))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 2891  lecture_pipe(struct_processus *s_etat_pr Line 2891  lecture_pipe(struct_processus *s_etat_pr
         }          }
   
         if (((*((struct_vecteur *) (*s_objet).objet)).tableau =          if (((*((struct_vecteur *) (*s_objet).objet)).tableau =
                 malloc((*((struct_vecteur *) (*s_objet).objet)).taille *                  malloc(((size_t) (*((struct_vecteur *) (*s_objet).objet))
                 sizeof(complex16))) == NULL)                  .taille) * sizeof(complex16))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 2946  lecture_pipe(struct_processus *s_etat_pr Line 2946  lecture_pipe(struct_processus *s_etat_pr
         }          }
   
         if (((*((struct_matrice *) (*s_objet).objet)).tableau =          if (((*((struct_matrice *) (*s_objet).objet)).tableau =
                 malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *                  malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
                 sizeof(integer8 *))) == NULL)                  .nombre_lignes) * sizeof(integer8 *))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 2957  lecture_pipe(struct_processus *s_etat_pr Line 2957  lecture_pipe(struct_processus *s_etat_pr
                 (*s_objet).objet)).nombre_lignes; i++)                  (*s_objet).objet)).nombre_lignes; i++)
         {          {
             if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =              if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
                     malloc((*((struct_matrice *) (*s_objet).objet))                      malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
                     .nombre_colonnes * sizeof(integer8))) == NULL)                      .nombre_colonnes) * sizeof(integer8))) == NULL)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;                  (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 return(NULL);                  return(NULL);
Line 3014  lecture_pipe(struct_processus *s_etat_pr Line 3014  lecture_pipe(struct_processus *s_etat_pr
         }          }
   
         if (((*((struct_matrice *) (*s_objet).objet)).tableau =          if (((*((struct_matrice *) (*s_objet).objet)).tableau =
                 malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *                  malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
                 sizeof(real8 *))) == NULL)                  .nombre_lignes) * sizeof(real8 *))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 3025  lecture_pipe(struct_processus *s_etat_pr Line 3025  lecture_pipe(struct_processus *s_etat_pr
                 (*s_objet).objet)).nombre_lignes; i++)                  (*s_objet).objet)).nombre_lignes; i++)
         {          {
             if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =              if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
                     malloc((*((struct_matrice *) (*s_objet).objet))                      malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
                     .nombre_colonnes * sizeof(real8))) == NULL)                      .nombre_colonnes) * sizeof(real8))) == NULL)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;                  (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 return(NULL);                  return(NULL);
Line 3082  lecture_pipe(struct_processus *s_etat_pr Line 3082  lecture_pipe(struct_processus *s_etat_pr
         }          }
   
         if (((*((struct_matrice *) (*s_objet).objet)).tableau =          if (((*((struct_matrice *) (*s_objet).objet)).tableau =
                 malloc((*((struct_matrice *) (*s_objet).objet)).nombre_lignes *                  malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
                 sizeof(complex16 *))) == NULL)                  .nombre_lignes) * sizeof(complex16 *))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 3093  lecture_pipe(struct_processus *s_etat_pr Line 3093  lecture_pipe(struct_processus *s_etat_pr
                 (*s_objet).objet)).nombre_lignes; i++)                  (*s_objet).objet)).nombre_lignes; i++)
         {          {
             if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =              if ((((*((struct_matrice *) (*s_objet).objet)).tableau)[i] =
                     malloc((*((struct_matrice *) (*s_objet).objet))                      malloc(((size_t) (*((struct_matrice *) (*s_objet).objet))
                     .nombre_colonnes * sizeof(complex16))) == NULL)                      .nombre_colonnes) * sizeof(complex16))) == NULL)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;                  (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 return(NULL);                  return(NULL);
Line 3350  lecture_pipe(struct_processus *s_etat_pr Line 3350  lecture_pipe(struct_processus *s_etat_pr
         }          }
   
         if (((*((struct_tableau *) (*s_objet).objet)).elements = malloc(          if (((*((struct_tableau *) (*s_objet).objet)).elements = malloc(
                 (*((struct_tableau *) (*s_objet).objet)).nombre_elements *                  ((size_t) (*((struct_tableau *) (*s_objet).objet))
                 sizeof(struct_objet *))) == NULL)                  .nombre_elements) * sizeof(struct_objet *))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);

Removed from v.1.61  
changed lines
  Added in v.1.62


CVSweb interface <joel.bertrand@systella.fr>