--- rpl/src/instructions_t2.c 2012/04/13 14:13:00 1.40 +++ rpl/src/instructions_t2.c 2020/01/10 11:15:49 1.76 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.8 - Copyright (C) 1989-2012 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; @@ -123,26 +123,12 @@ instruction_trn(struct_processus *s_etat } 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).pointeur_variable_courante).nom, (*(*s_etat_processus).pointeur_variable_courante) .variable_partagee, (*(*s_etat_processus) - .pointeur_variable_courante).origine) == d_faux) + .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; @@ -173,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; @@ -192,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; @@ -213,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; @@ -255,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; @@ -274,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; @@ -295,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; @@ -337,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; @@ -356,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; @@ -378,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; @@ -431,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; @@ -456,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; @@ -497,7 +482,7 @@ instruction_tot(struct_processus *s_etat struct_objet *s_objet_resultat; struct_objet *s_objet_temporaire; - unsigned long nombre_colonnes; + integer8 nombre_colonnes; (*s_etat_processus).erreur_execution = d_ex; @@ -586,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; @@ -865,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)); @@ -890,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)); @@ -915,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)); @@ -940,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)); @@ -1935,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 = @@ -1943,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 *) @@ -1954,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 { @@ -1973,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) @@ -1992,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 = @@ -2000,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 *) @@ -2011,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 { @@ -2030,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 { @@ -2092,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 = @@ -2144,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 = @@ -2152,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') { @@ -2212,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))); }