--- rpl/src/instructions_w1.c 2013/03/11 15:41:06 1.77 +++ rpl/src/instructions_w1.c 2015/01/27 14:18:08 1.94 @@ -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.20 + Copyright (C) 1989-2015 Dr. BERTRAND Joël This file is part of RPL/2. @@ -245,9 +245,9 @@ instruction_wait(struct_processus *s_eta return; } - temporisation.tv_sec = (long) floor((double) attente); - temporisation.tv_nsec = (attente - temporisation.tv_sec) * - (long) 1000000000; + temporisation.tv_sec = (time_t) floor((double) attente); + temporisation.tv_nsec = (long) ((attente - + ((real8) temporisation.tv_sec)) * (integer8) 1000000000); if ((*s_etat_processus).profilage == d_vrai) { @@ -289,11 +289,25 @@ instruction_wait(struct_processus *s_eta scrutation_injection(s_etat_processus); + if (pthread_mutex_lock(&(*s_etat_processus).mutex_interruptions) + != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&(*s_etat_processus).mutex_interruptions) + != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { traitement_interruptions_logicielles(s_etat_processus); @@ -390,14 +404,14 @@ instruction_write(struct_processus *s_et integer8 clef; integer8 compteur; integer8 id; + integer8 longueur; + integer8 longueur_effective; integer8 ordre; + integer8 recursivite; logical1 format_degenere; logical1 mise_a_jour; - long longueur; - long longueur_effective; - long recursivite; sqlite3_stmt *ppStmt; @@ -698,7 +712,8 @@ instruction_write(struct_processus *s_et free(chaine); - if (alsprintf(&commande, "insert or replace into data " + if (alsprintf(s_etat_processus, &commande, + "insert or replace into data " "(id, data) values (%lld, '%s')", (*((integer8 *) (*s_objet_argument_2).objet)), chaine_utf8) < 0) { @@ -710,7 +725,7 @@ instruction_write(struct_processus *s_et free(chaine_utf8); if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + commande, (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -748,8 +763,8 @@ instruction_write(struct_processus *s_et // 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; @@ -757,7 +772,7 @@ instruction_write(struct_processus *s_et } if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + commande, (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -925,8 +940,8 @@ instruction_write(struct_processus *s_et // 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; @@ -934,7 +949,7 @@ instruction_write(struct_processus *s_et } if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + commande, (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -971,8 +986,9 @@ instruction_write(struct_processus *s_et free(commande); - if (alsprintf(&commande, "insert into key " - "(key) values ('%s')", clef_utf8) < 0) + if (alsprintf(s_etat_processus, &commande, + "insert into key (key) values ('%s')", + clef_utf8) < 0) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -980,8 +996,8 @@ instruction_write(struct_processus *s_et } if (sqlite3_prepare_v2((*descripteur) - .descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + .descripteur_sqlite, commande, + (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = @@ -1005,8 +1021,9 @@ instruction_write(struct_processus *s_et free(commande); - 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; @@ -1014,8 +1031,8 @@ instruction_write(struct_processus *s_et } if (sqlite3_prepare_v2((*descripteur) - .descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + .descripteur_sqlite, commande, + (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = @@ -1069,8 +1086,9 @@ instruction_write(struct_processus *s_et if (mise_a_jour == d_vrai) { - if (alsprintf(&commande, "update key set key = '%s' where " - "id = %lld", clef_utf8, id) < 0) + if (alsprintf(s_etat_processus, &commande, + "update key set key = '%s' where id = %lld", + clef_utf8, id) < 0) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -1078,7 +1096,7 @@ instruction_write(struct_processus *s_et } if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + commande, (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = @@ -1105,8 +1123,8 @@ instruction_write(struct_processus *s_et // Effacement de l'enregistrement existant - if (alsprintf(&commande, "delete from data where " - "key_id = %lld", id) < 0) + if (alsprintf(s_etat_processus, &commande, + "delete from data where key_id = %lld", id) < 0) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -1114,7 +1132,7 @@ instruction_write(struct_processus *s_et } if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + commande, (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = d_es_erreur_fichier; @@ -1240,8 +1258,8 @@ instruction_write(struct_processus *s_et free(chaine); - if (alsprintf(&commande, "insert into data " - "(data, key_id, sequence) values " + if (alsprintf(s_etat_processus, &commande, + "insert into data (data, key_id, sequence) values " "('%s', %lld, %lld)", chaine_utf8, id, ordre) < 0) { (*s_etat_processus).erreur_systeme = @@ -1250,7 +1268,7 @@ instruction_write(struct_processus *s_et } if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite, - commande, strlen(commande), &ppStmt, &queue) + commande, (int) strlen(commande), &ppStmt, &queue) != SQLITE_OK) { (*s_etat_processus).erreur_systeme = @@ -1343,7 +1361,8 @@ instruction_write(struct_processus *s_et return; } - if (fwrite(chaine, sizeof(unsigned char), longueur_effective, + if (fwrite(chaine, sizeof(unsigned char), + (size_t) longueur_effective, (*descripteur).descripteur_c) != (size_t) longueur_effective) { @@ -1479,9 +1498,9 @@ instruction_write(struct_processus *s_et return; } - if ((format_chaine = conversion_majuscule((unsigned char *) - (*(*l_element_courant_format).donnee).objet)) - == NULL) + if ((format_chaine = conversion_majuscule(s_etat_processus, + (unsigned char *) (*(*l_element_courant_format) + .donnee).objet)) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -1500,7 +1519,7 @@ instruction_write(struct_processus *s_et return; } - longueur = strlen(format_chaine); + longueur = (integer8) strlen(format_chaine); if (format_chaine[longueur - 1] != ')') { @@ -1525,7 +1544,7 @@ instruction_write(struct_processus *s_et // 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) { free(format_chaine); @@ -1553,7 +1572,7 @@ instruction_write(struct_processus *s_et (longueur_effective < longueur)) { if (fwrite(chaine, sizeof(unsigned char), - longueur_effective, + (size_t) longueur_effective, (*descripteur).descripteur_c) != (size_t) longueur_effective) { @@ -1565,7 +1584,7 @@ instruction_write(struct_processus *s_et else { if (fwrite(chaine, sizeof(unsigned char), - longueur_effective, + (size_t) longueur_effective, (*descripteur).descripteur_c) != (size_t) longueur) { @@ -1716,7 +1735,7 @@ instruction_write(struct_processus *s_et } if (send((*((struct_socket *) (*s_objet_argument_1).objet)) - .socket, chaine, longueur_effective, 0) < 0) + .socket, chaine, (size_t) longueur_effective, 0) < 0) { ios = errno; @@ -1819,7 +1838,7 @@ instruction_write(struct_processus *s_et if (sendto((*((struct_socket *) (*s_objet_argument_1).objet)).socket, chaine, - longueur_effective, 0, (struct sockaddr *) + (size_t) longueur_effective, 0, (struct sockaddr *) &adresse_unix, sizeof(adresse_unix)) < 0) { ios = errno; @@ -1880,11 +1899,12 @@ instruction_write(struct_processus *s_et { // Adresse IPv4 calcul_adresse = 0; for(i = 0; i < 4; calcul_adresse = - (256 * calcul_adresse) + adresse[i++]); + (256 * calcul_adresse) + + ((unsigned char) adresse[i++])); memset(&adresse_ipv4, 0, sizeof(adresse_ipv4)); adresse_ipv4.sin_family = AF_INET; - adresse_ipv4.sin_port = htons(port); + adresse_ipv4.sin_port = htons((uint16_t) port); adresse_ipv4.sin_addr.s_addr = htonl(calcul_adresse); # ifndef SEMAPHORES_NOMMES @@ -1900,7 +1920,7 @@ instruction_write(struct_processus *s_et if (sendto((*((struct_socket *) (*s_objet_argument_1).objet)).socket, chaine, - longueur_effective, 0, (struct sockaddr *) + (size_t) longueur_effective, 0, (struct sockaddr *) &adresse_ipv4, sizeof(adresse_ipv4)) < 0) { ios = errno; @@ -1984,7 +2004,7 @@ instruction_write(struct_processus *s_et for(i = 0; i < 16; adresse_ipv6.sin6_addr.s6_addr[i] = - adresse[i], i++); + (unsigned char) adresse[i], i++); # ifndef SEMAPHORES_NOMMES if (sem_post(&((*s_etat_processus).semaphore_fork)) @@ -1999,7 +2019,7 @@ instruction_write(struct_processus *s_et if (sendto((*((struct_socket *) (*s_objet_argument_1).objet)).socket, chaine, - longueur_effective, 0, (struct sockaddr *) + (size_t) longueur_effective, 0, (struct sockaddr *) &adresse_ipv6, sizeof(adresse_ipv6)) < 0) { ios = errno; @@ -2195,8 +2215,8 @@ instruction_wflock(struct_processus *s_e do { - if ((chaine = conversion_majuscule((unsigned char *) - (*s_objet_argument_1).objet)) == NULL) + if ((chaine = conversion_majuscule(s_etat_processus, + (unsigned char *) (*s_objet_argument_1).objet)) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -2277,13 +2297,26 @@ instruction_wflock(struct_processus *s_e } else { + if (pthread_mutex_lock(&(*s_etat_processus).mutex_interruptions) + != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } - if ((*s_etat_processus).nombre_interruptions_en_queue - != 0) + if (pthread_mutex_unlock(&(*s_etat_processus) + .mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { registre_instruction_valide = (*s_etat_processus).instruction_valide; @@ -2397,7 +2430,8 @@ instruction_wfproc(struct_processus *s_e } } - if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) + != 0) { if ((*s_etat_processus).profilage == d_vrai) { @@ -2462,7 +2496,8 @@ instruction_wfproc(struct_processus *s_e profilage(s_etat_processus, NULL); } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -2542,8 +2577,12 @@ instruction_wfproc(struct_processus *s_e * Le processus n'est pas terminé */ - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus) + .mutex_interruptions)) != 0) { + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); + if ((*s_etat_processus).profilage == d_vrai) { profilage(s_etat_processus, NULL); @@ -2560,8 +2599,36 @@ instruction_wfproc(struct_processus *s_e affectation_interruptions_logicielles(s_etat_processus); } - if ((*s_etat_processus).nombre_interruptions_en_queue - != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_interruptions)) != 0) + { + pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)); + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } + + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } + + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) + { + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } + + (*s_etat_processus).erreur_systeme = + d_es_processus; + return; + } + + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { registre_instruction_valide = (*s_etat_processus).instruction_valide; @@ -2600,7 +2667,8 @@ instruction_wfproc(struct_processus *s_e scrutation_injection(s_etat_processus); - if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { if ((*s_etat_processus).profilage == d_vrai) { @@ -2622,7 +2690,8 @@ instruction_wfproc(struct_processus *s_e profilage(s_etat_processus, NULL); } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) + != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -2725,7 +2794,8 @@ instruction_wfdata(struct_processus *s_e } } - if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) + != 0) { if ((*s_etat_processus).profilage == d_vrai) { @@ -2785,7 +2855,8 @@ instruction_wfdata(struct_processus *s_e profilage(s_etat_processus, NULL); } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -2828,7 +2899,8 @@ instruction_wfdata(struct_processus *s_e return; } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { if ((*s_etat_processus).profilage == d_vrai) { @@ -2869,12 +2941,26 @@ instruction_wfdata(struct_processus *s_e scrutation_injection(s_etat_processus); + if (pthread_mutex_lock(&(*s_etat_processus) + .mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&(*s_etat_processus) + .mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { registre_instruction_valide = @@ -2894,7 +2980,8 @@ instruction_wfdata(struct_processus *s_e return; } - if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_lock(&((*s_etat_processus) + .mutex_pile_processus)) != 0) { if ((*s_etat_processus).profilage == d_vrai) { @@ -2921,7 +3008,8 @@ instruction_wfdata(struct_processus *s_e profilage(s_etat_processus, NULL); } - if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) + if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) + != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -3605,11 +3693,25 @@ instruction_wfswi(struct_processus *s_et return; } + if (pthread_mutex_lock(&(*s_etat_processus).mutex_interruptions) + != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&(*s_etat_processus).mutex_interruptions) + != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).queue_interruptions[interruption - 1] > 0) { drapeau_fin = d_vrai; @@ -3742,11 +3844,23 @@ instruction_wfpoke(struct_processus *s_e scrutation_injection(s_etat_processus); + if (pthread_mutex_lock(&(*s_etat_processus).mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&(*s_etat_processus).mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { registre_instruction_valide = @@ -3849,11 +3963,23 @@ instruction_wfack(struct_processus *s_et { scrutation_injection(s_etat_processus); + if (pthread_mutex_lock(&(*s_etat_processus).mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_non_affectees != 0) { affectation_interruptions_logicielles(s_etat_processus); } + if (pthread_mutex_unlock(&(*s_etat_processus).mutex_interruptions) != 0) + { + (*s_etat_processus).erreur_systeme = d_es_processus; + return; + } + if ((*s_etat_processus).nombre_interruptions_en_queue != 0) { registre_instruction_valide =