[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.141 and 1.149

version 1.141, 2016/03/09 22:11:27 version 1.149, 2016/03/22 19:03:36
Line 1122  instruction_detach(struct_processus *s_e Line 1122  instruction_detach(struct_processus *s_e
     {      {
         // On ne déverrouille les threads concurrents que dans le processus          // On ne déverrouille les threads concurrents que dans le processus
         // père. Dans le fils, les valeurs sont non initialisées.          // père. Dans le fils, les valeurs sont non initialisées.
 uprintf("PID=%d\n", getpid());  
         deverrouillage_threads_concurrents(s_etat_processus);          deverrouillage_threads_concurrents(s_etat_processus);
     }      }
   
Line 1290  uprintf("PID=%d\n", getpid()); Line 1289  uprintf("PID=%d\n", getpid());
          */           */
   
         pthread_mutex_destroy(&mutex_liste_variables_partagees);          pthread_mutex_destroy(&mutex_liste_variables_partagees);
           pthread_mutex_destroy(&mutex_liste_threads);
   
         pthread_mutexattr_init(&attributs_mutex);          pthread_mutexattr_init(&attributs_mutex);
         pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);          pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
         pthread_mutex_init(&mutex_liste_variables_partagees, &attributs_mutex);          pthread_mutex_init(&mutex_liste_variables_partagees, &attributs_mutex);
         pthread_mutexattr_destroy(&attributs_mutex);          pthread_mutexattr_destroy(&attributs_mutex);
   
         pthread_mutex_destroy(&mutex_liste_threads);  
   
         pthread_mutexattr_init(&attributs_mutex);          pthread_mutexattr_init(&attributs_mutex);
         pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);          pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
         pthread_mutex_init(&mutex_liste_threads, &attributs_mutex);          pthread_mutex_init(&mutex_liste_threads, &attributs_mutex);
Line 1306  uprintf("PID=%d\n", getpid()); Line 1304  uprintf("PID=%d\n", getpid());
         liberation_queue_signaux(s_etat_processus);          liberation_queue_signaux(s_etat_processus);
         creation_queue_signaux(s_etat_processus);          creation_queue_signaux(s_etat_processus);
   
         if (lancement_thread_signaux(s_etat_processus) != d_absence_erreur)  
         {  
             (*s_etat_processus).erreur_systeme = d_es_processus;  
         }  
   
         routine_recursive = 0;          routine_recursive = 0;
           nombre_thread_surveillance_processus = 0;
   
         (*s_etat_processus).pointeur_signal_lecture = 0;          (*s_etat_processus).pointeur_signal_lecture = 0;
         (*s_etat_processus).pointeur_signal_ecriture = 0;          (*s_etat_processus).pointeur_signal_ecriture = 0;
Line 2198  uprintf("PID=%d\n", getpid()); Line 2192  uprintf("PID=%d\n", getpid());
             }              }
         }          }
   
         close((*s_argument_thread).pipe_erreurs[1]);  
         close((*s_argument_thread).pipe_interruptions[1]);  
         close((*s_argument_thread).pipe_nombre_elements_attente[1]);  
         close((*s_argument_thread).pipe_objets[1]);  
         close((*s_argument_thread).pipe_injections[0]);  
         close((*s_argument_thread).pipe_nombre_injections[0]);  
         close((*s_argument_thread).pipe_acquittement[0]);  
   
         l_element_courant = (*s_etat_processus).s_fichiers;          l_element_courant = (*s_etat_processus).s_fichiers;
   
         while(l_element_courant != NULL)          while(l_element_courant != NULL)
Line 2285  uprintf("PID=%d\n", getpid()); Line 2271  uprintf("PID=%d\n", getpid());
                 {                  {
                     envoi_signal_processus((*(*((struct_processus_fils *)                      envoi_signal_processus((*(*((struct_processus_fils *)
                             (*(*l_element_courant).donnee).objet)).thread).pid,                              (*(*l_element_courant).donnee).objet)).thread).pid,
                             rpl_sigurg);                              rpl_sigurg, d_faux);
                 }                  }
                 else                  else
                 {                  {
Line 2293  uprintf("PID=%d\n", getpid()); Line 2279  uprintf("PID=%d\n", getpid());
                     {                      {
                         envoi_signal_processus((*(*((struct_processus_fils *)                          envoi_signal_processus((*(*((struct_processus_fils *)
                                 (*(*l_element_courant).donnee).objet)).thread)                                  (*(*l_element_courant).donnee).objet)).thread)
                                 .pid, rpl_sigabort);                                  .pid, rpl_sigabort, d_faux);
                     }                      }
                     else                      else
                     {                      {
                         envoi_signal_processus((*(*((struct_processus_fils *)                          envoi_signal_processus((*(*((struct_processus_fils *)
                                 (*(*l_element_courant).donnee).objet)).thread)                                  (*(*l_element_courant).donnee).objet)).thread)
                                 .pid, rpl_sigstop);                                  .pid, rpl_sigstop, d_faux);
                     }                      }
                 }                  }
             }              }
