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

Diff for /rpl/src/gestion_objets.c between versions 1.116 and 1.117

version 1.116, 2015/01/30 07:53:14 version 1.117, 2015/02/01 09:47:18
Line 2852  copie_etat_processus(struct_processus *s Line 2852  copie_etat_processus(struct_processus *s
   
     (*s_nouvel_etat_processus) = (*s_etat_processus);      (*s_nouvel_etat_processus) = (*s_etat_processus);
   
     // On réinitialise l'allocateur.      // On réinitialise les allocateurs.
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
       pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation_buffer),
               &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
       pthread_mutexattr_init(&attributs_mutex);
       pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
       pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation),
               &attributs_mutex);
       pthread_mutexattr_destroy(&attributs_mutex);
   
     initialisation_allocateur(s_nouvel_etat_processus);      initialisation_allocateur(s_nouvel_etat_processus);
       initialisation_allocateur_buffer(s_nouvel_etat_processus);
   
     /*      /*
      * (*s_etat_processus).definition_chainee,       * (*s_etat_processus).definition_chainee,
Line 2932  copie_etat_processus(struct_processus *s Line 2945  copie_etat_processus(struct_processus *s
   
     // Copie de la localisation      // Copie de la localisation
   
     if (((*s_nouvel_etat_processus).localisation = malloc((strlen(      if (((*s_nouvel_etat_processus).localisation = rpl_malloc(
             (*s_etat_processus).localisation) + 1) * sizeof(unsigned char)))              s_nouvel_etat_processus, (strlen((*s_etat_processus).localisation)
             == NULL)              + 1) * sizeof(unsigned char))) == NULL)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         return(NULL);          return(NULL);
Line 3012  copie_etat_processus(struct_processus *s Line 3025  copie_etat_processus(struct_processus *s
     if (((*s_etat_processus).instruction_courante != NULL) &&      if (((*s_etat_processus).instruction_courante != NULL) &&
             (*s_etat_processus).evaluation_expression_compilee == 'N')              (*s_etat_processus).evaluation_expression_compilee == 'N')
     {      {
         if (((*s_nouvel_etat_processus).instruction_courante = malloc((strlen(          if (((*s_nouvel_etat_processus).instruction_courante = rpl_malloc(
                   s_nouvel_etat_processus, (strlen(
                 (*s_etat_processus).instruction_courante) + 1) *                  (*s_etat_processus).instruction_courante) + 1) *
                 sizeof(unsigned char))) == NULL)                  sizeof(unsigned char))) == NULL)
         {          {
Line 3037  copie_etat_processus(struct_processus *s Line 3051  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).label_x != NULL)      if ((*s_etat_processus).label_x != NULL)
     {      {
         if (((*s_nouvel_etat_processus).label_x = malloc((strlen(          if (((*s_nouvel_etat_processus).label_x = rpl_malloc(
                   s_nouvel_etat_processus, (strlen(
                 (*s_etat_processus).label_x) + 1) *                  (*s_etat_processus).label_x) + 1) *
                 sizeof(unsigned char))) == NULL)                  sizeof(unsigned char))) == NULL)
         {          {
Line 3062  copie_etat_processus(struct_processus *s Line 3077  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).label_y != NULL)      if ((*s_etat_processus).label_y != NULL)
     {      {
         if (((*s_nouvel_etat_processus).label_y = malloc((strlen(          if (((*s_nouvel_etat_processus).label_y = rpl_malloc(
                 (*s_etat_processus).label_y) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).label_y)
                 sizeof(unsigned char))) == NULL)                  + 1) * sizeof(unsigned char))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3087  copie_etat_processus(struct_processus *s Line 3102  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).label_z != NULL)      if ((*s_etat_processus).label_z != NULL)
     {      {
         if (((*s_nouvel_etat_processus).label_z = malloc((strlen(          if (((*s_nouvel_etat_processus).label_z = rpl_malloc(
                 (*s_etat_processus).label_z) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).label_z)
                 sizeof(unsigned char))) == NULL)                  + 1) * sizeof(unsigned char))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3112  copie_etat_processus(struct_processus *s Line 3127  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).titre != NULL)      if ((*s_etat_processus).titre != NULL)
     {      {
         if (((*s_nouvel_etat_processus).titre = malloc((strlen(          if (((*s_nouvel_etat_processus).titre = rpl_malloc(
                 (*s_etat_processus).titre) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).titre) + 1)
                 sizeof(unsigned char))) == NULL)                  * sizeof(unsigned char))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3137  copie_etat_processus(struct_processus *s Line 3152  copie_etat_processus(struct_processus *s
   
     if ((*s_etat_processus).legende != NULL)      if ((*s_etat_processus).legende != NULL)
     {      {
         if (((*s_nouvel_etat_processus).legende = malloc((strlen(          if (((*s_nouvel_etat_processus).legende = rpl_malloc(
                 (*s_etat_processus).legende) + 1) *                  s_nouvel_etat_processus, (strlen((*s_etat_processus).legende)
                 sizeof(unsigned char))) == NULL)                  + 1) * sizeof(unsigned char))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3187  copie_etat_processus(struct_processus *s Line 3202  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3296  copie_etat_processus(struct_processus *s Line 3312  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3344  copie_etat_processus(struct_processus *s Line 3361  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3397  copie_etat_processus(struct_processus *s Line 3415  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3445  copie_etat_processus(struct_processus *s Line 3464  copie_etat_processus(struct_processus *s
   
     while(l_element_lecture != NULL)      while(l_element_lecture != NULL)
     {      {
         if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)          if ((l_element_suivant = rpl_malloc(s_nouvel_etat_processus,
                   sizeof(struct_liste_chainee))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
                     .mutex_pile_processus)) != 0)                      .mutex_pile_processus)) != 0)
Line 3458  copie_etat_processus(struct_processus *s Line 3478  copie_etat_processus(struct_processus *s
             return(NULL);              return(NULL);
         }          }
   
         if (((*l_element_suivant).donnee = malloc(sizeof(struct_bibliotheque)))          if (((*l_element_suivant).donnee = rpl_malloc(s_nouvel_etat_processus,
                 == NULL)                  sizeof(struct_bibliotheque))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;              (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
             return(NULL);              return(NULL);
Line 3474  copie_etat_processus(struct_processus *s Line 3494  copie_etat_processus(struct_processus *s
                 = (*((struct_bibliotheque *) (*l_element_lecture).donnee)).tid;                  = (*((struct_bibliotheque *) (*l_element_lecture).donnee)).tid;
   
         if (((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom =          if (((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom =
                 malloc((strlen((*((struct_bibliotheque *) (*l_element_lecture)                  rpl_malloc(s_nouvel_etat_processus,
                   (strlen((*((struct_bibliotheque *) (*l_element_lecture)
                 .donnee)).nom) + 1) * sizeof(unsigned char))) == NULL)                  .donnee)).nom) + 1) * sizeof(unsigned char))) == NULL)
         {          {
             if (pthread_mutex_unlock(&((*s_etat_processus)              if (pthread_mutex_unlock(&((*s_etat_processus)
Line 3509  copie_etat_processus(struct_processus *s Line 3530  copie_etat_processus(struct_processus *s
     if ((*s_etat_processus).nombre_instructions_externes != 0)      if ((*s_etat_processus).nombre_instructions_externes != 0)
     {      {
         if (((*s_nouvel_etat_processus).s_instructions_externes =          if (((*s_nouvel_etat_processus).s_instructions_externes =
                 malloc(((size_t) (*s_etat_processus)                  rpl_malloc(s_nouvel_etat_processus, ((size_t)
                 .nombre_instructions_externes) *                  (*s_etat_processus).nombre_instructions_externes) *
                 sizeof(struct_instruction_externe))) == NULL)                  sizeof(struct_instruction_externe))) == NULL)
         {          {
             (*s_etat_processus).erreur_systeme = d_es_processus;              (*s_etat_processus).erreur_systeme = d_es_processus;
Line 3520  copie_etat_processus(struct_processus *s Line 3541  copie_etat_processus(struct_processus *s
         for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)          for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)
         {          {
             if (((*s_nouvel_etat_processus).s_instructions_externes[i].nom =              if (((*s_nouvel_etat_processus).s_instructions_externes[i].nom =
                     malloc((strlen((*s_etat_processus).s_instructions_externes                      rpl_malloc(s_nouvel_etat_processus,
                       (strlen((*s_etat_processus).s_instructions_externes
                     [i].nom) + 1) * sizeof(unsigned char))) == NULL)                      [i].nom) + 1) * sizeof(unsigned char))) == NULL)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
Line 3531  copie_etat_processus(struct_processus *s Line 3553  copie_etat_processus(struct_processus *s
                     (*s_etat_processus).s_instructions_externes[i].nom);                      (*s_etat_processus).s_instructions_externes[i].nom);
   
             if (((*s_nouvel_etat_processus).s_instructions_externes[i]              if (((*s_nouvel_etat_processus).s_instructions_externes[i]
                     .nom_bibliotheque = malloc((strlen((*s_etat_processus)                      .nom_bibliotheque = rpl_malloc(s_nouvel_etat_processus,
                     .s_instructions_externes[i].nom_bibliotheque) + 1) *                      (strlen((*s_etat_processus).s_instructions_externes[i]
                     sizeof(unsigned char))) == NULL)                      .nom_bibliotheque) + 1) * sizeof(unsigned char))) == NULL)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return(NULL);                  return(NULL);
Line 3553  copie_etat_processus(struct_processus *s Line 3575  copie_etat_processus(struct_processus *s
         (*s_nouvel_etat_processus).s_instructions_externes = NULL;          (*s_nouvel_etat_processus).s_instructions_externes = NULL;
     }      }
   
     initialisation_allocateur_buffer(s_nouvel_etat_processus);  
   
     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_nouvel_etat_processus).mutex_pile_processus),      pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_pile_processus),
Line 3573  copie_etat_processus(struct_processus *s Line 3593  copie_etat_processus(struct_processus *s
             &attributs_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_nouvel_etat_processus).mutex_allocation),  
             &attributs_mutex);  
     pthread_mutexattr_destroy(&attributs_mutex);  
   
     pthread_mutexattr_init(&attributs_mutex);  
     pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);  
     pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation_buffer),  
             &attributs_mutex);  
     pthread_mutexattr_destroy(&attributs_mutex);  
   
     if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)      if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
     {      {
         (*s_etat_processus).erreur_systeme = d_es_processus;          (*s_etat_processus).erreur_systeme = d_es_processus;
Removed from v.1.116  
changed lines
  Added in v.1.117

CVSweb interface <joel.bertrand@systella.fr>