--- rpl/src/daemon.c 2011/07/22 07:38:34 1.28 +++ rpl/src/daemon.c 2013/02/26 19:56:12 1.48 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.1 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.12 + Copyright (C) 1989-2013 Dr. BERTRAND Joël This file is part of RPL/2. @@ -59,22 +59,8 @@ lancement_daemon(struct_processus *s_eta fflush(NULL); -# ifdef _BROKEN_SIGINFO - destruction_fifos_signaux(s_etat_processus); -# endif - pid = fork(); -# ifdef OS2 - if (pid == 0) - { - sem_init(&semaphore_liste_threads, 0, 1); - sem_init(&semaphore_gestionnaires_signaux, 0, 0); - sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1); - sem_init(&((*s_etat_processus).semaphore_fork), 0, 0); - } -# endif - if (pid < 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -84,6 +70,27 @@ lancement_daemon(struct_processus *s_eta if (pid > 0) { // Fin du processus père. + + // À noter : dans le cas où l'on utilise l'émulation des + // sémaphores anonymes POSIX ou la sémantique SysV, il faut + // détruire les sémaphores et les recréer dans le processus fils. + +# ifndef SEMAPHORE_NOMMES + sem_post(&((*s_etat_processus).semaphore_fork)); + sem_destroy(&((*s_etat_processus).semaphore_fork)); + + sem_post(&semaphore_gestionnaires_signaux); + sem_destroy(&semaphore_gestionnaires_signaux); +# else + sem_post((*s_etat_processus).semaphore_fork); + sem_destroy3((*s_etat_processus).semaphore_fork, getpid(), + pthread_self(), SEM_FORK); + + sem_post(semaphore_gestionnaires_signaux); + sem_destroy2(semaphore_gestionnaires_signaux, getpid(), SEM_SIGNAUX); +# endif + + destruction_queue_signaux(s_etat_processus); _exit(EXIT_SUCCESS); } @@ -112,20 +119,6 @@ lancement_daemon(struct_processus *s_eta fflush(NULL); pid = fork(); -# ifdef _BROKEN_SIGINFO - creation_fifos_signaux(s_etat_processus); -# endif - -# ifdef OS2 - if (pid == 0) - { - sem_init(&semaphore_liste_threads, 0, 1); - sem_init(&semaphore_gestionnaires_signaux, 0, 0); - sem_init(&semaphore_gestionnaires_signaux_atomique, 0, 1); - sem_init(&((*s_etat_processus).semaphore_fork), 0, 0); - } -# endif - if (pid < 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -139,8 +132,28 @@ lancement_daemon(struct_processus *s_eta } (*s_etat_processus).pid_processus_pere = getpid(); + creation_queue_signaux(s_etat_processus); modification_pid_thread_pere(s_etat_processus); +# ifndef SEMAPHORES_NOMMES + sem_init(&semaphore_gestionnaires_signaux, 0, 0); + sem_init(&((*s_etat_processus).semaphore_fork), 0, 0); +# else + if ((semaphore_gestionnaires_signaux = sem_init2(0, getpid(), SEM_SIGNAUX)) + == SEM_FAILED) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } + + if ((sem_init(&((*s_etat_processus).semaphore_fork), 0, 0)) + == SEM_FAILED) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } +# endif + return; }