--- rpl/src/instructions_r4.c 2013/03/20 22:24:37 1.76 +++ rpl/src/instructions_r4.c 2016/03/01 22:12:33 1.98 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.13 - Copyright (C) 1989-2013 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.25 + Copyright (C) 1989-2016 Dr. BERTRAND Joël This file is part of RPL/2. @@ -850,11 +850,15 @@ instruction_read(struct_processus *s_eta int c; int ios; + int timeout; integer8 element; integer8 i; integer8 id; + integer8 index; + integer8 longueur; integer8 position_clef; + integer8 longueur_effective; integer8 longueur_enregistrement; integer8 longueur_questure; @@ -863,27 +867,28 @@ instruction_read(struct_processus *s_eta integer8 position_finale; integer8 position_initiale; + logical1 device; logical1 format_degenere; logical1 indicateur_48; logical1 presence_chaine; logical1 presence_indicateur; logical1 trame_complete; - long longueur; - socklen_t longueur_adresse; sqlite3_stmt *ppStmt; struct flock lock; + struct pollfd fds[1]; + struct sockaddr_un adresse_unix; struct sockaddr_in adresse_ipv4; # ifdef IPV6 struct sockaddr_in6 adresse_ipv6; # endif - struct pollfd poll_fd; + struct termios tc; struct timespec attente; @@ -907,6 +912,39 @@ instruction_read(struct_processus *s_eta unsigned char *tampon_lecture; unsigned char *tampon; unsigned char *tampon2; + unsigned char *tampon3; + + int vitesses[] = + { + 50, 75, 110, 134, 150, 200, 300, 600, + 1200, 1800, 2400, 4800, 9600, 19200, 38400, +#ifdef B57600 + 57600, +#endif +#ifdef B115200 + 115200, +#endif +#ifdef B230400 + 230400, +#endif + 0 + }; + + tcflag_t vitesses_constantes[] = + { + B50, B75, B110, B134, B150, B200, B300, B600, + B1200, B1800, B2400, B4800, B9600, B19200, B38400, +#ifdef B57600 + B57600, +#endif +#ifdef B115200 + B115200, +#endif +#ifdef B230400 + B230400, +#endif + 0 + }; (*s_etat_processus).erreur_execution = d_ex; @@ -1111,7 +1149,7 @@ instruction_read(struct_processus *s_eta presence_chaine = d_faux; niveau = 1; - if (fseek((*descripteur).descripteur_c, position_finale, + if (fseek((*descripteur).descripteur_c, (long) position_finale, SEEK_SET) != 0) { liberation(s_etat_processus, s_objet_argument_1); @@ -1201,8 +1239,8 @@ instruction_read(struct_processus *s_eta return; } - if (fseek((*descripteur).descripteur_c, position_initiale, - SEEK_SET) != 0) + if (fseek((*descripteur).descripteur_c, + (long) position_initiale, SEEK_SET) != 0) { liberation(s_etat_processus, s_objet_argument_1); free(tampon_lecture); @@ -1237,6 +1275,7 @@ instruction_read(struct_processus *s_eta indicateur_48 = test_cfsf(s_etat_processus, 48); cf(s_etat_processus, 48); + (*s_etat_processus).type_en_cours = NON; recherche_type(s_etat_processus); free((*s_etat_processus).instruction_courante); @@ -1292,9 +1331,9 @@ instruction_read(struct_processus *s_eta return; } - if (alsprintf(&commande, "select data from data where " - "id = %lld", (*((integer8 *) (*s_objet_argument_2) - .objet))) < 0) + if (alsprintf(s_etat_processus, &commande, + "select data from data where id = %lld", + (*((integer8 *) (*s_objet_argument_2).objet))) < 0) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -1391,6 +1430,7 @@ instruction_read(struct_processus *s_eta indicateur_48 = test_cfsf(s_etat_processus, 48); cf(s_etat_processus, 48); + (*s_etat_processus).type_en_cours = NON; recherche_type(s_etat_processus); if ((*s_etat_processus).erreur_execution != d_ex) @@ -1464,8 +1504,8 @@ instruction_read(struct_processus *s_eta // Récupération de la position de la clef - if (alsprintf(&commande, "select key from control " - "where id = 1") < 0) + if (alsprintf(s_etat_processus, &commande, + "select key from control where id = 1") < 0) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -1538,8 +1578,9 @@ instruction_read(struct_processus *s_eta // Récupération de l'identifiant de la clef - if (alsprintf(&commande, "select id from key where key = " - "'{ \"%s\" }'", clef_utf8) < 0) + if (alsprintf(s_etat_processus, &commande, + "select id from key where key = '{ \"%s\" }'", + clef_utf8) < 0) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -1631,7 +1672,8 @@ instruction_read(struct_processus *s_eta free(commande); - if (alsprintf(&commande, "select data from data where " + if (alsprintf(s_etat_processus, &commande, + "select data from data where " "key_id = %lld order by sequence asc", id) < 0) { (*s_etat_processus).erreur_systeme = @@ -1698,6 +1740,7 @@ instruction_read(struct_processus *s_eta indicateur_48 = test_cfsf(s_etat_processus, 48); cf(s_etat_processus, 48); + (*s_etat_processus).type_en_cours = NON; recherche_type(s_etat_processus); if ((*s_etat_processus).erreur_execution != d_ex) @@ -1760,8 +1803,8 @@ instruction_read(struct_processus *s_eta return; } - if (alsprintf(&tampon2, "{ \"%s\" }", - (*s_etat_processus) + if (alsprintf(s_etat_processus, &tampon2, + "{ \"%s\" }", (*s_etat_processus) .instruction_courante) < 0) { (*s_etat_processus).erreur_systeme = @@ -1776,6 +1819,7 @@ instruction_read(struct_processus *s_eta indicateur_48 = test_cfsf(s_etat_processus, 48); cf(s_etat_processus, 48); + (*s_etat_processus).type_en_cours = NON; recherche_type(s_etat_processus); if ((*s_etat_processus).erreur_execution @@ -1976,11 +2020,21 @@ instruction_read(struct_processus *s_eta BUG(((*descripteur).type != 'C'), uprintf("Bad filtype !\n")); longueur_enregistrement = 0; + device = d_faux; + if ((position_initiale = ftell((*descripteur).descripteur_c)) == -1) { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; - return; + if (errno == ESPIPE) + { + device = d_vrai; + } + else + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } } l_element_courant_format = (struct_liste_chainee *) @@ -2008,7 +2062,8 @@ instruction_read(struct_processus *s_eta return; } - if ((format_chaine = conversion_majuscule((unsigned char *) + if ((format_chaine = conversion_majuscule( + s_etat_processus, (unsigned char *) (*(*l_element_courant_format).donnee).objet)) == NULL) { @@ -2052,7 +2107,7 @@ instruction_read(struct_processus *s_eta // Détermination de la longueur format_degenere = d_faux; - if (sscanf(&(format_chaine[8]), "%ld", &longueur) != 1) + if (sscanf(&(format_chaine[8]), "%lld", &longueur) != 1) { liberation(s_etat_processus, s_objet_argument_1); liberation(s_etat_processus, s_objet_resultat); @@ -2065,24 +2120,95 @@ instruction_read(struct_processus *s_eta } free(format_chaine); + tampon3 = NULL; if (format_degenere == d_vrai) { + if (device == d_vrai) + { + longueur_questure = 4096; + index = 0; + + if ((tampon3 = malloc(((size_t) longueur_questure) * + sizeof(unsigned char))) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + + tampon3[index] = d_code_fin_chaine; + + fds[0].fd = fileno((*descripteur).descripteur_c); + fds[0].events = POLLIN; + fds[0].revents = 0; + + tcgetattr(fileno((*descripteur).descripteur_c), + &tc); + timeout = 0; + + for(i = 0; vitesses[i] != 0; i++) + { + if (cfgetispeed(&tc) == vitesses_constantes[i]) + { + // La durée entre deux caractères sur le + // périphérique série ne doit pas dépasser + // la moitié de la durée de transmission + // d'un caractère complet. + + timeout = (int) (((double) 1000) / + (((double) vitesses_constantes[i]) / + 4)); + break; + } + } + } + do { + if (device == d_vrai) + { + if (poll(fds, 1, timeout) == 0) + { + break; + } + } + c = getc((*descripteur).descripteur_c); longueur_enregistrement++; - } while((c != '\n') && (c != EOF)); - if (fseek((*descripteur).descripteur_c, - position_initiale, SEEK_SET) != 0) + if (device == d_vrai) + { + if (longueur_enregistrement >= + longueur_questure) + { + if ((tampon3 = realloc(tampon3, + (size_t) (longueur_questure *= 2))) + == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } + } + + tampon3[index++] = (unsigned char) c; + } + } while(c != EOF); + + if (device == d_faux) { - liberation(s_etat_processus, s_objet_argument_1); - liberation(s_etat_processus, s_objet_resultat); + if (fseek((*descripteur).descripteur_c, + (long) position_initiale, SEEK_SET) != 0) + { + liberation(s_etat_processus, + s_objet_argument_1); + liberation(s_etat_processus, s_objet_resultat); - (*s_etat_processus).erreur_systeme = - d_es_erreur_fichier; - return; + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } } } else @@ -2090,19 +2216,27 @@ instruction_read(struct_processus *s_eta longueur_enregistrement = longueur; } - if ((tampon_lecture = malloc(((size_t) - longueur_enregistrement) * sizeof(unsigned char))) - == NULL) + if ((device == d_vrai) && (format_degenere == d_vrai)) { - (*s_etat_processus).erreur_systeme = - d_es_allocation_memoire; - return; + longueur_effective = longueur_enregistrement; + tampon_lecture = tampon3; } + else + { + if ((tampon_lecture = malloc(((size_t) + longueur_enregistrement) * + sizeof(unsigned char))) == NULL) + { + (*s_etat_processus).erreur_systeme = + d_es_allocation_memoire; + return; + } - longueur_effective = (integer8) fread(tampon_lecture, - sizeof(unsigned char), - (size_t) longueur_enregistrement, - (*descripteur).descripteur_c); + longueur_effective = (integer8) fread(tampon_lecture, + sizeof(unsigned char), + (size_t) longueur_enregistrement, + (*descripteur).descripteur_c); + } if (l_element_courant == NULL) { @@ -2142,11 +2276,23 @@ instruction_read(struct_processus *s_eta if (format_degenere == d_vrai) { - if (((*(*l_element_courant).donnee).objet = - analyse_flux(s_etat_processus, tampon_lecture, - longueur_enregistrement - 1)) == NULL) + if (device == d_faux) { - return; + if (((*(*l_element_courant).donnee).objet = + analyse_flux(s_etat_processus, tampon_lecture, + longueur_enregistrement - 1)) == NULL) + { + return; + } + } + else + { + if (((*(*l_element_courant).donnee).objet = + analyse_flux(s_etat_processus, tampon_lecture, + longueur_enregistrement)) == NULL) + { + return; + } } } else @@ -2498,45 +2644,74 @@ instruction_read(struct_processus *s_eta } else { - // Installation d'un timeout pour sortir de - // l'instruction dans le cas où la transmission serait - // invalide et que la trame reçue serait erronée. - - poll_fd.fd = (*((struct_socket *) - (*s_objet_argument_1).objet)).socket; - poll_fd.events = POLLIN; + // Si on a lu toute une trame et qu'on n'a pas + // réussi à en trouver la structure, on remonte + // une erreur de syntaxe. - while((ios = poll(&poll_fd, 1, 10000)) <= 0) + if (longueur_effective == ios) { - // La fin de la trame n'est pas atteinte. - - switch(ios) + if ((*((struct_socket *) (*s_objet_argument_1) + .objet)).domaine == PF_UNIX) { - case EINTR: + do { - if ((*s_etat_processus) - .var_volatile_requete_arret == -1) - { - liberation(s_etat_processus, - s_objet_argument_1); - free(tampon_lecture); - return; - } - - break; + longueur_adresse = sizeof(adresse_unix); + recvfrom((*((struct_socket *) + (*s_objet_argument_1).objet)) + .socket, tampon_lecture, + (size_t) longueur_effective, + 0, (struct sockaddr *) + &adresse_unix, &longueur_adresse); + } while((ios == -1) && (errno == EINTR)); + } + else if ((*((struct_socket *) (*s_objet_argument_1) + .objet)).domaine == PF_INET) + { + do + { + longueur_adresse = sizeof(adresse_ipv4); + recvfrom((*((struct_socket *) + (*s_objet_argument_1).objet)) + .socket, tampon_lecture, + (size_t) longueur_effective, + 0, (struct sockaddr *) + &adresse_ipv4, &longueur_adresse); + } while((ios == -1) && (errno == EINTR)); + } + else if ((*((struct_socket *) (*s_objet_argument_1) + .objet)) .domaine == PF_INET6) + { +# ifdef IPV6 + do + { + longueur_adresse = sizeof(adresse_ipv6); + recvfrom((*((struct_socket *) + (*s_objet_argument_1).objet)) + .socket, tampon_lecture, + (size_t) longueur_effective, + 0, (struct sockaddr *) + &adresse_ipv6, &longueur_adresse); + } while((ios == -1) && (errno == EINTR)); +# else + if ((*s_etat_processus).langue == 'F') + { + printf("+++Attention : Support du protocole" + " IPv6 indisponible\n"); } - - case 0: + else { - liberation(s_etat_processus, - s_objet_argument_1); - free(tampon_lecture); - - (*s_etat_processus).erreur_execution = - d_ex_fin_de_fichier_atteinte; - return; + printf("+++Warning : IPv6 support " + "unavailable\n"); } + +# endif } + + liberation(s_etat_processus, s_objet_argument_1); + free(tampon_lecture); + + (*s_etat_processus).erreur_execution = d_ex_syntaxe; + return; } } } @@ -2587,6 +2762,7 @@ instruction_read(struct_processus *s_eta indicateur_48 = test_cfsf(s_etat_processus, 48); cf(s_etat_processus, 48); + (*s_etat_processus).type_en_cours = NON; recherche_type(s_etat_processus); if ((*s_etat_processus).erreur_execution != d_ex)