--- rpl/src/instructions_m4.c 2010/04/07 13:45:07 1.6 +++ rpl/src/instructions_m4.c 2011/09/14 17:55:59 1.31 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.14 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.3 + Copyright (C) 1989-2011 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -38,11 +38,16 @@ void instruction_mem(struct_processus *s_etat_processus) { - struct_liste_chainee *l_element_courant; + int j; + int nb_variables; - struct_objet *s_objet_resultat; + struct_liste_chainee *l_element_courant; + + struct_objet *s_objet_resultat; + + struct_tableau_variables *tableau; - unsigned long i; + unsigned long i; (*s_etat_processus).erreur_execution = d_ex; @@ -139,16 +144,31 @@ instruction_mem(struct_processus *s_etat (*((integer8 *) (*((*((*((struct_liste_chainee *) (*s_objet_resultat).objet)).suivant)).donnee)).objet)) = 0; - for(i = 0; i < (*s_etat_processus).nombre_variables; i++) + nb_variables = nombre_variables(s_etat_processus, + (*s_etat_processus).s_arbre_variables); + + if ((tableau = malloc(nb_variables * sizeof(struct_tableau_variables))) + == NULL) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } + + liste_variables(s_etat_processus, tableau, 0, + (*s_etat_processus).s_arbre_variables); + + for(j = 0; j < nb_variables; j++) { (*((integer8 *) (*((*((*((struct_liste_chainee *) (*s_objet_resultat) .objet)).suivant)).donnee)).objet)) += sizeof(unsigned char) * - strlen((*s_etat_processus).s_liste_variables[i].nom); + strlen(tableau[j].nom); (*((integer8 *) (*((*((*((struct_liste_chainee *) (*s_objet_resultat) .objet)).suivant)).donnee)).objet)) += occupation_memoire( - (*s_etat_processus).s_liste_variables[i].objet); + tableau[j].objet); } + free(tableau); + for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++) { // Comptabilisation des empreintes mémoire des variables @@ -396,7 +416,7 @@ instruction_mtxlock(struct_processus *s_ } } - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -405,18 +425,10 @@ instruction_mtxlock(struct_processus *s_ if (pthread_mutex_lock(&((*((struct_mutex *) (*s_objet_argument).objet)) .mutex)) != 0) { - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0) { - if ((*s_etat_processus).profilage == d_vrai) - { - profilage(s_etat_processus, NULL); - } - - if (errno != EINTR) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + (*s_etat_processus).erreur_systeme = d_es_processus; + return; } liberation(s_etat_processus, s_objet_argument); @@ -430,13 +442,10 @@ instruction_mtxlock(struct_processus *s_ return; } - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0) { - if (errno != EINTR) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + (*s_etat_processus).erreur_systeme = d_es_processus; + return; } if ((*s_etat_processus).profilage == d_vrai)