version 1.200, 2019/02/03 14:41:25
|
version 1.202, 2019/02/11 06:18:20
|
Line 70 thread_surveillance_signaux(void *argume
|
Line 70 thread_surveillance_signaux(void *argume
|
// nécessaires dans la queue des signaux et incrémentent le sémaphore. |
// nécessaires dans la queue des signaux et incrémentent le sémaphore. |
// Le sémaphore est décrémenté lorsque le signal est effectivement traité. |
// Le sémaphore est décrémenté lorsque le signal est effectivement traité. |
|
|
int ios; |
|
int nombre_signaux_envoyes; |
int nombre_signaux_envoyes; |
|
|
struct_processus *s_etat_processus; |
struct_processus *s_etat_processus; |
Line 93 thread_surveillance_signaux(void *argume
|
Line 92 thread_surveillance_signaux(void *argume
|
|
|
if (sem_wait(semaphore_signalisation) == 0) |
if (sem_wait(semaphore_signalisation) == 0) |
{ |
{ |
while((ios = sem_wait(semaphore_arret_signalisation)) != 0) |
while(sem_wait(semaphore_arret_signalisation) != 0) |
{ |
{ |
if (errno != EINTR) |
if (errno != EINTR) |
{ |
{ |
Line 117 thread_surveillance_signaux(void *argume
|
Line 116 thread_surveillance_signaux(void *argume
|
// affectée au processus courant pour vérifier s'il y a quelque |
// affectée au processus courant pour vérifier s'il y a quelque |
// chose à traiter. |
// chose à traiter. |
|
|
while((ios = sem_wait(semaphore_queue_signaux)) != 0) |
while(sem_wait(semaphore_queue_signaux) != 0) |
{ |
{ |
if (errno != EINTR) |
if (errno != EINTR) |
{ |
{ |
Line 217 modification_pid_thread_pere(struct_proc
|
Line 216 modification_pid_thread_pere(struct_proc
|
void |
void |
insertion_thread(struct_processus *s_etat_processus, logical1 thread_principal) |
insertion_thread(struct_processus *s_etat_processus, logical1 thread_principal) |
{ |
{ |
|
int ios; |
|
|
|
struct timespec attente; |
|
|
volatile struct_liste_chainee_volatile *l_nouvel_objet; |
volatile struct_liste_chainee_volatile *l_nouvel_objet; |
|
|
if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile))) |
if ((l_nouvel_objet = malloc(sizeof(struct_liste_chainee_volatile))) |
Line 239 insertion_thread(struct_processus *s_eta
|
Line 242 insertion_thread(struct_processus *s_eta
|
(*((struct_thread *) (*l_nouvel_objet).donnee)).s_etat_processus = |
(*((struct_thread *) (*l_nouvel_objet).donnee)).s_etat_processus = |
s_etat_processus; |
s_etat_processus; |
|
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
if (ios != EBUSY) |
return; |
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
|
|
|
while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) |
|
{ |
|
if (errno != EINTR) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
} |
} |
} |
|
|
(*l_nouvel_objet).suivant = liste_threads; |
(*l_nouvel_objet).suivant = liste_threads; |
Line 297 insertion_thread_surveillance(struct_pro
|
Line 324 insertion_thread_surveillance(struct_pro
|
void |
void |
retrait_thread(struct_processus *s_etat_processus) |
retrait_thread(struct_processus *s_etat_processus) |
{ |
{ |
|
int ios; |
|
|
|
struct timespec attente; |
|
|
volatile struct_liste_chainee_volatile *l_element_precedent; |
volatile struct_liste_chainee_volatile *l_element_precedent; |
volatile struct_liste_chainee_volatile *l_element_courant; |
volatile struct_liste_chainee_volatile *l_element_courant; |
|
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
if (ios != EBUSY) |
return; |
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
|
|
|
while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) |
|
{ |
|
if (errno != EINTR) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
} |
} |
} |
|
|
l_element_precedent = NULL; |
l_element_precedent = NULL; |
Line 468 retrait_thread_surveillance(struct_proce
|
Line 523 retrait_thread_surveillance(struct_proce
|
void |
void |
verrouillage_threads_concurrents(struct_processus *s_etat_processus) |
verrouillage_threads_concurrents(struct_processus *s_etat_processus) |
{ |
{ |
|
int ios; |
|
|
|
struct timespec attente; |
|
|
volatile struct_liste_chainee_volatile *l_element_courant; |
volatile struct_liste_chainee_volatile *l_element_courant; |
|
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
if (ios != EBUSY) |
return; |
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
|
|
|
while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) |
|
{ |
|
if (errno != EINTR) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
} |
} |
} |
|
|
l_element_courant = liste_threads; |
l_element_courant = liste_threads; |
Line 492 verrouillage_threads_concurrents(struct_
|
Line 575 verrouillage_threads_concurrents(struct_
|
.donnee)).s_etat_processus).semaphore_fork) == -1) |
.donnee)).s_etat_processus).semaphore_fork) == -1) |
# endif |
# endif |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
if (errno != EINTR) |
return; |
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
} |
} |
} |
} |
|
|
Line 1902 inline static void
|
Line 1988 inline static void
|
signal_int(struct_processus *s_etat_processus, pid_t pid) |
signal_int(struct_processus *s_etat_processus, pid_t pid) |
{ |
{ |
struct_processus *s_thread_principal; |
struct_processus *s_thread_principal; |
volatile sig_atomic_t exclusion = 0; |
pthread_mutex_t exclusion = PTHREAD_MUTEX_INITIALIZER; |
|
|
verrouillage_gestionnaire_signaux(s_etat_processus); |
verrouillage_gestionnaire_signaux(s_etat_processus); |
|
|
Line 1924 signal_int(struct_processus *s_etat_proc
|
Line 2010 signal_int(struct_processus *s_etat_proc
|
{ |
{ |
(*s_etat_processus).var_volatile_traitement_sigint = -1; |
(*s_etat_processus).var_volatile_traitement_sigint = -1; |
|
|
while(exclusion == 1); |
pthread_mutex_lock(&exclusion); |
exclusion = 1; |
|
|
|
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
if ((*s_etat_processus).var_volatile_requete_arret == -1) |
{ |
{ |
deverrouillage_gestionnaire_signaux(s_etat_processus); |
deverrouillage_gestionnaire_signaux(s_etat_processus); |
exclusion = 0; |
pthread_mutex_unlock(&exclusion); |
return; |
return; |
} |
} |
|
|
Line 1948 signal_int(struct_processus *s_etat_proc
|
Line 2033 signal_int(struct_processus *s_etat_proc
|
(*s_etat_processus).var_volatile_requete_arret = -1; |
(*s_etat_processus).var_volatile_requete_arret = -1; |
(*s_etat_processus).var_volatile_alarme = -1; |
(*s_etat_processus).var_volatile_alarme = -1; |
|
|
exclusion = 0; |
pthread_mutex_unlock(&exclusion); |
} |
} |
} |
} |
else |
else |
Line 3103 envoi_signal_processus(pid_t pid, enum s
|
Line 3188 envoi_signal_processus(pid_t pid, enum s
|
} |
} |
|
|
int |
int |
envoi_signal_thread(pthread_t tid, enum signaux_rpl signal) |
envoi_signal_thread(struct_processus *s_contexte, |
|
pthread_t tid, enum signaux_rpl signal) |
{ |
{ |
// Un signal est envoyé d'un thread à un autre thread du même processus. |
// Un signal est envoyé d'un thread à un autre thread du même processus. |
|
|
|
int ios; |
|
|
|
struct timespec attente; |
|
|
volatile struct_liste_chainee_volatile *l_element_courant; |
volatile struct_liste_chainee_volatile *l_element_courant; |
|
|
struct_processus *s_etat_processus; |
struct_processus *s_etat_processus; |
|
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
if (s_contexte != NULL) |
{ |
{ |
return(1); |
attente.tv_sec = 0; |
|
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
|
while((ios = pthread_mutex_trylock(&mutex_liste_threads)) != 0) |
|
{ |
|
if (ios != EBUSY) |
|
{ |
|
return(1); |
|
} |
|
|
|
if (sem_post(&((*s_contexte).semaphore_fork)) != 0) |
|
{ |
|
return(1); |
|
} |
|
|
|
nanosleep(&attente, NULL); |
|
INCR_GRANULARITE(attente.tv_nsec); |
|
|
|
while(sem_wait(&((*s_contexte).semaphore_fork)) != 0) |
|
{ |
|
if (errno != EINTR) |
|
{ |
|
return(1); |
|
} |
|
} |
|
} |
|
} |
|
else |
|
{ |
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
|
{ |
|
return(1); |
|
} |
} |
} |
|
|
l_element_courant = liste_threads; |
l_element_courant = liste_threads; |