version 1.128, 2013/05/22 12:05:42
|
version 1.159, 2015/07/21 12:22:16
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.14 |
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 (sem_wait(semaphore_arret_signalisation) != 0) |
|
{ |
|
(*s_etat_processus).erreur_systeme = d_es_processus; |
|
} |
|
|
if ((*s_queue_signaux).requete_arret == d_vrai) |
if ((*s_queue_signaux).requete_arret == d_vrai) |
{ |
{ |
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
sem_post(semaphore_arret_signalisation); |
sem_post(&(*s_queue_signaux).signalisation); |
|
# else |
|
sem_post(semaphore_signalisation); |
sem_post(semaphore_signalisation); |
# endif |
|
|
|
break; |
break; |
} |
} |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
sem_post(semaphore_arret_signalisation); |
sem_post(&(*s_queue_signaux).signalisation); |
|
# else |
|
sem_post(semaphore_signalisation); |
sem_post(semaphore_signalisation); |
# endif |
|
|
|
nombre_signaux_envoyes = 0; |
nombre_signaux_envoyes = 0; |
sched_yield(); |
sched_yield(); |
Line 123 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 142 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 159 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()) |
{ |
{ |
if (pthread_mutex_lock(&mutex_interruptions) != 0) |
pthread_mutex_lock(&((*(*((struct_thread *) |
|
(*l_element_courant).donnee)).s_etat_processus) |
|
.mutex_signaux)); |
|
|
|
if ((*(*((struct_thread *) (*l_element_courant).donnee)) |
|
.s_etat_processus).pointeur_signal_ecriture != |
|
(*(*((struct_thread *) (*l_element_courant) |
|
.donnee)).s_etat_processus) |
|
.pointeur_signal_lecture) |
{ |
{ |
(*s_etat_processus).erreur_systeme = d_es_processus; |
nombre_signaux_envoyes++; |
|
pthread_kill((*((struct_thread *) |
|
(*l_element_courant).donnee)).tid, SIGALRM); |
} |
} |
else |
|
{ |
|
if ((*(*((struct_thread *) (*l_element_courant).donnee)) |
|
.s_etat_processus).pointeur_signal_ecriture != |
|
(*(*((struct_thread *) (*l_element_courant) |
|
.donnee)).s_etat_processus) |
|
.pointeur_signal_lecture) |
|
{ |
|
nombre_signaux_envoyes++; |
|
pthread_kill((*((struct_thread *) |
|
(*l_element_courant).donnee)).tid, SIGALRM); |
|
} |
|
|
|
if (pthread_mutex_unlock(&mutex_interruptions) != 0) |
pthread_mutex_unlock(&((*(*((struct_thread *) |
{ |
(*l_element_courant).donnee)).s_etat_processus) |
(*s_etat_processus).erreur_systeme = d_es_processus; |
.mutex_signaux)); |
} |
|
} |
|
} |
} |
|
|
l_element_courant = (*l_element_courant).suivant; |
l_element_courant = (*l_element_courant).suivant; |
Line 358 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 1285 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 1386 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 1406 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 1467 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 1479 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 1631 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 1750 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 1774 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 1796 interruption1(int signal)
|
Line 1652 interruption1(int signal)
|
break; |
break; |
} |
} |
|
|
|
# pragma GCC diagnostic pop |
|
|
return; |
return; |
} |
} |
|
|
Line 1817 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 1840 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 1849 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 1863 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 1879 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 1886 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 2167 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 2428 signal_hup(struct_processus *s_etat_proc
|
Line 2316 signal_hup(struct_processus *s_etat_proc
|
(unsigned long long) getpid(), |
(unsigned long long) getpid(), |
(unsigned long long) pthread_self()); |
(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) |
{ |
{ |
fclose(fichier); |
fclose(fichier); |
Line 2438 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 2558 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 2578 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 2592 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 2616 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 2630 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 2657 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 2665 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 2675 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 2708 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 2735 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 2756 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 2787 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 2795 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 2812 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 2826 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 2841 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 2891 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 2967 envoi_signal_thread(pthread_t tid, enum
|
Line 2816 envoi_signal_thread(pthread_t tid, enum
|
|
|
struct_processus *s_etat_processus; |
struct_processus *s_etat_processus; |
|
|
if (pthread_mutex_lock(&mutex_interruptions) != 0) |
|
{ |
|
pthread_mutex_unlock(&mutex_liste_threads); |
|
return(1); |
|
} |
|
|
|
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
if (pthread_mutex_lock(&mutex_liste_threads) != 0) |
{ |
{ |
return(1); |
return(1); |
Line 3001 envoi_signal_thread(pthread_t tid, enum
|
Line 2844 envoi_signal_thread(pthread_t tid, enum
|
s_etat_processus = (*((struct_thread *) (*l_element_courant).donnee)) |
s_etat_processus = (*((struct_thread *) (*l_element_courant).donnee)) |
.s_etat_processus; |
.s_etat_processus; |
|
|
|
if (pthread_mutex_lock(&((*s_etat_processus).mutex_signaux)) != 0) |
|
{ |
|
pthread_mutex_unlock(&mutex_liste_threads); |
|
return(1); |
|
} |
|
|
(*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 3018 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 3037 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 3095 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 3114 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 3185 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 3210 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 3226 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 3293 creation_queue_signaux(struct_processus
|
Line 3152 creation_queue_signaux(struct_processus
|
return; |
return; |
} |
} |
|
|
|
(*s_queue_signaux).controle = getpid(); |
return; |
return; |
} |
} |
|
|
Line 3313 creation_queue_signaux(struct_processus
|
Line 3173 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 |
|
|
pthread_join((*s_queue_signaux).thread_signaux, NULL); |
sem_post(semaphore_arret_signalisation); |
|
|
|
// Incrémenter le sémaphore pour être sûr de le débloquer. |
|
|
|
sem_post(semaphore_signalisation); |
|
|
|
if (getpid() == (*s_queue_signaux).controle) |
|
{ |
|
pthread_join((*s_queue_signaux).thread_signaux, NULL); |
|
} |
|
|
# ifdef IPCS_SYSV // SystemV |
# ifdef IPCS_SYSV // SystemV |
# ifndef OS2 |
# ifndef OS2 |
Line 3335 liberation_queue_signaux(struct_processu
|
Line 3201 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); |
// Rien à faire, les sémaphores sont anonymes. |
sem_close(semaphore_signalisation); |
# else |
sem_close(semaphore_arret_signalisation); |
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 3375 destruction_queue_signaux(struct_process
|
Line 3238 destruction_queue_signaux(struct_process
|
unsigned char *nom; |
unsigned char *nom; |
# endif |
# endif |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
sem_wait(semaphore_arret_signalisation); |
sem_wait(&((*s_queue_signaux).signalisation)); |
|
# else |
|
sem_wait(semaphore_signalisation); |
|
# endif |
|
|
|
(*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. |
// Incrémenter le sémaphore pour être sûr de le débloquer. |
|
|
# if (!defined(SEMAPHORES_NOMMES)) || defined(IPCS_SYSV) |
|
sem_post(&((*s_queue_signaux).signalisation)); |
|
# else |
|
sem_post(semaphore_signalisation); |
sem_post(semaphore_signalisation); |
# endif |
|
|
|
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 3441 destruction_queue_signaux(struct_process
|
Line 3304 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 3449 destruction_queue_signaux(struct_process
|
Line 3312 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 3456 destruction_queue_signaux(struct_process
|
Line 3322 destruction_queue_signaux(struct_process
|
} |
} |
# endif |
# endif |
# else // POSIX |
# else // POSIX |
# ifndef SEMAPHORES_NOMMES |
sem_destroy2(semaphore_queue_signaux, getpid(), SEM_QUEUE); |
sem_destroy(&((*s_queue_signaux).semaphore)); |
sem_destroy2(semaphore_signalisation, getpid(), SEM_SIGNALISATION); |
sem_destroy(&((*s_queue_signaux).signalisation)); |
sem_destroy2(semaphore_arret_signalisation, getpid(), |
# else |
SEM_ARRET_SIGNALISATION); |
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 3483 destruction_queue_signaux(struct_process
|
Line 3343 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; |