--- rpl/src/instructions_w1.c 2010/04/07 13:45:09 1.11 +++ rpl/src/instructions_w1.c 2011/04/14 08:46:48 1.34.2.2 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.14 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.0.23 + Copyright (C) 1989-2011 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -124,7 +124,7 @@ instruction_while(struct_processus *s_et void instruction_warranty(struct_processus *s_etat_processus) { -# include "garanties.conv.h" +# include "garanties-conv.h" (*s_etat_processus).erreur_execution = d_ex; @@ -226,8 +226,7 @@ instruction_wait(struct_processus *s_eta return; } - if (((*s_objet).type == INT) || - ((*s_objet).type == REL)) + if (((*s_objet).type == INT) || ((*s_objet).type == REL)) { if ((*s_objet).type == INT) { @@ -262,16 +261,28 @@ 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; } +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) + { + (*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) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) == -1) +# endif { if (errno != EINTR) { @@ -408,7 +419,9 @@ instruction_write(struct_processus *s_et struct sigaction registre; struct sockaddr_in adresse_ipv4; +# ifdef IPV6 struct sockaddr_in6 adresse_ipv6; +# endif struct sockaddr_un adresse_unix; struct flock lock; @@ -1313,6 +1326,51 @@ instruction_write(struct_processus *s_et /* * Fichiers de type FLOW */ + + if ((*((struct_fichier *) (*s_objet_argument_1).objet)).acces + == 'S') + { + BUG(((*descripteur).type != 'C'), uprintf("Bad filetype !\n")); + + if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet)) + .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 ((chaine = formateur_flux(s_etat_processus, (unsigned char *) + (*((*((struct_liste_chainee *) (*s_objet_argument_2) + .objet)).donnee)).objet, &longueur_effective)) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + 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; + } + + free(chaine); + } + else + { + liberation(s_etat_processus, s_objet_argument_1); + liberation(s_etat_processus, s_objet_argument_2); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_fichier; + return; + } } } else if (((*s_objet_argument_2).type == LST) && @@ -1348,131 +1406,270 @@ instruction_write(struct_processus *s_et return; } + } + else if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire + == 'Y') + { + /* + * Sockets non formatées + */ + } + else + { + /* + * Sockets de type FLOW + */ - if ((strcmp((*((struct_socket *) (*s_objet_argument_1).objet)).type, - "STREAM") == 0) || (strcmp((*((struct_socket *) - (*s_objet_argument_1).objet)).type, - "SEQUENTIAL DATAGRAM") == 0)) - { // Sockets connectées + if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet)) + .donnee)).type != CHN) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); - action.sa_handler = SIG_IGN; - action.sa_flags = SA_ONSTACK; + (*s_etat_processus).erreur_execution = + d_ex_erreur_type_argument; + return; + } - if (sigaction(SIGPIPE, &action, ®istre) != 0) + if ((chaine = formateur_flux(s_etat_processus, (unsigned char *) + (*((*((struct_liste_chainee *) (*s_objet_argument_2) + .objet)).donnee)).objet, &longueur_effective)) == NULL) + { + liberation(s_etat_processus, s_objet_argument_2); + liberation(s_etat_processus, s_objet_argument_1); + + return; + } + } + + if ((strcmp((*((struct_socket *) (*s_objet_argument_1).objet)).type, + "STREAM") == 0) || (strcmp((*((struct_socket *) + (*s_objet_argument_1).objet)).type, + "SEQUENTIAL DATAGRAM") == 0)) + { // Sockets connectées + + action.sa_handler = SIG_IGN; + action.sa_flags = SA_ONSTACK; + + if (sigaction(SIGPIPE, &action, ®istre) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_signal; + return; + } + +# ifndef SEMAPHORES_NOMMES + if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) +# endif + { + if (sigaction(SIGPIPE, ®istre, NULL) != 0) { (*s_etat_processus).erreur_systeme = d_es_signal; return; } - if (sem_post(&((*s_etat_processus).semaphore_fork)) - != 0) + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + + if (send((*((struct_socket *) (*s_objet_argument_1).objet)) + .socket, chaine, longueur_effective, 0) < 0) + { + ios = errno; + + if (sigaction(SIGPIPE, ®istre, NULL) != 0) { - if (sigaction(SIGPIPE, ®istre, NULL) != 0) + (*s_etat_processus).erreur_systeme = d_es_signal; + return; + } + +# 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) { - (*s_etat_processus).erreur_systeme = d_es_signal; + (*s_etat_processus).erreur_systeme = d_es_processus; return; } + } - (*s_etat_processus).erreur_systeme = d_es_processus; + if ((ios == EPIPE) || (ios == ECONNRESET)) + { + (*s_etat_processus).erreur_execution = + d_ex_erreur_acces_fichier; return; } - if (send((*((struct_socket *) (*s_objet_argument_1).objet)) - .socket, chaine, strlen(chaine), 0) < 0) - { - ios = errno; + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + return; + } +# 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) + { if (sigaction(SIGPIPE, ®istre, NULL) != 0) { (*s_etat_processus).erreur_systeme = d_es_signal; return; } - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + } + + if (sigaction(SIGPIPE, ®istre, NULL) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_signal; + return; + } + } + else + { // Sockets non connectées + + /* + * Vérification de l'adresse distante + */ + + if (strcmp((*((struct_socket *) (*s_objet_argument_1).objet)) + .adresse_distante, "") == 0) + { + liberation(s_etat_processus, s_objet_argument_1); + liberation(s_etat_processus, s_objet_argument_2); + + (*s_etat_processus).erreur_execution = + d_ex_erreur_acces_fichier; + return; + } + + /* + * Création de l'adresse logique + */ + + if ((*((struct_socket *) (*s_objet_argument_1).objet)) + .domaine == PF_UNIX) + { + adresse_unix.sun_family = AF_UNIX; + strncpy(adresse_unix.sun_path, (*((struct_socket *) + (*s_objet_argument_1).objet)).adresse_distante, + UNIX_PATH_MAX); + adresse_unix.sun_path[UNIX_PATH_MAX - 1] = + 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; + } +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) + { + (*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) + { +# 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) { - (*s_etat_processus).erreur_systeme = d_es_processus; + (*s_etat_processus).erreur_systeme = + d_es_processus; return; } } - if (ios == EPIPE) + if ((ios == EPIPE) || (ios == ECONNRESET)) { (*s_etat_processus).erreur_execution = d_ex_erreur_acces_fichier; return; } + (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; return; } +# 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) { - if (sigaction(SIGPIPE, ®istre, NULL) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_signal; - return; - } - (*s_etat_processus).erreur_systeme = d_es_processus; return; } } - - if (sigaction(SIGPIPE, ®istre, NULL) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_signal; - return; - } } - else - { // Sockets non connectées - - /* - * Vérification de l'adresse distante - */ - - if (strcmp((*((struct_socket *) (*s_objet_argument_1).objet)) - .adresse_distante, "") == 0) - { - liberation(s_etat_processus, s_objet_argument_1); - liberation(s_etat_processus, s_objet_argument_2); - - (*s_etat_processus).erreur_execution = - d_ex_erreur_acces_fichier; - return; - } - - /* - * Création de l'adresse logique - */ - - if ((*((struct_socket *) (*s_objet_argument_1).objet)) - .domaine == PF_UNIX) - { - adresse_unix.sun_family = AF_UNIX; - strncpy(adresse_unix.sun_path, (*((struct_socket *) - (*s_objet_argument_1).objet)).adresse_distante, - 108); - adresse_unix.sun_path[108 - 1] = d_code_fin_chaine; - - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) + else if ((*((struct_socket *) (*s_objet_argument_1).objet)) + .domaine == PF_INET) + { + if (sscanf((*((struct_socket *) + (*s_objet_argument_1).objet)) + .adresse_distante, "%d.%d.%d.%d(%d)", + &(adresse[0]), &(adresse[1]), &(adresse[2]), + &(adresse[3]), &port) == 5) + { // Adresse IPv4 + calcul_adresse = 0; + for(i = 0; i < 4; calcul_adresse = + (256 * calcul_adresse) + adresse[i++]); + + memset(&adresse_ipv4, 0, sizeof(adresse_ipv4)); + adresse_ipv4.sin_family = AF_INET; + adresse_ipv4.sin_port = htons(port); + 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; } +# else + if (sem_post((*s_etat_processus) .semaphore_fork) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } +# endif if (sendto((*((struct_socket *) (*s_objet_argument_1).objet)).socket, chaine, - strlen(chaine), 0, (struct sockaddr *) - &adresse_unix, sizeof(adresse_unix)) < 0) + longueur_effective, 0, (struct sockaddr *) + &adresse_ipv4, sizeof(adresse_ipv4)) < 0) { +# 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) { @@ -1487,63 +1684,81 @@ instruction_write(struct_processus *s_et return; } - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) +# 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) { - (*s_etat_processus).erreur_systeme = d_es_processus; + (*s_etat_processus).erreur_systeme = + d_es_processus; return; } } } - else if ((*((struct_socket *) (*s_objet_argument_1).objet)) - .domaine == PF_INET) + else { - if (sscanf((*((struct_socket *) - (*s_objet_argument_1).objet)) - .adresse_distante, "%d.%d.%d.%d(%d)", - &(adresse[0]), &(adresse[1]), &(adresse[2]), - &(adresse[3]), &port) == 5) - { // Adresse IPv4 - calcul_adresse = 0; - for(i = 0; i < 4; calcul_adresse = - (256 * calcul_adresse) + adresse[i++]); - - memset(&adresse_ipv4, 0, sizeof(adresse_ipv4)); - adresse_ipv4.sin_family = AF_INET; - adresse_ipv4.sin_port = htons(port); - adresse_ipv4.sin_addr.s_addr = htonl(calcul_adresse); - - if (sem_post(&((*s_etat_processus) - .semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - if (sendto((*((struct_socket *) - (*s_objet_argument_1).objet)).socket, chaine, - strlen(chaine), 0, (struct sockaddr *) - &adresse_ipv4, sizeof(adresse_ipv4)) < 0) - { - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) - { - if (errno != EINTR) - { - (*s_etat_processus).erreur_systeme = - d_es_processus; - return; - } - } + liberation(s_etat_processus, s_objet_argument_1); + liberation(s_etat_processus, s_objet_argument_2); - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; - } + (*s_etat_processus).erreur_execution = + d_ex_erreur_parametre_fichier; + return; + } + } + else if ((*((struct_socket *) (*s_objet_argument_1).objet)) + .domaine == PF_INET6) + { + if (sscanf((*((struct_socket *) (*s_objet_argument_1) + .objet)).adresse_distante, "%X:%X:%X:%X:%X:" + "%X:%X:%X:%X:%X:%X:%X:%X:%X:%X:%X(%d)", + &(adresse[0]), &(adresse[1]), &(adresse[2]), + &(adresse[3]), &(adresse[4]), &(adresse[5]), + &(adresse[6]), &(adresse[7]), &(adresse[8]), + &(adresse[9]), &(adresse[10]), &(adresse[11]), + &(adresse[12]), &(adresse[13]), &(adresse[14]), + &(adresse[15]), &port)== 17) + { // Adresse IPv6 +# ifdef IPV6 + memset(&adresse_ipv6, 0, sizeof(adresse_ipv6)); + adresse_ipv6.sin6_family = AF_INET6; + adresse_ipv6.sin6_port = htons((uint16_t) port); + + for(i = 0; i < 16; + adresse_ipv6.sin6_addr.s6_addr[i] = + adresse[i], i++); + +# 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 + if (sendto((*((struct_socket *) + (*s_objet_argument_1).objet)).socket, chaine, + longueur_effective, 0, (struct sockaddr *) + &adresse_ipv6, sizeof(adresse_ipv6)) < 0) + { +# 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) { @@ -1552,88 +1767,41 @@ instruction_write(struct_processus *s_et return; } } - } - else - { - liberation(s_etat_processus, s_objet_argument_1); - liberation(s_etat_processus, s_objet_argument_2); - (*s_etat_processus).erreur_execution = - d_ex_erreur_parametre_fichier; + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; return; } - } - else if ((*((struct_socket *) (*s_objet_argument_1).objet)) - .domaine == PF_INET6) - { - if (sscanf((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, "%X:%X:%X:%X:%X:" - "%X:%X:%X:%X:%X:%X:%X:%X:%X:%X:%X(%d)", - &(adresse[0]), &(adresse[1]), &(adresse[2]), - &(adresse[3]), &(adresse[4]), &(adresse[5]), - &(adresse[6]), &(adresse[7]), &(adresse[8]), - &(adresse[9]), &(adresse[10]), &(adresse[11]), - &(adresse[12]), &(adresse[13]), &(adresse[14]), - &(adresse[15]), &port)== 17) - { // Adresse IPv6 - memset(&adresse_ipv6, 0, sizeof(adresse_ipv6)); - adresse_ipv6.sin6_family = AF_INET6; - adresse_ipv6.sin6_port = htons((uint16_t) port); - - for(i = 0; i < 16; - adresse_ipv6.sin6_addr.s6_addr[i] = - adresse[i], i++); - if (sem_post(&((*s_etat_processus) - .semaphore_fork)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - - if (sendto((*((struct_socket *) - (*s_objet_argument_1).objet)).socket, chaine, - strlen(chaine), 0, (struct sockaddr *) - &adresse_ipv6, sizeof(adresse_ipv6)) < 0) +# 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) { - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) - { - if (errno != EINTR) - { - (*s_etat_processus).erreur_systeme = - d_es_processus; - return; - } - } - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; + d_es_processus; return; } - - while(sem_wait(&((*s_etat_processus) - .semaphore_fork)) == -1) - { - if (errno != EINTR) - { - (*s_etat_processus).erreur_systeme = - d_es_processus; - return; - } - } + } +# else + if ((*s_etat_processus).langue == 'F') + { + printf("+++Attention : Support du protocole" + " IPv6 indisponible\n"); } else { - liberation(s_etat_processus, s_objet_argument_1); - liberation(s_etat_processus, s_objet_argument_2); - - (*s_etat_processus).erreur_execution = - d_ex_erreur_parametre_fichier; - return; + printf("+++Warning : IPv6 support " + "unavailable\n"); } +# endif } - else + else { liberation(s_etat_processus, s_objet_argument_1); liberation(s_etat_processus, s_objet_argument_2); @@ -1643,22 +1811,18 @@ instruction_write(struct_processus *s_et return; } } + else + { + liberation(s_etat_processus, s_objet_argument_1); + liberation(s_etat_processus, s_objet_argument_2); - free(chaine); - } - else if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire - == 'Y') - { - /* - * Sockets non formatées - */ - } - else - { - /* - * Sockets de type FLOW - */ + (*s_etat_processus).erreur_execution = + d_ex_erreur_parametre_fichier; + return; + } } + + free(chaine); } else { @@ -1819,13 +1983,25 @@ instruction_wflock(struct_processus *s_e return; } +# 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 +# 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) { @@ -2134,15 +2310,27 @@ instruction_wfproc(struct_processus *s_e registre_instruction_valide; } +# 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 nanosleep(&attente, NULL); +# 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) { @@ -2393,15 +2581,27 @@ instruction_wfdata(struct_processus *s_e return; } +# 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 nanosleep(&attente, NULL); +# 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) { @@ -2511,7 +2711,9 @@ instruction_wfsock(struct_processus *s_e struct_objet *s_objet_resultat; struct sockaddr_in adresse_ipv4; +# ifdef IPV6 struct sockaddr_in6 adresse_ipv6; +# endif unsigned long i; @@ -2585,11 +2787,19 @@ instruction_wfsock(struct_processus *s_e { drapeau = d_vrai; +# 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 if (((*((struct_socket *) (*s_objet_resultat).objet)).socket = accept((*((struct_socket *) (*s_objet_argument).objet)) @@ -2598,7 +2808,11 @@ instruction_wfsock(struct_processus *s_e { erreur = errno; +# 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) { @@ -2630,7 +2844,11 @@ instruction_wfsock(struct_processus *s_e } else { +# 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) { @@ -2661,17 +2879,26 @@ instruction_wfsock(struct_processus *s_e 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) { (*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 if (((*((struct_socket *) (*s_objet_resultat).objet)).socket = accept((*((struct_socket *) (*s_objet_argument).objet)) @@ -2680,7 +2907,11 @@ instruction_wfsock(struct_processus *s_e { erreur = errno; +# 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) { @@ -2712,7 +2943,11 @@ instruction_wfsock(struct_processus *s_e } else { +# 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) { @@ -2748,6 +2983,18 @@ instruction_wfsock(struct_processus *s_e .objet)).adresse_distante, "%s(%u)", (*((struct_socket *) (*s_objet_resultat) .objet)).adresse_distante, ntohs(adresse_ipv6.sin6_port)); +# else + if ((*s_etat_processus).langue == 'F') + { + printf("+++Attention : Support du protocole" + " IPv6 indisponible\n"); + } + else + { + printf("+++Warning : IPv6 support " + "unavailable\n"); + } +# endif } else { @@ -2757,11 +3004,19 @@ instruction_wfsock(struct_processus *s_e { drapeau = d_vrai; +# 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 if (((*((struct_socket *) (*s_objet_resultat).objet)).socket = accept((*((struct_socket *) (*s_objet_argument).objet)) @@ -2769,7 +3024,11 @@ instruction_wfsock(struct_processus *s_e { erreur = errno; +# 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) { @@ -2801,7 +3060,11 @@ instruction_wfsock(struct_processus *s_e } else { +# 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) { @@ -3087,15 +3350,27 @@ 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; } +# else + if (sem_post((*s_etat_processus).semaphore_fork) != 0) + { + (*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) +# else + while(sem_wait((*s_etat_processus).semaphore_fork) == -1) +# endif { if (errno != EINTR) { @@ -3237,16 +3512,28 @@ instruction_wfack(struct_processus *s_et return; } +# 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 nanosleep(&attente, NULL); INCR_GRANULARITE(attente.tv_nsec); +# 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) {