--- rpl/src/instructions_w1.c 2011/12/06 13:27:14 1.56 +++ rpl/src/instructions_w1.c 2013/03/20 17:11:45 1.78 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.5 - 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. @@ -385,15 +385,18 @@ instruction_write(struct_processus *s_et int adresse[16]; int port; + int sqlite_status; integer8 clef; integer8 compteur; integer8 id; + integer8 longueur_effective; integer8 ordre; + logical1 format_degenere; logical1 mise_a_jour; - long longueur_effective; + long longueur; long recursivite; sqlite3_stmt *ppStmt; @@ -422,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; @@ -586,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); @@ -668,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); @@ -757,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) { @@ -872,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); @@ -914,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) { @@ -1179,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); @@ -1272,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) @@ -1309,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); @@ -1349,35 +1451,147 @@ instruction_write(struct_processus *s_et return; } - if ((*((*((struct_liste_chainee *) (*s_objet_argument_2).objet)) - .donnee)).type != CHN) + 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)) { - liberation(s_etat_processus, s_objet_argument_2); - liberation(s_etat_processus, s_objet_argument_1); + 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; - } + (*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 ((*(*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; } - if (fwrite(chaine, sizeof(unsigned char), longueur_effective, - (*descripteur).descripteur_c) != - (size_t) longueur_effective) + if ((l_element_courant_format != NULL) || + (l_element_courant != NULL)) { - (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; + 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(chaine); } else { @@ -1416,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); @@ -1431,7 +1645,16 @@ instruction_write(struct_processus *s_et * Sockets non formatées */ - chaine = NULL; + if ((chaine = formateur_fichier(s_etat_processus, + s_objet_argument_2, (*((struct_socket *) + (*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 { @@ -1622,6 +1845,12 @@ 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; @@ -1674,6 +1903,8 @@ instruction_write(struct_processus *s_et longueur_effective, 0, (struct sockaddr *) &adresse_ipv4, sizeof(adresse_ipv4)) < 0) { + ios = errno; + # ifndef SEMAPHORES_NOMMES while(sem_wait(&((*s_etat_processus) .semaphore_fork)) != 0) @@ -1690,6 +1921,20 @@ 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; @@ -1757,6 +2002,8 @@ instruction_write(struct_processus *s_et longueur_effective, 0, (struct sockaddr *) &adresse_ipv6, sizeof(adresse_ipv6)) < 0) { + ios = errno; + # ifndef SEMAPHORES_NOMMES while(sem_wait(&((*s_etat_processus) .semaphore_fork)) != 0) @@ -1773,6 +2020,20 @@ 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;