--- rpl/src/instructions_d5.c 2012/10/14 21:37:10 1.96 +++ rpl/src/instructions_d5.c 2013/03/27 09:14:51 1.106 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.11 - 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. @@ -40,12 +40,13 @@ instruction_dft(struct_processus *s_etat { integer4 erreur; integer4 inverse; + integer4 longueur_dft; integer4 nombre_colonnes; integer4 nombre_lignes; logical1 presence_longueur_dft; - long longueur_dft_signee; + integer8 longueur_dft_signee; struct_complexe16 *matrice_f77; @@ -53,10 +54,9 @@ instruction_dft(struct_processus *s_etat struct_objet *s_objet_longueur_dft; struct_objet *s_objet_resultat; - unsigned long i; - unsigned long j; - unsigned long k; - unsigned long longueur_dft; + integer8 i; + integer8 j; + integer8 k; (*s_etat_processus).erreur_execution = d_ex; @@ -135,7 +135,7 @@ instruction_dft(struct_processus *s_etat return; } - longueur_dft = longueur_dft_signee; + longueur_dft = (integer4) longueur_dft_signee; } else { @@ -170,11 +170,11 @@ instruction_dft(struct_processus *s_etat { if (presence_longueur_dft == d_faux) { - longueur_dft = (*((struct_vecteur *) + longueur_dft = (integer4) (*((struct_vecteur *) (*s_objet_argument).objet)).taille; } - if ((matrice_f77 = malloc(longueur_dft * + if ((matrice_f77 = malloc(((size_t) longueur_dft) * sizeof(struct_complexe16))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -260,13 +260,13 @@ instruction_dft(struct_processus *s_etat { if (presence_longueur_dft == d_faux) { - longueur_dft = (*((struct_matrice *) + longueur_dft = (integer4) (*((struct_matrice *) (*s_objet_argument).objet)).nombre_colonnes; } - if ((matrice_f77 = malloc(longueur_dft * + if ((matrice_f77 = malloc(((size_t) longueur_dft) * ((size_t) (*((struct_matrice *) (*s_objet_argument).objet)) - .nombre_lignes * sizeof(struct_complexe16))) == NULL) + .nombre_lignes) * sizeof(struct_complexe16))) == NULL) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -342,8 +342,8 @@ instruction_dft(struct_processus *s_etat } } - nombre_lignes = (*((struct_matrice *) (*s_objet_argument).objet)) - .nombre_lignes; + nombre_lignes = (integer4) (*((struct_matrice *) (*s_objet_argument) + .objet)).nombre_lignes; nombre_colonnes = longueur_dft; inverse = 0; @@ -371,8 +371,8 @@ instruction_dft(struct_processus *s_etat longueur_dft; 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) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; return; @@ -383,8 +383,8 @@ instruction_dft(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) { (*s_etat_processus).erreur_systeme = d_es_allocation_memoire; @@ -838,6 +838,9 @@ instruction_detach(struct_processus *s_e struct_liste_chainee *l_element_precedent; struct_liste_chainee *l_element_suivant; + struct_liste_variables_partagees *l_element_partage_courant; + struct_liste_variables_partagees *l_element_partage_suivant; + struct_liste_variables_statiques *l_element_statique_courant; struct_liste_variables_statiques *l_element_statique_suivant; @@ -856,7 +859,7 @@ instruction_detach(struct_processus *s_e unsigned int erreur; - unsigned long i; + integer8 i; volatile logical1 variable_partagee; @@ -934,26 +937,12 @@ instruction_detach(struct_processus *s_e if ((*(*s_etat_processus).pointeur_variable_courante).objet == NULL) { - 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; - } - liberation(s_etat_processus, s_objet); (*s_etat_processus).erreur_systeme = d_es; @@ -962,16 +951,14 @@ instruction_detach(struct_processus *s_e return; } - if (((*(*(*s_etat_processus).s_liste_variables_partagees) - .table[(*(*s_etat_processus) - .s_liste_variables_partagees).position_variable].objet) - .type != RPN) && ((*(*(*s_etat_processus) - .s_liste_variables_partagees).table - [(*(*s_etat_processus).s_liste_variables_partagees) - .position_variable].objet).type != ADR)) + if (((*(*(*s_etat_processus) + .pointeur_variable_partagee_courante).objet).type + == RPN) && ((*(*(*s_etat_processus) + .pointeur_variable_partagee_courante).objet).type + == ADR)) { 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; @@ -985,12 +972,12 @@ instruction_detach(struct_processus *s_e } if ((s_copie = copie_objet(s_etat_processus, - (*(*s_etat_processus).s_liste_variables_partagees).table - [(*(*s_etat_processus).s_liste_variables_partagees) - .position_variable].objet, 'P')) == NULL) + (*(*s_etat_processus) + .pointeur_variable_partagee_courante).objet, 'P')) + == NULL) { 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; @@ -1005,7 +992,7 @@ instruction_detach(struct_processus *s_e 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; @@ -1384,14 +1371,6 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).liste_mutexes = NULL; liberation_threads(s_etat_processus); - - (*(*s_etat_processus).s_liste_variables_partagees) - .table = NULL; - (*(*s_etat_processus).s_liste_variables_partagees) - .nombre_variables = 0; - (*(*s_etat_processus).s_liste_variables_partagees) - .nombre_variables_allouees = 0; - insertion_thread(s_etat_processus, d_vrai); // Envoi d'une donnée pour signaler le démarrage du processus au thread @@ -2020,11 +1999,18 @@ instruction_detach(struct_processus *s_e } else { - if (((*s_etat_processus).var_volatile_alarme == 0) - && ((*s_etat_processus).arret_depuis_abort == 0) + if (((*s_etat_processus).arret_depuis_abort == 0) && ((*s_etat_processus).at_exit != NULL)) { (*s_etat_processus).var_volatile_requete_arret = 0; + (*s_etat_processus).var_volatile_alarme = 0; + (*s_etat_processus).var_volatile_traitement_sigint + = 0; + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, "ATEXIT"); + } if (evaluation(s_etat_processus, (*s_etat_processus).at_exit, 'E') == @@ -2033,6 +2019,11 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).erreur_execution = d_ex_erreur_evaluation; } + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } } } } @@ -2049,11 +2040,18 @@ instruction_detach(struct_processus *s_e } else { - if (((*s_etat_processus).var_volatile_alarme == 0) - && ((*s_etat_processus).arret_depuis_abort == 0) + if (((*s_etat_processus).arret_depuis_abort == 0) && ((*s_etat_processus).at_exit != NULL)) { (*s_etat_processus).var_volatile_requete_arret = 0; + (*s_etat_processus).var_volatile_alarme = 0; + (*s_etat_processus).var_volatile_traitement_sigint + = 0; + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, "ATEXIT"); + } if (evaluation(s_etat_processus, (*s_etat_processus).at_exit, 'E') == @@ -2062,6 +2060,11 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).erreur_execution = d_ex_erreur_evaluation; } + + if ((*s_etat_processus).profilage == d_vrai) + { + profilage(s_etat_processus, NULL); + } } } @@ -2398,7 +2401,7 @@ instruction_detach(struct_processus *s_e .var_volatile_traitement_retarde_stop; (*s_etat_processus).var_volatile_traitement_retarde_stop = 1; - for(i = 0; i < (unsigned long) (*(*((struct_processus_fils *) + for(i = 0; i < (*(*((struct_processus_fils *) (*(*l_element_courant) .donnee).objet)).thread).nombre_objets_dans_pipe; i++) { @@ -2598,6 +2601,16 @@ instruction_detach(struct_processus *s_e l_element_statique_courant = l_element_statique_suivant; } + l_element_partage_courant = (*(*s_etat_processus) + .l_liste_variables_partagees); + + while(l_element_partage_courant != NULL) + { + l_element_partage_suivant = (*l_element_partage_courant).suivant; + free(l_element_partage_courant); + l_element_partage_courant = l_element_partage_suivant; + } + if ((*s_etat_processus).entree_standard != NULL) { pclose((*s_etat_processus).entree_standard); @@ -2622,30 +2635,12 @@ instruction_detach(struct_processus *s_e (*s_etat_processus).instruction_derniere_erreur = NULL; } + liberation_arbre_variables_partagees(s_etat_processus, + (*(*s_etat_processus).s_arbre_variables_partagees)); liberation_arbre_variables(s_etat_processus, (*s_etat_processus).s_arbre_variables, d_vrai); free((*s_etat_processus).pointeurs_caracteres_variables); - for(i = 0; i < (*(*s_etat_processus).s_liste_variables_partagees) - .nombre_variables; i++) - { - liberation(s_etat_processus, - (*(*s_etat_processus).s_liste_variables_partagees) - .table[i].objet); - free((*(*s_etat_processus).s_liste_variables_partagees) - .table[i].nom); - } - - if ((*(*s_etat_processus).s_liste_variables_partagees).table - != NULL) - { - free((struct_variable_partagee *) - (*(*s_etat_processus).s_liste_variables_partagees).table); - } - - pthread_mutex_destroy(&((*(*s_etat_processus) - .s_liste_variables_partagees).mutex)); - l_element_courant = (*s_etat_processus).l_base_pile; while(l_element_courant != NULL) {