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

Diff for /rpl/src/instructions_d5.c between versions 1.131 and 1.141

version 1.131, 2015/07/21 12:30:38 version 1.141, 2016/03/09 22:11:27
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.22    RPL/2 (R) version 4.1.25
   Copyright (C) 1989-2015 Dr. BERTRAND Joël    Copyright (C) 1989-2016 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 1088  instruction_detach(struct_processus *s_e Line 1088  instruction_detach(struct_processus *s_e
         return;          return;
     }      }
   
       if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0)
       {
           (*s_etat_processus).erreur_systeme = d_es_processus;
           return;
       }
   
       verrouillage_threads_concurrents(s_etat_processus);
   
     if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0)      if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
Line 1101  instruction_detach(struct_processus *s_e Line 1109  instruction_detach(struct_processus *s_e
      * de mémoire, ni libération, ni copie d'objet concurrent au fork().       * de mémoire, ni libération, ni copie d'objet concurrent au fork().
      */       */
   
     verrouillage_threads_concurrents(s_etat_processus);  
     (*s_argument_thread).pid = fork();      (*s_argument_thread).pid = fork();
     deverrouillage_threads_concurrents(s_etat_processus);  
   
     if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer))      if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer))
             != 0)              != 0)
Line 1112  instruction_detach(struct_processus *s_e Line 1118  instruction_detach(struct_processus *s_e
         return;          return;
     }      }
   
       if ((*s_argument_thread).pid > 0)
       {
           // On ne déverrouille les threads concurrents que dans le processus
           // père. Dans le fils, les valeurs sont non initialisées.
   uprintf("PID=%d\n", getpid());
           deverrouillage_threads_concurrents(s_etat_processus);
       }
   
     (*s_argument_thread).thread_pere = pthread_self();      (*s_argument_thread).thread_pere = pthread_self();
     (*s_argument_thread).processus_detache = d_vrai;      (*s_argument_thread).processus_detache = d_vrai;
   
Line 1132  instruction_detach(struct_processus *s_e Line 1146  instruction_detach(struct_processus *s_e
          * Processus père           * Processus père
          */           */
   
           if (pthread_mutex_unlock(&mutex_liste_variables_partagees) != 0)
           {
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return;
           }
   
         if (variable_partagee == d_vrai)          if (variable_partagee == d_vrai)
         {          {
             liberation(s_etat_processus, s_copie);              liberation(s_etat_processus, s_copie);
Line 1269  instruction_detach(struct_processus *s_e Line 1289  instruction_detach(struct_processus *s_e
          * Processus fils           * Processus fils
          */           */
   
           pthread_mutex_destroy(&mutex_liste_variables_partagees);
   
           pthread_mutexattr_init(&attributs_mutex);
           pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
           pthread_mutex_init(&mutex_liste_variables_partagees, &attributs_mutex);
           pthread_mutexattr_destroy(&attributs_mutex);
   
           pthread_mutex_destroy(&mutex_liste_threads);
   
           pthread_mutexattr_init(&attributs_mutex);
           pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
           pthread_mutex_init(&mutex_liste_threads, &attributs_mutex);
           pthread_mutexattr_destroy(&attributs_mutex);
   
         liberation_queue_signaux(s_etat_processus);          liberation_queue_signaux(s_etat_processus);
         creation_queue_signaux(s_etat_processus);          creation_queue_signaux(s_etat_processus);
   
Removed from v.1.131  
changed lines
  Added in v.1.141

CVSweb interface <joel.bertrand@systella.fr>