Diff for /rpl/src/gestion_processus.c between versions 1.35 and 1.63

version 1.35, 2011/04/21 16:00:55 version 1.63, 2013/03/21 12:07:38
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.0.prerelease.0    RPL/2 (R) version 4.1.13
   Copyright (C) 1989-2011 Dr. BERTRAND Joël    Copyright (C) 1989-2013 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
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;
   
     sigset_t                        masque;      ssize_t                         iostat;
   
     ssize_t                         longueur_ecriture;      ssize_t                         longueur_ecriture;
   
     struct_descripteur_thread       *s_argument_thread;      struct_descripteur_thread       *s_argument_thread;
Line 72  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;
   
     sigemptyset(&masque);      sigfillset(&set);
     sigaddset(&masque, SIGINJECT);      pthread_sigmask(SIG_BLOCK, &set, NULL);
     sigaddset(&masque, SIGFSTOP);  
     sigaddset(&masque, SIGFABORT);  
     sigaddset(&masque, SIGURG);  
     sigaddset(&masque, SIGALRM);  
     sigaddset(&masque, SIGCONT);  
     sigaddset(&masque, SIGINT);  
     pthread_sigmask(SIG_BLOCK, &masque, NULL);  
   
     s_argument_thread = argument;      s_argument_thread = argument;
     s_etat_processus = (*s_argument_thread).s_etat_processus;      s_etat_processus = (*s_argument_thread).s_etat_processus;
Line 344  surveillance_processus(void *argument) Line 337  surveillance_processus(void *argument)
                                     d_es_processus;                                      d_es_processus;
                         }                          }
   
                         pthread_kill((*s_argument_thread).thread_pere,                          envoi_signal_thread((*s_argument_thread).thread_pere,
                                 SIGINJECT);                                  rpl_siginject);
                     }                      }
                 }                  }
                 else                  else
Line 530  surveillance_processus(void *argument) Line 523  surveillance_processus(void *argument)
                                     d_es_processus;                                      d_es_processus;
                         }                          }
   
                         pthread_kill((*s_argument_thread).thread_pere,                          envoi_signal_thread((*s_argument_thread).thread_pere,
                                 SIGINJECT);                                  rpl_siginject);
                     }                      }
                 }                  }
                 else                  else
Line 926  surveillance_processus(void *argument) Line 919  surveillance_processus(void *argument)
                                     d_es_processus;                                      d_es_processus;
                         }                          }
   
                         pthread_kill((*s_argument_thread).thread_pere,                          envoi_signal_thread((*s_argument_thread).thread_pere,
                                 SIGINJECT);                                  rpl_siginject);
                     }                      }
                 }                  }
                 else                  else
Line 1867  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 1998  ecriture_pipe(struct_processus *s_etat_p Line 1991  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_vecteur *) (*s_objet).objet))                  &((*((struct_vecteur *) (*s_objet).objet))
                 .taille), sizeof(unsigned long))) != sizeof(unsigned long))                  .taille), sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2051  ecriture_pipe(struct_processus *s_etat_p Line 2044  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_vecteur *) (*s_objet).objet))                  &((*((struct_vecteur *) (*s_objet).objet))
                 .taille), sizeof(unsigned long))) != sizeof(unsigned long))                  .taille), sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2104  ecriture_pipe(struct_processus *s_etat_p Line 2097  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_vecteur *) (*s_objet).objet))                  &((*((struct_vecteur *) (*s_objet).objet))
                 .taille), sizeof(unsigned long))) != sizeof(unsigned long))                  .taille), sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2157  ecriture_pipe(struct_processus *s_etat_p Line 2150  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),                  &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2173  ecriture_pipe(struct_processus *s_etat_p Line 2166  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),                  &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2232  ecriture_pipe(struct_processus *s_etat_p Line 2225  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),                  &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2248  ecriture_pipe(struct_processus *s_etat_p Line 2241  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),                  &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2307  ecriture_pipe(struct_processus *s_etat_p Line 2300  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),                  &((*((struct_matrice *) (*s_objet).objet)).nombre_lignes),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2323  ecriture_pipe(struct_processus *s_etat_p Line 2316  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),                  &((*((struct_matrice *) (*s_objet).objet)).nombre_colonnes),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2517  ecriture_pipe(struct_processus *s_etat_p Line 2510  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_fonction *) (*s_objet).objet)).nombre_arguments),                  &((*((struct_fonction *) (*s_objet).objet)).nombre_arguments),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2659  ecriture_pipe(struct_processus *s_etat_p Line 2652  ecriture_pipe(struct_processus *s_etat_p
   
         while((longueur_ecriture = write_atomic(s_etat_processus, pipe,          while((longueur_ecriture = write_atomic(s_etat_processus, pipe,
                 &((*((struct_tableau *) (*s_objet).objet)).nombre_elements),                  &((*((struct_tableau *) (*s_objet).objet)).nombre_elements),
                 sizeof(unsigned long))) != sizeof(unsigned long))                  sizeof(integer8))) != sizeof(integer8))
         {          {
             if (longueur_ecriture == -1)              if (longueur_ecriture == -1)
             {              {
Line 2715  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 2796  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
                 (*s_objet).objet)).taille),                  (*s_objet).objet)).taille),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
         }          }
   
         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 2840  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
                 (*s_objet).objet)).taille),                  (*s_objet).objet)).taille),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
         }          }
   
         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 2884  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_vecteur *)
                 (*s_objet).objet)).taille),                  (*s_objet).objet)).taille),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
         }          }
   
         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 2935  lecture_pipe(struct_processus *s_etat_pr Line 2928  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
                 (*s_objet).objet)).nombre_lignes),                  (*s_objet).objet)).nombre_lignes),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
