--- rpl/src/instructions_w1.c 2012/07/05 08:05:50 1.65 +++ rpl/src/instructions_w1.c 2013/03/20 17:11:45 1.78 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.9 - Copyright (C) 1989-2012 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,17 +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; - long longueur_effective; long recursivite; sqlite3_stmt *ppStmt; @@ -424,6 +425,8 @@ instruction_write(struct_processus *s_et struct flock lock; + struct timespec attente; + uint32_t calcul_adresse; unsigned char *chaine; @@ -589,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); @@ -671,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); @@ -760,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) { @@ -875,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); @@ -917,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) { @@ -1182,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); @@ -1275,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) @@ -1312,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); @@ -1531,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); @@ -1546,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 { @@ -1737,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; @@ -1789,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) @@ -1805,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; @@ -1872,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) @@ -1888,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;