--- rpl/src/instructions_t2.c 2010/03/09 10:18:49 1.6 +++ rpl/src/instructions_t2.c 2011/06/21 07:45:27 1.27 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.13 - Copyright (C) 1989-2010 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.0.prerelease.1 + Copyright (C) 1989-2011 Dr. BERTRAND Joël This file is part of RPL/2. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -109,18 +109,17 @@ 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 { @@ -132,13 +131,10 @@ instruction_trn(struct_processus *s_etat } 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) == d_faux) { if (pthread_mutex_unlock(&((*(*s_etat_processus) .s_liste_variables_partagees).mutex)) != 0) @@ -473,8 +469,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,10 +493,6 @@ 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; @@ -545,70 +536,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 +573,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)) @@ -857,6 +812,7 @@ instruction_time(struct_processus *s_eta * Lecture des différents temps */ +# ifndef OS2 if ((getrusage(RUSAGE_SELF, &s_usage_processus_pere)) != 0) { (*s_etat_processus).erreur_systeme = d_es_processus; @@ -868,6 +824,16 @@ instruction_time(struct_processus *s_eta (*s_etat_processus).erreur_systeme = d_es_processus; return; } +# else + s_usage_processus_pere.ru_utime.tv_sec = 0; + s_usage_processus_pere.ru_utime.tv_usec = 0; + s_usage_processus_pere.ru_stime.tv_sec = 0; + s_usage_processus_pere.ru_stime.tv_usec = 0; + s_usage_processus_fils.ru_utime.tv_sec = 0; + s_usage_processus_fils.ru_utime.tv_usec = 0; + s_usage_processus_fils.ru_stime.tv_sec = 0; + s_usage_processus_fils.ru_stime.tv_usec = 0; +# endif /* * Initialisation de la liste @@ -1819,8 +1785,6 @@ instruction_target(struct_processus *s_e struct_objet *s_objet_argument_1; struct_objet *s_objet_argument_2; - unsigned char *nom; - unsigned long i; unsigned long nombre_elements; @@ -2154,6 +2118,7 @@ instruction_target(struct_processus *s_e else if ((*((struct_socket *) (*s_objet_argument_1).objet)) .domaine == PF_INET6) { // Résolution du nom en IPv6 +# ifdef IPV6 resolution_courante = resolution; while(resolution_courante != NULL) @@ -2201,6 +2166,18 @@ instruction_target(struct_processus *s_e (*resolution_courante).ai_addr)).sin6_addr .s6_addr[i]); } +# else + if ((*s_etat_processus).langue == 'F') + { + printf("+++Attention : Support du protocole" + " IPv6 indisponible\n"); + } + else + { + printf("+++Warning : IPv6 support " + "unavailable\n"); + } +# endif } else {