--- rpl/src/instructions_c7.c 2011/03/06 16:44:10 1.20 +++ rpl/src/instructions_c7.c 2014/01/26 18:21:31 1.51 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.21 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.17 + Copyright (C) 1989-2014 Dr. BERTRAND Joël This file is part of RPL/2. @@ -90,7 +90,7 @@ instruction_crmtx(struct_processus *s_et } pthread_mutexattr_init(&attributs_mutex); - pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); + pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); pthread_mutex_init(&((*((struct_mutex *) (*s_objet).objet)).mutex), &attributs_mutex); pthread_mutexattr_destroy(&attributs_mutex); @@ -875,4 +875,72 @@ instruction_clratpoke(struct_processus * return; } + +/* +================================================================================ + Fonction 'critical' +================================================================================ + Entrées : +-------------------------------------------------------------------------------- + Sorties : +-------------------------------------------------------------------------------- + Effets de bord : néant +================================================================================ +*/ + +void +instruction_critical(struct_processus *s_etat_processus) +{ + (*s_etat_processus).erreur_execution = d_ex; + + if ((*s_etat_processus).affichage_arguments == 'Y') + { + printf("\n CRITICAL "); + + if ((*s_etat_processus).langue == 'F') + { + printf("(initialisation d'une section critique)\n\n"); + printf(" Aucun argument\n"); + } + else + { + printf("(critical section initialization)\n\n"); + printf(" No argument\n"); + } + + return; + } + else if ((*s_etat_processus).test_instruction == 'Y') + { + (*s_etat_processus).nombre_arguments = -1; + return; + } + + if (test_cfsf(s_etat_processus, 31) == d_vrai) + { + if (empilement_pile_last(s_etat_processus, 0) == d_erreur) + { + return; + } + } + + empilement_pile_systeme(s_etat_processus); + + if ((*s_etat_processus).erreur_systeme != d_es) + { + return; + } + + (*(*s_etat_processus).l_base_pile_systeme).type_cloture = 'Q'; + + if (pthread_mutex_lock(&mutex_sections_critiques) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + + (*s_etat_processus).sections_critiques++; + return; +} + // vim: ts=4