--- rpl/src/rpl.h 2012/10/07 08:18:36 1.182 +++ rpl/src/rpl.h 2012/12/13 16:59:43 1.185 @@ -19,7 +19,7 @@ ================================================================================ */ -#define DEBUG_ERREURS + #ifndef INCLUSION_RPL #define INCLUSION_RPL @@ -1553,19 +1553,9 @@ typedef struct variable_partage union_position_variable variable_partagee; struct_objet *objet; -} struct_variable_partagee; - -typedef struct table_variables_partagees -{ - pthread_mutex_t mutex; - volatile struct_variable_partagee *table; - - volatile unsigned long nombre_variables; - volatile unsigned long nombre_variables_allouees; - - unsigned long position_variable; -} struct_table_variables_partagees; + pthread_mutex_t mutex; +} struct_variable_partagee; #endif @@ -1748,8 +1738,20 @@ typedef struct arbre_variables struct liste_variables *feuille; struct liste_variables_statiques *feuille_statique; + struct liste_variables_partagees **feuille_partagee; + + pthread_mutex_t mutex_feuille_partagee; } struct_arbre_variables; +#define INITIALISATION_MUTEX(mutex) \ + do { \ + pthread_mutexattr_t attributs_mutex; \ + pthread_mutexattr_init(&attributs_mutex); \ + pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL); \ + pthread_mutex_init(&(mutex), &attributs_mutex); \ + pthread_mutexattr_destroy(&attributs_mutex); \ + } while(0) + typedef struct tableau_variables { unsigned char origine; @@ -1793,6 +1795,15 @@ typedef struct liste_variables_statiques struct_arbre_variables *feuille; struct_variable_statique *variable; } struct_liste_variables_statiques; + +typedef struct liste_variables_partagees +{ + struct liste_variables_partagees *suivant; + struct liste_variables_partagees *precedent; + struct liste_variables_partagees *reference; + struct_arbre_variables *feuille; + struct_variable_partagee *variable; +} struct_liste_variables_partagees; #endif /* @@ -1882,6 +1893,8 @@ typedef struct processus logical1 presence_fusible; pthread_t thread_fusible; pthread_t thread_surveille_par_fusible; + pthread_t thread_signaux; + int pipe_signaux[2]; volatile int pointeur_signal_ecriture; volatile int pointeur_signal_lecture; @@ -1910,14 +1923,15 @@ typedef struct processus struct_liste_variables *l_liste_variables_par_niveau; struct_liste_variables_statiques *l_liste_variables_statiques; - struct_table_variables_partagees - *s_liste_variables_partagees; + struct_liste_variables_partagees + *l_liste_variables_partagees; logical1 niveau_supprime; struct_variable *pointeur_variable_courante; struct_liste_variables *pointeur_feuille_courante; struct_variable_statique *pointeur_variable_statique_courante; + struct_variable_partagee *pointeur_variable_partagee_courante; int *pointeurs_caracteres_variables; int nombre_caracteres_variables; @@ -3005,6 +3019,7 @@ void scrutation_interruptions(struct_pro 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 *thread_signaux(void *argument); void trace(struct_processus *s_etat_processus, FILE *flux); void traitement_asynchrone_exceptions_gsl(struct_processus *s_etat_processus); void traitement_exceptions_gsl(const char *reason, const char *file, @@ -3174,6 +3189,7 @@ unsigned char *transliteration(struct_pr #ifndef RPLARGS logical1 analyse_syntaxique(struct_processus *s_etat_processus); +logical1 arret_thread_signaux(struct_processus *s_etat_processus); logical1 caracteristiques_fichier(struct_processus *s_etat_processus, unsigned char *nom, logical1 *existence, logical1 *ouverture, unsigned long *unite); @@ -3204,6 +3220,7 @@ logical1 initialisation_fichier_acces_di sqlite3 *sqlite, logical1 binaire); logical1 initialisation_fichier_acces_indexe(struct_processus *s_etat_processus, 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 retrait_variable(struct_processus *s_etat_processus, unsigned char *nom_variable, unsigned char type);