Diff for /rpl/src/rpl.c between versions 1.23 and 1.39

version 1.23, 2010/04/29 07:30:58 version 1.39, 2010/08/15 14:46:25
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.0.15    RPL/2 (R) version 4.0.18
   Copyright (C) 1989-2010 Dr. BERTRAND Joël    Copyright (C) 1989-2010 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
Line 21 Line 21
   
   
 #define  MAIN_RPL  #define  MAIN_RPL
 #include "rpl.conv.h"  #include "rpl-conv.h"
   
   #ifdef SEMAPHORES_SYSV
   #ifndef OS2
       unsigned char       *chemin_semaphores_SysV;
   #endif
   #endif
   
   
 /*  /*
Line 33 Line 39
 int  int
 rplinit(int argc, char *argv[], unsigned char ***resultats, char *rpl_home)  rplinit(int argc, char *argv[], unsigned char ***resultats, char *rpl_home)
 {  {
 #   include                             "copyright.conv.h"  #   include                             "copyright-conv.h"
 #   include                             "licence.conv.h"  #   include                             "licence-conv.h"
   
     file                                *f_source;      file                                *f_source;
   
Line 99  rplinit(int argc, char *argv[], unsigned Line 105  rplinit(int argc, char *argv[], unsigned
     volatile int                        erreur;      volatile int                        erreur;
     volatile unsigned char              traitement_fichier_temporaire;      volatile unsigned char              traitement_fichier_temporaire;
   
       errno = 0;
   
   #   ifdef DEBUG_MEMOIRE
       debug_memoire_initialisation();
   #   endif
   
     setvbuf(stdout, NULL, _IOLBF, 0);      setvbuf(stdout, NULL, _IOLBF, 0);
     setvbuf(stderr, NULL, _IOLBF, 0);      setvbuf(stderr, NULL, _IOLBF, 0);
   
Line 184  rplinit(int argc, char *argv[], unsigned Line 196  rplinit(int argc, char *argv[], unsigned
     pthread_mutex_init(&((*s_etat_processus).mutex), &attributs_mutex);      pthread_mutex_init(&((*s_etat_processus).mutex), &attributs_mutex);
     pthread_mutexattr_destroy(&attributs_mutex);      pthread_mutexattr_destroy(&attributs_mutex);
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
       pthread_mutex_init(&((*s_etat_processus).mutex_allocation),
               &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
 #   ifndef SEMAPHORES_NOMMES  #   ifndef SEMAPHORES_NOMMES
     sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);      sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
 #   else  #   else
Line 317  rplinit(int argc, char *argv[], unsigned Line 335  rplinit(int argc, char *argv[], unsigned
     // Initialisation d'une pile de signal pour récupérer les      // Initialisation d'une pile de signal pour récupérer les
     // débordement de pile      // débordement de pile
   
 #   ifndef Cygwin  #   if !defined(Cygwin) && !defined(OpenBSD)
     if (((*s_etat_processus).pile_signal.ss_sp =      if (((*s_etat_processus).pile_signal.ss_sp =
             malloc((*s_etat_processus).pile_signal.ss_size =              malloc((*s_etat_processus).pile_signal.ss_size =
             SIGSTKSZ)) == NULL)              SIGSTKSZ)) == NULL)
Line 447  rplinit(int argc, char *argv[], unsigned Line 465  rplinit(int argc, char *argv[], unsigned
         return(EXIT_FAILURE);          return(EXIT_FAILURE);
     }      }
   
       action.sa_sigaction = interruption11;
       action.sa_flags = SA_NODEFER | SA_ONSTACK | SA_SIGINFO;
   
     if (sigaction(SIGFABORT, &action, NULL) != 0)      if (sigaction(SIGFABORT, &action, NULL) != 0)
     {      {
         erreur = d_es_signal;          erreur = d_es_signal;
Line 570  rplinit(int argc, char *argv[], unsigned Line 591  rplinit(int argc, char *argv[], unsigned
     (*s_etat_processus).chemin_fichiers_temporaires =      (*s_etat_processus).chemin_fichiers_temporaires =
             recherche_chemin_fichiers_temporaires(s_etat_processus);              recherche_chemin_fichiers_temporaires(s_etat_processus);
   
   #   ifdef SEMAPHORES_SYSV
   #   ifndef OS2
       chemin_semaphores_SysV = (*s_etat_processus).chemin_fichiers_temporaires;
   #   endif
   #   endif
   
     erreur = d_absence_erreur;      erreur = d_absence_erreur;
     core = d_faux;      core = d_faux;
     mode_interactif = d_faux;      mode_interactif = d_faux;
Line 1858  rplinit(int argc, char *argv[], unsigned Line 1885  rplinit(int argc, char *argv[], unsigned
             }              }
   
             (*s_etat_processus).at_exit = NULL;              (*s_etat_processus).at_exit = NULL;
               (*s_etat_processus).at_poke = NULL;
               (*s_etat_processus).traitement_at_poke = 'N';
   
             (*s_etat_processus).pointeurs_caracteres = NULL;              (*s_etat_processus).pointeurs_caracteres = NULL;
             (*s_etat_processus).arbre_instructions = NULL;              (*s_etat_processus).arbre_instructions = NULL;
Line 1894  rplinit(int argc, char *argv[], unsigned Line 1923  rplinit(int argc, char *argv[], unsigned
             }              }
   
             if (((*s_etat_processus).instruction_derniere_erreur =              if (((*s_etat_processus).instruction_derniere_erreur =
                     malloc(2 * sizeof(unsigned char))) == NULL)                      malloc(sizeof(unsigned char))) == NULL)
             {              {
                 erreur = d_es_allocation_memoire;                  erreur = d_es_allocation_memoire;
   
Line 2650  rplinit(int argc, char *argv[], unsigned Line 2679  rplinit(int argc, char *argv[], unsigned
                                         (*s_etat_processus).at_exit, 'E');                                          (*s_etat_processus).at_exit, 'E');
                             }                              }
                         }                          }
   
                         liberation(s_etat_processus,  
                                 (*s_etat_processus).at_exit);  
                     }                      }
   
                       liberation(s_etat_processus, (*s_etat_processus).at_exit);
                       liberation(s_etat_processus, (*s_etat_processus).at_poke);
   
                     if ((*s_etat_processus).generateur_aleatoire != NULL)                      if ((*s_etat_processus).generateur_aleatoire != NULL)
                     {                      {
                         liberation_generateur_aleatoire(s_etat_processus);                          liberation_generateur_aleatoire(s_etat_processus);
Line 3449  rplinit(int argc, char *argv[], unsigned Line 3478  rplinit(int argc, char *argv[], unsigned
         }          }
     }      }
   
 #   ifndef Cygwin  #   if !defined(Cygwin) && !defined(OpenBSD)
       (*s_etat_processus).pile_signal.ss_flags = SS_DISABLE;
       sigaltstack(&((*s_etat_processus).pile_signal), NULL);
     free((*s_etat_processus).pile_signal.ss_sp);      free((*s_etat_processus).pile_signal.ss_sp);
 #   endif  #   endif
   
Line 3462  rplinit(int argc, char *argv[], unsigned Line 3493  rplinit(int argc, char *argv[], unsigned
     retrait_thread(s_etat_processus);      retrait_thread(s_etat_processus);
   
     pthread_mutex_destroy(&((*s_etat_processus).mutex));      pthread_mutex_destroy(&((*s_etat_processus).mutex));
       pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
   
 #   ifndef SEMAPHORES_NOMMES  #   ifndef SEMAPHORES_NOMMES
     sem_post(&((*s_etat_processus).semaphore_fork));      sem_post(&((*s_etat_processus).semaphore_fork));
     sem_destroy(&((*s_etat_processus).semaphore_fork));      sem_destroy(&((*s_etat_processus).semaphore_fork));
Line 3471  rplinit(int argc, char *argv[], unsigned Line 3504  rplinit(int argc, char *argv[], unsigned
 #   endif  #   endif
   
     free((*s_etat_processus).localisation);      free((*s_etat_processus).localisation);
     free(s_etat_processus);  
   
 #   ifndef SEMAPHORES_NOMMES  #   ifndef SEMAPHORES_NOMMES
     sem_destroy(&semaphore_liste_threads);      sem_destroy(&semaphore_liste_threads);
Line 3489  rplinit(int argc, char *argv[], unsigned Line 3521  rplinit(int argc, char *argv[], unsigned
             sem_gestionnaires_signaux_atomique);              sem_gestionnaires_signaux_atomique);
 #   endif  #   endif
   
       free(s_etat_processus);
   
 #   ifdef DEBUG_MEMOIRE  #   ifdef DEBUG_MEMOIRE
     debug_memoire_verification(s_etat_processus);      debug_memoire_verification();
       analyse_post_mortem();
 #   endif  #   endif
   
     return((erreur == d_absence_erreur) ? EXIT_SUCCESS : EXIT_FAILURE);      return((erreur == d_absence_erreur) ? EXIT_SUCCESS : EXIT_FAILURE);

Removed from v.1.23  
changed lines
  Added in v.1.39


CVSweb interface <joel.bertrand@systella.fr>