--- rpl/src/instructions_w1.c 2016/01/11 11:28:39 1.101 +++ rpl/src/instructions_w1.c 2018/12/24 15:56:32 1.112 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.24 - Copyright (C) 1989-2015 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.30 + Copyright (C) 1989-2018 Dr. BERTRAND Joël This file is part of RPL/2. @@ -410,9 +410,9 @@ instruction_write(struct_processus *s_et integer8 recursivite; logical1 format_degenere; + logical1 format_oriente_ligne; logical1 mise_a_jour; - sqlite3_stmt *ppStmt; ssize_t ios; @@ -1507,44 +1507,30 @@ instruction_write(struct_processus *s_et return; } - if (strncmp("LENGTH*(", format_chaine, 8) != 0) + if (strcmp("LINE*(*)", format_chaine) == 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; + format_oriente_ligne = d_vrai; + format_degenere = d_vrai; } - - longueur = (integer8) strlen(format_chaine); - - if (format_chaine[longueur - 1] != ')') + else { - free(format_chaine); + format_oriente_ligne = d_faux; + + 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); + 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; - } + (*s_etat_processus).erreur_execution = + d_ex_erreur_format_fichier; + return; + } - format_chaine[longueur] = d_code_fin_chaine; + longueur = (integer8) strlen(format_chaine); - if (format_chaine[8] == '*') - { - format_degenere = d_vrai; - } - else - { - // Détermination de la longueur - format_degenere = d_faux; - - if (sscanf(&(format_chaine[8]), "%lld", &longueur) != 1) + if (format_chaine[longueur - 1] != ')') { free(format_chaine); @@ -1555,6 +1541,33 @@ instruction_write(struct_processus *s_et 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]), "%lld", &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); @@ -1596,6 +1609,17 @@ instruction_write(struct_processus *s_et free(chaine); + if (format_oriente_ligne == d_vrai) + { + if (fwrite("\n", 1, 1, (*descripteur).descripteur_c) + != 1) + { + (*s_etat_processus).erreur_systeme = + d_es_erreur_fichier; + return; + } + } + l_element_courant = (*l_element_courant).suivant; l_element_courant_format = (*l_element_courant_format) .suivant; @@ -2522,7 +2546,7 @@ instruction_wfproc(struct_processus *s_e { if (envoi_signal_processus((*(*((struct_processus_fils *) (*(*l_element_courant).donnee).objet)).thread).pid, - rpl_signull) != 0) + rpl_signull, d_faux) != 0) { drapeau_fin = d_vrai; } @@ -3177,8 +3201,6 @@ instruction_wfsock(struct_processus *s_e struct sockaddr_in6 adresse_ipv6; # endif - unsigned long i; - if ((*s_etat_processus).affichage_arguments == 'Y') { printf("\n WFSOCK "); @@ -3542,7 +3564,7 @@ instruction_wfsock(struct_processus *s_e } while(drapeau == d_faux); if (((*((struct_socket *) (*s_objet_resultat).objet)) - .adresse_distante = malloc(55 * + .adresse_distante = malloc(47 * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = @@ -3550,22 +3572,26 @@ instruction_wfsock(struct_processus *s_e return; } - (*((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]); - } - sprintf((*((struct_socket *) (*s_objet_resultat) - .objet)).adresse_distante, "%s(%u)", - (*((struct_socket *) (*s_objet_resultat) .objet)).adresse_distante, + "%02X%02X:%02X%02X:%02X%02X:%02X%02X:" + "%02X%02X:%02X%02X:%02X%02X:%02X%02X(%u)", + adresse_ipv6.sin6_addr.s6_addr[0], + adresse_ipv6.sin6_addr.s6_addr[1], + adresse_ipv6.sin6_addr.s6_addr[2], + adresse_ipv6.sin6_addr.s6_addr[3], + adresse_ipv6.sin6_addr.s6_addr[4], + adresse_ipv6.sin6_addr.s6_addr[5], + adresse_ipv6.sin6_addr.s6_addr[6], + adresse_ipv6.sin6_addr.s6_addr[7], + adresse_ipv6.sin6_addr.s6_addr[8], + adresse_ipv6.sin6_addr.s6_addr[9], + adresse_ipv6.sin6_addr.s6_addr[10], + adresse_ipv6.sin6_addr.s6_addr[11], + adresse_ipv6.sin6_addr.s6_addr[12], + adresse_ipv6.sin6_addr.s6_addr[13], + adresse_ipv6.sin6_addr.s6_addr[14], + adresse_ipv6.sin6_addr.s6_addr[15], ntohs(adresse_ipv6.sin6_port)); # else if ((*s_etat_processus).langue == 'F')