Diff for /rpl/src/instructions_d5.c between versions 1.95 and 1.98

version 1.95, 2012/10/07 08:18:35 version 1.98, 2012/12/17 21:22:43
Line 838  instruction_detach(struct_processus *s_e Line 838  instruction_detach(struct_processus *s_e
     struct_liste_chainee                *l_element_precedent;      struct_liste_chainee                *l_element_precedent;
     struct_liste_chainee                *l_element_suivant;      struct_liste_chainee                *l_element_suivant;
   
       struct_liste_variables_partagees    *l_element_partage_courant;
       struct_liste_variables_partagees    *l_element_partage_suivant;
   
     struct_liste_variables_statiques    *l_element_statique_courant;      struct_liste_variables_statiques    *l_element_statique_courant;
     struct_liste_variables_statiques    *l_element_statique_suivant;      struct_liste_variables_statiques    *l_element_statique_suivant;
   
Line 934  instruction_detach(struct_processus *s_e Line 937  instruction_detach(struct_processus *s_e
             if ((*(*s_etat_processus).pointeur_variable_courante).objet              if ((*(*s_etat_processus).pointeur_variable_courante).objet
                     == NULL)                      == NULL)
             {              {
                 if (pthread_mutex_lock(&((*(*s_etat_processus)  
                         .s_liste_variables_partagees).mutex)) != 0)  
                 {  
                     (*s_etat_processus).erreur_systeme = d_es_processus;  
                     return;  
                 }  
   
                 if (recherche_variable_partagee(s_etat_processus,                  if (recherche_variable_partagee(s_etat_processus,
                         (*(*s_etat_processus).pointeur_variable_courante).nom,                          (*(*s_etat_processus).pointeur_variable_courante).nom,
                         (*(*s_etat_processus).pointeur_variable_courante)                          (*(*s_etat_processus).pointeur_variable_courante)
                         .variable_partagee, (*(*s_etat_processus)                          .variable_partagee, (*(*s_etat_processus)
                         .pointeur_variable_courante).origine) == d_faux)                          .pointeur_variable_courante).origine) == NULL)
                 {                  {
                     if (pthread_mutex_unlock(&((*(*s_etat_processus)  
                             .s_liste_variables_partagees).mutex)) != 0)  
                     {  
                         (*s_etat_processus).erreur_systeme = d_es_processus;  
                         return;  
                     }  
   
                     liberation(s_etat_processus, s_objet);                      liberation(s_etat_processus, s_objet);
   
                     (*s_etat_processus).erreur_systeme = d_es;                      (*s_etat_processus).erreur_systeme = d_es;
Line 962  instruction_detach(struct_processus *s_e Line 951  instruction_detach(struct_processus *s_e
                     return;                      return;
                 }                  }
   
                 if (((*(*(*s_etat_processus).s_liste_variables_partagees)                  if (((*(*(*s_etat_processus)
                         .table[(*(*s_etat_processus)                          .pointeur_variable_partagee_courante).objet).type
                         .s_liste_variables_partagees).position_variable].objet)                          == RPN) && ((*(*(*s_etat_processus)
                         .type != RPN) && ((*(*(*s_etat_processus)                          .pointeur_variable_partagee_courante).objet).type
                         .s_liste_variables_partagees).table                          == ADR))
                         [(*(*s_etat_processus).s_liste_variables_partagees)  
                         .position_variable].objet).type != ADR))  
                 {                  {
                     if (pthread_mutex_unlock(&((*(*s_etat_processus)                      if (pthread_mutex_unlock(&((*(*s_etat_processus)
                             .s_liste_variables_partagees).mutex)) != 0)                              .pointeur_variable_partagee_courante).mutex)) != 0)
                     {                      {
                         (*s_etat_processus).erreur_systeme = d_es_processus;                          (*s_etat_processus).erreur_systeme = d_es_processus;
                         return;                          return;
Line 985  instruction_detach(struct_processus *s_e Line 972  instruction_detach(struct_processus *s_e
                 }                  }
   
                 if ((s_copie = copie_objet(s_etat_processus,                  if ((s_copie = copie_objet(s_etat_processus,
                         (*(*s_etat_processus).s_liste_variables_partagees).table                          (*(*s_etat_processus)
                         [(*(*s_etat_processus).s_liste_variables_partagees)                          .pointeur_variable_partagee_courante).objet, 'P'))
                         .position_variable].objet, 'P')) == NULL)                          == NULL)
                 {                  {
                     if (pthread_mutex_unlock(&((*(*s_etat_processus)                      if (pthread_mutex_unlock(&((*(*s_etat_processus)
                             .s_liste_variables_partagees).mutex)) != 0)                              .pointeur_variable_partagee_courante).mutex)) != 0)
                     {                      {
                         (*s_etat_processus).erreur_systeme = d_es_processus;                          (*s_etat_processus).erreur_systeme = d_es_processus;
                         return;                          return;
Line 1005  instruction_detach(struct_processus *s_e Line 992  instruction_detach(struct_processus *s_e
                 variable_partagee = d_vrai;                  variable_partagee = d_vrai;
   
                 if (pthread_mutex_unlock(&((*(*s_etat_processus)                  if (pthread_mutex_unlock(&((*(*s_etat_processus)
                         .s_liste_variables_partagees).mutex)) != 0)                          .pointeur_variable_partagee_courante).mutex)) != 0)
                 {                  {
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
Line 1281  instruction_detach(struct_processus *s_e Line 1268  instruction_detach(struct_processus *s_e
          * Processus fils           * Processus fils
          */           */
   
           if (lancement_thread_signaux(s_etat_processus) != d_absence_erreur)
           {
               (*s_etat_processus).erreur_systeme = d_es_processus;
           }
   
         liberation_queue_signaux(s_etat_processus);          liberation_queue_signaux(s_etat_processus);
         creation_queue_signaux(s_etat_processus);          creation_queue_signaux(s_etat_processus);
         routine_recursive = 0;          routine_recursive = 0;
Line 1379  instruction_detach(struct_processus *s_e Line 1371  instruction_detach(struct_processus *s_e
         (*s_etat_processus).liste_mutexes = NULL;          (*s_etat_processus).liste_mutexes = NULL;
   
         liberation_threads(s_etat_processus);          liberation_threads(s_etat_processus);
   
         (*(*s_etat_processus).s_liste_variables_partagees)  
                 .table = NULL;  
         (*(*s_etat_processus).s_liste_variables_partagees)  
                 .nombre_variables = 0;  
         (*(*s_etat_processus).s_liste_variables_partagees)  
                 .nombre_variables_allouees = 0;  
   
         insertion_thread(s_etat_processus, d_vrai);          insertion_thread(s_etat_processus, d_vrai);
   
         // Envoi d'une donnée pour signaler le démarrage du processus au thread          // Envoi d'une donnée pour signaler le démarrage du processus au thread
Line 2593  instruction_detach(struct_processus *s_e Line 2577  instruction_detach(struct_processus *s_e
             l_element_statique_courant = l_element_statique_suivant;              l_element_statique_courant = l_element_statique_suivant;
         }          }
   
           l_element_partage_courant = (*(*s_etat_processus)
                   .l_liste_variables_partagees);
   
           while(l_element_partage_courant != NULL)
           {
               l_element_partage_suivant = (*l_element_partage_courant).suivant;
               free(l_element_partage_courant);
               l_element_partage_courant = l_element_partage_suivant;
           }
   
         if ((*s_etat_processus).entree_standard != NULL)          if ((*s_etat_processus).entree_standard != NULL)
         {          {
             pclose((*s_etat_processus).entree_standard);              pclose((*s_etat_processus).entree_standard);
Line 2617  instruction_detach(struct_processus *s_e Line 2611  instruction_detach(struct_processus *s_e
             (*s_etat_processus).instruction_derniere_erreur = NULL;              (*s_etat_processus).instruction_derniere_erreur = NULL;
         }          }
   
           liberation_arbre_variables_partagees(s_etat_processus,
                   (*(*s_etat_processus).s_arbre_variables_partagees));
         liberation_arbre_variables(s_etat_processus,          liberation_arbre_variables(s_etat_processus,
                 (*s_etat_processus).s_arbre_variables, d_vrai);                  (*s_etat_processus).s_arbre_variables, d_vrai);
         free((*s_etat_processus).pointeurs_caracteres_variables);          free((*s_etat_processus).pointeurs_caracteres_variables);
   
         for(i = 0; i < (*(*s_etat_processus).s_liste_variables_partagees)  
                 .nombre_variables; i++)  
         {  
             liberation(s_etat_processus,  
                     (*(*s_etat_processus).s_liste_variables_partagees)  
                     .table[i].objet);  
             free((*(*s_etat_processus).s_liste_variables_partagees)  
                     .table[i].nom);  
         }  
   
         if ((*(*s_etat_processus).s_liste_variables_partagees).table  
                 != NULL)  
         {  
             free((struct_variable_partagee *)  
                     (*(*s_etat_processus).s_liste_variables_partagees).table);  
         }  
   
         pthread_mutex_destroy(&((*(*s_etat_processus)  
                 .s_liste_variables_partagees).mutex));  
   
         l_element_courant = (*s_etat_processus).l_base_pile;          l_element_courant = (*s_etat_processus).l_base_pile;
         while(l_element_courant != NULL)          while(l_element_courant != NULL)
         {          {
Line 2837  instruction_detach(struct_processus *s_e Line 2813  instruction_detach(struct_processus *s_e
   
         destruction_queue_signaux(s_etat_processus);          destruction_queue_signaux(s_etat_processus);
         liberation_contexte_cas(s_etat_processus);          liberation_contexte_cas(s_etat_processus);
           arret_thread_signaux(s_etat_processus);
         free(s_etat_processus);          free(s_etat_processus);
   
 #       ifdef DEBUG_MEMOIRE  #       ifdef DEBUG_MEMOIRE

Removed from v.1.95  
changed lines
  Added in v.1.98


CVSweb interface <joel.bertrand@systella.fr>