--- rpl/src/gestion_threads.c 2012/05/18 14:09:41 1.62 +++ rpl/src/gestion_threads.c 2013/03/24 22:06:10 1.75 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.8 - Copyright (C) 1989-2012 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.13 + Copyright (C) 1989-2013 Dr. BERTRAND Joël This file is part of RPL/2. @@ -38,35 +38,38 @@ void * lancement_thread(void *argument) { - int status; + int status; - pid_t ppid; + pid_t ppid; - pthread_t tid_final; + pthread_t tid_final; - sig_atomic_t registre_stop; + sig_atomic_t registre_stop; - ssize_t longueur_ecriture; + ssize_t longueur_ecriture; - struct_descripteur_thread *s_argument_thread; + struct_descripteur_thread *s_argument_thread; - struct_liste_chainee *l_element_courant; - struct_liste_chainee *l_element_suivant; + struct_liste_chainee *l_element_courant; + struct_liste_chainee *l_element_suivant; - struct_objet *s_objet_temporaire; + struct_liste_variables_statiques *l_element_statique_courant; + struct_liste_variables_statiques *l_element_statique_suivant; - struct_processus *s_etat_processus; + struct_objet *s_objet_temporaire; - struct sigaction action; - struct sigaction registre; + struct_processus *s_etat_processus; - struct timespec attente; + struct sigaction action; + struct sigaction registre; - unsigned char *message; + struct timespec attente; - unsigned int erreur; + unsigned char *message; - unsigned long i; + unsigned int erreur; + + integer8 i; attente.tv_sec = 0; attente.tv_nsec = GRANULARITE_us * 1000; @@ -86,9 +89,8 @@ lancement_thread(void *argument) # endif (*s_argument_thread).tid = pthread_self(); - (*s_argument_thread).thread_actif = d_vrai; - insertion_thread(s_etat_processus, d_faux); + (*s_argument_thread).thread_actif = d_vrai; // Envoi d'une donnée pour signaler le démarrage du thread au thread // de surveillance. @@ -104,7 +106,7 @@ lancement_thread(void *argument) (*s_argument_thread).thread_actif = d_faux; - tid_final = -2; + tid_final = (pthread_t) -2; while((longueur_ecriture = write_atomic(s_etat_processus, (*s_argument_thread).pipe_nombre_interruptions_attente[1], @@ -219,7 +221,7 @@ lancement_thread(void *argument) pthread_cancel((*s_etat_processus).thread_fusible); } - tid_final = -2; + tid_final = (pthread_t) -2; while((longueur_ecriture = write_atomic(s_etat_processus, (*s_argument_thread).pipe_nombre_interruptions_attente[1], @@ -575,7 +577,7 @@ lancement_thread(void *argument) .var_volatile_traitement_retarde_stop; (*s_etat_processus).var_volatile_traitement_retarde_stop = 1; - for(i = 0; i < (unsigned long) (*(*((struct_processus_fils *) + for(i = 0; i < (*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread) .nombre_objets_dans_pipe; i++) { @@ -813,15 +815,16 @@ lancement_thread(void *argument) liberation_arbre_variables(s_etat_processus, (*s_etat_processus).s_arbre_variables, d_faux); - for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++) + l_element_statique_courant = (*s_etat_processus) + .l_liste_variables_statiques; + + while(l_element_statique_courant != NULL) { - liberation(s_etat_processus, - (*s_etat_processus).s_liste_variables_statiques[i].objet); - free((*s_etat_processus).s_liste_variables_statiques[i].nom); + l_element_statique_suivant = (*l_element_statique_courant).suivant; + free(l_element_statique_courant); + l_element_statique_courant = l_element_statique_suivant; } - free((*s_etat_processus).s_liste_variables_statiques); - l_element_courant = (*s_etat_processus).l_base_pile; while(l_element_courant != NULL) {