--- rpl/src/optimisation.c 2013/02/27 17:11:45 1.48 +++ rpl/src/optimisation.c 2013/03/23 16:14:39 1.50 @@ -38,9 +38,11 @@ logical1 sequenceur_optimise(struct_processus *s_etat_processus) { - int i; - int nb_variables; - int point_entree; + integer8 adresse_point_entree; + integer8 i; + integer8 j; + integer8 nb_variables; + integer8 point_entree; logical1 erreur; @@ -51,8 +53,6 @@ sequenceur_optimise(struct_processus *s_ unsigned char *message; unsigned char registre; - unsigned long adresse_point_entree; - if ((*s_etat_processus).debug == d_vrai) if (((*s_etat_processus).type_debug & d_debug_analyse) != 0) @@ -79,10 +79,16 @@ sequenceur_optimise(struct_processus *s_ (*s_etat_processus).autorisation_empilement_programme = 'Y'; (*s_etat_processus).mode_execution_programme = 'N'; + if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return(d_erreur); + } + nb_variables = nombre_variables(s_etat_processus); - if ((tableau = malloc(nb_variables * sizeof(struct_tableau_variables))) - == NULL) + if ((tableau = malloc(((size_t) nb_variables) * + sizeof(struct_tableau_variables))) == NULL) { if ((*s_etat_processus).langue == 'F') { @@ -95,10 +101,17 @@ sequenceur_optimise(struct_processus *s_ liberation_mutexes_arbre_variables_partagees(s_etat_processus, (*(*s_etat_processus).s_arbre_variables_partagees)); + pthread_mutex_unlock(&mutex_liste_variables_partagees); return(d_erreur); } - liste_variables(s_etat_processus, tableau); + nb_variables = liste_variables(s_etat_processus, tableau); + + if (pthread_mutex_unlock(&mutex_liste_variables_partagees) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return(d_erreur); + } for(i = 0; i < nb_variables; i++) { @@ -106,7 +119,7 @@ sequenceur_optimise(struct_processus *s_ { // Variables qui contiennent les points d'entrée des définitions. - (*s_etat_processus).position_courante = (*((unsigned long *) + (*s_etat_processus).position_courante = (*((integer8 *) (*(tableau[i].objet)).objet)); if (point_entree == -1) @@ -137,6 +150,14 @@ sequenceur_optimise(struct_processus *s_ printf("+++Fatal : Compilation failed\n"); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); return(d_erreur); } @@ -195,6 +216,14 @@ sequenceur_optimise(struct_processus *s_ printf("+++Fatal : Compilation failed\n"); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); return(d_erreur); } @@ -214,6 +243,14 @@ sequenceur_optimise(struct_processus *s_ printf("+++Fatal : Compilation failed\n"); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); return(d_erreur); } @@ -233,6 +270,14 @@ sequenceur_optimise(struct_processus *s_ printf("+++Fatal : Compilation failed\n"); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); return(d_erreur); } @@ -259,6 +304,14 @@ sequenceur_optimise(struct_processus *s_ printf("+++Fatal : Compilation failed\n"); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); return(d_erreur); } @@ -300,6 +353,14 @@ sequenceur_optimise(struct_processus *s_ printf("+++Fatal : Compilation failed\n"); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); return(d_erreur); } @@ -324,10 +385,26 @@ sequenceur_optimise(struct_processus *s_ printf("+++System : Not enough memory\n"); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); return(d_erreur); } + for(j = 0; j < nb_variables; j++) + { + if (tableau[j].mutex != NULL) + { + pthread_mutex_unlock(tableau[j].mutex); + } + } + free(tableau); erreur = evaluation(s_etat_processus, programme_principal, 'E');