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

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

version 1.116, 2019/02/11 09:45:52 version 1.117, 2019/02/12 14:38:43
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
   #           ifndef SEMAPHORES_NOMMES
                   if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
   #           else
                   if (sem_post((*s_etat_processus).semaphore_fork) != 0)
   #           endif
               {
                   (*s_etat_processus).erreur_systeme = d_es_processus;
                   return;
               }
   
             if (pthread_mutex_lock(&mutex_sigaction) != 0)              if (pthread_mutex_lock(&mutex_sigaction) != 0)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_processus;                  (*s_etat_processus).erreur_systeme = d_es_processus;
Line 1748  instruction_write(struct_processus *s_et Line 1758  instruction_write(struct_processus *s_et
                 return;                  return;
             }              }
   
 #           ifndef SEMAPHORES_NOMMES  
                 if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)  
 #           else  
                 if (sem_post((*s_etat_processus).semaphore_fork) != 0)  
 #           endif  
             {  
                 if (sigaction(SIGPIPE, &registre, NULL) != 0)  
                 {  
                     pthread_mutex_unlock(&mutex_sigaction);  
                     (*s_etat_processus).erreur_systeme = d_es_signal;  
                     return;  
                 }  
   
                 pthread_mutex_unlock(&mutex_sigaction);  
                 (*s_etat_processus).erreur_systeme = d_es_processus;  
                 return;  
             }  
   
             if (send((*((struct_socket *) (*s_objet_argument_1).objet))              if (send((*((struct_socket *) (*s_objet_argument_1).objet))
                     .socket, chaine, (size_t) longueur_effective, 0) < 0)                      .socket, chaine, (size_t) longueur_effective, 0) < 0)
             {              {
Line 1808  instruction_write(struct_processus *s_et Line 1800  instruction_write(struct_processus *s_et
                 return;                  return;
             }              }
   
               if (sigaction(SIGPIPE, &registre, NULL) != 0)
               {
                   pthread_mutex_unlock(&mutex_sigaction);
   
   #               ifndef SEMAPHORES_NOMMES
                       while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
   #               else
                       while(sem_wait((*s_etat_processus).semaphore_fork) != 0)
   #               endif
                   {
                       if (errno != EINTR)
                       {
                           if (sigaction(SIGPIPE, &registre, NULL) != 0)
                           {
                               pthread_mutex_unlock(&mutex_sigaction);
                               (*s_etat_processus).erreur_systeme = d_es_signal;
                               return;
                           }
   
                           pthread_mutex_unlock(&mutex_sigaction);
                           (*s_etat_processus).erreur_systeme = d_es_processus;
                           return;
                       }
                   }
   
                   (*s_etat_processus).erreur_systeme = d_es_signal;
                   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 1818  instruction_write(struct_processus *s_et Line 1845  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;
                 }                  }
             }              }
   
             if (sigaction(SIGPIPE, &registre, NULL) != 0)  
             {  
                 pthread_mutex_unlock(&mutex_sigaction);  
                 (*s_etat_processus).erreur_systeme = d_es_signal;  
                 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.116  
changed lines
  Added in v.1.117

CVSweb interface <joel.bertrand@systella.fr>