[BACK]Return to instructions_s10.c CVS log [TXT] [DIR] Up to [local] / rpl / src

Diff for /rpl/src/instructions_s10.c between versions 1.42 and 1.43

version 1.42, 2011/08/09 11:31:35 version 1.43, 2011/09/14 14:34:28
Line 48  instruction_spawn(struct_processus *s_et Line 48  instruction_spawn(struct_processus *s_et
     pthread_t                   thread_id;      pthread_t                   thread_id;
     pthread_t                   thread_surveillance;      pthread_t                   thread_surveillance;
   
     sigset_t                    oldset;  
     sigset_t                    set;  
   
     struct_descripteur_thread   *s_argument_thread;      struct_descripteur_thread   *s_argument_thread;
   
     struct_liste_chainee        *l_element_courant;      struct_liste_chainee        *l_element_courant;
Line 236  instruction_spawn(struct_processus *s_et Line 233  instruction_spawn(struct_processus *s_et
         }          }
     }      }
   
     if (sigemptyset(&set) != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_processus;  
         return;  
     }  
   
     if (sigaddset(&set, SIGSTART) != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_processus;  
         return;  
     }  
   
     /*  
      * Le signal SIGFSTOP doit être traité !  
      */  
   
     if (sigaddset(&set, SIGFSTOP) != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_processus;  
         return;  
     }  
   
     if (sigaddset(&set, SIGFABORT) != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_processus;  
         return;  
     }  
   
     if (sigaddset(&set, SIGURG) != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_processus;  
         return;  
     }  
   
     if (pthread_sigmask(SIG_BLOCK, &set, &oldset) != 0)  
     {  
         (*s_etat_processus).erreur_systeme = d_es_processus;  
         return;  
     }  
   
     if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL)      if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
Line 460  instruction_spawn(struct_processus *s_et Line 417  instruction_spawn(struct_processus *s_et
         (*s_argument_thread).destruction_objet = d_faux;          (*s_argument_thread).destruction_objet = d_faux;
     }      }
   
     (*s_argument_thread).set = set;  
     (*s_argument_thread).oldset = oldset;  
     (*s_argument_thread).thread_actif = d_faux;      (*s_argument_thread).thread_actif = d_faux;
   
     if (pthread_create(&thread_id, &attributs, lancement_thread,      if (pthread_create(&thread_id, &attributs, lancement_thread,
Line 680  instruction_spawn(struct_processus *s_et Line 635  instruction_spawn(struct_processus *s_et
   
     // Le fils peut être présent sans être en attente du signal de départ.      // Le fils peut être présent sans être en attente du signal de départ.
   
     if (pthread_kill((*s_argument_thread).tid, SIGSTART) != 0)      if (envoi_signal_thread((*s_argument_thread).tid, rpl_sigstart) != 0)
     {  
         (*s_etat_processus).erreur_systeme = d_es_processus;  
         return;  
     }  
   
     if (pthread_sigmask(SIG_SETMASK, &oldset, NULL) != 0)  
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         return;          return;
     }      }
   
     sigpending(&set);  
   
     return;      return;
 }  }
   
Removed from v.1.42  
changed lines
  Added in v.1.43

CVSweb interface <joel.bertrand@systella.fr>