Line 2768  uprintf("PID=%d\n", getpid()); Line 2754  uprintf("PID=%d\n", getpid());
             l_element_courant = l_element_suivant;              l_element_courant = l_element_suivant;
         }          }
   
         free((*s_etat_processus).chemin_fichiers_temporaires);  
   
         if ((*s_etat_processus).debug == d_vrai)          if ((*s_etat_processus).debug == d_vrai)
             if (((*s_etat_processus).type_debug &              if (((*s_etat_processus).type_debug &
                     d_debug_processus) != 0)                      d_debug_processus) != 0)
Line 2823  uprintf("PID=%d\n", getpid()); Line 2807  uprintf("PID=%d\n", getpid());
   
         closelog();          closelog();
   
         retrait_thread(s_etat_processus);          close((*s_argument_thread).pipe_erreurs[1]);
           close((*s_argument_thread).pipe_interruptions[1]);
           close((*s_argument_thread).pipe_nombre_elements_attente[1]);
           close((*s_argument_thread).pipe_objets[1]);
           close((*s_argument_thread).pipe_injections[0]);
           close((*s_argument_thread).pipe_nombre_injections[0]);
           close((*s_argument_thread).pipe_acquittement[0]);
   
         pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus));          retrait_thread(s_etat_processus);
         pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));  
         pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions));  
         pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));  
         pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes));  
         pthread_mutex_destroy(&mutex_sections_critiques);  
   
 #       ifndef SEMAPHORES_NOMMES  #       ifndef SEMAPHORES_NOMMES
         sem_post(&((*s_etat_processus).semaphore_fork));          sem_post(&((*s_etat_processus).semaphore_fork));
Line 2841  uprintf("PID=%d\n", getpid()); Line 2826  uprintf("PID=%d\n", getpid());
                 pthread_self(), SEM_FORK);                  pthread_self(), SEM_FORK);
 #       endif  #       endif
   
         free((*s_etat_processus).localisation);  
         free(s_argument_thread);  
   
         clear_history();          clear_history();
   
         destruction_queue_signaux(s_etat_processus);  
         liberation_contexte_cas(s_etat_processus);          liberation_contexte_cas(s_etat_processus);
         arret_thread_signaux(s_etat_processus);          destruction_queue_signaux(s_etat_processus);
   
           free((*s_etat_processus).localisation);
           free((*s_etat_processus).chemin_fichiers_temporaires);
           free(s_argument_thread);
   
         liberation_allocateur(s_etat_processus);          liberation_allocateur(s_etat_processus);
         liberation_allocateur_buffer(s_etat_processus);          liberation_allocateur_buffer(s_etat_processus);
   
           attente.tv_sec = 0;
           attente.tv_nsec = GRANULARITE_us * 1000;
   
           while(nombre_thread_surveillance_processus != 0)
           {
               nanosleep(&attente, NULL);
               INCR_GRANULARITE(attente.tv_nsec);
           }
   
           pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus));
           pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
           pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions));
           pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));
           pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes));
         pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer));          pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer));
           pthread_mutex_destroy(&mutex_sections_critiques);
   
         sys_free(s_etat_processus);          sys_free(s_etat_processus);
   
 #       ifdef DEBUG_MEMOIRE  #       ifdef DEBUG_MEMOIRE
Line 2952  uprintf("PID=%d\n", getpid()); Line 2955  uprintf("PID=%d\n", getpid());
   
     // 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 (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart) != 0)      if (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart,
               d_vrai) != 0)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
         pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));          pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
Removed from v.1.141  
changed lines
  Added in v.1.149

CVSweb interface <joel.bertrand@systella.fr>