--- rpl/src/instructions_a5.c 2010/04/21 13:45:46 1.7 +++ rpl/src/instructions_a5.c 2020/01/10 11:15:43 1.72 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.0.15 - Copyright (C) 1989-2010 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. @@ -20,7 +20,7 @@ */ -#include "rpl.conv.h" +#include "rpl-conv.h" /* @@ -43,6 +43,8 @@ instruction_alarm(struct_processus *s_et int code_retour; int erreur; + integer8 nombre_elements; + logical1 specification_date; struct_liste_chainee *l_element_courant; @@ -63,8 +65,6 @@ instruction_alarm(struct_processus *s_et time_t alarme; - unsigned long nombre_elements; - (*s_etat_processus).erreur_execution = d_ex; if ((*s_etat_processus).affichage_arguments == 'Y') @@ -153,10 +153,10 @@ instruction_alarm(struct_processus *s_et s_time_actuel = localtime(&(st.time)); l_element_courant = (*s_objet_argument).objet; - s_time_alarme.tm_hour = (*((integer8 *) (*(*l_element_courant) + s_time_alarme.tm_hour = (int) (*((integer8 *) (*(*l_element_courant) .donnee).objet)); l_element_courant = (*l_element_courant).suivant; - s_time_alarme.tm_min = (*((integer8 *) (*(*l_element_courant) + s_time_alarme.tm_min = (int) (*((integer8 *) (*(*l_element_courant) .donnee).objet)); l_element_courant = (*l_element_courant).suivant; @@ -164,7 +164,7 @@ instruction_alarm(struct_processus *s_et if (l_element_courant != NULL) { - s_time_alarme.tm_sec = (*((integer8 *) (*(*l_element_courant) + s_time_alarme.tm_sec = (int) (*((integer8 *) (*(*l_element_courant) .donnee).objet)); l_element_courant = (*l_element_courant).suivant; @@ -172,21 +172,21 @@ instruction_alarm(struct_processus *s_et { specification_date = d_vrai; - s_time_alarme.tm_mday = (*((integer8 *) (*(*l_element_courant) - .donnee).objet)); + s_time_alarme.tm_mday = (int) (*((integer8 *) + (*(*l_element_courant).donnee).objet)); l_element_courant = (*l_element_courant).suivant; if (l_element_courant != NULL) { - s_time_alarme.tm_mon = (*((integer8 *) - (*(*l_element_courant).donnee).objet)) - 1; + s_time_alarme.tm_mon = (int) ((*((integer8 *) + (*(*l_element_courant).donnee).objet)) - 1); l_element_courant = (*l_element_courant).suivant; if (l_element_courant != NULL) { - s_time_alarme.tm_year = (*((integer8 *) + s_time_alarme.tm_year = (int) ((*((integer8 *) (*(*l_element_courant).donnee).objet)) - - 1900; + - 1900); l_element_courant = (*l_element_courant).suivant; } else @@ -215,6 +215,7 @@ instruction_alarm(struct_processus *s_et s_time_alarme.tm_year = (*s_time_actuel).tm_year; } + s_time_alarme.tm_isdst = -1; s_time_registre = s_time_alarme; alarme = mktime(&s_time_alarme); @@ -247,8 +248,8 @@ instruction_alarm(struct_processus *s_et alarme = mktime(&s_time_alarme); } - attente.tv_nsec = (long) ((duree - (attente.tv_sec = - (long) floor(duree))) * 1000000000); + attente.tv_nsec = (long) ((duree - (double) (attente.tv_sec = + (time_t) floor(duree))) * 1000000000); if ((*s_etat_processus).profilage == d_vrai) { @@ -271,11 +272,25 @@ instruction_alarm(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) { traitement_interruptions_logicielles(s_etat_processus); @@ -336,6 +351,166 @@ instruction_alarm(struct_processus *s_et } liberation(s_etat_processus, s_objet_argument); + return; +} + + +/* +================================================================================ + Fonction 'atexit' +================================================================================ + Entrées : +-------------------------------------------------------------------------------- + Sorties : +-------------------------------------------------------------------------------- + Effets de bord : néant +================================================================================ +*/ + +void +instruction_atexit(struct_processus *s_etat_processus) +{ + struct_objet *s_objet_argument; + + (*s_etat_processus).erreur_execution = d_ex; + + if ((*s_etat_processus).affichage_arguments == 'Y') + { + printf("\n ATEXIT "); + + if ((*s_etat_processus).langue == 'F') + { + printf("(exécution d'une fonction à la sortie d'une tâche)\n\n"); + } + else + { + printf("(register a function to be called on task exit)\n\n"); + } + + printf(" 1: %s, %s\n", d_NOM, d_RPN); + + return; + } + else if ((*s_etat_processus).test_instruction == 'Y') + { + (*s_etat_processus).nombre_arguments = 1; + return; + } + + if (test_cfsf(s_etat_processus, 31) == d_vrai) + { + if (empilement_pile_last(s_etat_processus, 1) == d_erreur) + { + return; + } + } + + if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile), + &s_objet_argument) == d_erreur) + { + (*s_etat_processus).erreur_execution = d_ex_manque_argument; + return; + } + + if ((*s_objet_argument).type == NOM) + { + liberation(s_etat_processus, (*s_etat_processus).at_exit); + (*s_etat_processus).at_exit = s_objet_argument; + } + else if ((*s_objet_argument).type == RPN) + { + liberation(s_etat_processus, (*s_etat_processus).at_exit); + (*s_etat_processus).at_exit = s_objet_argument; + } + else + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = d_ex_erreur_type_argument; + return; + } + + return; +} + + +/* +================================================================================ + Fonction 'atpoke' +================================================================================ + Entrées : +-------------------------------------------------------------------------------- + Sorties : +-------------------------------------------------------------------------------- + Effets de bord : néant +================================================================================ +*/ + +void +instruction_atpoke(struct_processus *s_etat_processus) +{ + struct_objet *s_objet_argument; + + (*s_etat_processus).erreur_execution = d_ex; + + if ((*s_etat_processus).affichage_arguments == 'Y') + { + printf("\n ATPOKE "); + + if ((*s_etat_processus).langue == 'F') + { + printf("(exécution d'une fonction lors de l'injection " + "d'une donnée)\n\n"); + } + else + { + printf("(register a function to be called on data injection)\n\n"); + } + + printf(" 1: %s, %s\n", d_NOM, d_RPN); + + return; + } + else if ((*s_etat_processus).test_instruction == 'Y') + { + (*s_etat_processus).nombre_arguments = 1; + return; + } + + if (test_cfsf(s_etat_processus, 31) == d_vrai) + { + if (empilement_pile_last(s_etat_processus, 1) == d_erreur) + { + return; + } + } + + if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile), + &s_objet_argument) == d_erreur) + { + (*s_etat_processus).erreur_execution = d_ex_manque_argument; + return; + } + + if ((*s_objet_argument).type == NOM) + { + liberation(s_etat_processus, (*s_etat_processus).at_poke); + (*s_etat_processus).at_poke = s_objet_argument; + } + else if ((*s_objet_argument).type == RPN) + { + liberation(s_etat_processus, (*s_etat_processus).at_poke); + (*s_etat_processus).at_poke = s_objet_argument; + } + else + { + liberation(s_etat_processus, s_objet_argument); + + (*s_etat_processus).erreur_execution = d_ex_erreur_type_argument; + return; + } + + return; } // vim: ts=4