--- rpl/src/instructions_t2.c 2011/04/11 12:10:11 1.23 +++ rpl/src/instructions_t2.c 2020/01/10 11:15:49 1.76 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.0.prerelease.0 - Copyright (C) 1989-2011 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.32 + Copyright (C) 1989-2020 Dr. BERTRAND Joël This file is part of RPL/2. @@ -44,8 +44,8 @@ instruction_trn(struct_processus *s_etat logical1 argument_nom; logical1 variable_partagee; - unsigned long i; - unsigned long j; + integer8 i; + integer8 j; (*s_etat_processus).erreur_execution = d_ex; @@ -109,44 +109,26 @@ instruction_trn(struct_processus *s_etat liberation(s_etat_processus, s_objet_argument); - if ((*s_etat_processus).s_liste_variables[(*s_etat_processus) - .position_variable_courante].variable_verrouillee == d_vrai) + if ((*(*s_etat_processus).pointeur_variable_courante) + .variable_verrouillee == d_vrai) { (*s_etat_processus).erreur_execution = d_ex_variable_verrouillee; return; } - if ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet != NULL) + if ((*(*s_etat_processus).pointeur_variable_courante).objet != NULL) { - s_objet_argument = (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet; + s_objet_argument = (*(*s_etat_processus).pointeur_variable_courante) + .objet; } else { - if (pthread_mutex_lock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - if (recherche_variable_partagee(s_etat_processus, - (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].nom, - (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante] - .variable_partagee, (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].origine) - == d_faux) + (*(*s_etat_processus).pointeur_variable_courante).nom, + (*(*s_etat_processus).pointeur_variable_courante) + .variable_partagee, (*(*s_etat_processus) + .pointeur_variable_courante).origine) == NULL) { - if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) - { - (*s_etat_processus).erreur_systeme = d_es_processus; - return; - } - (*s_etat_processus).erreur_systeme = d_es; (*s_etat_processus).erreur_execution = d_ex_variable_non_definie; @@ -177,7 +159,7 @@ instruction_trn(struct_processus *s_etat if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -196,13 +178,13 @@ instruction_trn(struct_processus *s_etat .nombre_lignes; if (((*((struct_matrice *) (*s_objet_resultat).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet_resultat).objet)) - .nombre_lignes * sizeof(integer8 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat) + .objet)).nombre_lignes) * sizeof(integer8 *))) == NULL) { if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -217,14 +199,14 @@ instruction_trn(struct_processus *s_etat .nombre_lignes; i++) { if ((((integer8 **) (*((struct_matrice *) (*s_objet_resultat) - .objet)).tableau)[i] = - malloc((*((struct_matrice *) (*s_objet_resultat).objet)) - .nombre_colonnes * sizeof(integer8))) == NULL) + .objet)).tableau)[i] = malloc(((size_t) + (*((struct_matrice *) (*s_objet_resultat).objet)) + .nombre_colonnes) * sizeof(integer8))) == NULL) { if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -259,7 +241,7 @@ instruction_trn(struct_processus *s_etat if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -278,13 +260,13 @@ instruction_trn(struct_processus *s_etat .nombre_lignes; if (((*((struct_matrice *) (*s_objet_resultat).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet_resultat).objet)) - .nombre_lignes * sizeof(real8 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat) + .objet)).nombre_lignes) * sizeof(real8 *))) == NULL) { if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -299,14 +281,14 @@ instruction_trn(struct_processus *s_etat .nombre_lignes; i++) { if ((((real8 **) (*((struct_matrice *) (*s_objet_resultat) - .objet)).tableau)[i] = - malloc((*((struct_matrice *) (*s_objet_resultat).objet)) - .nombre_colonnes * sizeof(real8))) == NULL) + .objet)).tableau)[i] = malloc(((size_t) + (*((struct_matrice *) (*s_objet_resultat).objet)) + .nombre_colonnes) * sizeof(real8))) == NULL) { if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -341,7 +323,7 @@ instruction_trn(struct_processus *s_etat if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -360,13 +342,13 @@ instruction_trn(struct_processus *s_etat .nombre_lignes; if (((*((struct_matrice *) (*s_objet_resultat).objet)).tableau = - malloc((*((struct_matrice *) (*s_objet_resultat).objet)) - .nombre_lignes * sizeof(struct_complexe16 *))) == NULL) + malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat) + .objet)).nombre_lignes) * sizeof(struct_complexe16 *))) == NULL) { if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -382,14 +364,14 @@ instruction_trn(struct_processus *s_etat { if ((((struct_complexe16 **) (*((struct_matrice *) (*s_objet_resultat).objet)).tableau)[i] = - malloc((*((struct_matrice *) - (*s_objet_resultat).objet)).nombre_colonnes * + malloc(((size_t) (*((struct_matrice *) + (*s_objet_resultat).objet)).nombre_colonnes) * sizeof(struct_complexe16))) == NULL) { if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -435,7 +417,7 @@ instruction_trn(struct_processus *s_etat if (variable_partagee == d_vrai) { if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -460,12 +442,11 @@ instruction_trn(struct_processus *s_etat { if (variable_partagee == d_vrai) { - (*(*s_etat_processus).s_liste_variables_partagees).table - [(*(*s_etat_processus).s_liste_variables_partagees) - .position_variable].objet = s_objet_resultat; + (*(*s_etat_processus).pointeur_variable_partagee_courante).objet = + s_objet_resultat; if (pthread_mutex_unlock(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)) != 0) + .pointeur_variable_partagee_courante).mutex)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; return; @@ -473,8 +454,7 @@ instruction_trn(struct_processus *s_etat } else { - (*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet = + (*(*s_etat_processus).pointeur_variable_courante).objet = s_objet_resultat; } } @@ -498,15 +478,11 @@ instruction_trn(struct_processus *s_etat void instruction_tot(struct_processus *s_etat_processus) { - logical1 presence_variable; - - long i; - struct_objet *s_objet_statistique; struct_objet *s_objet_resultat; struct_objet *s_objet_temporaire; - unsigned long nombre_colonnes; + integer8 nombre_colonnes; (*s_etat_processus).erreur_execution = d_ex; @@ -545,70 +521,34 @@ instruction_tot(struct_processus *s_etat * Recherche d'une variable globale référencée par SIGMA */ - if (recherche_variable(s_etat_processus, ds_sdat) == d_faux) + if (recherche_variable_globale(s_etat_processus, ds_sdat) == d_faux) { /* * Aucune variable SIGMA */ (*s_etat_processus).erreur_systeme = d_es; - (*s_etat_processus).erreur_execution = d_ex_absence_observations; - return; - } - else - { - /* - * Il existe une variable locale SIGMA. Reste à vérifier l'existence - * d'une variable SIGMA globale... - */ - - i = (*s_etat_processus).position_variable_courante; - presence_variable = d_faux; - while(i >= 0) + if ((*s_etat_processus).erreur_execution == d_ex) { - if ((strcmp((*s_etat_processus).s_liste_variables[i].nom, - ds_sdat) == 0) && ((*s_etat_processus) - .s_liste_variables[i].niveau == 1)) - { - presence_variable = d_vrai; - break; - } - - i--; + (*s_etat_processus).erreur_execution = d_ex_absence_observations; } - if (presence_variable == d_faux) + return; + } + else + { + if (((*(*(*s_etat_processus).pointeur_variable_courante).objet) + .type != MIN) && ((*(*(*s_etat_processus) + .pointeur_variable_courante).objet).type != MRL)) { - (*s_etat_processus).erreur_execution = d_ex_absence_observations; + (*s_etat_processus).erreur_execution = + d_ex_matrice_statistique_invalide; return; } - else - { - (*s_etat_processus).position_variable_courante = i; - - if ((*s_etat_processus).s_liste_variables[i].objet == NULL) - { - (*s_etat_processus).erreur_execution = d_ex_variable_partagee; - return; - } - if (((*((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante].objet)) - .type != MIN) && ((*((*s_etat_processus) - .s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet)).type != MRL)) - { - (*s_etat_processus).erreur_execution = - d_ex_matrice_statistique_invalide; - return; - } - - nombre_colonnes = (*((struct_matrice *) (*((*s_etat_processus) - .s_liste_variables[(*s_etat_processus) - .position_variable_courante].objet)).objet)) - .nombre_colonnes; - } + nombre_colonnes = (*((struct_matrice *) (*(*(*s_etat_processus) + .pointeur_variable_courante).objet).objet)).nombre_colonnes; } if (nombre_colonnes == 0) @@ -618,8 +558,8 @@ instruction_tot(struct_processus *s_etat return; } - s_objet_statistique = ((*s_etat_processus).s_liste_variables - [(*s_etat_processus).position_variable_courante]).objet; + s_objet_statistique = (*(*s_etat_processus).pointeur_variable_courante) + .objet; if (((*s_objet_statistique).type == MIN) || ((*s_objet_statistique).type == MRL)) @@ -631,6 +571,7 @@ instruction_tot(struct_processus *s_etat } if (((*s_objet_resultat).objet = sommation_statistique( + s_etat_processus, (struct_matrice *) (*s_objet_statistique).objet)) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -910,7 +851,7 @@ instruction_time(struct_processus *s_eta } (*((real8 *) (*(*l_element_courant).donnee).objet)) = - s_usage_processus_pere.ru_utime.tv_sec + + ((real8) s_usage_processus_pere.ru_utime.tv_sec) + (((real8) s_usage_processus_pere.ru_utime.tv_usec) / ((real8) 1E6)); @@ -935,7 +876,7 @@ instruction_time(struct_processus *s_eta } (*((real8 *) (*(*l_element_courant).donnee).objet)) = - s_usage_processus_pere.ru_stime.tv_sec + + ((real8) s_usage_processus_pere.ru_stime.tv_sec) + (((real8) s_usage_processus_pere.ru_stime.tv_usec) / ((real8) 1E6)); @@ -960,7 +901,7 @@ instruction_time(struct_processus *s_eta } (*((real8 *) (*(*l_element_courant).donnee).objet)) = - s_usage_processus_fils.ru_utime.tv_sec + + ((real8) s_usage_processus_fils.ru_utime.tv_sec) + (((real8) s_usage_processus_fils.ru_utime.tv_usec) / ((real8) 1E6)); @@ -985,7 +926,7 @@ instruction_time(struct_processus *s_eta } (*((real8 *) (*(*l_element_courant).donnee).objet)) = - s_usage_processus_fils.ru_stime.tv_sec + + ((real8) s_usage_processus_fils.ru_stime.tv_sec) + (((real8) s_usage_processus_fils.ru_stime.tv_usec) / ((real8) 1E6)); @@ -1980,7 +1921,7 @@ instruction_target(struct_processus *s_e .adresse_distante); if (((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante = malloc(22 * + .objet)).adresse_distante = malloc(23 * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = @@ -1988,9 +1929,6 @@ instruction_target(struct_processus *s_e return; } - (*((struct_socket *) (*s_objet_argument_1).objet)) - .adresse_distante[0] = d_code_fin_chaine; - for(i = 0; i < 4; i++) { if ((((integer8 *) (*((struct_vecteur *) @@ -1999,14 +1937,6 @@ instruction_target(struct_processus *s_e (*((struct_vecteur *) (*(*l_element_courant) .donnee).objet)).tableau)[i] <= 255)) { - sprintf((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, - (i == 0) ? "%s%d" : "%s.%d", - (*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, (int) - ((integer8 *) (*((struct_vecteur *) - (*(*l_element_courant).donnee).objet)) - .tableau)[i]); } else { @@ -2018,6 +1948,21 @@ instruction_target(struct_processus *s_e return; } } + + sprintf((*((struct_socket *) (*s_objet_argument_1) + .objet)).adresse_distante, "%d.%d.%d.%d", + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[0], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[1], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[2], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[3]); } else if ((*((struct_vecteur *) (*(*l_element_courant).donnee) .objet)).taille == 16) @@ -2037,7 +1982,7 @@ instruction_target(struct_processus *s_e .adresse_distante); if (((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante = malloc(55 * + .objet)).adresse_distante = malloc(47 * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = @@ -2045,9 +1990,6 @@ instruction_target(struct_processus *s_e return; } - (*((struct_socket *) (*s_objet_argument_1).objet)) - .adresse_distante[0] = d_code_fin_chaine; - for(i = 0; i < 16; i++) { if ((((integer8 *) (*((struct_vecteur *) @@ -2056,14 +1998,6 @@ instruction_target(struct_processus *s_e (*((struct_vecteur *) (*(*l_element_courant) .donnee).objet)).tableau)[i] <= 255)) { - sprintf((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, - (i == 0) ? "%s%d" : "%s:%X", - (*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, (int) - ((integer8 *) (*((struct_vecteur *) - (*(*l_element_courant).donnee).objet)) - .tableau)[i]); } else { @@ -2075,6 +2009,59 @@ instruction_target(struct_processus *s_e return; } } + + sprintf((*((struct_socket *) (*s_objet_argument_1) + .objet)).adresse_distante, + "%02X%02X:%02X%02X:%02X%02X:%02X%02X:" + "%02X%02X:%02X%02X:%02X%02X:%02X%02X", + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[0], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[1], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[2], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[3], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[4], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[5], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[6], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[7], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[8], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[9], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[10], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[11], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[12], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[13], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[14], + (int) ((integer8 *) (*((struct_vecteur *) + (*(*l_element_courant).donnee).objet)) + .tableau)[15]); } else { @@ -2137,7 +2124,7 @@ instruction_target(struct_processus *s_e .adresse_distante); if (((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante = malloc(22 * + .objet)).adresse_distante = malloc(23 * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = @@ -2189,7 +2176,7 @@ instruction_target(struct_processus *s_e } if (((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante = malloc(55 * + .objet)).adresse_distante = malloc(47 * sizeof(unsigned char))) == NULL) { (*s_etat_processus).erreur_systeme = @@ -2197,20 +2184,42 @@ instruction_target(struct_processus *s_e return; } - (*((struct_socket *) (*s_objet_argument_1).objet)) - .adresse_distante[0] = d_code_fin_chaine; - - for(i = 0; i < 16; i++) - { - sprintf((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, - (i == 0) ? "%s%X" : "%s:%X", - (*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, - (*((struct sockaddr_in6 *) - (*resolution_courante).ai_addr)).sin6_addr - .s6_addr[i]); - } + sprintf((*((struct_socket *) (*s_objet_argument_1) + .objet)).adresse_distante, + "%02X%02X:%02X%02X:%02X%02X:%02X%02X:" + "%02X%02X:%02X%02X:%02X%02X:%02X%02X", + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[0], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[1], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[2], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[3], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[4], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[5], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[6], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[7], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[8], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[9], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[10], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[11], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[12], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[13], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[14], + (*((struct sockaddr_in6 *) (*resolution_courante) + .ai_addr)).sin6_addr.s6_addr[15]); # else if ((*s_etat_processus).langue == 'F') { @@ -2257,9 +2266,9 @@ instruction_target(struct_processus *s_e .donnee).objet)) <= 65535)) { sprintf((*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, "%s(%u)", - (*((struct_socket *) (*s_objet_argument_1) - .objet)).adresse_distante, (unsigned int) + .objet)).adresse_distante + + strlen((*((struct_socket *) (*s_objet_argument_1) + .objet)).adresse_distante), "(%u)", (unsigned int) (*((integer8 *) (*(*l_element_courant).donnee) .objet))); }