--- rpl/src/rpl.h 2013/03/16 11:31:41 1.207 +++ rpl/src/rpl.h 2015/01/27 14:18:09 1.258 @@ -1,7 +1,7 @@ /* ================================================================================ - RPL/2 (R) version 4.1.13 - Copyright (C) 1989-2013 Dr. BERTRAND Joël + RPL/2 (R) version 4.1.20 + Copyright (C) 1989-2015 Dr. BERTRAND Joël This file is part of RPL/2. @@ -19,6 +19,7 @@ ================================================================================ */ + #ifndef INCLUSION_RPL #define INCLUSION_RPL @@ -55,6 +56,10 @@ # define sched_yield(arg) #endif +#ifdef CYGWIN +# define SA_ONSTACK 0 +#endif + /* ================================================================================ @@ -72,6 +77,7 @@ #include #include #include +#include #ifndef RPLARGS # include @@ -153,7 +159,6 @@ # endif # include -# include # include # include # include @@ -163,6 +168,7 @@ # include "readline.h" # include "termcap.h" # include "iconv.h" +# include "zlib.h" # include "openssl/evp.h" # ifndef OPENSSL_NO_MD2 @@ -222,7 +228,7 @@ # include #endif -// Définition spécifique à Hurd +// Définition spécifique à Hurd #ifndef PIPE_BUF # define fpathconf (".", _PC_PIPE_BUF) #endif @@ -260,11 +266,11 @@ /* ================================================================================ - Bugs spécifiques + Bugs spécifiques ================================================================================ */ -// Néant +// Néant /* ================================================================================ @@ -286,17 +292,17 @@ enum signaux_rpl rpl_signull = 0, rpl_sigint, rpl_sigterm, - rpl_sigstart, // Signal envoyé par un père pour lancer son fils. - rpl_sigcont, // Signal de redémarrage d'un processus arrêté par + rpl_sigstart, // Signal envoyé par un père pour lancer son fils. + rpl_sigcont, // Signal de redémarrage d'un processus arrêté par // SUSPEND - rpl_sigstop, // Signal d'arrêt envoyé par l'instruction STOP ou + rpl_sigstop, // Signal d'arrêt envoyé par l'instruction STOP ou // FUSE. (FSTOP) - rpl_sigabort, // Signal envoyé par l'instruction ABORT (à regrouper + rpl_sigabort, // Signal envoyé par l'instruction ABORT (à regrouper // avec FABORT) - rpl_sigurg, // Signal d'arrêt urgent - rpl_siginject, // Signal indiquant la présence d'une donnée à lire - // envoyée depuis le père - rpl_sigalrm, // Signal d'alarme (erreur système) depuis un fils + rpl_sigurg, // Signal d'arrêt urgent + rpl_siginject, // Signal indiquant la présence d'une donnée à lire + // envoyée depuis le père + rpl_sigalrm, // Signal d'alarme (erreur système) depuis un fils rpl_sighup, rpl_sigtstp, rpl_sigexcept, @@ -305,49 +311,42 @@ enum signaux_rpl #define LONGUEUR_QUEUE_SIGNAUX 1024 -// Une structure s_queue_signaux est créée par processus (et non par thread). -// Elle est projetée dans un segment de mémoire partagée pour qu'elle soit -// accessible à la fois du père et des fils. +// Une structure s_queue_signaux est créée par processus (et non par thread). +// Elle est projetée dans un segment de mémoire partagée pour qu'elle soit +// accessible à la fois du père et des fils. #ifndef RPLARGS typedef struct queue_signaux { -# ifndef IPCS_SYSV -# ifndef SEMAPHORES_NOMMES - sem_t semaphore; - sem_t signalisation; -# endif -# else - sem_t semaphore; - sem_t signalisation; -# endif - volatile int pointeur_lecture; volatile int pointeur_ecriture; - pthread_t thread_signaux; volatile logical1 requete_arret; + pthread_t thread_signaux; + volatile struct { pid_t pid; enum signaux_rpl signal; } queue[LONGUEUR_QUEUE_SIGNAUX]; + +# ifdef OS2 + sem_t semaphore; + sem_t signalisation; + sem_t arret_signalisation; +# endif } struct_queue_signaux; -__EXTERN__ struct_queue_signaux *s_queue_signaux; -__EXTERN__ int f_queue_signaux; +__EXTERN__ struct_queue_signaux *s_queue_signaux; +__EXTERN__ int f_queue_signaux; -# ifdef SEMAPHORES_NOMMES - __EXTERN__ sem_t *semaphore_queue_signaux; - __EXTERN__ sem_t *semaphore_signalisation; +# ifndef OS2 + __EXTERN__ sem_t *semaphore_queue_signaux; + __EXTERN__ sem_t *semaphore_signalisation; + __EXTERN__ sem_t *semaphore_arret_signalisation; # endif #endif -#ifdef OS2 -# define readline(s) readline_wrapper(s) - unsigned char *readline_wrapper(unsigned char *s); -#endif - #if ! defined(UNION_SEMUN) && defined(IPCS_SYSV) union semun { @@ -366,23 +365,67 @@ union semun # define SIGSTKSZ 65536 #endif + /* ================================================================================ - SÉMAPHORES + SÉMAPHORES ================================================================================ */ #ifdef IPCS_SYSV +# ifdef DEBUG_SEMAPHORES +# define sem_wait(a) ({ int value; sem_getvalue(a, &value); \ + uprintf("[%d-%llu] Semaphore %s (%p) "\ + "waiting at %s() " \ + "line #%d\n", (int) getpid(), (unsigned long long) i\ + pthread_self(), \ + #a, a, __FUNCTION__, __LINE__), fflush(stdout); \ + if (value > 1) BUG(1, uprintf("Value %d\n", value)); \ + sem_wait_SysV(a); }) +# define sem_post(a) ({ int value; sem_getvalue(a, &value); \ + uprintf("[%d-%llu] Semaphore %s (%p) "\ + "posting at %s() " \ + "line #%d\n", (int) getpid(), (unsigned long long) \ + pthread_self(), \ + #a, a, __FUNCTION__, __LINE__), fflush(stdout); \ + if (value > 0) BUG(1, uprintf("Value %d\n", value)); \ + sem_post_SysV(a); }) +# define sem_destroy(a) ({ int value; sem_getvalue(a, &value); \ + if (value == 0) BUG(1, uprintf("Value %d\n", value)); \ + sem_destroy_SysV(a); }) +# else +# define sem_destroy(a) sem_destroy_SysV(a) +# define sem_wait(a) sem_wait_SysV(a) +# define sem_post(a) sem_post_SysV(a) +# endif + # define sem_init(a, b, c) sem_init_SysV(a, b, c) -# define sem_destroy(a) sem_destroy_SysV(a) -# define sem_wait(a) sem_wait_SysV(a) # define sem_trywait(a) sem_trywait_SysV(a) # define sem_timedwait(a, b) sem_timedwait_SysV(a, b) -# define sem_post(a) sem_post_SysV(a) # define sem_getvalue(a, b) sem_getvalue_SysV(a, b) # define sem_open(...) sem_open_SysV(__VA_ARGS__) # define sem_close(a) sem_close_SysV(a) # define sem_unlink(a) sem_unlink_SysV(a) +#else +# ifdef DEBUG_SEMAPHORES +# define sem_wait(a) ({ int value; sem_getvalue(a, &value); \ + uprintf("[%d-%llu] Semaphore %s (%p) "\ + "waiting at %s() " \ + "line #%d\n", (int) getpid(), (unsigned long long) \ + pthread_self(), \ + #a, a, __FUNCTION__, __LINE__), fflush(stdout); \ + if (value > 1) BUG(1, uprintf("Value %d\n", value)); sem_wait(a); }) +# define sem_post(a) ({ int value; sem_getvalue(a, &value); \ + uprintf("[%d-%llu] Semaphore %s (%p) "\ + "posting at %s() " \ + "line #%d\n", (int) getpid(), (unsigned long long) \ + pthread_self(), \ + #a, a, __FUNCTION__, __LINE__), fflush(stdout); \ + if (value > 0) BUG(1, uprintf("Value %d\n", value)); sem_post(a); }) +# define sem_destroy(a) ({ int value; sem_getvalue(a, &value); \ + if (value == 0) BUG(1, uprintf("Value %d\n", value)); \ + sem_destroy(a); }) +# endif #endif @@ -394,12 +437,12 @@ union semun #ifndef RPLARGS -// Signaux utilisés par défaut : +// Signaux utilisés par défaut : // SIGINT // SIGTSTP // SIGCONT // SIGPIPE -// SIGUSR1 et SIGUSR2 sont utilisé par libsigsegv. +// SIGUSR1 et SIGUSR2 sont utilisé par libsigsegv. // SIGHUP // SIGALRM @@ -411,7 +454,7 @@ union semun /* ================================================================================ - Granularité temporelle + Granularité temporelle ================================================================================ */ @@ -453,9 +496,6 @@ union semun #ifndef RPLARGS # ifdef SEMAPHORES_NOMMES # define LONGUEUR_NOM_SEMAPHORE 64 -# endif - -# ifdef SEMAPHORES_NOMMES # define __PTR__ * # else # define __PTR__ @@ -471,40 +511,34 @@ union semun __EXTERN__ pid_t pid_processus_pere; -# ifdef SEMAPHORES_NOMMES - __EXTERN__ pthread_mutex_t mutex_sem __STATIC_MUTEX_INITIALIZATION__; -# endif - __EXTERN__ pthread_mutex_t mutex_liste_threads __STATIC_MUTEX_INITIALIZATION__; - __EXTERN__ pthread_mutex_t mutex_gestionnaires_signaux_atomique - __STATIC_MUTEX_INITIALIZATION__; __EXTERN__ pthread_mutex_t mutex_creation_variable_partagee __STATIC_MUTEX_INITIALIZATION__; __EXTERN__ pthread_mutex_t mutex_sections_critiques; __EXTERN__ pthread_mutex_t mutex_liste_variables_partagees; - - __EXTERN__ sem_t __PTR__ semaphore_gestionnaires_signaux; + __EXTERN__ pthread_mutex_t mutex_sem __STATIC_MUTEX_INITIALIZATION__; __EXTERN__ volatile int routine_recursive; -#endif -#ifdef SEMAPHORES_NOMMES -#define SEM_FORK 0 -#define SEM_QUEUE 1 -#define SEM_SIGNAUX 2 -#define SEM_SIGNALISATION 3 -sem_t *sem_init2(unsigned int valeur, pid_t pid, int ordre); -sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid, int ordre); -int sem_destroy2(sem_t *semaphore_p, pid_t pid, int ordre); -int sem_destroy3(sem_t *semaphore_p, pid_t pid, pthread_t tid, int ordre); -int sem_getvalue2(sem_t *semaphore, int *valeur); -sem_t *sem_open2(pid_t pid, int ordre); +# define SEM_FORK 0 +# define SEM_QUEUE 1 +# define SEM_SIGNALISATION 2 +# define SEM_ARRET_SIGNALISATION 3 + + sem_t *sem_init2(unsigned int valeur, pid_t pid, int ordre); + sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid, int ordre); + int sem_destroy2(sem_t *semaphore_p, pid_t pid, int ordre); + int sem_destroy3(sem_t *semaphore_p, pid_t pid, pthread_t tid, int ordre); + int sem_getvalue2(sem_t *semaphore, int *valeur); + sem_t *sem_open2(pid_t pid, int ordre); +#endif -// Le mutex est là uniquement pour pouvoir émuler le comportement -// de sem_getvalue() sur un système comme MacOS X qui ne possède pas +// Le mutex est là uniquement pour pouvoir émuler le comportement +// de sem_getvalue() sur un système comme MacOS X qui ne possède pas // cette fonction. +#ifdef Darwin #define sem_getvalue(semaphore, value) sem_getvalue2(semaphore, value) #define sem_post(semaphore) \ ({ int r; pthread_mutex_lock(&mutex_sem); \ @@ -523,17 +557,15 @@ sem_t *sem_open2(pid_t pid, int ordre); ================================================================================ */ -// Par défaut, tout est redirigé vers stderr sauf indication explicite de +// Par défaut, tout est redirigé vers stderr sauf indication explicite de // stdout. #define printf(...) transliterated_fprintf(s_etat_processus, \ stderr, __VA_ARGS__) #define fprintf(flux, ...) transliterated_fprintf(s_etat_processus, \ flux, __VA_ARGS__) -#define uprintf(...) transliterated_fprintf(NULL, \ - stderr, __VA_ARGS__) -#define ufprintf(flux, ...) transliterated_fprintf(NULL, \ - flux, __VA_ARGS__) +#define uprintf(...) std_fprintf(stderr, __VA_ARGS__) +#define ufprintf(flux, ...) std_fprintf(flux, __VA_ARGS__) #ifdef SunOS # define fopen(...) ({ FILE *desc; \ @@ -555,8 +587,8 @@ sem_t *sem_open2(pid_t pid, int ordre); # define fflush(flux) fflush((flux == stdout) ? stderr : flux) #endif -// Ajout d'un timeout sur les fonctions pipe() pour éviter une erreur -// système dans le cas où l'on a atteint le nombre maximale de fichiers +// Ajout d'un timeout sur les fonctions pipe() pour éviter une erreur +// système dans le cas où l'on a atteint le nombre maximale de fichiers // ouverts. #define pipe(descripteurs) \ @@ -575,14 +607,14 @@ sem_t *sem_open2(pid_t pid, int ordre); erreur; \ }) -// Redéfinition de abs pour un fonctionnement en entier de type long long int +// Redéfinition de abs pour un fonctionnement en entier de type long long int #ifdef __GNUC__ # define abs(i) ({ typeof(i) _i; _i = (i); (_i >= 0) ? _i : -_i; }) -// typeof() est une extension de gcc, mais est présent sur d'autres compilateurs -// comme Sun Studio. Dans le cas où typeof() n'existe pas, il est possible -// d'utiliser la macro suivante, mais elle possède un effet de bord dû à -// l'évaluation multiple de l'argument. +// typeof() est une extension de gcc, mais est présent sur d'autres compilateurs +// comme Sun Studio. Dans le cas où typeof() n'existe pas, il est possible +// d'utiliser la macro suivante, mais elle possède un effet de bord dû à +// l'évaluation multiple de l'argument. #else # define abs(i) (((i) >= 0) ? (i) : (-i)) #endif @@ -615,7 +647,7 @@ sem_t *sem_open2(pid_t pid, int ordre); { \ for(i = 0; i < nb; i++) \ uprintf(" %s\n", appels[i]); \ - free(appels); \ + sys_free(appels); \ } \ else \ uprintf("Nullified backtrace\n"); \ @@ -689,23 +721,6 @@ pid_t debug_fork(); pthread_mutex_unlock(mutex) #endif -#ifdef DEBUG_SEMAPHORES -#define sem_wait(a) ({ int value; sem_getvalue(a, &value); \ - uprintf("[%d-%llu] Semaphore %s (%p) "\ - "waiting at %s() " \ - "line #%d\n", (int) getpid(), (unsigned long long) pthread_self(), \ - #a, a, __FUNCTION__, __LINE__), fflush(stdout); \ - if (value > 1) BUG(1, uprintf("Value %d\n", value)); sem_wait(a); }) -#define sem_post(a) ({ int value; sem_getvalue(a, &value); \ - uprintf("[%d-%llu] Semaphore %s (%p) "\ - "posting at %s() " \ - "line #%d\n", (int) getpid(), (unsigned long long) pthread_self(), \ - #a, a, __FUNCTION__, __LINE__), fflush(stdout); \ - if (value > 0) BUG(1, uprintf("Value %d\n", value)); sem_post(a); }) -#define sem_destroy(a) ({ int value; sem_getvalue(a, &value); \ - if (value == 0) BUG(1, uprintf("Value %d\n", value)); sem_destroy(a); }) -#endif - /* ================================================================================ @@ -757,7 +772,7 @@ pid_t debug_fork(); /* -------------------------------------------------------------------------------- - Paramètres du système + Paramètres du système -------------------------------------------------------------------------------- */ @@ -776,7 +791,7 @@ pid_t debug_fork(); /* -------------------------------------------------------------------------------- - Erreurs système + Erreurs système -------------------------------------------------------------------------------- */ @@ -802,7 +817,7 @@ pid_t debug_fork(); #endif -// -1 : erreur provoquée par une bibliothèque externe +// -1 : erreur provoquée par une bibliothèque externe #ifndef RPLARGS # define d_es 2000 # define d_es_allocation_memoire __erreur(2001) @@ -868,11 +883,11 @@ pid_t debug_fork(); /* -------------------------------------------------------------------------------- - Erreurs à l'exécution + Erreurs à l'exécution -------------------------------------------------------------------------------- */ -// -1 : erreur provoquée par une bibliothèque externe +// -1 : erreur provoquée par une bibliothèque externe #ifndef RPLARGS # define d_ex 0 # define d_ex_pile_vide __erreur(1) @@ -1024,19 +1039,19 @@ enum t_type { ADR = 0, ALG, BIN, CHN, C SLB, SPH, SQL, TBL, VCX, VIN, VRL }; /* - ADR : adresse sur 32 bits (au moins) non signés (unsigned long) - Adresse d'une définition à interpréter. + ADR : adresse sur 64 bits signés. + Adresse d'une définition à interpréter. - ALG : expression algébrique (struct_liste_chainee *) - La liste chaînée contient la définition convertie en notation - polonaise inversée. Ce type diffère du type 'RPN' au niveau - du format de sortie (notation algébrique). + ALG : expression algébrique (struct_liste_chainee *) + La liste chaînée contient la définition convertie en notation + polonaise inversée. Ce type diffère du type 'RPN' au niveau + du format de sortie (notation algébrique). BIN : entier binaire sur 64 bits (unsigned integer8 *) Sans objet. Type C/Fortran : unsigned integer8 - CHN : chaine de caracteres (character*(*), unsigned char *) + CHN : chaine de caracteres (unsigned char *) Sans objet. CPL : complexe sur 2*64 bits (complex*16, struct_complexe16 *) @@ -1045,8 +1060,8 @@ enum t_type { ADR = 0, ALG, BIN, CHN, C FCH : descripteur de fichier (struct_fichier *). - FCT : déclaration d'une fonction et de son nombre d'arguments - (struct_fonction *). Ce type n'est nécessaire que dans le + FCT : déclaration d'une fonction et de son nombre d'arguments + (struct_fonction *). Ce type n'est nécessaire que dans le traitement des types 'ALG' et 'RPN'. INT : entier sur 64 bits (integer*8, integer8 *) @@ -1054,10 +1069,10 @@ enum t_type { ADR = 0, ALG, BIN, CHN, C Type C/Fortran : integer8 LST : liste (struct_liste_chainee *) - Les objets sont enregistrés sous forme de liste chaînée récursive. - Cela permet de traiter des tableaux de données hétérogènes de - grandes dimensions. Le nombre de dimensions maximal est fixé par - la mémoire de la station. + Les objets sont enregistrés sous forme de liste chaînée récursive. + Cela permet de traiter des tableaux de données hétérogènes de + grandes dimensions. Le nombre de dimensions maximal est fixé par + la mémoire de la station. MCX : matrice de complexes (struct_matrice *) Sans objet. @@ -1081,17 +1096,17 @@ enum t_type { ADR = 0, ALG, BIN, CHN, C Sans objet. RPN : definition (struct_liste_chainee *) - Ce type diffère du type 'ALG' au niveau du format de sortie - (notation polonaise inversée). + Ce type diffère du type 'ALG' au niveau du format de sortie + (notation polonaise inversée). SCK : socket (struct_socket *) - SLB : bibliothèque dynamique partagée (struct_bibliotheque *) + SLB : bibliothèque dynamique partagée (struct_bibliotheque *) Sans objet. - SPH : sémaphore nommé (struct_semaphore *) + SPH : sémaphore nommé (struct_semaphore *) - SQL : connecteur sur une base de données SQL (struct_connecteur_sql *) + SQL : connecteur sur une base de données SQL (struct_connecteur_sql *) TBL : tableau multidimensionnel d'objets (struct_tableau *). @@ -1126,7 +1141,7 @@ typedef struct objet #ifndef RPLARGS typedef struct fichier { - unsigned long descripteur; + int descripteur; unsigned char acces; /* S/D/I */ unsigned char binaire; /* Y/N/F */ @@ -1161,7 +1176,7 @@ typedef struct rpl_mutex /* -------------------------------------------------------------------------------- - Structure sémaphore + Structure sémaphore -------------------------------------------------------------------------------- */ @@ -1193,7 +1208,7 @@ typedef struct marque /* -------------------------------------------------------------------------------- - Structure bibliothèque + Structure bibliothèque -------------------------------------------------------------------------------- */ @@ -1219,7 +1234,7 @@ typedef struct bibliotheque #ifndef RPLARGS typedef struct descripteur_fichier { - unsigned long identifiant; + int identifiant; unsigned char effacement; unsigned char type; // C (file *) ou S (sqlite *) @@ -1318,7 +1333,7 @@ typedef struct socket /* -------------------------------------------------------------------------------- - Structure liste chaînee + Structure liste chaînee -------------------------------------------------------------------------------- */ @@ -1343,8 +1358,8 @@ typedef struct gestion_signaux unsigned char masque_signaux[d_NOMBRE_SIGNAUX]; /* - * 'I' : signal ignoré - * 'Q' : signal mis en queue pour un traitement ultérieur + * 'I' : signal ignoré + * 'Q' : signal mis en queue pour un traitement ultérieur * 'N' : traitement normal du signal */ @@ -1392,7 +1407,7 @@ typedef struct liste_profilage2 /* -------------------------------------------------------------------------------- - Structure contenant les fichiers graphiques (liste chaînée) + Structure contenant les fichiers graphiques (liste chaînée) -------------------------------------------------------------------------------- */ @@ -1424,7 +1439,7 @@ typedef struct nom { unsigned char *nom; logical1 symbole; /* d_vrai/d_faux */ - // symbole == d_vrai signifie que le nom a été introduit dans un + // symbole == d_vrai signifie que le nom a été introduit dans un // calcul sans les apostrophes. } struct_nom; @@ -1458,8 +1473,10 @@ typedef struct descripteur_thread int pipe_injections[2]; int pipe_nombre_injections[2]; int pipe_interruptions[2]; - int pipe_nombre_objets_attente[2]; - int pipe_nombre_interruptions_attente[2]; + // pipe_nombre_elements_attente == 0 => initialisation ou terminaison + // pipe_nombre_elements_attente == 1 => objet en attente + // pipe_nombre_elements_attente == 2 => interruption en attente + int pipe_nombre_elements_attente[2]; int pipe_acquittement[2]; volatile integer8 nombre_objets_dans_pipe; @@ -1504,7 +1521,7 @@ typedef struct liste_pile_systeme clause : I : IF R : IFERR - X : IFERR indiquant la présence d'une erreur. + X : IFERR indiquant la présence d'une erreur. T : THEN E : ELSE Z : traitement en cours de ELSE @@ -1513,8 +1530,8 @@ typedef struct liste_pile_systeme W : WHILE M : WHILE avec une clause fausse. S : SELECT - K : aucun cas CASE n'a encore été traité. - C : au moins un cas de SELECT...CASE a été traité. + K : aucun cas CASE n'a encore été traité. + C : au moins un cas de SELECT...CASE a été traité. Q : traitement en cours d'un cas CASE. F : traitement du cas DEFAULT */ @@ -1525,7 +1542,7 @@ typedef struct liste_pile_systeme unsigned char type_cloture; /* - type clôture : + type clôture : C SELECT : END termine un test SELECT/DEFAULT/END. D DO : END termine une boucle DO/UNTIL/END. I IF : END termine un test IF/THEN (ELSE)/END. @@ -1536,14 +1553,14 @@ typedef struct liste_pile_systeme F FOR : NEXT ou STEP termine une boucle avec compteur. S START : NEXT ou STEP termine une boucle sans compteur. - L LOOP : boucle utilisé dans le traitement de l'instruction RETURN. - Elle correspond à une boucle FOR ou START mais sans son + L LOOP : boucle utilisé dans le traitement de l'instruction RETURN. + Elle correspond à une boucle FOR ou START mais sans son initialisation. A FORALL : NEXT termine une boucle sur un objet. */ - unsigned long adresse_retour; - unsigned long niveau_courant; + integer8 adresse_retour; + integer8 niveau_courant; struct_liste_chainee *pointeur_objet_retour; } struct_liste_pile_systeme; #endif @@ -1558,7 +1575,7 @@ typedef struct liste_pile_systeme #ifndef RPLARGS typedef union position_variable { - unsigned long adresse; + integer8 adresse; struct_objet *pointeur; } union_position_variable; @@ -1567,7 +1584,7 @@ typedef struct variable unsigned char *nom; unsigned char origine; // P(rogramme) ou E(valuation) - unsigned long niveau; + integer8 niveau; union_position_variable variable_statique; union_position_variable variable_partagee; @@ -1581,7 +1598,7 @@ typedef struct variable /* -------------------------------------------------------------------------------- - Structure variable partagée + Structure variable partagée -------------------------------------------------------------------------------- */ @@ -1592,7 +1609,7 @@ typedef struct variable_partage unsigned char *nom; unsigned char origine; - unsigned long niveau; + integer8 niveau; union_position_variable variable_partagee; @@ -1616,10 +1633,10 @@ typedef struct variable_statique unsigned char *nom; unsigned char origine; - // Position de création de la variable statique dans le programme ou dans + // Position de création de la variable statique dans le programme ou dans // l'expression. 'origine' vaut 'P' pour programme ou 'E' pour expression. - unsigned long niveau; + integer8 niveau; union_position_variable variable_statique; @@ -1636,7 +1653,7 @@ typedef struct variable_statique typedef struct vecteur { - unsigned long taille; + integer8 taille; unsigned char type; /* C (complex*16), R (real*8), I (integer*8) */ @@ -1652,8 +1669,8 @@ typedef struct vecteur typedef struct matrice { - unsigned long nombre_lignes; - unsigned long nombre_colonnes; + integer8 nombre_lignes; + integer8 nombre_colonnes; unsigned char type; /* C (complex*16), R (real*8), I (integer*8) */ @@ -1669,7 +1686,7 @@ typedef struct matrice typedef struct tableau { - unsigned long nombre_elements; + integer8 nombre_elements; struct_objet **elements; } struct_tableau; @@ -1683,10 +1700,10 @@ typedef struct tableau typedef struct arbre { - struct_objet *objet; + struct_liste_chainee *feuille; - unsigned long nombre_feuilles; - struct arbre **feuilles; + integer8 nombre_branches; + struct arbre **branches; } struct_arbre; @@ -1724,8 +1741,8 @@ typedef struct rpl_arguments /* Traitement des erreurs */ unsigned char *message_erreur; - unsigned char type_erreur; /* S = système - E = exécution */ + unsigned char type_erreur; /* S = système + E = exécution */ integer8 erreur; /* Traitement des messages d'aide */ @@ -1749,7 +1766,7 @@ typedef struct rpl_arguments /* -------------------------------------------------------------------------------- - Structure d'arbre des instructions intrinsèques + Structure d'arbre des instructions intrinsèques -------------------------------------------------------------------------------- */ @@ -1771,11 +1788,11 @@ typedef struct instruction typedef struct arbre_variables { unsigned int noeuds_utilises; - // Nombre de noeuds utilisés dans le + // Nombre de noeuds utilisés dans le // tableau **noeuds signed int indice_tableau_pere; // Position de la structure dans le - // tableau **noeuds du père + // tableau **noeuds du père struct arbre_variables *noeud_pere; struct arbre_variables **noeuds; @@ -1787,11 +1804,11 @@ typedef struct arbre_variables typedef struct arbre_variables_partagees { unsigned int noeuds_utilises; - // Nombre de noeuds utilisés dans le + // Nombre de noeuds utilisés dans le // tableau **noeuds signed int indice_tableau_pere; // Position de la structure dans le - // tableau **noeuds du père + // tableau **noeuds du père struct arbre_variables_partagees *noeud_pere; struct arbre_variables_partagees **noeuds; @@ -1805,7 +1822,7 @@ typedef struct arbre_variables_partagees do { \ pthread_mutexattr_t attributs_mutex; \ pthread_mutexattr_init(&attributs_mutex); \ - pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); \ + pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE); \ pthread_mutex_init(&(mutex), &attributs_mutex); \ pthread_mutexattr_destroy(&attributs_mutex); \ } while(0) @@ -1814,26 +1831,27 @@ typedef struct tableau_variables { unsigned char origine; unsigned char *nom; // pointeur sur la struct_variable - // réelle et non copie de la chaîne - unsigned long niveau; + // réelle et non copie de la chaîne + integer8 niveau; struct_objet *objet; // pointeur sur l'objet et non copie // de l'objet. logical1 variable_verrouillee; logical1 variable_masquee; + pthread_mutex_t *mutex; union_position_variable variable_statique; union_position_variable variable_partagee; } struct_tableau_variables; -// La liste des variables est une liste doublement chaînée et circulaire. +// La liste des variables est une liste doublement chaînée et circulaire. typedef struct liste_variables { union { // Utilisation dans la gestion des variables struct_variable *variable; - // Utilisation dans la pile système (variables par niveau) + // Utilisation dans la pile système (variables par niveau) struct_liste_chainee *liste; }; @@ -1843,7 +1861,7 @@ typedef struct liste_variables struct liste_variables *precedent; } struct_liste_variables; -// La liste des variables statiques et une liste double chaînée et non +// La liste des variables statiques et une liste double chaînée et non // circulaire. typedef struct liste_variables_statiques { @@ -1866,6 +1884,42 @@ typedef struct liste_variables_partagees } struct_liste_variables_partagees; #endif + +/* +-------------------------------------------------------------------------------- + Structure fonction +-------------------------------------------------------------------------------- +*/ + +#ifndef RPLARGS +typedef struct fonction +{ + unsigned char *nom_fonction; + integer8 nombre_arguments; + + void (*fonction)(struct processus *); + + volatile struct_liste_chainee *prediction_saut; + volatile logical1 prediction_execution; +} struct_fonction; +#endif + + +/* +-------------------------------------------------------------------------------- + Structure buffer +-------------------------------------------------------------------------------- +*/ + +typedef struct buffer +{ + unsigned char *buffer; + + size_t longueur_requise; + int classe; +} struct_buffer; + + /* -------------------------------------------------------------------------------- Structure processus @@ -1904,8 +1958,8 @@ typedef struct processus unsigned char traitement_cycle_exit; /*N/E/C*/ unsigned char recherche_type; /*Y/N*/ - unsigned long position_courante; - unsigned long longueur_definitions_chainees; + integer8 position_courante; + integer8 longueur_definitions_chainees; /* Pointeurs sur les instructions */ @@ -1922,13 +1976,13 @@ typedef struct processus struct_liste_chainee *l_base_pile; struct_liste_chainee *l_base_pile_last; - unsigned long hauteur_pile_operationnelle; + integer8 hauteur_pile_operationnelle; /* Piles systemes */ struct_liste_pile_systeme *l_base_pile_systeme; - unsigned long hauteur_pile_systeme; + integer8 hauteur_pile_systeme; /* Gestion des processus */ @@ -1942,8 +1996,7 @@ typedef struct processus int pipe_injections; int pipe_nombre_injections; int pipe_interruptions; - int pipe_nombre_objets_attente; - int pipe_nombre_interruptions_attente; + int pipe_nombre_elements_attente; int nombre_objets_envoyes_non_lus; int nombre_objets_injectes; @@ -1969,13 +2022,13 @@ typedef struct processus /* Variables */ - // La liste des variables par niveau est doublement chaînée. - // À tout moment, elle pointe sur le niveau le plus haut existant et + // La liste des variables par niveau est doublement chaînée. + // À tout moment, elle pointe sur le niveau le plus haut existant et // l_liste_variable_par_niveau->precedent renvoie la liste des - // définitions. l_liste_variable_par_niveau->precedent->precedent pointe + // définitions. l_liste_variable_par_niveau->precedent->precedent pointe // sur la liste des variables globales. // - // À l'initialisation : + // À l'initialisation : // l_liste_variables_par_niveau->suivant == l_liste_variables_par_niveau // l_liste_variables_par_niveau->precedent == l_liste_variables_par_niveau @@ -1999,8 +2052,8 @@ typedef struct processus int *pointeurs_caracteres_variables; int nombre_caracteres_variables; - unsigned long niveau_courant; - unsigned long niveau_initial; + integer8 niveau_courant; + integer8 niveau_initial; logical1 creation_variables_statiques; logical1 creation_variables_partagees; @@ -2014,15 +2067,15 @@ typedef struct processus struct_liste_chainee *s_sockets; -/* Connecteurs aux bases de données */ +/* Connecteurs aux bases de données */ struct_liste_chainee *s_connecteurs_sql; -/* Bibliothèques dynamiques */ +/* Bibliothèques dynamiques */ struct_liste_chainee *s_bibliotheques; struct_instruction_externe *s_instructions_externes; - unsigned long nombre_instructions_externes; + integer8 nombre_instructions_externes; /* Fichier d'impression */ @@ -2172,23 +2225,23 @@ typedef struct processus /* Traitement des exceptions */ logical1 arret_si_exception; - unsigned int exception; - unsigned int derniere_exception; - unsigned int exception_processus_fils; + int exception; + int derniere_exception; + int exception_processus_fils; /* Traitement des erreurs */ - unsigned int erreur_compilation; - unsigned int erreur_execution; - unsigned int erreur_systeme; + int erreur_compilation; + volatile int erreur_execution; + volatile int erreur_systeme; struct_objet *s_objet_errone; struct_objet *s_objet_erreur; logical1 erreur_scrutation; - volatile unsigned int erreur_systeme_processus_fils; - unsigned int erreur_execution_processus_fils; + volatile int erreur_systeme_processus_fils; + int erreur_execution_processus_fils; pid_t pid_erreur_processus_fils; @@ -2196,13 +2249,13 @@ typedef struct processus integer8 derniere_erreur_fonction_externe; - unsigned int derniere_erreur_systeme; - unsigned int derniere_erreur_execution; - unsigned int derniere_erreur_evaluation; + int derniere_erreur_systeme; + int derniere_erreur_execution; + int derniere_erreur_evaluation; unsigned char *instruction_derniere_erreur; - unsigned long niveau_derniere_erreur; + integer8 niveau_derniere_erreur; logical1 core; logical1 invalidation_message_erreur; @@ -2210,7 +2263,7 @@ typedef struct processus /* Debug */ logical1 debug; - integer8 type_debug; + logical8 type_debug; logical1 debug_programme; logical1 execution_pas_suivant; logical1 traitement_instruction_halt; @@ -2220,8 +2273,8 @@ typedef struct processus unsigned char masque_interruptions[d_NOMBRE_INTERRUPTIONS]; /* - * 'I' : interruption ignorée - * 'Q' : interruption mise en queue pour un traitement ultérieur + * 'I' : interruption ignorée + * 'Q' : interruption mise en queue pour un traitement ultérieur * 'N' : traitement normal de l'interruption */ @@ -2243,7 +2296,7 @@ typedef struct processus /* Variables volatiles */ volatile sig_atomic_t var_volatile_alarme; - // Traitement de ctrl+C et des arrêts brutaux + // Traitement de ctrl+C et des arrêts brutaux volatile sig_atomic_t var_volatile_requete_arret; // Traitement de ctrl+Z volatile sig_atomic_t var_volatile_requete_arret2; @@ -2270,12 +2323,12 @@ typedef struct processus integer8 nombre_arguments; /* - * Il s'agit du nombre d'arguments utilisé pour l'évaluation - * des expressions algébriques. - * -1 : la fonction ne peut être dans un objet de type ALG. + * Il s'agit du nombre d'arguments utilisé pour l'évaluation + * des expressions algébriques. + * -1 : la fonction ne peut être dans un objet de type ALG. * -2 : nombre d'arguments inconnu - * 0 : la fonction doit apparaître en notation infixe - * >0 : la fonction apparaît comme une fonction normale + * 0 : la fonction doit apparaître en notation infixe + * >0 : la fonction apparaît comme une fonction normale */ logical1 lancement_interactif; @@ -2285,7 +2338,7 @@ typedef struct processus unsigned char retour_routine_evaluation; unsigned char *localisation; - unsigned long niveau_recursivite; + integer8 niveau_recursivite; pid_t pid_processus_pere; pthread_t tid_processus_pere; @@ -2293,6 +2346,8 @@ typedef struct processus logical1 processus_detache; + enum t_type type_en_cours; + /* Profilage */ logical1 profilage; @@ -2301,9 +2356,10 @@ typedef struct processus struct_liste_profilage2 *pile_profilage_fonctions; struct timeval horodatage_profilage; - // Mutex spécifique au processus et donnant accès à la pile des processus - pthread_mutex_t mutex; pthread_mutex_t mutex_allocation; + pthread_mutex_t mutex_interruptions; + pthread_mutex_t mutex_pile_processus; + pthread_mutex_t mutex_signaux; // Mutex autorisant les fork() sem_t __PTR__ semaphore_fork; @@ -2314,99 +2370,88 @@ typedef struct processus pthread_mutex_t protection_liste_mutexes; unsigned int sections_critiques; -/* Drapeau nécessaire à RESTART */ +/* Variable d'initialisation pour SCHED */ + + logical1 initialisation_scheduler; + +/* Drapeau nécessaire à RESTART */ volatile logical1 requete_redemarrage; -/* Gestion optimisée de la mémoire */ +/* Gestion optimisée de la mémoire */ double estimation_taille_pile_tampon; - unsigned long taille_pile_tampon; + integer8 taille_pile_tampon; struct_liste_chainee *pile_tampon; double estimation_taille_pile_systeme_tampon; - unsigned long taille_pile_systeme_tampon; + integer8 taille_pile_systeme_tampon; struct_liste_pile_systeme *pile_systeme_tampon; - unsigned long taille_pile_objets; + integer8 taille_pile_objets; struct_objet *pile_objets; -# define TAILLE_CACHE 16384 - - unsigned long *objets_adr[TAILLE_CACHE]; - int pointeur_adr; - - logical8 *objets_bin[TAILLE_CACHE]; - int pointeur_bin; - - complex16 *objets_cpl[TAILLE_CACHE]; - int pointeur_cpl; - - struct fonction *objets_fct[TAILLE_CACHE]; - int pointeur_fct; - - integer8 *objets_int[TAILLE_CACHE]; - int pointeur_int; - - struct_matrice *objets_mat[TAILLE_CACHE]; - int pointeur_mat; - - struct_nom *objets_nom[TAILLE_CACHE]; - int pointeur_nom; - - real8 *objets_rel[TAILLE_CACHE]; - int pointeur_rel; - - struct_tableau *objets_tab[TAILLE_CACHE]; - int pointeur_tab; - - struct_vecteur *objets_vec[TAILLE_CACHE]; - int pointeur_vec; - - struct_liste_chainee *maillons[TAILLE_CACHE]; - int pointeur_maillons; - - struct_arbre_variables *variables_noeud[TAILLE_CACHE]; - int pointeur_variables_noeud; - - struct_arbre_variables_partagees - *variables_partagees_noeud[TAILLE_CACHE]; - int pointeur_variables_partagees_noeud; - - struct_liste_variables *variables_feuille[TAILLE_CACHE]; - int pointeur_variables_feuille; - - struct_variable *variables_variable[TAILLE_CACHE]; - int pointeur_variables_variable; - - struct_arbre_variables **variables_tableau_noeuds[TAILLE_CACHE]; - int pointeur_variables_tableau_noeuds; - - struct_arbre_variables_partagees - **variables_tableau_noeuds_partages - [TAILLE_CACHE]; - int pointeur_variables_tableau_noeuds_partages; +# define TAILLE_CACHE 1024 +# define CACHE(type, nom) \ + type *objets_##nom[TAILLE_CACHE]; \ + int pointeur_##nom; + +# define CACHE2(type, nom) \ + type *nom[TAILLE_CACHE]; \ + int pointeur_##nom; + + CACHE(integer8, adr) + CACHE(logical8, bin) + CACHE(complex16, cpl) + CACHE(struct_fonction, fct) + CACHE(integer8, int) + CACHE(struct_matrice, mat) + CACHE(struct_nom, nom) + CACHE(real8, rel) + CACHE(struct_tableau, tab) + CACHE(struct_vecteur, vec) + + CACHE2(struct_liste_chainee, maillons) + CACHE2(struct_arbre_variables, variables_noeud) + CACHE2(struct_arbre_variables_partagees, variables_partagees_noeud) + CACHE2(struct_liste_variables, variables_feuille) + CACHE2(struct_variable, variables_variable) + CACHE2(struct_arbre_variables *, variables_tableau_noeuds) + CACHE2(struct_arbre_variables_partagees *, + variables_tableau_noeuds_partages) + + CACHE2(struct_buffer, enveloppes_buffers) + unsigned char ***cache_buffer; + int *pointeur_cache_buffer; } struct_processus; #endif + /* --------------------------------------------------------------------------------- - Structure fonction --------------------------------------------------------------------------------- -*/ +================================================================================ + MISE EN PLACE DE L'ALLOCATEUR SPÉCIFIQUE +================================================================================*/ -#ifndef RPLARGS -typedef struct fonction -{ - unsigned char *nom_fonction; - unsigned long nombre_arguments; +#ifndef DEBUG_MEMOIRE +# define malloc(a) rpl_malloc(s_etat_processus, a) +# define realloc(a, b) rpl_realloc(s_etat_processus, a, b) +# define free(a) rpl_free(s_etat_processus, a) +#endif - void (*fonction)(struct_processus *); +void *rpl_malloc(struct_processus *s_etat_processus, size_t s); +void *rpl_realloc(struct_processus *s_etat_processus, void *ptr, size_t s); +void rpl_free(struct_processus *s_etat_processus, void *ptr); +void *sys_malloc(size_t s); +void sys_free(void *ptr); - volatile struct_liste_chainee *prediction_saut; - volatile logical1 prediction_execution; -} struct_fonction; -#endif +/* + * Wrapper de readline() pour que la fonction renvoie un pointeur sur un + * buffer alloué par rpl_malloc(). + */ + +#define readline(s) readline_wrapper(s_etat_processus, s) +unsigned char *readline_wrapper(struct_processus *s_etat_processus, + unsigned char *s); /* @@ -2417,7 +2462,7 @@ typedef struct fonction /* -------------------------------------------------------------------------------- - Procédures d'exécution des mots-clef du langage RPL/2 + Procédures d'exécution des mots-clef du langage RPL/2 -------------------------------------------------------------------------------- */ @@ -2481,6 +2526,7 @@ void instruction_col_fleche(struct_proce void instruction_col_moins(struct_processus *s_etat_processus); void instruction_col_plus(struct_processus *s_etat_processus); void instruction_comb(struct_processus *s_etat_processus); +void instruction_compress(struct_processus *s_etat_processus); void instruction_con(struct_processus *s_etat_processus); void instruction_cond(struct_processus *s_etat_processus); void instruction_cont(struct_processus *s_etat_processus); @@ -2548,6 +2594,7 @@ void instruction_elseif(struct_processus void instruction_end(struct_processus *s_etat_processus); void instruction_eng(struct_processus *s_etat_processus); void instruction_epsilon(struct_processus *s_etat_processus); +void instruction_eqv(struct_processus *s_etat_processus); void instruction_erase(struct_processus *s_etat_processus); void instruction_errm(struct_processus *s_etat_processus); void instruction_errn(struct_processus *s_etat_processus); @@ -2788,6 +2835,8 @@ void instruction_return(struct_processus void instruction_revlist(struct_processus *s_etat_processus); void instruction_rewind(struct_processus *s_etat_processus); void instruction_rfuse(struct_processus *s_etat_processus); +void instruction_rgdl(struct_processus *s_etat_processus); +void instruction_rgdr(struct_processus *s_etat_processus); void instruction_rl(struct_processus *s_etat_processus); void instruction_rlb(struct_processus *s_etat_processus); void instruction_rnd(struct_processus *s_etat_processus); @@ -2907,6 +2956,7 @@ void instruction_t_vers_l(struct_process void instruction_ucase(struct_processus *s_etat_processus); void instruction_uchol(struct_processus *s_etat_processus); +void instruction_uncompress(struct_processus *s_etat_processus); void instruction_unlock(struct_processus *s_etat_processus); void instruction_unprotect(struct_processus *s_etat_processus); void instruction_until(struct_processus *s_etat_processus); @@ -2950,15 +3000,14 @@ void instruction_yield(struct_processus /* -------------------------------------------------------------------------------- - Procédures + Procédures -------------------------------------------------------------------------------- */ #ifndef RPLARGS void affectation_interruptions_logicielles(struct_processus *s_etat_processus); void affichage_pile(struct_processus *s_etat_processus, - struct_liste_chainee *l_element_courant, unsigned long - niveau_courant); + struct_liste_chainee *l_element_courant, integer8 niveau_courant); #endif void *allocation_maillon(struct_processus *s_etat_processus); @@ -2976,12 +3025,14 @@ void conversion_chaine(struct_processus unsigned char *chaine, unsigned char type); void conversion_decimal_vers_hms(real8 *angle); void conversion_degres_vers_radians(real8 *angle); -void conversion_element_tex(unsigned char **element, unsigned char *fonction); +void conversion_element_tex(struct_processus *s_etat_processus, + unsigned char **element, unsigned char *fonction); void conversion_format(struct_processus *s_etat_processus, unsigned char *chaine); void conversion_hms_vers_decimal(real8 *angle); -void conversion_majuscule_limitee(unsigned char *chaine_entree, - unsigned char *chaine_sortie, unsigned long longueur); +void conversion_majuscule_limitee( + unsigned char *chaine_entree, unsigned char *chaine_sortie, + integer8 longueur); void conversion_radians_vers_degres(real8 *angle); void copie_arbre_variables(struct_processus *s_etat_processus, struct_processus *s_nouvel_etat_processus); @@ -2994,11 +3045,11 @@ void determinant(struct_processus *s_eta void *valeur); void deverrouillage_threads_concurrents(struct_processus *s_etat_processus); void ecriture_pile(struct_processus *s_etat_processus, file *flux, - struct_liste_chainee *l_element_courant, unsigned long niveau_courant); + struct_liste_chainee *l_element_courant, integer8 niveau_courant); void ecriture_profil(struct_processus *s_etat_processus); void effacement_pile_systeme(struct_processus *s_etat_processus); void empilement_pile_systeme(struct_processus *s_etat_processus); -void encart(struct_processus *s_etat_processus, unsigned long duree); +void encart(struct_processus *s_etat_processus, integer8 duree); void evaluation_romberg(struct_processus *s_etat_processus, struct_objet *s_expression, unsigned char *variable, real8 *point, real8 *valeur, logical1 *validite); @@ -3019,7 +3070,7 @@ void formateur_elementaire_tex(struct_pr file *fichier, struct_objet *s_objet, unsigned char environnement); void impression_pile(struct_processus *s_etat_processus, struct_liste_chainee *l_element_courant, - unsigned char methode, unsigned long niveau_courant); + unsigned char methode, integer8 niveau_courant); void impression_tex(struct_processus *s_etat_processus); void informations(struct_processus *s_etat_processus); void initialisation_allocateur(struct_processus *s_etat_processus); @@ -3027,7 +3078,7 @@ void initialisation_completion(void); void initialisation_contexte_cas(struct_processus *s_etat_processus); void initialisation_drapeaux(struct_processus *s_etat_processus); void initialisation_generateur_aleatoire(struct_processus *s_etat_processus, - logical1 initialisation_automatique, unsigned long int racine); + logical1 initialisation_automatique, integer8 racine); void initialisation_instructions(struct_processus *s_etat_processus); void initialisation_variables(struct_processus *s_etat_processus); #endif @@ -3096,7 +3147,7 @@ void scrutation_injection(struct_process void scrutation_interruptions(struct_processus *s_etat_processus); void sf(struct_processus *s_etat_processus, unsigned char indice_drapeau); void *surveillance_processus(void *argument); -void swap(void *variable_1, void *variable_2, unsigned long taille_octets); +void swap(void *variable_1, void *variable_2, integer8 taille_octets); void *thread_signaux(void *argument); void trace(struct_processus *s_etat_processus, FILE *flux); void traitement_asynchrone_exceptions_gsl(struct_processus *s_etat_processus); @@ -3104,7 +3155,7 @@ void traitement_exceptions_gsl(const cha int line, int gsl_errno); void traitement_interruptions_logicielles(struct_processus *s_etat_processus); void tri_base_symboles_externes(struct_processus *s_etat_processus); -void tri_vecteur(real8 *vecteur, unsigned long taille); +void tri_vecteur(real8 *vecteur, integer8 taille); void valeurs_propres(struct_processus *s_etat_processus, struct_matrice *s_matrice, struct_vecteur *s_valeurs_propres, @@ -3140,13 +3191,13 @@ int envoi_signal_thread(pthread_t tid, e /* -------------------------------------------------------------------------------- - Fonctions de sommation de vecteur dans perte de précision + Fonctions de sommation de vecteur dans perte de précision -------------------------------------------------------------------------------- */ -real8 sommation_vecteur_reel(real8 *vecteur, unsigned long *taille, +real8 sommation_vecteur_reel(real8 *vecteur, integer8 *taille, logical1 *erreur_memoire); -complex16 sommation_vecteur_complexe(complex16 *vecteur, unsigned long *taille, +complex16 sommation_vecteur_complexe(complex16 *vecteur, integer8 *taille, logical1 *erreur_memoire); /* @@ -3168,25 +3219,29 @@ int rplinit(int argc, char *argv[], char #ifndef RPLARGS real8 correlation_statistique(struct_matrice *s_matrice, - unsigned long colonne_1, unsigned long colonne_2, logical1 *erreur); + integer8 colonne_1, integer8 colonne_2, logical1 *erreur); real8 covariance_statistique(struct_matrice *s_matrice, - unsigned long colonne_1, unsigned long colonne_2, + integer8 colonne_1, integer8 colonne_2, unsigned char type, logical1 *erreur); -struct_vecteur *ecart_type_statistique(struct_matrice *s_matrice, - unsigned char type); -struct_vecteur *moyenne_statistique(struct_matrice *s_matrice); -struct_vecteur *sommation_colonne_statistique(struct_matrice *s_matrice, - unsigned long colonne); -struct_vecteur *sommation_produits_colonnes_statistiques(struct_matrice - *s_matrice, unsigned long colonne_1, unsigned long colonne_2); -struct_vecteur *sommation_statistique(struct_matrice *s_matrice); -struct_vecteur *variance_statistique(struct_matrice *s_matrice, - unsigned char type); +struct_vecteur *ecart_type_statistique(struct_processus *s_etat_processus, + struct_matrice *s_matrice, unsigned char type); +struct_vecteur *moyenne_statistique(struct_processus *s_etat_processus, + struct_matrice *s_matrice); +struct_vecteur *sommation_colonne_statistique( + struct_processus *s_etat_processus, struct_matrice *s_matrice, + integer8 colonne); +struct_vecteur *sommation_produits_colonnes_statistiques( + struct_processus *s_etat_processus, struct_matrice + *s_matrice, integer8 colonne_1, integer8 colonne_2); +struct_vecteur *sommation_statistique(struct_processus *s_etat_processus, + struct_matrice *s_matrice); +struct_vecteur *variance_statistique(struct_processus *s_etat_processus, + struct_matrice *s_matrice, unsigned char type); #endif /* -------------------------------------------------------------------------------- - Gestion des bibliothèques + Gestion des bibliothèques -------------------------------------------------------------------------------- */ @@ -3204,7 +3259,7 @@ struct_liste_chainee *depilement_pile_op struct_liste_chainee *empilement_pile_operationnelle(struct_rpl_arguments *s_rpl_arguments, struct_objet *s_objet); struct_liste_chainee *sauvegarde_arguments(struct_rpl_arguments - *s_rpl_arguments, unsigned long nombre_arguments); + *s_rpl_arguments, integer8 nombre_arguments); /* -------------------------------------------------------------------------------- @@ -3216,37 +3271,40 @@ struct_liste_chainee *sauvegarde_argumen unsigned char *analyse_algebrique(struct_processus *s_etat_processus, unsigned char *chaine_algebrique, struct_liste_chainee **l_base_liste); unsigned char *analyse_flux(struct_processus *s_etat_processus, - unsigned char *flux, long longueur); -unsigned char *chiffrement(const EVP_CIPHER *type_chiffrement, - logical1 encodage, unsigned char *message, unsigned int - longueur_message, unsigned char *clef, unsigned int longueur_clef, + unsigned char *flux, integer8 longueur); +unsigned char *chiffrement(struct_processus *s_etat_processus, + const EVP_CIPHER *type_chiffrement, + logical1 encodage, unsigned char *message, integer8 longueur_message, + unsigned char *clef, integer8 longueur_clef, unsigned char *vecteur_initialisation, - unsigned int *longueur_message_chiffre); -unsigned char *compactage(unsigned char *chaine); -unsigned char *conversion_majuscule(unsigned char *chaine); + integer8 *longueur_message_chiffre); +unsigned char *compactage(struct_processus *s_etat_processus, + unsigned char *chaine); +unsigned char *conversion_majuscule(struct_processus *s_etat_processus, + unsigned char *chaine); unsigned char *creation_nom_fichier(struct_processus *s_etat_processus, unsigned char *chemin); -unsigned char *date_compilation(); -unsigned char *extraction_chaine(unsigned char *chaine, unsigned long i, - unsigned long j); +unsigned char *date_compilation(struct_processus *s_etat_processus); +unsigned char *extraction_chaine(struct_processus *s_etat_processus, + unsigned char *chaine, integer8 i, integer8 j); unsigned char *formateur(struct_processus *s_etat_processus, long offset, struct_objet *s_objet); unsigned char *formateur_fichier(struct_processus *s_etat_processus, struct_objet *s_objet, struct_objet *s_format, - long longueur, long longueur_champ, unsigned char format, - unsigned char type, long *longueur_effective, long *recursivite, + integer8 longueur, integer8 longueur_champ, unsigned char format, + unsigned char type, integer8 *longueur_effective, integer8 *recursivite, logical1 export_fichier); unsigned char *formateur_flux(struct_processus *s_etat_processus, - unsigned char *donnees, long *longueur); + unsigned char *donnees, integer8 *longueur); unsigned char *formateur_fichier_nombre(struct_processus *s_etat_processus, void *valeur_numerique, unsigned char type, - long longueur, long longueur_champ, unsigned char format); + integer8 longueur, integer8 longueur_champ, unsigned char format); unsigned char *formateur_fichier_binaire_nombre(struct_processus *s_etat_processus, void *valeur_numerique, unsigned char type_entree, - unsigned char type, long longueur, long *longueur_conversion); + unsigned char type, integer8 longueur, integer8 *longueur_conversion); unsigned char *formateur_fichier_reel(struct_processus *s_etat_processus, void *valeur_numerique, unsigned char type, - long longueur, long longueur_champ, unsigned char format); + integer8 longueur, integer8 longueur_champ, unsigned char format); unsigned char *formateur_nombre(struct_processus *s_etat_processus, void *valeur_numerique, unsigned char type); unsigned char *formateur_reel(struct_processus *s_etat_processus, @@ -3254,7 +3312,8 @@ unsigned char *formateur_reel(struct_pro unsigned char *messages(struct_processus *s_etat_processus); unsigned char *pointeur_ieme_caractere(struct_processus *s_etat_processus, unsigned char *chaine, integer8 position); -unsigned char *purification_chaine(unsigned char *chaine); +unsigned char *purification_chaine(struct_processus *s_etat_processus, + unsigned char *chaine); unsigned char *recherche_chemin_fichiers_temporaires(struct_processus *s_etat_processus); unsigned char *reencodage(struct_processus *s_etat_processus, @@ -3297,7 +3356,7 @@ logical1 destruction_fichier(unsigned ch logical1 empilement(struct_processus *s_etat_processus, struct_liste_chainee **l_base_liste, struct_objet *s_objet); logical1 empilement_pile_last(struct_processus *s_etat_processus, - unsigned long nombre_arguments); + integer8 nombre_arguments); logical1 evaluation(struct_processus *s_etat_processus, struct_objet *s_objet, unsigned char type_evaluation); logical1 initialisation_fichier_acces_direct(struct_processus *s_etat_processus, @@ -3306,6 +3365,8 @@ logical1 initialisation_fichier_acces_in sqlite3 *sqlite, integer8 position_clef, logical1 binaire); logical1 lancement_thread_signaux(struct_processus *s_etat_processus); logical1 recherche_instruction_suivante(struct_processus *s_etat_processus); +logical1 recherche_instruction_suivante_recursive( + struct_processus *s_etat_processus, integer8 recursivite); logical1 retrait_variable(struct_processus *s_etat_processus, unsigned char *nom_variable, unsigned char type); logical1 retrait_variables_par_niveau(struct_processus *s_etat_processus); @@ -3366,20 +3427,28 @@ ssize_t write_atomic(struct_processus *s -------------------------------------------------------------------------------- */ -int alsprintf(unsigned char **strp, const char *fmt, ...); +int alsprintf(struct_processus *s_etat_processus, + unsigned char **strp, const char *fmt, ...); +#ifndef RPLARGS +int association_etat_processus_readline(); +#endif int interruption_violation_access(void *adresse_fautive, int gravite); #ifndef RPLARGS -int liste_variables(struct_processus *s_etat_processus, +int initialisation_etat_processus_readline(); +int liberation_etat_processus_readline(); +integer8 liste_variables(struct_processus *s_etat_processus, struct_tableau_variables *tableau); -int nombre_variables(struct_processus *s_etat_processus); +integer8 nombre_variables(struct_processus *s_etat_processus); int readline_analyse_syntaxique(int count, int key); int readline_effacement(int count, int key); #endif +int std_fprintf(file *flux, const char *format, ...); int tex_fprintf(struct_processus *s_etat_processus, file *flux, const char *format, ...); int transliterated_fprintf(struct_processus *s_etat_processus, file *flux, const char *format, ...); -int valsprintf(unsigned char **strp, const char *fmt, va_list ap); +int valsprintf(struct_processus *s_etat_processus, + unsigned char **strp, const char *fmt, va_list ap); int wrapper_instruction_intrinseque(void (*fonction)(), struct_rpl_arguments *rpl_arguments); @@ -3395,7 +3464,7 @@ unsigned char longueur_entiers_binaires( /* -------------------------------------------------------------------------------- - Fonctions retournant un INTEGER*8 (valeur binaire non signée) + Fonctions retournant un INTEGER*8 (valeur binaire non signée) -------------------------------------------------------------------------------- */ @@ -3419,7 +3488,7 @@ integer8 position_caractere_de_chaine(st /* -------------------------------------------------------------------------------- - Fonctions renvoyant une liste chaînée (pointeur sur *struct_liste_chainee) + Fonctions renvoyant une liste chaînée (pointeur sur *struct_liste_chainee) -------------------------------------------------------------------------------- */ @@ -3430,6 +3499,19 @@ struct_liste_chainee *analyse_rpn(struct /* -------------------------------------------------------------------------------- + Allocateur de buffers à cache +-------------------------------------------------------------------------------- +*/ + +void initialisation_allocateur_buffer(struct_processus *s_etat_processus); +void liberation_allocateur_buffer(struct_processus *s_etat_pocessus); +struct_buffer *allocation_buffer(struct_processus *s_etat_processus, + size_t longueur); +void liberation_buffer(struct_processus *s_etat_processus, + struct_buffer *buffer); + +/* +-------------------------------------------------------------------------------- Fonctions renvoyant une copie de la structure de description des processus -------------------------------------------------------------------------------- */ @@ -3492,24 +3574,7 @@ struct_liste_variables_partagees *recher /* -------------------------------------------------------------------------------- - Fonctions gérant les arbres de simplification --------------------------------------------------------------------------------- -*/ - -#ifndef RPLARGS -struct_arbre *creation_arbre(struct_processus *s_etat_processus, - struct_objet **t_objets, unsigned long indice, - unsigned long indice_maximal); -void liberation_arbre(struct_processus *s_etat_processus, - struct_arbre *s_noeud); -void parcours_arbre(struct_processus *s_etat_processus, struct_arbre *s_noeud); -void simplification_arbre(struct_processus *s_etat_processus, - struct_arbre *s_noeud); -#endif - -/* --------------------------------------------------------------------------------- - Fonctions gérant la complétion automatique + Fonctions gérant la complétion automatique -------------------------------------------------------------------------------- */ @@ -3521,7 +3586,7 @@ char **completion_matches(); /* -------------------------------------------------------------------------------- - Arithmétique + Arithmétique -------------------------------------------------------------------------------- */ @@ -3565,7 +3630,7 @@ void f77soustractionrc_(real8 *ra, compl /* -------------------------------------------------------------------------------- - Trigonométrie complexe + Trigonométrie complexe -------------------------------------------------------------------------------- */ @@ -3662,7 +3727,7 @@ void zgeev_(unsigned char *calcul_vp_gau integer4 *erreur, integer4 longueur_1, integer4 longueur_2); /* - * Valeurs propres généralisées + * Valeurs propres généralisées */ void zggev_(unsigned char *calcul_vp_gauches, unsigned char *calcul_vp_droits, @@ -3675,7 +3740,7 @@ void zggev_(unsigned char *calcul_vp_gau integer4 *erreur, integer4 longueur_1, integer4 longueur_2); /* - * Moindres carrés + * Moindres carrés */ void dgelsd_(integer4 *nombre_lignes_a, integer4 *nombre_colonnes_a, @@ -3690,11 +3755,11 @@ void zgelsd_(integer4 *nombre_lignes_a, real8 *rwork, integer4 *iwork, integer4 *info); /* - * Moindres carrés généralisé + * Moindres carrés généralisé */ /* - * Décomposition en valeurs singulières + * Décomposition en valeurs singulières */ void dgesvd_(unsigned char *jobu, unsigned char *jobvh, @@ -3751,7 +3816,7 @@ void zgees_(unsigned char *calcul_vecteu real8 *rwork, logical4 *bwork, integer4 *info, integer4 l1, integer4 l2); - /* Déterminant et rang */ + /* Déterminant et rang */ void dgecon_(unsigned char *norm, integer4 *n, real8 *a, integer4 *lda, real8 *anorm, real8 *rcond, real8 *work, integer4 *iwork, integer4 *info, integer4 l1); @@ -3772,8 +3837,8 @@ void zgelsy_(integer4 *m, integer4 *n, i #endif /* - * Fonction testant la requête d'arrêt (nécessaire pour tester le - * drapeau depuis une bibliothèque). + * Fonction testant la requête d'arrêt (nécessaire pour tester le + * drapeau depuis une bibliothèque). */ int test_arret(struct_processus *s_etat_processus);