[BACK]Return to rpl.c CVS log [TXT] [DIR] Up to [local] / rpl / src

Diff for /rpl/src/rpl.c between versions 1.141 and 1.149

version 1.141, 2013/04/02 12:20:51 version 1.149, 2013/09/06 10:30:56
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.14    RPL/2 (R) version 4.1.16
   Copyright (C) 1989-2013 Dr. BERTRAND Joël    Copyright (C) 1989-2013 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
Line 260  rplinit(int argc, char *argv[], char *en Line 260  rplinit(int argc, char *argv[], char *en
   
     pthread_mutexattr_init(&attributs_mutex);      pthread_mutexattr_init(&attributs_mutex);
     pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);      pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
     pthread_mutex_init(&((*s_etat_processus).mutex), &attributs_mutex);      pthread_mutex_init(&((*s_etat_processus).mutex_pile_processus),
               &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_interruptions),
               &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_signaux),
               &attributs_mutex);
     pthread_mutexattr_destroy(&attributs_mutex);      pthread_mutexattr_destroy(&attributs_mutex);
   
     pthread_mutexattr_init(&attributs_mutex);      pthread_mutexattr_init(&attributs_mutex);
Line 357  rplinit(int argc, char *argv[], char *en Line 370  rplinit(int argc, char *argv[], char *en
     }      }
     else      else
     {      {
 #       ifndef SEMAPHORES_NOMMES  
             sem_post(&((*s_etat_processus).semaphore_fork));  
             sem_post(&semaphore_gestionnaires_signaux);  
             sem_destroy(&semaphore_gestionnaires_signaux);  
             sem_destroy(&((*s_etat_processus).semaphore_fork));  
 #       else  
             sem_post((*s_etat_processus).semaphore_fork);  
             sem_post(semaphore_gestionnaires_signaux);  
             sem_destroy2(semaphore_gestionnaires_signaux, getpid(),  
                     SEM_SIGNAUX);  
             sem_destroy3((*s_etat_processus).semphore_fork, getpid(),  
                     pthread_self(), SEM_FORK);  
 #       endif  
   
         liberation_contexte_cas(s_etat_processus);  
         liberation_queue_signaux(s_etat_processus);  
   
         if (((*s_etat_processus).localisation = malloc((strlen(d_locale)          if (((*s_etat_processus).localisation = malloc((strlen(d_locale)
                 + 1) * sizeof(unsigned char))) == NULL)                  + 1) * sizeof(unsigned char))) == NULL)
         {          {
   #           ifndef SEMAPHORES_NOMMES
                   sem_post(&((*s_etat_processus).semaphore_fork));
                   sem_post(&semaphore_gestionnaires_signaux);
                   sem_destroy(&semaphore_gestionnaires_signaux);
                   sem_destroy(&((*s_etat_processus).semaphore_fork));
   #           else
                   sem_post((*s_etat_processus).semaphore_fork);
                   sem_post(semaphore_gestionnaires_signaux);
                   sem_destroy2(semaphore_gestionnaires_signaux, getpid(),
                           SEM_SIGNAUX);
                   sem_destroy3((*s_etat_processus).semphore_fork, getpid(),
                           pthread_self(), SEM_FORK);
   #           endif
   
               liberation_contexte_cas(s_etat_processus);
               liberation_queue_signaux(s_etat_processus);
   
             if ((*s_etat_processus).langue == 'F')              if ((*s_etat_processus).langue == 'F')
             {              {
                 uprintf("+++Système : Mémoire insuffisante\n");                  uprintf("+++Système : Mémoire insuffisante\n");
Line 3404  rplinit(int argc, char *argv[], char *en Line 3417  rplinit(int argc, char *argv[], char *en
   
             (*s_etat_processus).liste_mutexes = NULL;              (*s_etat_processus).liste_mutexes = NULL;
             (*s_etat_processus).sections_critiques = 0;              (*s_etat_processus).sections_critiques = 0;
               (*s_etat_processus).initialisation_scheduler = d_faux;
   
             (*s_etat_processus).test_instruction = 'N';              (*s_etat_processus).test_instruction = 'N';
             (*s_etat_processus).nombre_arguments = 0;              (*s_etat_processus).nombre_arguments = 0;
Line 4905  rplinit(int argc, char *argv[], char *en Line 4919  rplinit(int argc, char *argv[], char *en
                             return(EXIT_FAILURE);                              return(EXIT_FAILURE);
                         }                          }
   
                           empilement_pile_systeme(s_etat_processus);
   
                         if (evaluation(s_etat_processus, s_objet, 'E')                          if (evaluation(s_etat_processus, s_objet, 'E')
                                 == d_erreur)                                  == d_erreur)
                         {                          {
Line 5369  rplinit(int argc, char *argv[], char *en Line 5385  rplinit(int argc, char *argv[], char *en
                         pthread_cancel((*s_etat_processus).thread_fusible);                          pthread_cancel((*s_etat_processus).thread_fusible);
                     }                      }
   
                     pthread_mutex_lock(&((*s_etat_processus).mutex));                      pthread_mutex_lock(&((*s_etat_processus)
                               .mutex_pile_processus));
   
                     l_element_courant = (void *) (*s_etat_processus)                      l_element_courant = (void *) (*s_etat_processus)
                             .l_base_pile_processus;                              .l_base_pile_processus;
Line 5605  rplinit(int argc, char *argv[], char *en Line 5622  rplinit(int argc, char *argv[], char *en
                                         }                                          }
 #                                   endif  #                                   endif
   
                                     pthread_mutex_unlock(                                      pthread_mutex_unlock(&((*s_etat_processus)
                                             &((*s_etat_processus).mutex));                                              .mutex_pile_processus));
                                     return(EXIT_FAILURE);                                      return(EXIT_FAILURE);
                                 }                                  }
   
Line 5668  rplinit(int argc, char *argv[], char *en Line 5685  rplinit(int argc, char *argv[], char *en
                                         }                                          }
 #                                   endif  #                                   endif
   
                                     pthread_mutex_unlock(                                      pthread_mutex_unlock(&((*s_etat_processus)
                                             &((*s_etat_processus).mutex));                                              .mutex_pile_processus));
                                     return(EXIT_FAILURE);                                      return(EXIT_FAILURE);
                                 }                                  }
                             }                              }
                         }                          }
   
                         pthread_mutex_unlock(&((*s_etat_processus).mutex));                          pthread_mutex_lock(&((*s_etat_processus)
                                   .mutex_interruptions));
   
                         if ((*s_etat_processus)                          if ((*s_etat_processus)
                                 .nombre_interruptions_non_affectees != 0)                                  .nombre_interruptions_non_affectees != 0)
Line 5684  rplinit(int argc, char *argv[], char *en Line 5702  rplinit(int argc, char *argv[], char *en
                                     s_etat_processus);                                      s_etat_processus);
                         }                          }
   
                           pthread_mutex_unlock(&((*s_etat_processus)
                                   .mutex_interruptions));
                           pthread_mutex_unlock(&((*s_etat_processus)
                                   .mutex_pile_processus));
                         nanosleep(&attente, NULL);                          nanosleep(&attente, NULL);
                         scrutation_interruptions(s_etat_processus);                          scrutation_interruptions(s_etat_processus);
                         pthread_mutex_lock(&((*s_etat_processus).mutex));                          pthread_mutex_lock(&((*s_etat_processus)
                                   .mutex_pile_processus));
                     }                      }
   
                     pthread_mutex_unlock(&((*s_etat_processus).mutex));                      pthread_mutex_unlock(&((*s_etat_processus)
                               .mutex_pile_processus));
   
                     erreur_historique = write_history(                      erreur_historique = write_history(
                             (*s_etat_processus).nom_fichier_historique);                              (*s_etat_processus).nom_fichier_historique);
Line 6202  rplinit(int argc, char *argv[], char *en Line 6226  rplinit(int argc, char *argv[], char *en
   
     retrait_thread(s_etat_processus);      retrait_thread(s_etat_processus);
   
     pthread_mutex_destroy(&((*s_etat_processus).mutex));      pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus));
     pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));      pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
       pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions));
       pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));
     pthread_mutex_destroy(&mutex_sections_critiques);      pthread_mutex_destroy(&mutex_sections_critiques);
     pthread_mutex_destroy(&mutex_liste_variables_partagees);      pthread_mutex_destroy(&mutex_liste_variables_partagees);
   
Removed from v.1.141  
changed lines
  Added in v.1.149

CVSweb interface <joel.bertrand@systella.fr>