--- rpl/src/instructions_w1.c 2010/04/17 18:57:36 1.12 +++ rpl/src/instructions_w1.c 2011/07/22 07:38:40 1.44 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.14 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.1 + 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) { @@ -420,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; @@ -1325,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) && @@ -1360,69 +1406,212 @@ instruction_write(struct_processus *s_et return; } + } + else if ((*((struct_socket *) (*s_objet_argument_1).objet)).binaire + == 'Y') + { + /* + * Sockets non formatées + */ + + chaine = NULL; + } + else + { + /* + * Sockets de type FLOW + */ + + 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) + { + 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 - 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; - 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; + } - if (sigaction(SIGPIPE, &action, ®istre) != 0) +# 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; + } + + (*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) { (*s_etat_processus).erreur_systeme = d_es_signal; return; } # ifndef SEMAPHORES_NOMMES - if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0) + while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) # else - if (sem_post((*s_etat_processus).semaphore_fork) != 0) + while(sem_wait((*s_etat_processus).semaphore_fork) == -1) # endif { - if (sigaction(SIGPIPE, ®istre, NULL) != 0) + 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; } + (*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) + { + ios = errno; + # ifndef SEMAPHORES_NOMMES - while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1) + while(sem_wait(&((*s_etat_processus) + .semaphore_fork)) == -1) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + 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; } @@ -1435,62 +1624,38 @@ instruction_write(struct_processus *s_et { 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; + 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) + 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) + if (sem_post((*s_etat_processus) .semaphore_fork) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -1499,8 +1664,8 @@ instruction_write(struct_processus *s_et 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) @@ -1524,77 +1689,73 @@ 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)) == -1) # else - while(sem_wait((*s_etat_processus).semaphore_fork) == -1) + 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); - -# 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 + liberation(s_etat_processus, s_objet_argument_1); + liberation(s_etat_processus, s_objet_argument_2); - if (sendto((*((struct_socket *) - (*s_objet_argument_1).objet)).socket, chaine, - strlen(chaine), 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) - { - (*s_etat_processus).erreur_systeme = - d_es_processus; - 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++); - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - 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 + 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) @@ -1610,106 +1771,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++); -# 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) +# 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; - return; - } -# endif - - 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) - { - (*s_etat_processus).erreur_systeme = - d_es_processus; - return; - } - } - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; + d_es_processus; 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_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); @@ -1719,22 +1815,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 { @@ -2623,7 +2715,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; @@ -2789,6 +2883,7 @@ instruction_wfsock(struct_processus *s_e else if ((*((struct_socket *) (*s_objet_resultat).objet)).domaine == PF_INET6) { +# ifdef IPV6 longueur = sizeof(adresse_ipv6); do @@ -2892,6 +2987,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 {