Line 2946  lecture_pipe(struct_processus *s_etat_pr Line 2939  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
                 (*s_objet).objet)).nombre_colonnes),                  (*s_objet).objet)).nombre_colonnes),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
         }          }
   
         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 2964  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 3003  lecture_pipe(struct_processus *s_etat_pr Line 2996  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
                 (*s_objet).objet)).nombre_lignes),                  (*s_objet).objet)).nombre_lignes),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
Line 3014  lecture_pipe(struct_processus *s_etat_pr Line 3007  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
                 (*s_objet).objet)).nombre_colonnes),                  (*s_objet).objet)).nombre_colonnes),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
         }          }
   
         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 3032  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 3071  lecture_pipe(struct_processus *s_etat_pr Line 3064  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
                 (*s_objet).objet)).nombre_lignes),                  (*s_objet).objet)).nombre_lignes),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
Line 3082  lecture_pipe(struct_processus *s_etat_pr Line 3075  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_matrice *)
                 (*s_objet).objet)).nombre_colonnes),                  (*s_objet).objet)).nombre_colonnes),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
         }          }
   
         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 3100  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 3229  lecture_pipe(struct_processus *s_etat_pr Line 3222  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe,          while(read_atomic(s_etat_processus, pipe,
                 &((*((struct_fonction *) (*s_objet).objet))                  &((*((struct_fonction *) (*s_objet).objet))
                 .nombre_arguments), sizeof(unsigned long)) !=                  .nombre_arguments), sizeof(integer8)) !=
                 sizeof(unsigned long))                  sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
Line 3350  lecture_pipe(struct_processus *s_etat_pr Line 3343  lecture_pipe(struct_processus *s_etat_pr
   
         while(read_atomic(s_etat_processus, pipe, &((*((struct_tableau *)          while(read_atomic(s_etat_processus, pipe, &((*((struct_tableau *)
                 (*s_objet).objet)).nombre_elements),                  (*s_objet).objet)).nombre_elements),
                 sizeof(unsigned long)) != sizeof(unsigned long))                  sizeof(integer8)) != sizeof(integer8))
         {          {
             nanosleep(&attente, NULL);              nanosleep(&attente, NULL);
             INCR_GRANULARITE(attente.tv_nsec);              INCR_GRANULARITE(attente.tv_nsec);
         }          }
   
         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);
Line 3408  scrutation_injection(struct_processus *s Line 3401  scrutation_injection(struct_processus *s
     logical1                        drapeau_erreur;      logical1                        drapeau_erreur;
     logical1                        registre_arret_si_exception;      logical1                        registre_arret_si_exception;
   
 #   if !defined(OpenBSD) && !defined(OS2)  #   ifdef PSELECT
         struct timespec             timeout;          struct timespec             timeout;
 #   else  #   else
         struct timeval              timeout;          struct timeval              timeout;
Line 3419  scrutation_injection(struct_processus *s Line 3412  scrutation_injection(struct_processus *s
   
     // Si on est dans le processus père, il n'y a rien à surveiller.      // Si on est dans le processus père, il n'y a rien à surveiller.
   
       scrutation_interruptions(s_etat_processus);
   
     if ((*s_etat_processus).var_volatile_processus_racine == 0)      if ((*s_etat_processus).var_volatile_processus_racine == 0)
     {      {
         FD_ZERO(&ensemble_descripteurs);          FD_ZERO(&ensemble_descripteurs);
         FD_SET((*s_etat_processus).pipe_nombre_injections,          FD_SET((*s_etat_processus).pipe_nombre_injections,
                 &ensemble_descripteurs);                  &ensemble_descripteurs);
   
 #       if !defined(OpenBSD) && !defined(OS2)  #       ifdef PSELECT
         timeout.tv_sec = 0;          timeout.tv_sec = 0;
         timeout.tv_nsec = 0;          timeout.tv_nsec = 0;
   

Removed from v.1.35  
changed lines
  Added in v.1.63


CVSweb interface <joel.bertrand@systella.fr>