--- rpl/src/instructions_w1.c 2011/06/20 17:54:20 1.37 +++ rpl/src/instructions_w1.c 2013/03/11 11:07:25 1.76 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.0.prerelease.1 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.13 + Copyright (C) 1989-2013 Dr. BERTRAND Joël This file is part of RPL/2. @@ -262,26 +262,22 @@ instruction_wait(struct_processus *s_eta do { # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif code_retour = nanosleep(&temporisation, &temporisation); erreur = errno; # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -389,14 +385,17 @@ instruction_write(struct_processus *s_et int adresse[16]; int port; + int sqlite_status; integer8 clef; integer8 compteur; integer8 id; integer8 ordre; + logical1 format_degenere; logical1 mise_a_jour; + long longueur; long longueur_effective; long recursivite; @@ -426,12 +425,15 @@ instruction_write(struct_processus *s_et struct flock lock; + struct timespec attente; + uint32_t calcul_adresse; unsigned char *chaine; unsigned char *chaine_utf8; unsigned char *clef_utf8; unsigned char *commande; + unsigned char *format_chaine; unsigned long i; @@ -590,7 +592,7 @@ instruction_write(struct_processus *s_et if ((chaine = formateur_fichier(s_etat_processus, s_objet_argument_2, (*((struct_fichier *) (*s_objet_argument_1).objet)).format, 0, 0, ' ', 'F', - &longueur_effective, &recursivite)) == NULL) + &longueur_effective, &recursivite, d_vrai)) == NULL) { liberation(s_etat_processus, s_objet_argument_2); liberation(s_etat_processus, s_objet_argument_1); @@ -672,7 +674,8 @@ instruction_write(struct_processus *s_et if ((chaine = formateur_fichier(s_etat_processus, s_objet_argument_3, (*((struct_fichier *) (*s_objet_argument_1).objet)).format, 0, 0, ' ', - 'F', &longueur_effective, &recursivite)) == NULL) + 'F', &longueur_effective, &recursivite, d_vrai)) + == NULL) { liberation(s_etat_processus, s_objet_argument_3); liberation(s_etat_processus, s_objet_argument_2); @@ -761,11 +764,30 @@ instruction_write(struct_processus *s_et return; } - if (sqlite3_step(ppStmt) != SQLITE_ROW) + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + do { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return; - } + sqlite_status = sqlite3_step(ppStmt); + + if (sqlite_status == SQLITE_ROW) + { + break; + } + else if ((sqlite_status == SQLITE_BUSY) || + (sqlite_status == SQLITE_LOCKED)) + { + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + } + else + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + } while(sqlite_status != SQLITE_ROW); if (sqlite3_column_type(ppStmt, 0) != SQLITE_INTEGER) { @@ -876,7 +898,8 @@ instruction_write(struct_processus *s_et if ((chaine = formateur_fichier(s_etat_processus, s_element, s_format, 0, 0, ' ', - 'F', &longueur_effective, &recursivite)) == NULL) + 'F', &longueur_effective, &recursivite, d_vrai)) + == NULL) { liberation(s_etat_processus, s_element); liberation(s_etat_processus, s_format); @@ -918,100 +941,107 @@ instruction_write(struct_processus *s_et return; } - switch(sqlite3_step(ppStmt)) + attente.tv_sec = 0; + attente.tv_nsec = GRANULARITE_us * 1000; + + do { - case SQLITE_ROW: + switch(sqlite_status = sqlite3_step(ppStmt)) { - // Une clef existe. + case SQLITE_ROW: + { + // Une clef existe. - mise_a_jour = d_vrai; - break; - } + mise_a_jour = d_vrai; + break; + } - case SQLITE_DONE: - { - // Aucune clef n'existe. + case SQLITE_DONE: + { + // Aucune clef n'existe. - mise_a_jour = d_faux; + mise_a_jour = d_faux; - if (sqlite3_finalize(ppStmt) != SQLITE_OK) - { - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; - } + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } - free(commande); + free(commande); - if (alsprintf(&commande, "insert into key " - "(key) values ('%s')", clef_utf8) < 0) - { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; - return; - } + if (alsprintf(&commande, "insert into key " + "(key) values ('%s')", clef_utf8) < 0) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } - if (sqlite3_prepare_v2((*descripteur) - .descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) - != SQLITE_OK) - { - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; - } + if (sqlite3_prepare_v2((*descripteur) + .descripteur_sqlite, + commande, strlen(commande), &ppStmt, &queue) + != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } - if (sqlite3_step(ppStmt) != SQLITE_DONE) - { - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; - } + if (sqlite3_step(ppStmt) != SQLITE_DONE) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } - if (sqlite3_finalize(ppStmt) != SQLITE_OK) - { - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; - } + if (sqlite3_finalize(ppStmt) != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } - free(commande); + free(commande); - if (alsprintf(&commande, "select id from key " - "where key = '%s'", clef_utf8) < 0) - { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; - return; + if (alsprintf(&commande, "select id from key " + "where key = '%s'", clef_utf8) < 0) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if (sqlite3_prepare_v2((*descripteur) + .descripteur_sqlite, + commande, strlen(commande), &ppStmt, &queue) + != SQLITE_OK) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + + break; } - if (sqlite3_prepare_v2((*descripteur) - .descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) - != SQLITE_OK) + case SQLITE_BUSY: + case SQLITE_LOCKED: { - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; + nanosleep(&attente, NULL); + INCR_GRANULARITE(attente.tv_nsec); + break; } - if (sqlite3_step(ppStmt) != SQLITE_ROW) + default: { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return; } - - break; } - - default: - { - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; - } - } + } while(sqlite_status != SQLITE_ROW); if (sqlite3_column_type(ppStmt, 0) != SQLITE_INTEGER) { @@ -1183,7 +1213,8 @@ instruction_write(struct_processus *s_et if ((chaine = formateur_fichier(s_etat_processus, s_element, s_format, 0, 0, ' ', - 'F', &longueur_effective, &recursivite)) == NULL) + 'F', &longueur_effective, &recursivite, d_vrai)) + == NULL) { free(clef_utf8); @@ -1276,20 +1307,30 @@ instruction_write(struct_processus *s_et * Fichiers non formatés */ - if ((chaine = formateur_fichier(s_etat_processus, - s_objet_argument_2, (*((struct_fichier *) - (*s_objet_argument_1).objet)).format, 0, 0, ' ', 'U', - &longueur_effective, &recursivite)) == NULL) - { - liberation(s_etat_processus, s_objet_argument_2); - liberation(s_etat_processus, s_objet_argument_1); - - return; - } - if ((*((struct_fichier *) (*s_objet_argument_1).objet)).acces == 'S') { + if ((*s_objet_argument_2).type != LST) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + if ((chaine = formateur_fichier(s_etat_processus, + s_objet_argument_2, (*((struct_fichier *) + (*s_objet_argument_1).objet)).format, 0, 0, ' ', 'U', + &longueur_effective, &recursivite, d_vrai)) == NULL) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + return; + } + BUG(((*descripteur).type != 'C'), uprintf("Bad filetype !\n")); if (fseek((*descripteur).descripteur_c, (long) 0, SEEK_END) @@ -1313,10 +1354,67 @@ instruction_write(struct_processus *s_et else if ((*((struct_fichier *) (*s_objet_argument_1).objet)).acces == 'D') { + if ((*s_objet_argument_2).type != INT) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + if (depilement(s_etat_processus, &((*s_etat_processus) + .l_base_pile), &s_objet_argument_3) == d_erreur) + { + (*s_etat_processus).erreur_execution = d_ex_manque_argument; + return; + } + + if ((*s_objet_argument_3).type != LST) + { + liberation(s_etat_processus, s_objet_argument_3); + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + if ((chaine = formateur_fichier(s_etat_processus, + s_objet_argument_2, (*((struct_fichier *) + (*s_objet_argument_1).objet)).format, 0, 0, ' ', 'U', + &longueur_effective, &recursivite, d_faux)) == NULL) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + return; + } } - else + else // Fichiers indexés { - /* Fichiers indexés : panique totale ! */ + if ((*s_objet_argument_2).type != LST) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + if ((chaine = formateur_fichier(s_etat_processus, + s_objet_argument_2, (*((struct_fichier *) + (*s_objet_argument_1).objet)).format, 0, 0, ' ', 'U', + &longueur_effective, &recursivite, d_faux)) == NULL) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + return; + } } free(chaine); @@ -1332,8 +1430,7 @@ instruction_write(struct_processus *s_et { BUG(((*descripteur).type != 'C'), uprintf("Bad filetype !\n")); - if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet)) - .donnee)).type != CHN) + if ((*s_objet_argument_2).type != LST) { liberation(s_etat_processus, s_objet_argument_2); liberation(s_etat_processus, s_objet_argument_1); @@ -1343,24 +1440,158 @@ instruction_write(struct_processus *s_et return; } - if ((chaine = formateur_flux(s_etat_processus, (unsigned char *) - (*((*((struct_liste_chainee *) (*s_objet_argument_2) - .objet)).donnee)).objet, &longueur_effective)) == NULL) + if ((*((struct_liste_chainee *) (*s_objet_argument_2).objet)) + .donnee == NULL) { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; return; } - if (fwrite(chaine, sizeof(unsigned char), longueur_effective, - (*descripteur).descripteur_c) != - (size_t) longueur_effective) + l_element_courant = (*s_objet_argument_2).objet; + l_element_courant_format = (struct_liste_chainee *) + (*(*((struct_fichier *) (*s_objet_argument_1).objet)) + .format).objet; + + while((l_element_courant != NULL) && + (l_element_courant_format != NULL)) { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return; + if ((*(*l_element_courant).donnee).type != CHN) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + if ((*(*l_element_courant_format).donnee).type != CHN) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } + + if ((format_chaine = conversion_majuscule((unsigned char *) + (*(*l_element_courant_format).donnee).objet)) + == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if (strncmp("LENGTH*(", format_chaine, 8) != 0) + { + free(format_chaine); + + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } + + longueur = strlen(format_chaine); + + if (format_chaine[longueur - 1] != ')') + { + free(format_chaine); + + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } + + format_chaine[longueur] = d_code_fin_chaine; + + if (format_chaine[8] == '*') + { + format_degenere = d_vrai; + } + else + { + // Détermination de la longueur + format_degenere = d_faux; + + if (sscanf(&(format_chaine[8]), "%ld", &longueur) != 1) + { + free(format_chaine); + + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } + } + + free(format_chaine); + + if ((chaine = formateur_flux(s_etat_processus, + (unsigned char *) (*(*l_element_courant).donnee) + .objet, &longueur_effective)) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + if ((format_degenere == d_vrai) || + (longueur_effective < longueur)) + { + if (fwrite(chaine, sizeof(unsigned char), + longueur_effective, + (*descripteur).descripteur_c) != + (size_t) longueur_effective) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + } + else + { + if (fwrite(chaine, sizeof(unsigned char), + longueur_effective, + (*descripteur).descripteur_c) != + (size_t) longueur) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + } + + free(chaine); + + l_element_courant = (*l_element_courant).suivant; + l_element_courant_format = (*l_element_courant_format) + .suivant; } - free(chaine); + if ((l_element_courant_format != NULL) || + (l_element_courant != NULL)) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } } else { @@ -1399,7 +1630,7 @@ instruction_write(struct_processus *s_et if ((chaine = formateur_fichier(s_etat_processus, s_objet_argument_2, (*((struct_socket *) (*s_objet_argument_1).objet)).format, 0, 0, ' ', 'F', - &longueur_effective, &recursivite)) == NULL) + &longueur_effective, &recursivite, d_faux)) == NULL) { liberation(s_etat_processus, s_objet_argument_2); liberation(s_etat_processus, s_objet_argument_1); @@ -1413,6 +1644,8 @@ instruction_write(struct_processus *s_et /* * Sockets non formatées */ + + chaine = NULL; } else { @@ -1458,9 +1691,9 @@ instruction_write(struct_processus *s_et } # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) # endif { if (sigaction(SIGPIPE, ®istre, NULL) != 0) @@ -1485,9 +1718,9 @@ instruction_write(struct_processus *s_et } # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -1509,9 +1742,9 @@ instruction_write(struct_processus *s_et } # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -1566,36 +1799,32 @@ instruction_write(struct_processus *s_et d_code_fin_chaine; # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif if (sendto((*((struct_socket *) (*s_objet_argument_1).objet)).socket, chaine, longueur_effective, 0, (struct sockaddr *) &adresse_unix, sizeof(adresse_unix)) < 0) { + ios = errno; + # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) + != 0) # else - while(sem_wait((*s_etat_processus) - .semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) { - (*s_etat_processus).erreur_systeme = - d_es_processus; + (*s_etat_processus).erreur_systeme = d_es_processus; return; } } @@ -1607,15 +1836,21 @@ instruction_write(struct_processus *s_et return; } + if (ios == EMSGSIZE) + { + (*s_etat_processus).erreur_execution = + d_ex_taille_message; + return; + } (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return; } # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -1644,31 +1879,29 @@ instruction_write(struct_processus *s_et adresse_ipv4.sin_addr.s_addr = htonl(calcul_adresse); # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus) - .semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) + != 0) # else - if (sem_post((*s_etat_processus) .semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif if (sendto((*((struct_socket *) (*s_objet_argument_1).objet)).socket, chaine, longueur_effective, 0, (struct sockaddr *) &adresse_ipv4, sizeof(adresse_ipv4)) < 0) { + ios = errno; + # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus) - .semaphore_fork) == -1) + while(sem_wait((*s_etat_processus) + .semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -1679,23 +1912,35 @@ instruction_write(struct_processus *s_et } } + if ((ios == EPIPE) || (ios == ECONNRESET)) + { + (*s_etat_processus).erreur_execution = + d_ex_erreur_acces_fichier; + return; + } + + if (ios == EMSGSIZE) + { + (*s_etat_processus).erreur_execution = + d_ex_taille_message; + return; + } + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return; } # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) + != 0) # else - while(sem_wait((*s_etat_processus) - .semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) { - (*s_etat_processus).erreur_systeme = - d_es_processus; + (*s_etat_processus).erreur_systeme = d_es_processus; return; } } @@ -1733,31 +1978,29 @@ instruction_write(struct_processus *s_et adresse[i], i++); # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus) - .semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) + != 0) # else - if (sem_post((*s_etat_processus) .semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif if (sendto((*((struct_socket *) (*s_objet_argument_1).objet)).socket, chaine, longueur_effective, 0, (struct sockaddr *) &adresse_ipv6, sizeof(adresse_ipv6)) < 0) { + ios = errno; + # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus) - .semaphore_fork) == -1) + while(sem_wait((*s_etat_processus) + .semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -1768,17 +2011,30 @@ instruction_write(struct_processus *s_et } } + if ((ios == EPIPE) || (ios == ECONNRESET)) + { + (*s_etat_processus).erreur_execution = + d_ex_erreur_acces_fichier; + return; + } + + if (ios == EMSGSIZE) + { + (*s_etat_processus).erreur_execution = + d_ex_taille_message; + return; + } + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return; } # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) + != 0) # else - while(sem_wait((*s_etat_processus) - .semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -1984,23 +2240,19 @@ instruction_wflock(struct_processus *s_e } # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -2224,9 +2476,9 @@ instruction_wfproc(struct_processus *s_e if ((*(*((struct_processus_fils *) (*(*l_element_courant) .donnee).objet)).thread).processus_detache == d_vrai) { - if (kill((*(*((struct_processus_fils *) + if (envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread).pid, - 0) != 0) + rpl_signull) != 0) { drapeau_fin = d_vrai; } @@ -2311,25 +2563,23 @@ instruction_wfproc(struct_processus *s_e } # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) + != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif nanosleep(&attente, NULL); # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) + != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -2582,25 +2832,23 @@ instruction_wfdata(struct_processus *s_e } # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) + != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif nanosleep(&attente, NULL); # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) + != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -2710,6 +2958,8 @@ instruction_wfsock(struct_processus *s_e struct_objet *s_objet_argument; struct_objet *s_objet_resultat; + struct pollfd s_poll; + struct sockaddr_in adresse_ipv4; # ifdef IPV6 struct sockaddr_in6 adresse_ipv6; @@ -2763,25 +3013,18 @@ instruction_wfsock(struct_processus *s_e "STREAM") != 0) && (strcmp((*((struct_socket *) (*s_objet_argument).objet)).type, "SEQUENTIAL DATAGRAM") != 0)) { - liberation(s_etat_processus, s_objet_argument); - - (*s_etat_processus).erreur_execution = d_ex_erreur_acces_fichier; - return; - } - - if ((s_objet_resultat = copie_objet(s_etat_processus, s_objet_argument, - 'O')) == NULL) - { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; - return; - } + // Mode non connecté : l'attente se fait sur un poll() - (*((struct_socket *) (*s_objet_resultat).objet)).socket_en_ecoute = 'N'; - (*((struct_socket *) (*s_objet_resultat).objet)).effacement = 'N'; + if ((s_objet_resultat = copie_objet(s_etat_processus, + s_objet_argument, 'P')) == NULL) + { + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } - if ((*((struct_socket *) (*s_objet_resultat).objet)).domaine == PF_INET) - { - longueur = sizeof(adresse_ipv4); + s_poll.fd = (*((struct_socket *) (*s_objet_argument).objet)).socket; + s_poll.events = POLLIN; + s_poll.revents = 0; do { @@ -2789,37 +3032,25 @@ instruction_wfsock(struct_processus *s_e # 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) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif - if (((*((struct_socket *) (*s_objet_resultat).objet)).socket = - accept((*((struct_socket *) (*s_objet_argument).objet)) - .socket, (struct sockaddr *) &adresse_ipv4, &longueur)) - < 0) + if (poll(&s_poll, 1, -1) < 0) { erreur = errno; # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) # endif - { - if (errno != EINTR) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - } if (erreur != EINTR) { @@ -2845,299 +3076,424 @@ instruction_wfsock(struct_processus *s_e else { # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) # endif { if (errno != EINTR) { - (*s_etat_processus).erreur_systeme = d_es_processus; + (*s_etat_processus).erreur_systeme = + d_es_processus; return; } } } } while(drapeau == d_faux); - if (((*((struct_socket *) (*s_objet_resultat).objet)) - .adresse_distante = malloc(22 * - sizeof(unsigned char))) == NULL) + if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), + s_objet_argument) == d_erreur) { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; return; } - sprintf((*((struct_socket *) (*s_objet_resultat).objet)) - .adresse_distante, "%d.%d.%d.%d(%d)", - (ntohl(adresse_ipv4.sin_addr.s_addr) >> 24) & 0xFF, - (ntohl(adresse_ipv4.sin_addr.s_addr) >> 16) & 0xFF, - (ntohl(adresse_ipv4.sin_addr.s_addr) >> 8) & 0xFF, - ntohl(adresse_ipv4.sin_addr.s_addr) & 0xFF, - ntohs(adresse_ipv4.sin_port)); + if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), + s_objet_resultat) == d_erreur) + { + return; + } } - else if ((*((struct_socket *) (*s_objet_resultat).objet)).domaine == - PF_INET6) + else { -# ifdef IPV6 - longueur = sizeof(adresse_ipv6); + // Mode connecté - do + if ((s_objet_resultat = copie_objet(s_etat_processus, + s_objet_argument, 'O')) == NULL) { - drapeau = d_vrai; + (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; + return; + } -# ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) + (*((struct_socket *) (*s_objet_resultat).objet)).effacement = 'N'; + (*((struct_socket *) (*s_objet_resultat).objet)).socket_en_ecoute + = 'N'; + + if ((*((struct_socket *) (*s_objet_resultat).objet)).domaine == + PF_INET) + { + longueur = sizeof(adresse_ipv4); + + do { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + drapeau = d_vrai; + +# ifndef SEMAPHORES_NOMMES + if (sem_post(&((*s_etat_processus).semaphore_fork)) + != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post((*s_etat_processus).semaphore_fork) != 0) # endif + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } - if (((*((struct_socket *) (*s_objet_resultat).objet)).socket = - accept((*((struct_socket *) (*s_objet_argument).objet)) - .socket, (struct sockaddr *) &adresse_ipv6, &longueur)) - < 0) - { - erreur = errno; + if (((*((struct_socket *) (*s_objet_resultat).objet)) + .socket = accept((*((struct_socket *) + (*s_objet_argument).objet)).socket, + (struct sockaddr *) &adresse_ipv4, &longueur)) + < 0) + { + erreur = errno; + +# ifndef SEMAPHORES_NOMMES + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) +# endif + { + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } + } + + if (erreur != EINTR) + { + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_resultat); + (*s_etat_processus).erreur_execution = + d_ex_erreur_acces_fichier; + return; + } + + scrutation_injection(s_etat_processus); + + if ((*s_etat_processus).var_volatile_requete_arret != 0) + { + drapeau = d_vrai; + } + else + { + drapeau = d_faux; + } + } + else + { # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) # endif - { - if (errno != EINTR) { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } } } + } while(drapeau == d_faux); - if (erreur != EINTR) - { - liberation(s_etat_processus, s_objet_argument); - liberation(s_etat_processus, s_objet_resultat); + if (((*((struct_socket *) (*s_objet_resultat).objet)) + .adresse_distante = malloc(22 * + sizeof(unsigned char))) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } - (*s_etat_processus).erreur_execution = - d_ex_erreur_acces_fichier; + sprintf((*((struct_socket *) (*s_objet_resultat).objet)) + .adresse_distante, "%d.%d.%d.%d(%d)", + (ntohl(adresse_ipv4.sin_addr.s_addr) >> 24) & 0xFF, + (ntohl(adresse_ipv4.sin_addr.s_addr) >> 16) & 0xFF, + (ntohl(adresse_ipv4.sin_addr.s_addr) >> 8) & 0xFF, + ntohl(adresse_ipv4.sin_addr.s_addr) & 0xFF, + ntohs(adresse_ipv4.sin_port)); + } + else if ((*((struct_socket *) (*s_objet_resultat).objet)).domaine == + PF_INET6) + { +# ifdef IPV6 + longueur = sizeof(adresse_ipv6); + + do + { + drapeau = d_vrai; + +# ifndef SEMAPHORES_NOMMES + if (sem_post(&((*s_etat_processus).semaphore_fork)) + != 0) +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif + { + (*s_etat_processus).erreur_systeme = d_es_processus; return; } - scrutation_injection(s_etat_processus); - - if ((*s_etat_processus).var_volatile_requete_arret != 0) + if (((*((struct_socket *) (*s_objet_resultat).objet)) + .socket = accept((*((struct_socket *) + (*s_objet_argument).objet)).socket, + (struct sockaddr *) &adresse_ipv6, &longueur)) < 0) { - drapeau = d_vrai; + erreur = errno; + +# ifndef SEMAPHORES_NOMMES + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) +# endif + { + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } + } + + if (erreur != EINTR) + { + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_resultat); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_acces_fichier; + return; + } + + scrutation_injection(s_etat_processus); + + if ((*s_etat_processus).var_volatile_requete_arret != 0) + { + drapeau = d_vrai; + } + else + { + drapeau = d_faux; + } } else { - drapeau = d_faux; - } - } - else - { # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) # endif - { - if (errno != EINTR) { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } } } + } while(drapeau == d_faux); + + if (((*((struct_socket *) (*s_objet_resultat).objet)) + .adresse_distante = malloc(55 * + sizeof(unsigned char))) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; } - } while(drapeau == d_faux); - if (((*((struct_socket *) (*s_objet_resultat).objet)) - .adresse_distante = malloc(55 * - sizeof(unsigned char))) == NULL) - { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; - return; - } + (*((struct_socket *) (*s_objet_resultat).objet)) + .adresse_distante = d_code_fin_chaine; - (*((struct_socket *) (*s_objet_resultat).objet)) - .adresse_distante = d_code_fin_chaine; + for(i = 0; i < 16; i++) + { + sprintf((*((struct_socket *) (*s_objet_resultat) + .objet)).adresse_distante, (i == 0) ? "%s%X" + : "%s:%X", (*((struct_socket *) (*s_objet_resultat) + .objet)).adresse_distante, + adresse_ipv6.sin6_addr.s6_addr[i]); + } - for(i = 0; i < 16; i++) - { sprintf((*((struct_socket *) (*s_objet_resultat) - .objet)).adresse_distante, (i == 0) ? "%s%X" : "%s:%X", + .objet)).adresse_distante, "%s(%u)", (*((struct_socket *) (*s_objet_resultat) .objet)).adresse_distante, - adresse_ipv6.sin6_addr.s6_addr[i]); - } - - sprintf((*((struct_socket *) (*s_objet_resultat) - .objet)).adresse_distante, "%s(%u)", - (*((struct_socket *) (*s_objet_resultat) - .objet)).adresse_distante, ntohs(adresse_ipv6.sin6_port)); + ntohs(adresse_ipv6.sin6_port)); # else - if ((*s_etat_processus).langue == 'F') - { - printf("+++Attention : Support du protocole" - " IPv6 indisponible\n"); + if ((*s_etat_processus).langue == 'F') + { + printf("+++Attention : Support du protocole" + " IPv6 indisponible\n"); + } + else + { + printf("+++Warning : IPv6 support " + "unavailable\n"); + } +# endif } else { - printf("+++Warning : IPv6 support " - "unavailable\n"); - } -# endif - } - else - { - longueur = 0; + longueur = 0; - do - { - drapeau = d_vrai; + do + { + drapeau = d_vrai; # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) + != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post((*s_etat_processus).semaphore_fork) != 0) # endif + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } - if (((*((struct_socket *) (*s_objet_resultat).objet)).socket = - accept((*((struct_socket *) (*s_objet_argument).objet)) - .socket, NULL, &longueur)) < 0) - { - erreur = errno; + if (((*((struct_socket *) (*s_objet_resultat).objet)) + .socket = accept((*((struct_socket *) + (*s_objet_argument).objet)).socket, NULL, + &longueur)) < 0) + { + erreur = errno; # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) # endif - { - if (errno != EINTR) { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } } - } - if (erreur != EINTR) - { - liberation(s_etat_processus, s_objet_argument); - liberation(s_etat_processus, s_objet_resultat); + if (erreur != EINTR) + { + liberation(s_etat_processus, s_objet_argument); + liberation(s_etat_processus, s_objet_resultat); - (*s_etat_processus).erreur_execution = - d_ex_erreur_acces_fichier; - return; - } + (*s_etat_processus).erreur_execution = + d_ex_erreur_acces_fichier; + return; + } - scrutation_injection(s_etat_processus); + scrutation_injection(s_etat_processus); - if ((*s_etat_processus).var_volatile_requete_arret != 0) - { - drapeau = d_vrai; + if ((*s_etat_processus).var_volatile_requete_arret != 0) + { + drapeau = d_vrai; + } + else + { + drapeau = d_faux; + } } else { - drapeau = d_faux; - } - } - else - { # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) + != 0) # endif - { - if (errno != EINTR) { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; + if (errno != EINTR) + { + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } } } - } - } while(drapeau == d_faux); - } - - // Si accept() renvoie une erreur non récupérée, il ne peut s'agir - // que de EINTR sachant qu'une requête d'arrêt est en court de - // traitement. + } while(drapeau == d_faux); + } - if ((*((struct_socket *) (*s_objet_resultat).objet)).socket >= 0) - { - l_element_courant = (*s_etat_processus).s_sockets; + // Si accept() renvoie une erreur non récupérée, il ne peut s'agir + // que de EINTR sachant qu'une requête d'arrêt est en court de + // traitement. - if (l_element_courant == NULL) + if ((*((struct_socket *) (*s_objet_resultat).objet)).socket >= 0) { - if (((*s_etat_processus).s_sockets = - allocation_maillon(s_etat_processus)) == NULL) + l_element_courant = (*s_etat_processus).s_sockets; + + if (l_element_courant == NULL) { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; - return; + if (((*s_etat_processus).s_sockets = + allocation_maillon(s_etat_processus)) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + (*(*s_etat_processus).s_sockets).suivant = NULL; + l_element_courant = (*s_etat_processus).s_sockets; } + else + { + /* + * Ajout d'un élément à la fin de la liste chaînée + */ - (*(*s_etat_processus).s_sockets).suivant = NULL; - l_element_courant = (*s_etat_processus).s_sockets; - } - else - { - /* - * Ajout d'un élément à la fin de la liste chaînée - */ + while((*l_element_courant).suivant != NULL) + { + l_element_courant = (*l_element_courant).suivant; + } + + if (((*l_element_courant).suivant = + allocation_maillon(s_etat_processus)) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } - while((*l_element_courant).suivant != NULL) - { l_element_courant = (*l_element_courant).suivant; + (*l_element_courant).suivant = NULL; } - if (((*l_element_courant).suivant = - allocation_maillon(s_etat_processus)) == NULL) + if (((*l_element_courant).donnee = copie_objet(s_etat_processus, + s_objet_resultat, 'O')) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; } - - l_element_courant = (*l_element_courant).suivant; - (*l_element_courant).suivant = NULL; } - if (((*l_element_courant).donnee = copie_objet(s_etat_processus, - s_objet_resultat, 'O')) == NULL) + if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), + s_objet_argument) == d_erreur) { - (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; } - } - if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), - s_objet_argument) == d_erreur) - { - return; - } - - if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), - s_objet_resultat) == d_erreur) - { - return; + if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile), + s_objet_resultat) == d_erreur) + { + return; + } } } else @@ -3351,25 +3707,21 @@ instruction_wfpoke(struct_processus *s_e do { # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif nanosleep(&attente, NULL); # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR) @@ -3513,26 +3865,22 @@ instruction_wfack(struct_processus *s_et } # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif { (*s_etat_processus).erreur_systeme = d_es_processus; return; } -# endif nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + while(sem_wait((*s_etat_processus).semaphore_fork) != 0) # endif { if (errno != EINTR)