version 1.35, 2011/09/26 15:57:14
|
version 1.45, 2012/10/01 11:05:05
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.4 |
RPL/2 (R) version 4.1.11 |
Copyright (C) 1989-2011 Dr. BERTRAND Joël |
Copyright (C) 1989-2012 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
|
|
Line 453 instruction_mtxlock(struct_processus *s_
|
Line 453 instruction_mtxlock(struct_processus *s_
|
return; |
return; |
} |
} |
|
|
|
(*((struct_mutex *) (*s_objet_argument).objet)).tid = pthread_self(); |
|
|
# ifndef SEMAPHORES_NOMMES |
# ifndef SEMAPHORES_NOMMES |
while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) |
while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) |
# else |
# else |
Line 608 instruction_mtxtrylock(struct_processus
|
Line 610 instruction_mtxtrylock(struct_processus
|
return; |
return; |
} |
} |
} |
} |
|
else |
|
{ |
|
(*((struct_mutex *) (*s_objet_argument).objet)).tid = |
|
pthread_self(); |
|
} |
|
|
if ((*s_etat_processus).profilage == d_vrai) |
if ((*s_etat_processus).profilage == d_vrai) |
{ |
{ |
Line 631 instruction_mtxtrylock(struct_processus
|
Line 638 instruction_mtxtrylock(struct_processus
|
return; |
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), |
if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), |
s_objet_resultat) == d_erreur) |
s_objet_resultat) == d_erreur) |
Line 642 instruction_mtxtrylock(struct_processus
|
Line 649 instruction_mtxtrylock(struct_processus
|
return; |
return; |
} |
} |
|
|
|
|
/* |
/* |
================================================================================ |
================================================================================ |
Fonction 'mtxstatus' |
Fonction 'mtxstatus' |
Line 766 instruction_mtxstatus(struct_processus *
|
Line 774 instruction_mtxstatus(struct_processus *
|
} |
} |
} |
} |
|
|
if (pthread_mutex_unlock(&((*((struct_mutex *) |
if (ios == 0) |
(*s_objet_argument).objet)).mutex)) != 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; |
if ((*s_etat_processus).profilage == d_vrai) |
return; |
{ |
|
profilage(s_etat_processus, NULL); |
|
} |
|
|
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
} |
} |
|
|
if ((*s_etat_processus).profilage == d_vrai) |
if ((*s_etat_processus).profilage == d_vrai) |
Line 891 instruction_mtxunlock(struct_processus *
|
Line 904 instruction_mtxunlock(struct_processus *
|
|
|
if (l_element_courant == NULL) |
if (l_element_courant == NULL) |
{ |
{ |
|
liberation(s_etat_processus, s_objet_argument); |
|
|
(*s_etat_processus).erreur_execution = d_ex_mutex; |
(*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); |
liberation(s_etat_processus, s_objet_argument); |
|
|
|
(*s_etat_processus).erreur_execution = |
|
d_ex_mutex_acquis_autre_thread; |
return; |
return; |
} |
} |
|
|