--- rpl/src/interruptions.c 2016/03/15 16:31:15 1.168 +++ rpl/src/interruptions.c 2016/03/16 12:19:34 1.169 @@ -1615,7 +1615,7 @@ thread_signaux(void *argument) if (signal != (0xFF & rpl_sigmax)) { - envoi_signal_processus(getpid(), signal); + envoi_signal_processus(getpid(), signal, d_faux); // Un signal SIGALRM est envoyé par le thread de surveillance // des signaux jusqu'à ce que les signaux soient tous traités. } @@ -1805,7 +1805,7 @@ signal_alrm(struct_processus *s_etat_pro { // On n'est pas dans le processus père, on remonte le signal. envoi_signal_processus((*s_etat_processus).pid_processus_pere, - rpl_sigalrm); + rpl_sigalrm, d_faux); } else { @@ -1850,7 +1850,7 @@ signal_term(struct_processus *s_etat_pro if ((*s_etat_processus).pid_processus_pere != getpid()) { envoi_signal_processus((*s_etat_processus).pid_processus_pere, - rpl_sigterm); + rpl_sigterm, d_faux); } else { @@ -1904,7 +1904,7 @@ signal_int(struct_processus *s_etat_proc if ((*s_etat_processus).pid_processus_pere != getpid()) { envoi_signal_processus((*s_etat_processus).pid_processus_pere, - rpl_sigint); + rpl_sigint, d_faux); } else { @@ -1975,7 +1975,7 @@ signal_tstp(struct_processus *s_etat_pro if ((*s_etat_processus).var_volatile_processus_pere == 0) { envoi_signal_processus((*s_etat_processus).pid_processus_pere, - rpl_sigtstp); + rpl_sigtstp, d_faux); } else { @@ -2356,7 +2356,7 @@ traitement_exceptions_gsl(const char *re int line, int gsl_errno) { code_erreur_gsl = gsl_errno; - envoi_signal_processus(getpid(), rpl_sigexcept); + envoi_signal_processus(getpid(), rpl_sigexcept, d_faux); return; } @@ -2609,7 +2609,8 @@ nom_segment(unsigned char *chemin, pid_t */ int -envoi_signal_processus(pid_t pid, enum signaux_rpl signal) +envoi_signal_processus(pid_t pid, enum signaux_rpl signal, + logical1 test_ouverture) { # ifndef OS2 int segment; @@ -2629,6 +2630,8 @@ envoi_signal_processus(pid_t pid, enum s struct_queue_signaux *queue; + struct timespec attente; + unsigned char *nom; // Il s'agit d'ouvrir le segment de mémoire partagée, de le projeter en @@ -2690,10 +2693,24 @@ envoi_signal_processus(pid_t pid, enum s } # ifndef OS2 // SysV - if ((desc = open(nom, O_RDWR)) == -1) + if (test_ouverture == d_vrai) { - sys_free(nom); - return(1); + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + while((desc = open(nom, O_RDWR)) == -1) + { + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + } + } + else + { + if ((desc = open(nom, O_RDWR)) == -1) + { + sys_free(nom); + return(1); + } } close(desc); @@ -2729,10 +2746,24 @@ envoi_signal_processus(pid_t pid, enum s return(1); } - if ((segment = shm_open(nom, O_RDWR, 0)) == -1) + if (test_ouverture == d_vrai) { - sys_free(nom); - return(1); + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + while((segment = shm_open(nom, O_RDWR, 0)) == -1) + { + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + } + } + else + { + if ((segment = shm_open(nom, O_RDWR, 0)) == -1) + { + sys_free(nom); + return(1); + } } sys_free(nom);