[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.112 and 1.127

version 1.112, 2015/01/05 13:12:32 version 1.127, 2016/03/01 22:12:27
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.19    RPL/2 (R) version 4.1.25
   Copyright (C) 1989-2015 Dr. BERTRAND Joël    Copyright (C) 1989-2016 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
   
Line 926  liberation(struct_processus *s_etat_proc Line 926  liberation(struct_processus *s_etat_proc
                 return;                  return;
             }              }
   
             free((unsigned char *) ((*s_objet).objet));              free((unsigned char *) (*s_objet).objet);
             break;              break;
         }          }
   
Line 2434  copie_objet(struct_processus *s_etat_pro Line 2434  copie_objet(struct_processus *s_etat_pro
                     (*((struct_socket *) ((*s_objet).objet))).pid;                      (*((struct_socket *) ((*s_objet).objet))).pid;
             (*((struct_socket *) ((*s_nouvel_objet).objet))).tid =              (*((struct_socket *) ((*s_nouvel_objet).objet))).tid =
                     (*((struct_socket *) ((*s_objet).objet))).tid;                      (*((struct_socket *) ((*s_objet).objet))).tid;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).options =
                       (*((struct_socket *) ((*s_objet).objet))).options;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).priorite =
                       (*((struct_socket *) ((*s_objet).objet))).priorite;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).buffer_reception =
                       (*((struct_socket *) ((*s_objet).objet))).buffer_reception;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).buffer_emission =
                       (*((struct_socket *) ((*s_objet).objet))).buffer_emission;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).timeout_reception =
                       (*((struct_socket *) ((*s_objet).objet))).timeout_reception;
               (*((struct_socket *) ((*s_nouvel_objet).objet))).timeout_emission =
                       (*((struct_socket *) ((*s_objet).objet))).timeout_emission;
   
             if (((*((struct_socket *) ((*s_nouvel_objet).objet))).format =              if (((*((struct_socket *) ((*s_nouvel_objet).objet))).format =
                     copie_objet(s_etat_processus, (*((struct_socket *)                      copie_objet(s_etat_processus, (*((struct_socket *)
Line 2843  copie_etat_processus(struct_processus *s Line 2855  copie_etat_processus(struct_processus *s
         return(NULL);          return(NULL);
     }      }
   
     if ((s_nouvel_etat_processus = malloc(sizeof(struct_processus))) == NULL)      if ((s_nouvel_etat_processus = sys_malloc(sizeof(struct_processus)))
               == NULL)
     {      {
           if (pthread_mutex_unlock(&((*s_etat_processus)
                   .mutex_pile_processus)) != 0)
           {
               (*s_etat_processus).erreur_systeme = d_es_processus;
               return(NULL);
           }
   
         (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;          (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
         return(NULL);          return(NULL);
     }      }
   
     (*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 2931  copie_etat_processus(struct_processus *s Line 2964  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 3011  copie_etat_processus(struct_processus *s Line 3044  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 3036  copie_etat_processus(struct_processus *s Line 3070  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 3061  copie_etat_processus(struct_processus *s Line 3096  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 3086  copie_etat_processus(struct_processus *s Line 3121  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 3111  copie_etat_processus(struct_processus *s Line 3146  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 3136  copie_etat_processus(struct_processus *s Line 3171  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 3186  copie_etat_processus(struct_processus *s Line 3221  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 3295  copie_etat_processus(struct_processus *s Line 3331  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 3343  copie_etat_processus(struct_processus *s Line 3380  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 3396  copie_etat_processus(struct_processus *s Line 3434  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 3444  copie_etat_processus(struct_processus *s Line 3483  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 3457  copie_etat_processus(struct_processus *s Line 3497  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 3473  copie_etat_processus(struct_processus *s Line 3513  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 3508  copie_etat_processus(struct_processus *s Line 3549  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 3519  copie_etat_processus(struct_processus *s Line 3560  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 3530  copie_etat_processus(struct_processus *s Line 3572  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 3572  copie_etat_processus(struct_processus *s Line 3614  copie_etat_processus(struct_processus *s
   
     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_allocation),      pthread_mutex_init(&((*s_nouvel_etat_processus).protection_liste_mutexes),
             &attributs_mutex);              &attributs_mutex);
     pthread_mutexattr_destroy(&attributs_mutex);      pthread_mutexattr_destroy(&attributs_mutex);
   
Removed from v.1.112  
changed lines
  Added in v.1.127

CVSweb interface <joel.bertrand@systella.fr>