--- rpl/src/instructions_m4.c 2011/09/20 14:36:29 1.34 +++ rpl/src/instructions_m4.c 2012/10/05 13:12:39 1.47 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.3 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.11 + Copyright (C) 1989-2012 Dr. BERTRAND Joël This file is part of RPL/2. @@ -169,25 +169,6 @@ instruction_mem(struct_processus *s_etat free(tableau); - for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++) - { - // Comptabilisation des empreintes mémoire des variables - // statiques qui ne sont pas accessibles, les variables statiques - // accessibles étant déjà comptabilitées par la boucle précédente. - - if ((*s_etat_processus).s_liste_variables_statiques[i].objet != NULL) - { - (*((integer8 *) (*((*((*((struct_liste_chainee *) - (*s_objet_resultat).objet)).suivant)).donnee)).objet)) += - sizeof(unsigned char) * strlen((*s_etat_processus) - .s_liste_variables_statiques[i].nom); - (*((integer8 *) (*((*((*((struct_liste_chainee *) - (*s_objet_resultat).objet)).suivant)).donnee)).objet)) += - occupation_memoire((*s_etat_processus) - .s_liste_variables_statiques[i].objet); - } - } - for(i = 0; i < (*(*s_etat_processus).s_liste_variables_partagees) .nombre_variables; i++) { @@ -453,6 +434,8 @@ instruction_mtxlock(struct_processus *s_ return; } + (*((struct_mutex *) (*s_objet_argument).objet)).tid = pthread_self(); + # ifndef SEMAPHORES_NOMMES while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else @@ -608,6 +591,11 @@ instruction_mtxtrylock(struct_processus return; } } + else + { + (*((struct_mutex *) (*s_objet_argument).objet)).tid = + pthread_self(); + } if ((*s_etat_processus).profilage == d_vrai) { @@ -631,7 +619,7 @@ instruction_mtxtrylock(struct_processus return; } - (*((integer8 *) (*s_objet_resultat).objet)) = (ios == 0) ? 0 : -1; + (*((integer8 *) (*s_objet_resultat).objet)) = (ios == 0) ? -1 : 0; if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), s_objet_resultat) == d_erreur) @@ -642,6 +630,7 @@ instruction_mtxtrylock(struct_processus return; } + /* ================================================================================ Fonction 'mtxstatus' @@ -766,18 +755,23 @@ instruction_mtxstatus(struct_processus * } } - if (pthread_mutex_unlock(&((*((struct_mutex *) - (*s_objet_argument).objet)).mutex)) != 0) + if (ios == 0) { - liberation(s_etat_processus, s_objet_argument); + // Le mutex a été verrouillé par le trylock précédent. - if ((*s_etat_processus).profilage == d_vrai) + if (pthread_mutex_unlock(&((*((struct_mutex *) + (*s_objet_argument).objet)).mutex)) != 0) { - profilage(s_etat_processus, NULL); - } + liberation(s_etat_processus, s_objet_argument); - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } + + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } } if ((*s_etat_processus).profilage == d_vrai) @@ -891,9 +885,19 @@ instruction_mtxunlock(struct_processus * if (l_element_courant == NULL) { + liberation(s_etat_processus, s_objet_argument); + (*s_etat_processus).erreur_execution = d_ex_mutex; + return; + } + if (pthread_equal(pthread_self(), (*((struct_mutex *) + (*s_objet_argument).objet)).tid) == 0) + { liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = + d_ex_mutex_acquis_autre_thread; return; }