version 1.120, 2013/03/20 17:11:45
|
version 1.158, 2015/06/08 14:11:43
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.13 |
RPL/2 (R) version 4.1.22 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2015 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
|
|
Line 60 static volatile int code_erreur_g
|
Line 60 static volatile int code_erreur_g
|
|
|
unsigned char *racine_segment; |
unsigned char *racine_segment; |
|
|
static pthread_mutex_t mutex_interruptions |
|
= PTHREAD_MUTEX_INITIALIZER; |
|
|
|
static void * |
static void * |
thread_surveillance_signaux(void *argument) |
thread_surveillance_signaux(void *argument) |
{ |
{ |
Line 93 thread_surveillance_signaux(void *argume
|
Line 90 thread_surveillance_signaux(void *argume
|
attente.tv_sec = 0; |
attente.tv_sec = 0; |
attente.tv_nsec = GRANULARITE_us * 1000; |
attente.tv_nsec = GRANULARITE_us * 1000; |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
if (sem_wait(&(*s_queue_signaux).signalisation) == 0) |
|
# else |
|
if (sem_wait(semaphore_signalisation) == 0) |
if (sem_wait(semaphore_signalisation) == 0) |
# endif |
|
{ |
{ |
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
if (sem_wait(semaphore_arret_signalisation) != 0) |
sem_post(&(*s_queue_signaux).signalisation); |
{ |
# else |
(*s_etat_processus).erreur_systeme = d_es_processus; |
sem_post(semaphore_signalisation); |
} |
# endif |
|
|
|
if ((*s_queue_signaux).requete_arret == d_vrai) |
if ((*s_queue_signaux).requete_arret == d_vrai) |
{ |
{ |
|
sem_post(semaphore_arret_signalisation); |
|
sem_post(semaphore_signalisation); |
|
|
break; |
break; |
} |
} |
|
|
|
sem_post(semaphore_arret_signalisation); |
|
sem_post(semaphore_signalisation); |
|
|
nombre_signaux_envoyes = 0; |
nombre_signaux_envoyes = 0; |
sched_yield(); |
sched_yield(); |
|
|
Line 117 thread_surveillance_signaux(void *argume
|
Line 115 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. |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
sem_wait(&(*s_queue_signaux).semaphore); |
|
# else |
|
sem_wait(semaphore_queue_signaux); |
sem_wait(semaphore_queue_signaux); |
# endif |
|
|
|
if ((*s_queue_signaux).pointeur_lecture != |
if ((*s_queue_signaux).pointeur_lecture != |
(*s_queue_signaux).pointeur_ecriture) |
(*s_queue_signaux).pointeur_ecriture) |
Line 136 thread_surveillance_signaux(void *argume
|
Line 130 thread_surveillance_signaux(void *argume
|
kill(getpid(), SIGALRM); |
kill(getpid(), SIGALRM); |
} |
} |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
sem_post(&(*s_queue_signaux).semaphore); |
|
# else |
|
sem_post(semaphore_queue_signaux); |
sem_post(semaphore_queue_signaux); |
# endif |
|
|
|
// Dans un second temps, on balaye toutes les queues de signaux |
// Dans un second temps, on balaye toutes les queues de signaux |
// des threads du processus courant. |
// des threads du processus courant. |
|
|
|
// Attention : l'ordre de verrouillage des mutexes est important |
|
// pour éviter les conditions bloquantes ! |
|
|
pthread_mutex_lock(&mutex_liste_threads); |
pthread_mutex_lock(&mutex_liste_threads); |
|
|
l_element_courant = liste_threads; |
l_element_courant = liste_threads; |
|
|
while(l_element_courant != NULL) |
while(l_element_courant != NULL) |
Line 153 thread_surveillance_signaux(void *argume
|
Line 147 thread_surveillance_signaux(void *argume
|
if ((*((struct_thread *) (*l_element_courant).donnee)).pid |
if ((*((struct_thread *) (*l_element_courant).donnee)).pid |
== getpid()) |
== getpid()) |
{ |
{ |
|
pthread_mutex_lock(&((*(*((struct_thread *) |
|
(*l_element_courant).donnee)).s_etat_processus) |
|
.mutex_signaux)); |
|
|
if ((*(*((struct_thread *) (*l_element_courant).donnee)) |
if ((*(*((struct_thread *) (*l_element_courant).donnee)) |
.s_etat_processus).pointeur_signal_ecriture != |
.s_etat_processus).pointeur_signal_ecriture != |
(*(*((struct_thread *) (*l_element_courant).donnee)) |
(*(*((struct_thread *) (*l_element_courant) |
.s_etat_processus).pointeur_signal_lecture) |
.donnee)).s_etat_processus) |
|
.pointeur_signal_lecture) |
{ |
{ |
nombre_signaux_envoyes++; |
nombre_signaux_envoyes++; |
pthread_kill((*((struct_thread *) (*l_element_courant) |
pthread_kill((*((struct_thread *) |
.donnee)).tid, SIGALRM); |
(*l_element_courant).donnee)).tid, SIGALRM); |
} |
} |
|
|
|
pthread_mutex_unlock(&((*(*((struct_thread *) |
|
(*l_element_courant).donnee)).s_etat_processus) |
|
.mutex_signaux)); |
} |
} |
|
|
l_element_courant = (*l_element_courant).suivant; |
l_element_courant = (*l_element_courant).suivant; |
Line 339 retrait_thread(struct_processus *s_etat_
|
Line 342 retrait_thread(struct_processus *s_etat_
|
(*l_element_courant).donnee)).s_etat_processus) |
(*l_element_courant).donnee)).s_etat_processus) |
.pointeur_signal_lecture) |
.pointeur_signal_lecture) |
{ |
{ |
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
while(sem_wait(&((*s_queue_signaux).signalisation)) != 0) |
|
# else |
|
while(sem_wait(semaphore_signalisation) != 0) |
while(sem_wait(semaphore_signalisation) != 0) |
# endif |
|
{ |
{ |
if (errno != EINTR) |
if (errno != EINTR) |
{ |
{ |
Line 555 liberation_threads(struct_processus *s_e
|
Line 554 liberation_threads(struct_processus *s_e
|
struct_liste_variables_statiques *l_element_statique_courant; |
struct_liste_variables_statiques *l_element_statique_courant; |
struct_liste_variables_statiques *l_element_statique_suivant; |
struct_liste_variables_statiques *l_element_statique_suivant; |
|
|
unsigned long i; |
integer8 i; |
|
|
void *element_candidat; |
void *element_candidat; |
void *element_courant; |
void *element_courant; |
Line 598 liberation_threads(struct_processus *s_e
|
Line 597 liberation_threads(struct_processus *s_e
|
close((*s_etat_processus).pipe_injections); |
close((*s_etat_processus).pipe_injections); |
close((*s_etat_processus).pipe_nombre_injections); |
close((*s_etat_processus).pipe_nombre_injections); |
close((*s_etat_processus).pipe_interruptions); |
close((*s_etat_processus).pipe_interruptions); |
close((*s_etat_processus).pipe_nombre_objets_attente); |
close((*s_etat_processus).pipe_nombre_elements_attente); |
close((*s_etat_processus).pipe_nombre_interruptions_attente); |
|
|
|
liberation(s_etat_processus, (*s_etat_processus).at_exit); |
liberation(s_etat_processus, (*s_etat_processus).at_exit); |
|
|
Line 667 liberation_threads(struct_processus *s_e
|
Line 665 liberation_threads(struct_processus *s_e
|
close((*s_argument_thread).pipe_acquittement[1]); |
close((*s_argument_thread).pipe_acquittement[1]); |
close((*s_argument_thread).pipe_injections[1]); |
close((*s_argument_thread).pipe_injections[1]); |
close((*s_argument_thread).pipe_nombre_injections[1]); |
close((*s_argument_thread).pipe_nombre_injections[1]); |
close((*s_argument_thread).pipe_nombre_objets_attente[0]); |
close((*s_argument_thread).pipe_nombre_elements_attente[0]); |
close((*s_argument_thread).pipe_interruptions[0]); |
close((*s_argument_thread).pipe_interruptions[0]); |
close((*s_argument_thread) |
|
.pipe_nombre_interruptions_attente[0]); |
|
|
|
if (pthread_mutex_unlock(&((*s_argument_thread) |
if (pthread_mutex_unlock(&((*s_argument_thread) |
.mutex_nombre_references)) != 0) |
.mutex_nombre_references)) != 0) |
Line 1269 liberation_threads(struct_processus *s_e
|
Line 1265 liberation_threads(struct_processus *s_e
|
# endif |
# endif |
|
|
liberation_contexte_cas(s_etat_processus); |
liberation_contexte_cas(s_etat_processus); |
free(s_etat_processus); |
liberation_allocateur_buffer(s_etat_processus); |
|
sys_free(s_etat_processus); |
|
|
s_etat_processus = candidat; |
s_etat_processus = candidat; |
} |
} |
Line 1311 liberation_threads(struct_processus *s_e
|
Line 1308 liberation_threads(struct_processus *s_e
|
close((*s_argument_thread).pipe_acquittement[1]); |
close((*s_argument_thread).pipe_acquittement[1]); |
close((*s_argument_thread).pipe_injections[1]); |
close((*s_argument_thread).pipe_injections[1]); |
close((*s_argument_thread).pipe_nombre_injections[1]); |
close((*s_argument_thread).pipe_nombre_injections[1]); |
close((*s_argument_thread).pipe_nombre_objets_attente[0]); |
close((*s_argument_thread).pipe_nombre_elements_attente[0]); |
close((*s_argument_thread).pipe_interruptions[0]); |
close((*s_argument_thread).pipe_interruptions[0]); |
close((*s_argument_thread).pipe_nombre_interruptions_attente[0]); |
|
|
|
if (pthread_mutex_unlock(&((*s_argument_thread) |
if (pthread_mutex_unlock(&((*s_argument_thread) |
.mutex_nombre_references)) != 0) |
.mutex_nombre_references)) != 0) |
Line 1371 recherche_thread(pid_t pid, pthread_t ti
|
Line 1367 recherche_thread(pid_t pid, pthread_t ti
|
|
|
struct_processus *s_etat_processus; |
struct_processus *s_etat_processus; |
|
|
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
|
{ |
|
return(NULL); |
|
} |
|
|
l_element_courant = liste_threads; |
l_element_courant = liste_threads; |
|
|
while(l_element_courant != NULL) |
while(l_element_courant != NULL) |
Line 1391 recherche_thread(pid_t pid, pthread_t ti
|
Line 1392 recherche_thread(pid_t pid, pthread_t ti
|
* Le processus n'existe plus. On ne distribue aucun signal. |
* Le processus n'existe plus. On ne distribue aucun signal. |
*/ |
*/ |
|
|
|
pthread_mutex_unlock(&mutex_liste_threads); |
return(NULL); |
return(NULL); |
} |
} |
|
|
s_etat_processus = (*((struct_thread *) |
s_etat_processus = (*((struct_thread *) |
(*l_element_courant).donnee)).s_etat_processus; |
(*l_element_courant).donnee)).s_etat_processus; |
|
|
|
if (pthread_mutex_unlock(&mutex_liste_threads) != 0) |
|
{ |
|
return(NULL); |
|
} |
|
|
return(s_etat_processus); |
return(s_etat_processus); |
} |
} |
|
|
Line 1452 recherche_thread_principal(pid_t pid)
|
Line 1459 recherche_thread_principal(pid_t pid)
|
static inline void |
static inline void |
verrouillage_gestionnaire_signaux(struct_processus *s_etat_processus) |
verrouillage_gestionnaire_signaux(struct_processus *s_etat_processus) |
{ |
{ |
int semaphore; |
|
|
|
# ifndef SEMAPHORES_NOMMES |
# ifndef SEMAPHORES_NOMMES |
if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) |
if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) |
# else |
# else |
Line 1464 verrouillage_gestionnaire_signaux(struct
|
Line 1469 verrouillage_gestionnaire_signaux(struct
|
return; |
return; |
} |
} |
|
|
// Il faut respecteur l'atomicité des deux opérations suivantes ! |
|
|
|
if (pthread_mutex_lock(&mutex_gestionnaires_signaux_atomique) != 0) |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Unlock error !\n")); |
|
return; |
|
} |
|
|
|
# ifndef SEMAPHORES_NOMMES |
|
if (sem_post(&semaphore_gestionnaires_signaux) == -1) |
|
# else |
|
if (sem_post(semaphore_gestionnaires_signaux) == -1) |
|
# endif |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Lock error !\n")); |
|
return; |
|
} |
|
|
|
# ifndef SEMAPHORES_NOMMES |
|
if (sem_getvalue(&semaphore_gestionnaires_signaux, &semaphore) != 0) |
|
# else |
|
if (sem_getvalue(semaphore_gestionnaires_signaux, &semaphore) != 0) |
|
# endif |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Lock error !\n")); |
|
return; |
|
} |
|
|
|
if (pthread_mutex_unlock(&mutex_gestionnaires_signaux_atomique) != 0) |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Unlock error !\n")); |
|
return; |
|
} |
|
|
|
if (semaphore == 1) |
|
{ |
|
// Le semaphore ne peut être pris par le thread qui a appelé |
|
// le gestionnaire de signal car le signal est bloqué par ce thread |
|
// dans les zones critiques. Ce sémaphore ne peut donc être bloqué que |
|
// par un thread concurrent. On essaye donc de le bloquer jusqu'à |
|
// ce que ce soit possible. |
|
|
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Lock error !\n")); |
|
return; |
|
} |
|
} |
|
|
|
return; |
return; |
} |
} |
|
|
static inline void |
static inline void |
deverrouillage_gestionnaire_signaux(struct_processus *s_etat_processus) |
deverrouillage_gestionnaire_signaux(struct_processus *s_etat_processus) |
{ |
{ |
int semaphore; |
|
|
|
// Il faut respecteur l'atomicité des deux opérations suivantes ! |
|
|
|
if (pthread_mutex_lock(&mutex_gestionnaires_signaux_atomique) == -1) |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Unlock error !\n")); |
|
return; |
|
} |
|
|
|
# ifndef SEMAPHORES_NOMMES |
|
if (sem_getvalue(&semaphore_gestionnaires_signaux, &semaphore) != 0) |
|
# else |
|
if (sem_getvalue(semaphore_gestionnaires_signaux, &semaphore) != 0) |
|
# endif |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Unlock error !\n")); |
|
return; |
|
} |
|
|
|
# ifndef SEMAPHORES_NOMMES |
|
while(sem_wait(&semaphore_gestionnaires_signaux) == -1) |
|
# else |
|
while(sem_wait(semaphore_gestionnaires_signaux) == -1) |
|
# endif |
|
{ |
|
if (errno != EINTR) |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Unlock error !\n")); |
|
return; |
|
} |
|
} |
|
|
|
if (pthread_mutex_unlock(&mutex_gestionnaires_signaux_atomique) != 0) |
|
{ |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_wait(&((*s_etat_processus).semaphore_fork)); |
|
# else |
|
sem_wait((*s_etat_processus).semaphore_fork); |
|
# endif |
|
BUG(1, uprintf("Unlock error !\n")); |
|
return; |
|
} |
|
|
|
# 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 1616 deverrouillage_gestionnaire_signaux(stru
|
Line 1488 deverrouillage_gestionnaire_signaux(stru
|
} |
} |
} |
} |
|
|
if (semaphore == 1) |
|
{ |
|
if (pthread_mutex_unlock(&mutex_liste_threads) != 0) |
|
{ |
|
BUG(1, uprintf("Unlock error !\n")); |
|
return; |
|
} |
|
} |
|
|
|
return; |
return; |
} |
} |
|
|
Line 1735 thread_signaux(void *argument)
|
Line 1598 thread_signaux(void *argument)
|
pthread_exit(NULL); |
pthread_exit(NULL); |
} |
} |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
read(fds.fd, &signal, 1); |
read(fds.fd, &signal, 1); |
|
|
|
# pragma GCC diagnostic pop |
|
|
if (signal != (0xFF & rpl_sigmax)) |
if (signal != (0xFF & rpl_sigmax)) |
{ |
{ |
envoi_signal_processus(getpid(), signal); |
envoi_signal_processus(getpid(), signal); |
Line 1759 interruption1(int signal)
|
Line 1627 interruption1(int signal)
|
|
|
test_signal(signal); |
test_signal(signal); |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
switch(signal) |
switch(signal) |
{ |
{ |
case SIGINT: |
case SIGINT: |
Line 1781 interruption1(int signal)
|
Line 1652 interruption1(int signal)
|
break; |
break; |
} |
} |
|
|
|
# pragma GCC diagnostic pop |
|
|
return; |
return; |
} |
} |
|
|
Line 1802 interruption2(int signal)
|
Line 1675 interruption2(int signal)
|
test_signal(signal); |
test_signal(signal); |
|
|
signal_tronque = (unsigned char) (rpl_sigtstp & 0xFF); |
signal_tronque = (unsigned char) (rpl_sigtstp & 0xFF); |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
write(pipe_signaux, &signal_tronque, sizeof(signal_tronque)); |
write(pipe_signaux, &signal_tronque, sizeof(signal_tronque)); |
|
|
|
# pragma GCC diagnostic pop |
|
|
return; |
return; |
} |
} |
|
|
Line 1825 interruption3(int signal)
|
Line 1705 interruption3(int signal)
|
kill(pid_processus_pere, SIGUSR1); |
kill(pid_processus_pere, SIGUSR1); |
} |
} |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
if (signal != SIGUSR2) |
if (signal != SIGUSR2) |
{ |
{ |
write(STDERR_FILENO, message_1, strlen(message_1)); |
write(STDERR_FILENO, message_1, strlen(message_1)); |
Line 1834 interruption3(int signal)
|
Line 1717 interruption3(int signal)
|
write(STDERR_FILENO, message_2, strlen(message_2)); |
write(STDERR_FILENO, message_2, strlen(message_2)); |
} |
} |
|
|
|
# pragma GCC diagnostic pop |
|
|
_exit(EXIT_FAILURE); |
_exit(EXIT_FAILURE); |
} |
} |
|
|
Line 1848 interruption4(int signal)
|
Line 1733 interruption4(int signal)
|
test_signal(signal); |
test_signal(signal); |
|
|
signal_tronque = (unsigned char) (rpl_sighup & 0xFF); |
signal_tronque = (unsigned char) (rpl_sighup & 0xFF); |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
write(pipe_signaux, &signal_tronque, sizeof(signal_tronque)); |
write(pipe_signaux, &signal_tronque, sizeof(signal_tronque)); |
|
|
|
# pragma GCC diagnostic pop |
|
|
return; |
return; |
} |
} |
|
|
Line 1864 interruption5(int signal)
|
Line 1756 interruption5(int signal)
|
|
|
test_signal(signal); |
test_signal(signal); |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
if (pid_processus_pere == getpid()) |
if (pid_processus_pere == getpid()) |
{ |
{ |
signal_tronque = (unsigned char) (rpl_sigalrm & 0xFF); |
signal_tronque = (unsigned char) (rpl_sigalrm & 0xFF); |
Line 1871 interruption5(int signal)
|
Line 1766 interruption5(int signal)
|
} |
} |
|
|
write(STDERR_FILENO, message, strlen(message)); |
write(STDERR_FILENO, message, strlen(message)); |
|
|
|
# pragma GCC diagnostic pop |
|
|
return; |
return; |
} |
} |
|
|
Line 2152 interruption_violation_access(void *adre
|
Line 2050 interruption_violation_access(void *adre
|
return(0); |
return(0); |
} |
} |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
write(STDERR_FILENO, message, strlen(message)); |
write(STDERR_FILENO, message, strlen(message)); |
|
|
|
# pragma GCC diagnostic pop |
|
|
if (pid_processus_pere == getpid()) |
if (pid_processus_pere == getpid()) |
{ |
{ |
longjmp(contexte_initial, -1); |
longjmp(contexte_initial, -1); |
Line 2409 signal_hup(struct_processus *s_etat_proc
|
Line 2312 signal_hup(struct_processus *s_etat_proc
|
return; |
return; |
} |
} |
|
|
snprintf(nom, 8 + 64 + 1, "rpl-out-%lu-%lu", (unsigned long) getpid(), |
snprintf(nom, 8 + 64 + 1, "rpl-out-%llu-%llu", |
(unsigned long) pthread_self()); |
(unsigned long long) getpid(), |
|
(unsigned long long) pthread_self()); |
|
|
|
# pragma GCC diagnostic push |
|
# pragma GCC diagnostic ignored "-Wunused-result" |
|
|
if ((fichier = fopen(nom, "w+")) != NULL) |
if ((fichier = fopen(nom, "w+")) != NULL) |
{ |
{ |
Line 2422 signal_hup(struct_processus *s_etat_proc
|
Line 2329 signal_hup(struct_processus *s_etat_proc
|
|
|
freopen("/dev/null", "r", stdin); |
freopen("/dev/null", "r", stdin); |
|
|
|
# pragma GCC diagnostic pop |
|
|
if (((*s_etat_processus).type_debug & d_debug_signaux) != 0) |
if (((*s_etat_processus).type_debug & d_debug_signaux) != 0) |
{ |
{ |
printf("[%d] RPL/SIGHUP (thread %llu)\n", (int) getpid(), |
printf("[%d] RPL/SIGHUP (thread %llu)\n", (int) getpid(), |
Line 2542 scrutation_interruptions(struct_processu
|
Line 2451 scrutation_interruptions(struct_processu
|
// à lire. Les pointeurs d'écriture pointent sur les prochains éléments à |
// à lire. Les pointeurs d'écriture pointent sur les prochains éléments à |
// écrire. |
// écrire. |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
if (sem_trywait(semaphore_queue_signaux) == 0) |
if (sem_trywait(&((*s_queue_signaux).semaphore)) == 0) |
|
# else |
|
if (sem_trywait(semaphore_queue_signaux) == 0) |
|
# endif |
|
{ |
{ |
while((*s_queue_signaux).pointeur_lecture != |
while((*s_queue_signaux).pointeur_lecture != |
(*s_queue_signaux).pointeur_ecriture) |
(*s_queue_signaux).pointeur_ecriture) |
Line 2562 scrutation_interruptions(struct_processu
|
Line 2467 scrutation_interruptions(struct_processu
|
((*s_queue_signaux).pointeur_lecture + 1) |
((*s_queue_signaux).pointeur_lecture + 1) |
% LONGUEUR_QUEUE_SIGNAUX; |
% LONGUEUR_QUEUE_SIGNAUX; |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
# ifndef IPCS_SYSV |
while(sem_wait(&((*s_queue_signaux).signalisation)) != 0) |
if (msync(s_queue_signaux, sizeof(s_queue_signaux), |
# else |
MS_ASYNC | MS_INVALIDATE) != 0) |
while(sem_wait(semaphore_signalisation) != 0) |
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
# endif |
# endif |
|
|
|
while(sem_wait(semaphore_signalisation) != 0) |
{ |
{ |
if (errno != EINTR) |
if (errno != EINTR) |
{ |
{ |
Line 2576 scrutation_interruptions(struct_processu
|
Line 2486 scrutation_interruptions(struct_processu
|
} |
} |
} |
} |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
sem_post(semaphore_queue_signaux); |
sem_post(&((*s_queue_signaux).semaphore)); |
|
# else |
|
sem_post(semaphore_queue_signaux); |
|
# endif |
|
} |
} |
|
|
// Interruptions qui arrivent depuis le groupe courant de threads. |
// Interruptions qui arrivent depuis le groupe courant de threads. |
|
|
if (pthread_mutex_trylock(&mutex_interruptions) == 0) |
if (pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux)) == 0) |
{ |
{ |
while((*s_etat_processus).pointeur_signal_lecture != |
while((*s_etat_processus).pointeur_signal_lecture != |
(*s_etat_processus).pointeur_signal_ecriture) |
(*s_etat_processus).pointeur_signal_ecriture) |
Line 2600 scrutation_interruptions(struct_processu
|
Line 2506 scrutation_interruptions(struct_processu
|
((*s_etat_processus).pointeur_signal_lecture + 1) |
((*s_etat_processus).pointeur_signal_lecture + 1) |
% LONGUEUR_QUEUE_SIGNAUX; |
% LONGUEUR_QUEUE_SIGNAUX; |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
while(sem_wait(&((*s_queue_signaux).signalisation)) != 0) |
|
# else |
|
while(sem_wait(semaphore_signalisation) != 0) |
while(sem_wait(semaphore_signalisation) != 0) |
# endif |
|
{ |
{ |
if (errno != EINTR) |
if (errno != EINTR) |
{ |
{ |
Line 2614 scrutation_interruptions(struct_processu
|
Line 2516 scrutation_interruptions(struct_processu
|
} |
} |
} |
} |
|
|
pthread_mutex_unlock(&mutex_interruptions); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux)); |
} |
} |
|
|
return; |
return; |
} |
} |
|
|
|
|
/* |
/* |
================================================================================ |
================================================================================ |
Fonction renvoyant le nom du segment de mémoire partagée en fonction |
Fonction renvoyant le nom du segment de mémoire partagée en fonction |
Line 2641 nom_segment(unsigned char *chemin, pid_t
|
Line 2544 nom_segment(unsigned char *chemin, pid_t
|
# ifdef IPCS_SYSV // !POSIX |
# ifdef IPCS_SYSV // !POSIX |
# ifndef OS2 // !OS2 |
# ifndef OS2 // !OS2 |
|
|
if ((fichier = malloc((strlen(chemin) + 1 + 256 + 1) * |
if ((fichier = sys_malloc((strlen(chemin) + 1 + 256 + 1) * |
sizeof(unsigned char))) == NULL) |
sizeof(unsigned char))) == NULL) |
{ |
{ |
return(NULL); |
return(NULL); |
Line 2649 nom_segment(unsigned char *chemin, pid_t
|
Line 2552 nom_segment(unsigned char *chemin, pid_t
|
|
|
sprintf(fichier, "%s/RPL-SIGQUEUES-%d", chemin, (int) pid); |
sprintf(fichier, "%s/RPL-SIGQUEUES-%d", chemin, (int) pid); |
# else // OS2 |
# else // OS2 |
if ((fichier = malloc((10 + 256 + 1) * sizeof(unsigned char))) |
if ((fichier = sys_malloc((10 + 256 + 1) * sizeof(unsigned char))) |
== NULL) |
== NULL) |
{ |
{ |
return(NULL); |
return(NULL); |
Line 2659 nom_segment(unsigned char *chemin, pid_t
|
Line 2562 nom_segment(unsigned char *chemin, pid_t
|
# endif // OS2 |
# endif // OS2 |
# else // POSIX |
# else // POSIX |
|
|
if ((fichier = malloc((1 + 256 + 1) * |
if ((fichier = sys_malloc((1 + 256 + 1) * |
sizeof(unsigned char))) == NULL) |
sizeof(unsigned char))) == NULL) |
{ |
{ |
return(NULL); |
return(NULL); |
Line 2692 envoi_signal_processus(pid_t pid, enum s
|
Line 2595 envoi_signal_processus(pid_t pid, enum s
|
# endif |
# endif |
|
|
# ifndef IPCS_SYSV |
# ifndef IPCS_SYSV |
# ifdef SEMAPHORES_NOMMES |
sem_t *semaphore; |
sem_t *semaphore; |
sem_t *signalisation; |
sem_t *signalisation; |
|
# endif |
|
# else |
# else |
|
sem_t *semaphore; |
|
sem_t *signalisation; |
# ifndef OS2 |
# ifndef OS2 |
int desc; |
int desc; |
key_t clef; |
key_t clef; |
Line 2719 envoi_signal_processus(pid_t pid, enum s
|
Line 2622 envoi_signal_processus(pid_t pid, enum s
|
return(1); |
return(1); |
} |
} |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
while(sem_wait(semaphore_queue_signaux) != 0) |
while(sem_wait(&((*s_queue_signaux).semaphore)) != 0) |
|
# else |
|
while(sem_wait(semaphore_queue_signaux) != 0) |
|
# endif |
|
{ |
{ |
if (errno != EINTR) |
if (errno != EINTR) |
{ |
{ |
Line 2740 envoi_signal_processus(pid_t pid, enum s
|
Line 2639 envoi_signal_processus(pid_t pid, enum s
|
((*s_queue_signaux).pointeur_ecriture + 1) |
((*s_queue_signaux).pointeur_ecriture + 1) |
% LONGUEUR_QUEUE_SIGNAUX; |
% LONGUEUR_QUEUE_SIGNAUX; |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
# ifndef IPCS_SYSV |
if (sem_post(&((*s_queue_signaux).semaphore)) != 0) |
if (msync(s_queue_signaux, sizeof(s_queue_signaux), |
# else |
MS_ASYNC | MS_INVALIDATE) != 0) |
if (sem_post(semaphore_queue_signaux) != 0) |
{ |
|
return(1); |
|
} |
# endif |
# endif |
|
|
|
if (sem_post(semaphore_queue_signaux) != 0) |
{ |
{ |
return(1); |
return(1); |
} |
} |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
if (sem_post(semaphore_signalisation) != 0) |
if (sem_post(&((*s_queue_signaux).signalisation)) != 0) |
|
# else |
|
if (sem_post(semaphore_signalisation) != 0) |
|
# endif |
|
{ |
{ |
return(1); |
return(1); |
} |
} |
Line 2771 envoi_signal_processus(pid_t pid, enum s
|
Line 2670 envoi_signal_processus(pid_t pid, enum s
|
# ifndef OS2 // SysV |
# ifndef OS2 // SysV |
if ((desc = open(nom, O_RDWR)) == -1) |
if ((desc = open(nom, O_RDWR)) == -1) |
{ |
{ |
free(nom); |
sys_free(nom); |
return(1); |
return(1); |
} |
} |
|
|
Line 2779 envoi_signal_processus(pid_t pid, enum s
|
Line 2678 envoi_signal_processus(pid_t pid, enum s
|
|
|
if ((clef = ftok(nom, 1)) == -1) |
if ((clef = ftok(nom, 1)) == -1) |
{ |
{ |
free(nom); |
sys_free(nom); |
return(1); |
return(1); |
} |
} |
|
|
free(nom); |
sys_free(nom); |
|
|
if ((segment = shmget(clef, sizeof(struct_queue_signaux), 0)) |
if ((segment = shmget(clef, sizeof(struct_queue_signaux), 0)) |
== -1) |
== -1) |
Line 2796 envoi_signal_processus(pid_t pid, enum s
|
Line 2695 envoi_signal_processus(pid_t pid, enum s
|
if (DosGetNamedSharedMem((PVOID) &queue, nom, |
if (DosGetNamedSharedMem((PVOID) &queue, nom, |
PAG_WRITE | PAG_READ) != 0) |
PAG_WRITE | PAG_READ) != 0) |
{ |
{ |
free(nom); |
sys_free(nom); |
return(1); |
return(1); |
} |
} |
|
|
free(nom); |
sys_free(nom); |
# endif |
# endif |
# else // POSIX |
# else // POSIX |
if ((nom = nom_segment(racine_segment, pid)) == NULL) |
if ((nom = nom_segment(racine_segment, pid)) == NULL) |
Line 2810 envoi_signal_processus(pid_t pid, enum s
|
Line 2709 envoi_signal_processus(pid_t pid, enum s
|
|
|
if ((segment = shm_open(nom, O_RDWR, 0)) == -1) |
if ((segment = shm_open(nom, O_RDWR, 0)) == -1) |
{ |
{ |
free(nom); |
sys_free(nom); |
return(1); |
return(1); |
} |
} |
|
|
free(nom); |
sys_free(nom); |
|
|
if ((queue = mmap(NULL, sizeof(struct_queue_signaux), |
if ((queue = mmap(NULL, sizeof(struct_queue_signaux), |
PROT_READ | PROT_WRITE, MAP_SHARED, segment, 0)) == |
PROT_READ | PROT_WRITE, MAP_SHARED, segment, 0)) == |
Line 2825 envoi_signal_processus(pid_t pid, enum s
|
Line 2724 envoi_signal_processus(pid_t pid, enum s
|
} |
} |
# endif |
# endif |
|
|
// À ce moment, le segment de mémoire partagée est projeté |
// À ce moment, le segment de mémoire partagée est projeté |
// dans l'espace du processus. |
// dans l'espace du processus. |
|
|
# ifndef IPCS_SYSV // POSIX |
if ((semaphore = sem_open2(pid, SEM_QUEUE)) == SEM_FAILED) |
# ifndef SEMAPHORES_NOMMES |
{ |
while(sem_wait(&((*queue).semaphore)) != 0) |
return(1); |
{ |
} |
if (errno != EINTR) |
|
{ |
|
return(1); |
|
} |
|
} |
|
# else |
|
if ((semaphore = sem_open2(pid, SEM_QUEUE)) == SEM_FAILED) |
|
{ |
|
return(1); |
|
} |
|
|
|
if ((signalisation = sem_open2(pid, SEM_SIGNALISATION)) |
if ((signalisation = sem_open2(pid, SEM_SIGNALISATION)) |
== SEM_FAILED) |
== SEM_FAILED) |
{ |
{ |
return(1); |
return(1); |
} |
} |
|
|
while(sem_wait(semaphore) != 0) |
while(sem_wait(semaphore) != 0) |
{ |
{ |
if (errno != EINTR) |
if (errno != EINTR) |
{ |
|
sem_close(semaphore); |
|
sem_close(signalisation); |
|
return(1); |
|
} |
|
} |
|
# endif |
|
# else // IPCS_SYSV |
|
while(sem_wait(&((*queue).semaphore)) != 0) |
|
{ |
{ |
if (errno != EINTR) |
sem_close(semaphore); |
{ |
sem_close(signalisation); |
return(1); |
return(1); |
} |
|
} |
} |
# endif |
} |
|
|
(*queue).queue[(*queue).pointeur_ecriture].pid = getpid(); |
(*queue).queue[(*queue).pointeur_ecriture].pid = getpid(); |
(*queue).queue[(*queue).pointeur_ecriture].signal = signal; |
(*queue).queue[(*queue).pointeur_ecriture].signal = signal; |
Line 2875 envoi_signal_processus(pid_t pid, enum s
|
Line 2754 envoi_signal_processus(pid_t pid, enum s
|
(*queue).pointeur_ecriture = ((*queue).pointeur_ecriture + 1) |
(*queue).pointeur_ecriture = ((*queue).pointeur_ecriture + 1) |
% LONGUEUR_QUEUE_SIGNAUX; |
% LONGUEUR_QUEUE_SIGNAUX; |
|
|
# ifndef IPCS_SYSV // POSIX |
# ifndef IPCS_SYSV |
# ifndef SEMAPHORES_NOMMES |
if (msync(queue, sizeof(queue), MS_ASYNC | MS_INVALIDATE) != 0) |
if (sem_post(&((*queue).semaphore)) != 0) |
{ |
{ |
sem_close(semaphore); |
return(1); |
sem_close(signalisation); |
} |
return(1); |
|
} |
if (sem_post(&((*queue).signalisation)) != 0) |
# endif |
{ |
|
return(1); |
|
} |
|
# else |
|
if (sem_post(semaphore) != 0) |
|
{ |
|
sem_close(semaphore); |
|
sem_close(signalisation); |
|
return(1); |
|
} |
|
|
|
if (sem_close(semaphore) != 0) |
if (sem_post(semaphore) != 0) |
{ |
{ |
return(1); |
sem_close(semaphore); |
} |
sem_close(signalisation); |
|
return(1); |
|
} |
|
|
if (sem_post(signalisation) != 0) |
if (sem_close(semaphore) != 0) |
{ |
{ |
sem_close(signalisation); |
return(1); |
return(1); |
} |
} |
|
|
|
if (sem_close(signalisation) != 0) |
if (sem_post(signalisation) != 0) |
{ |
{ |
return(1); |
sem_close(signalisation); |
} |
return(1); |
|
} |
|
|
# endif |
if (sem_close(signalisation) != 0) |
|
{ |
|
return(1); |
|
} |
|
|
|
# ifndef IPCS_SYSV // POSIX |
if (munmap(queue, sizeof(struct_queue_signaux)) != 0) |
if (munmap(queue, sizeof(struct_queue_signaux)) != 0) |
{ |
{ |
close(segment); |
close(segment); |
return(1); |
return(1); |
} |
} |
# else // IPCS_SYSV |
# else // IPCS_SYSV |
if (sem_post(&((*queue).semaphore)) != 0) |
|
{ |
|
return(1); |
|
} |
|
|
|
if (sem_post(&((*queue).signalisation)) != 0) |
|
{ |
|
return(1); |
|
} |
|
|
|
# ifndef OS2 // SysV |
# ifndef OS2 // SysV |
if (shmdt(queue) != 0) |
if (shmdt(queue) != 0) |
{ |
{ |
Line 2976 envoi_signal_thread(pthread_t tid, enum
|
Line 2841 envoi_signal_thread(pthread_t tid, enum
|
return(1); |
return(1); |
} |
} |
|
|
if (pthread_mutex_lock(&mutex_interruptions) != 0) |
s_etat_processus = (*((struct_thread *) (*l_element_courant).donnee)) |
|
.s_etat_processus; |
|
|
|
if (pthread_mutex_lock(&((*s_etat_processus).mutex_signaux)) != 0) |
{ |
{ |
pthread_mutex_unlock(&mutex_liste_threads); |
pthread_mutex_unlock(&mutex_liste_threads); |
return(1); |
return(1); |
} |
} |
|
|
s_etat_processus = (*((struct_thread *) (*l_element_courant).donnee)) |
|
.s_etat_processus; |
|
|
|
(*s_etat_processus).signaux_en_queue |
(*s_etat_processus).signaux_en_queue |
[(*s_etat_processus).pointeur_signal_ecriture] = signal; |
[(*s_etat_processus).pointeur_signal_ecriture] = signal; |
(*s_etat_processus).pointeur_signal_ecriture = |
(*s_etat_processus).pointeur_signal_ecriture = |
((*s_etat_processus).pointeur_signal_ecriture + 1) |
((*s_etat_processus).pointeur_signal_ecriture + 1) |
% LONGUEUR_QUEUE_SIGNAUX; |
% LONGUEUR_QUEUE_SIGNAUX; |
|
|
if (pthread_mutex_unlock(&mutex_interruptions) != 0) |
if (pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux)) != 0) |
{ |
{ |
pthread_mutex_unlock(&mutex_liste_threads); |
pthread_mutex_unlock(&mutex_liste_threads); |
return(1); |
return(1); |
Line 3002 envoi_signal_thread(pthread_t tid, enum
|
Line 2867 envoi_signal_thread(pthread_t tid, enum
|
return(1); |
return(1); |
} |
} |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
if (sem_post(&((*s_queue_signaux).signalisation)) != 0) |
|
{ |
|
return(1); |
|
} |
|
# else |
|
if (sem_post(semaphore_signalisation) != 0) |
if (sem_post(semaphore_signalisation) != 0) |
{ |
{ |
return(1); |
return(1); |
} |
} |
# endif |
|
|
|
return(0); |
return(0); |
} |
} |
Line 3021 int
|
Line 2879 int
|
envoi_signal_contexte(struct_processus *s_etat_processus_a_signaler, |
envoi_signal_contexte(struct_processus *s_etat_processus_a_signaler, |
enum signaux_rpl signal) |
enum signaux_rpl signal) |
{ |
{ |
pthread_mutex_lock(&mutex_interruptions); |
pthread_mutex_lock(&((*s_etat_processus_a_signaler).mutex_signaux)); |
(*s_etat_processus_a_signaler).signaux_en_queue |
(*s_etat_processus_a_signaler).signaux_en_queue |
[(*s_etat_processus_a_signaler).pointeur_signal_ecriture] = |
[(*s_etat_processus_a_signaler).pointeur_signal_ecriture] = |
signal; |
signal; |
(*s_etat_processus_a_signaler).pointeur_signal_ecriture = |
(*s_etat_processus_a_signaler).pointeur_signal_ecriture = |
((*s_etat_processus_a_signaler).pointeur_signal_ecriture + 1) |
((*s_etat_processus_a_signaler).pointeur_signal_ecriture + 1) |
% LONGUEUR_QUEUE_SIGNAUX; |
% LONGUEUR_QUEUE_SIGNAUX; |
pthread_mutex_unlock(&mutex_interruptions); |
pthread_mutex_unlock(&((*s_etat_processus_a_signaler).mutex_signaux)); |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
if (sem_post(&((*s_queue_signaux).signalisation)) != 0) |
|
{ |
|
return(1); |
|
} |
|
# else |
|
if (sem_post(semaphore_signalisation) != 0) |
if (sem_post(semaphore_signalisation) != 0) |
{ |
{ |
return(1); |
return(1); |
} |
} |
# endif |
|
|
|
return(0); |
return(0); |
} |
} |
Line 3079 creation_queue_signaux(struct_processus
|
Line 2930 creation_queue_signaux(struct_processus
|
if ((f_queue_signaux = shm_open(nom, O_RDWR | O_CREAT | O_EXCL, |
if ((f_queue_signaux = shm_open(nom, O_RDWR | O_CREAT | O_EXCL, |
S_IRUSR | S_IWUSR)) == -1) |
S_IRUSR | S_IWUSR)) == -1) |
{ |
{ |
free(nom); |
sys_free(nom); |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |
} |
} |
|
|
if (ftruncate(f_queue_signaux, sizeof(struct_queue_signaux)) == -1) |
if (ftruncate(f_queue_signaux, sizeof(struct_queue_signaux)) == -1) |
{ |
{ |
free(nom); |
sys_free(nom); |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |
} |
} |
Line 3098 creation_queue_signaux(struct_processus
|
Line 2949 creation_queue_signaux(struct_processus
|
{ |
{ |
if (shm_unlink(nom) == -1) |
if (shm_unlink(nom) == -1) |
{ |
{ |
free(nom); |
sys_free(nom); |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |
} |
} |
|
|
free(nom); |
sys_free(nom); |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |
} |
} |
|
|
free(nom); |
sys_free(nom); |
|
|
# ifndef SEMAPHORES_NOMMES |
if ((semaphore_queue_signaux = sem_init2(1, getpid(), SEM_QUEUE)) |
sem_init(&((*s_queue_signaux).semaphore), 1, 1); |
== SEM_FAILED) |
sem_init(&((*s_queue_signaux).signalisation), 1, 0); |
{ |
# else |
(*s_etat_processus).erreur_systeme = d_es_processus; |
if ((semaphore_queue_signaux = sem_init2(1, getpid(), SEM_QUEUE)) |
return; |
== SEM_FAILED) |
} |
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if ((semaphore_signalisation = sem_init2(1, getpid(), |
if ((semaphore_signalisation = sem_init2(0, getpid(), |
SEM_SIGNALISATION)) == SEM_FAILED) |
SEM_SIGNALISATION)) == SEM_FAILED) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
} |
} |
# endif |
|
|
if ((semaphore_arret_signalisation = sem_init2(1, getpid(), |
|
SEM_ARRET_SIGNALISATION)) == SEM_FAILED) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
(*s_queue_signaux).pointeur_lecture = 0; |
(*s_queue_signaux).pointeur_lecture = 0; |
(*s_queue_signaux).pointeur_ecriture = 0; |
(*s_queue_signaux).pointeur_ecriture = 0; |
|
|
(*s_queue_signaux).requete_arret = d_faux; |
(*s_queue_signaux).requete_arret = d_faux; |
|
|
if (msync(s_queue_signaux, sizeof(struct_queue_signaux), 0)) |
if (msync(s_queue_signaux, sizeof(struct_queue_signaux), MS_SYNC)) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
Line 3169 creation_queue_signaux(struct_processus
|
Line 3023 creation_queue_signaux(struct_processus
|
} |
} |
|
|
close(support); |
close(support); |
free(nom); |
sys_free(nom); |
|
|
if ((segment = shmget(clef, sizeof(struct_queue_signaux), |
if ((segment = shmget(clef, sizeof(struct_queue_signaux), |
IPC_CREAT | IPC_EXCL | S_IRUSR | S_IWUSR)) == -1) |
IPC_CREAT | IPC_EXCL | S_IRUSR | S_IWUSR)) == -1) |
Line 3194 creation_queue_signaux(struct_processus
|
Line 3048 creation_queue_signaux(struct_processus
|
return; |
return; |
} |
} |
|
|
sem_init(&((*s_queue_signaux).semaphore), 1, 1); |
if ((semaphore_queue_signaux = sem_init2(1, getpid(), SEM_QUEUE)) |
sem_init(&((*s_queue_signaux).signalisation), 1, 0); |
== SEM_FAILED) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if ((semaphore_signalisation = sem_init2(0, getpid(), |
|
SEM_SIGNALISATION)) == SEM_FAILED) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
if ((semaphore_arret_signalisation = sem_init2(1, getpid(), |
|
SEM_ARRET_SIGNALISATION)) == SEM_FAILED) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
(*s_queue_signaux).pointeur_lecture = 0; |
(*s_queue_signaux).pointeur_lecture = 0; |
(*s_queue_signaux).pointeur_ecriture = 0; |
(*s_queue_signaux).pointeur_ecriture = 0; |
(*s_queue_signaux).requete_arret = d_faux; |
(*s_queue_signaux).requete_arret = d_faux; |
Line 3210 creation_queue_signaux(struct_processus
|
Line 3083 creation_queue_signaux(struct_processus
|
sizeof(struct_queue_signaux), |
sizeof(struct_queue_signaux), |
PAG_WRITE | PAG_READ | PAG_COMMIT) != 0) |
PAG_WRITE | PAG_READ | PAG_COMMIT) != 0) |
{ |
{ |
free(nom); |
sys_free(nom); |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |
} |
} |
|
|
free(nom); |
sys_free(nom); |
|
|
sem_init(&((*s_queue_signaux).semaphore), 1, 1); |
sem_init(&((*s_queue_signaux).semaphore), 1, 1); |
sem_init(&((*s_queue_signaux).signalisation), 1, 0); |
sem_init(&((*s_queue_signaux).signalisation), 1, 0); |
|
sem_init(&((*s_queue_signaux).arret_signalisation), 1, 1); |
|
|
(*s_queue_signaux).pointeur_lecture = 0; |
(*s_queue_signaux).pointeur_lecture = 0; |
(*s_queue_signaux).pointeur_ecriture = 0; |
(*s_queue_signaux).pointeur_ecriture = 0; |
(*s_queue_signaux).requete_arret = d_faux; |
(*s_queue_signaux).requete_arret = d_faux; |
Line 3297 creation_queue_signaux(struct_processus
|
Line 3172 creation_queue_signaux(struct_processus
|
void |
void |
liberation_queue_signaux(struct_processus *s_etat_processus) |
liberation_queue_signaux(struct_processus *s_etat_processus) |
{ |
{ |
// Incrémenter le sémaphore pour être sûr de le débloquer. |
sem_wait(semaphore_arret_signalisation); |
|
|
(*s_queue_signaux).requete_arret = d_vrai; |
(*s_queue_signaux).requete_arret = d_vrai; |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
# ifndef IPCS_SYSV |
sem_post(&((*s_queue_signaux).signalisation)); |
msync(s_queue_signaux, sizeof(s_queue_signaux), MS_ASYNC | MS_INVALIDATE); |
# else |
|
sem_post(semaphore_signalisation); |
|
# endif |
# endif |
|
|
|
sem_post(semaphore_arret_signalisation); |
|
|
|
// Incrémenter le sémaphore pour être sûr de le débloquer. |
|
|
|
sem_post(semaphore_signalisation); |
pthread_join((*s_queue_signaux).thread_signaux, NULL); |
pthread_join((*s_queue_signaux).thread_signaux, NULL); |
|
|
# ifdef IPCS_SYSV // SystemV |
# ifdef IPCS_SYSV // SystemV |
Line 3319 liberation_queue_signaux(struct_processu
|
Line 3196 liberation_queue_signaux(struct_processu
|
# else // OS/2 |
# else // OS/2 |
# endif |
# endif |
# else // POSIX |
# else // POSIX |
# ifndef SEMAPHORES_NOMMES |
sem_close(semaphore_queue_signaux); |
sem_close(&((*s_queue_signaux).semaphore)); |
sem_close(semaphore_signalisation); |
sem_close(&((*s_queue_signaux).signalisation)); |
sem_close(semaphore_arret_signalisation); |
# else |
|
sem_close(semaphore_queue_signaux); |
|
sem_close(semaphore_signalisation); |
|
# endif |
|
|
|
if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0) |
if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0) |
{ |
{ |
Line 3360 destruction_queue_signaux(struct_process
|
Line 3233 destruction_queue_signaux(struct_process
|
unsigned char *nom; |
unsigned char *nom; |
# endif |
# endif |
|
|
// Incrémenter le sémaphore pour être sûr de le débloquer. |
sem_wait(semaphore_arret_signalisation); |
|
|
(*s_queue_signaux).requete_arret = d_vrai; |
(*s_queue_signaux).requete_arret = d_vrai; |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
# ifndef IPCS_SYSV |
sem_post(&((*s_queue_signaux).signalisation)); |
msync(s_queue_signaux, sizeof(s_queue_signaux), MS_ASYNC | MS_INVALIDATE); |
# else |
|
sem_post(semaphore_signalisation); |
|
# endif |
# endif |
|
|
|
sem_post(semaphore_arret_signalisation); |
|
|
|
// Incrémenter le sémaphore pour être sûr de le débloquer. |
|
|
|
sem_post(semaphore_signalisation); |
pthread_join((*s_queue_signaux).thread_signaux, NULL); |
pthread_join((*s_queue_signaux).thread_signaux, NULL); |
|
|
# ifdef IPCS_SYSV // SystemV |
# ifdef IPCS_SYSV // SystemV |
# ifndef OS2 |
# ifndef OS2 |
// Il faut commencer par éliminer le sémaphore. |
// Il faut commencer par éliminer le sémaphore. |
|
|
if (semctl((*s_queue_signaux).semaphore.sem, 0, IPC_RMID) == -1) |
if (semctl((*semaphore_queue_signaux).sem, 0, IPC_RMID) == -1) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
return; |
|
} |
|
|
|
unlink((*semaphore_queue_signaux).path); |
|
sys_free((*semaphore_queue_signaux).path); |
|
|
|
if (semctl((*semaphore_signalisation).sem, 0, IPC_RMID) == -1) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
} |
} |
|
|
unlink((*s_queue_signaux).semaphore.path); |
unlink((*semaphore_signalisation).path); |
free((*s_queue_signaux).semaphore.path); |
sys_free((*semaphore_signalisation).path); |
|
|
if (semctl((*s_queue_signaux).signalisation.sem, 0, IPC_RMID) == -1) |
if (semctl((*semaphore_arret_signalisation).sem, 0, IPC_RMID) == -1) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
(*s_etat_processus).erreur_systeme = d_es_processus; |
return; |
return; |
} |
} |
|
|
unlink((*s_queue_signaux).signalisation.path); |
unlink((*semaphore_arret_signalisation).path); |
free((*s_queue_signaux).signalisation.path); |
sys_free((*semaphore_arret_signalisation).path); |
|
|
if (shmdt(s_queue_signaux) == -1) |
if (shmdt(s_queue_signaux) == -1) |
{ |
{ |
Line 3414 destruction_queue_signaux(struct_process
|
Line 3299 destruction_queue_signaux(struct_process
|
} |
} |
|
|
unlink(nom); |
unlink(nom); |
free(nom); |
sys_free(nom); |
# else |
# else |
sem_close(&((*s_queue_signaux).semaphore)); |
sem_close(&((*s_queue_signaux).semaphore)); |
sem_destroy(&((*s_queue_signaux).semaphore)); |
sem_destroy(&((*s_queue_signaux).semaphore)); |
Line 3422 destruction_queue_signaux(struct_process
|
Line 3307 destruction_queue_signaux(struct_process
|
sem_close(&((*s_queue_signaux).signalisation)); |
sem_close(&((*s_queue_signaux).signalisation)); |
sem_destroy(&((*s_queue_signaux).signalisation)); |
sem_destroy(&((*s_queue_signaux).signalisation)); |
|
|
|
sem_close(&((*s_queue_signaux).arret_signalisation)); |
|
sem_destroy(&((*s_queue_signaux).arret_signalisation)); |
|
|
if (DosFreeMem(s_queue_signaux) != 0) |
if (DosFreeMem(s_queue_signaux) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
Line 3429 destruction_queue_signaux(struct_process
|
Line 3317 destruction_queue_signaux(struct_process
|
} |
} |
# endif |
# endif |
# else // POSIX |
# else // POSIX |
# ifndef SEMAPHORES_NOMMES |
sem_destroy2(semaphore_queue_signaux, getpid(), SEM_QUEUE); |
sem_close(&((*s_queue_signaux).semaphore)); |
sem_destroy2(semaphore_signalisation, getpid(), SEM_SIGNALISATION); |
sem_destroy(&((*s_queue_signaux).semaphore)); |
sem_destroy2(semaphore_arret_signalisation, getpid(), |
|
SEM_ARRET_SIGNALISATION); |
sem_close(&((*s_queue_signaux).signalisation)); |
|
sem_destroy(&((*s_queue_signaux).signalisation)); |
|
# else |
|
sem_close(semaphore_queue_signaux); |
|
sem_destroy2(semaphore_queue_signaux, getpid(), SEM_QUEUE); |
|
|
|
sem_close(semaphore_signalisation); |
|
sem_destroy2(semaphore_signalisation, getpid(), SEM_SIGNALISATION); |
|
# endif |
|
|
|
if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0) |
if (munmap(s_queue_signaux, sizeof(struct_queue_signaux)) != 0) |
{ |
{ |
Line 3459 destruction_queue_signaux(struct_process
|
Line 3338 destruction_queue_signaux(struct_process
|
|
|
if (shm_unlink(nom) != 0) |
if (shm_unlink(nom) != 0) |
{ |
{ |
free(nom); |
sys_free(nom); |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire; |
return; |
return; |
} |
} |
|
|
free(nom); |
sys_free(nom); |
# endif |
# endif |
|
|
return; |
return; |