Diff for /rpl/src/instructions_w1.c between versions 1.115 and 1.116

version 1.115, 2019/02/09 13:36:41 version 1.116, 2019/02/11 09:45:52
Line 1732  instruction_write(struct_processus *s_et Line 1732  instruction_write(struct_processus *s_et
                 (*s_objet_argument_1).objet)).type,                  (*s_objet_argument_1).objet)).type,
                 "SEQUENTIAL DATAGRAM") == 0))                  "SEQUENTIAL DATAGRAM") == 0))
         { // Sockets connectées          { // Sockets connectées
               if (pthread_mutex_lock(&mutex_sigaction) != 0)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
   
             action.sa_handler = SIG_IGN;              action.sa_handler = SIG_IGN;
             action.sa_flags = 0;              action.sa_flags = 0;
   
             if (sigaction(SIGPIPE, &action, &registre) != 0)              if (sigaction(SIGPIPE, &action, &registre) != 0)
             {              {
                   pthread_mutex_unlock(&mutex_sigaction);
                 (*s_etat_processus).erreur_systeme = d_es_signal;                  (*s_etat_processus).erreur_systeme = d_es_signal;
                 return;                  return;
             }              }
Line 1750  instruction_write(struct_processus *s_et Line 1756  instruction_write(struct_processus *s_et
             {              {
                 if (sigaction(SIGPIPE, &registre, NULL) != 0)                  if (sigaction(SIGPIPE, &registre, NULL) != 0)
                 {                  {
                       pthread_mutex_unlock(&mutex_sigaction);
                     (*s_etat_processus).erreur_systeme = d_es_signal;                      (*s_etat_processus).erreur_systeme = d_es_signal;
                     return;                      return;
                 }                  }
   
                   pthread_mutex_unlock(&mutex_sigaction);
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
                 return;                  return;
             }              }
Line 1765  instruction_write(struct_processus *s_et Line 1773  instruction_write(struct_processus *s_et
   
                 if (sigaction(SIGPIPE, &registre, NULL) != 0)                  if (sigaction(SIGPIPE, &registre, NULL) != 0)
                 {                  {
                       pthread_mutex_unlock(&mutex_sigaction);
                     (*s_etat_processus).erreur_systeme = d_es_signal;                      (*s_etat_processus).erreur_systeme = d_es_signal;
                     return;                      return;
                 }                  }
   
                   if (pthread_mutex_unlock(&mutex_sigaction) != 0)
                   {
                       (*s_etat_processus).erreur_systeme = d_es_processus;
                       return;
                   }
   
 #               ifndef SEMAPHORES_NOMMES  #               ifndef SEMAPHORES_NOMMES
                     while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)                      while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
 #               else  #               else
Line 1803  instruction_write(struct_processus *s_et Line 1818  instruction_write(struct_processus *s_et
                 {                  {
                     if (sigaction(SIGPIPE, &registre, NULL) != 0)                      if (sigaction(SIGPIPE, &registre, NULL) != 0)
                     {                      {
                           pthread_mutex_unlock(&mutex_sigaction);
                         (*s_etat_processus).erreur_systeme = d_es_signal;                          (*s_etat_processus).erreur_systeme = d_es_signal;
                         return;                          return;
                     }                      }
   
                       pthread_mutex_unlock(&mutex_sigaction);
                     (*s_etat_processus).erreur_systeme = d_es_processus;                      (*s_etat_processus).erreur_systeme = d_es_processus;
                     return;                      return;
                 }                  }
Line 1814  instruction_write(struct_processus *s_et Line 1831  instruction_write(struct_processus *s_et
   
             if (sigaction(SIGPIPE, &registre, NULL) != 0)              if (sigaction(SIGPIPE, &registre, NULL) != 0)
             {              {
                   pthread_mutex_unlock(&mutex_sigaction);
                 (*s_etat_processus).erreur_systeme = d_es_signal;                  (*s_etat_processus).erreur_systeme = d_es_signal;
                 return;                  return;
             }              }
   
               if (pthread_mutex_unlock(&mutex_sigaction) != 0)
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
         }          }
         else          else
         { // Sockets non connectées          { // Sockets non connectées

Removed from v.1.115  
changed lines
  Added in v.1.116


CVSweb interface <joel.bertrand@systella.fr>