--- rpl/src/instructions_s10.c 2010/03/04 10:17:53 1.4 +++ rpl/src/instructions_s10.c 2010/07/14 14:19:38 1.18 @@ -1,6 +1,6 @@ /* ================================================================================ - RPL/2 (R) version 4.0.12 + RPL/2 (R) version 4.0.18 Copyright (C) 1989-2010 Dr. BERTRAND Joël This file is part of RPL/2. @@ -111,8 +111,7 @@ instruction_spawn(struct_processus *s_et * d'une fonction ou d'une expression RPN. */ - if (((*s_objet).type != NOM) && - ((*s_objet).type != RPN)) + if (((*s_objet).type != NOM) && ((*s_objet).type != RPN)) { liberation(s_etat_processus, s_objet); @@ -266,6 +265,12 @@ instruction_spawn(struct_processus *s_et return; } + if (sigaddset(&set, SIGFABORT) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if (sigaddset(&set, SIGURG) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -454,6 +459,7 @@ instruction_spawn(struct_processus *s_et (*s_argument_thread).set = set; (*s_argument_thread).oldset = oldset; + (*s_argument_thread).thread_actif = d_faux; if (pthread_create(&thread_id, &attributs, lancement_thread, s_argument_thread) != 0) @@ -462,6 +468,15 @@ instruction_spawn(struct_processus *s_et return; } + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + while((*s_argument_thread).thread_actif == d_faux) + { + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + } + if (pthread_attr_destroy(&attributs) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -795,7 +810,7 @@ instruction_sqlconnect(struct_processus /* ================================================================================ - Fonction 'sqlconnect' + Fonction 'sqldisconnect' ================================================================================ Entrées : -------------------------------------------------------------------------------- @@ -883,6 +898,7 @@ instruction_sqldisconnect(struct_process "MYSQL") == 0) { # ifdef MYSQL_SUPPORT + if ((*((struct_connecteur_sql *) (*(*l_element_courant) .donnee).objet)).descripteur.mysql == (*((struct_connecteur_sql *) (*s_objet).objet)) @@ -894,6 +910,7 @@ instruction_sqldisconnect(struct_process { drapeau = d_faux; } + # else if ((*s_etat_processus).langue == 'F') @@ -915,6 +932,7 @@ instruction_sqldisconnect(struct_process .type, "POSTGRESQL") == 0) { # ifdef POSTGRESQL_SUPPORT + if ((*((struct_connecteur_sql *) (*(*l_element_courant) .donnee).objet)).descripteur.postgresql == (*((struct_connecteur_sql *) (*s_objet).objet)) @@ -1155,11 +1173,19 @@ instruction_smphrdecr(struct_processus * } } +# ifndef SEMAPHORES_NOMMES if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } +# endif while(sem_wait((*((struct_semaphore *) (*s_objet_argument).objet)) .semaphore) == -1) @@ -1178,7 +1204,11 @@ instruction_smphrdecr(struct_processus * } } +# ifndef SEMAPHORES_NOMMES while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) == -1) +# endif { if (errno != EINTR) { @@ -1297,11 +1327,19 @@ instruction_smphrtrydecr(struct_processu } } +# ifndef SEMAPHORES_NOMMES if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; } +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } +# endif (*((integer8 *) (*s_objet_resultat).objet)) = 0; @@ -1341,7 +1379,11 @@ instruction_smphrtrydecr(struct_processu } } +# ifndef SEMAPHORES_NOMMES while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) == -1) +# endif { if (errno != EINTR) {