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

Diff for /rpl/src/interruptions.c between versions 1.81 and 1.89

version 1.81, 2011/09/21 09:09:22 version 1.89, 2011/12/16 13:46:56
Line 1 Line 1
 /*  /*
 ================================================================================  ================================================================================
   RPL/2 (R) version 4.1.3    RPL/2 (R) version 4.1.5
   Copyright (C) 1989-2011 Dr. BERTRAND Joël    Copyright (C) 1989-2011 Dr. BERTRAND Joël
   
   This file is part of RPL/2.    This file is part of RPL/2.
Line 1772  interruption3(int signal) Line 1772  interruption3(int signal)
         kill(pid_processus_pere, SIGUSR1);          kill(pid_processus_pere, SIGUSR1);
     }      }
   
   
     if (signal != SIGUSR2)      if (signal != SIGUSR2)
     {      {
         write(STDERR_FILENO, message_1, strlen(message_1));          write(STDERR_FILENO, message_1, strlen(message_1));
Line 1828  interruption_violation_access(void *adre Line 1827  interruption_violation_access(void *adre
     unsigned char       message[] = "+++System : Trying to catch access "      unsigned char       message[] = "+++System : Trying to catch access "
                                 "violation\n";                                  "violation\n";
   
     static int              compteur_erreur = 0;      static int          compteur_erreur = 0;
   
     if ((gravite == 0) && (routine_recursive != 0))      if ((gravite == 0) && (routine_recursive != 0))
     {      {
Line 1935  signal_stop(struct_processus *s_etat_pro Line 1934  signal_stop(struct_processus *s_etat_pro
   
     if (pid == getpid())      if (pid == getpid())
     {      {
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {  
             deverrouillage_gestionnaire_signaux(s_etat_processus);  
             return;  
         }  
   
         if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)          if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
         {          {
             printf("[%d] RPL/SIGSTOP (thread %llu)\n", (int) getpid(),              printf("[%d] RPL/SIGSTOP (thread %llu)\n", (int) getpid(),
Line 2033  signal_urg(struct_processus *s_etat_proc Line 2025  signal_urg(struct_processus *s_etat_proc
   
     if (pid == getpid())      if (pid == getpid())
     {      {
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {  
             deverrouillage_gestionnaire_signaux(s_etat_processus);  
             return;  
         }  
   
         if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)          if (((*s_etat_processus).type_debug & d_debug_signaux) != 0)
         {          {
             printf("[%d] RPL/SIGURG (thread %llu)\n", (int) getpid(),              printf("[%d] RPL/SIGURG (thread %llu)\n", (int) getpid(),
Line 2089  signal_abort(struct_processus *s_etat_pr Line 2074  signal_abort(struct_processus *s_etat_pr
   
     if (pid == getpid())      if (pid == getpid())
     {      {
         if ((s_etat_processus = recherche_thread(getpid(), pthread_self()))  
                 == NULL)  
         {  
             deverrouillage_gestionnaire_signaux(s_etat_processus);  
             return;  
         }  
   
         (*s_etat_processus).arret_depuis_abort = -1;          (*s_etat_processus).arret_depuis_abort = -1;
   
         /*          /*
Line 2409  nom_segment(unsigned char *chemin, pid_t Line 2387  nom_segment(unsigned char *chemin, pid_t
 int  int
 envoi_signal_processus(pid_t pid, enum signaux_rpl signal)  envoi_signal_processus(pid_t pid, enum signaux_rpl signal)
 {  {
     int                             segment;  #   ifndef OS2
           int                         segment;
   #   endif
   
 #   ifndef IPCS_SYSV  #   ifndef IPCS_SYSV
 #       ifdef SEMAPHORES_NOMMES  #       ifdef SEMAPHORES_NOMMES
             sem_t                   *semaphore;              sem_t                   *semaphore;
 #       endif  #       endif
 #   else  #   else
         int                         desc;  #       ifndef OS2
         key_t                       clef;              int                     desc;
               key_t                   clef;
   #       endif
 #   endif  #   endif
   
     struct_queue_signaux            *queue;      struct_queue_signaux            *queue;
Line 2476  envoi_signal_processus(pid_t pid, enum s Line 2458  envoi_signal_processus(pid_t pid, enum s
                 return(1);                  return(1);
             }              }
   
             if ((desc = open(nom, O_RDWR)) == -1)  #           ifndef OS2 // SysV
             {                  if ((desc = open(nom, O_RDWR)) == -1)
                 free(nom);                  {
                 return(1);                      free(nom);
             }                      return(1);
                   }
   
             close(desc);                  close(desc);
   
                   if ((clef = ftok(nom, 1)) == -1)
                   {
                       free(nom);
                       return(1);
                   }
   
             if ((clef = ftok(nom, 1)) == -1)  
             {  
                 free(nom);                  free(nom);
                 return(1);  
             }  
   
             free(nom);                  if ((segment = shmget(clef, sizeof(struct_queue_signaux), 0))
                           == -1)
                   {
                       return(1);
                   }
   
             if ((segment = shmget(clef, sizeof(struct_queue_signaux), 0)) == -1)                  queue = shmat(segment, NULL, 0);
             {  #           else // OS/2
                 return(1);                  if (DosGetNamedSharedMem((PVOID) &queue, nom,
             }                          PAG_WRITE | PAG_READ) != 0)
                   {
                       free(nom);
                       return(1);
                   }
   
             queue = shmat(segment, NULL, 0);                  free(nom);
   #           endif
 #       else // POSIX  #       else // POSIX
             if ((nom = nom_segment(racine_segment, pid)) == NULL)              if ((nom = nom_segment(racine_segment, pid)) == NULL)
             {              {
Line 2594  envoi_signal_processus(pid_t pid, enum s Line 2588  envoi_signal_processus(pid_t pid, enum s
                 return(1);                  return(1);
             }              }
   
             if (shmdt(queue) != 0)  #           ifndef OS2 // SysV
             {                  if (shmdt(queue) != 0)
                 return(1);                  {
             }                      return(1);
                   }
   #           else // OS/2
                   // Pendant de DosGetNamedSHaredMem()
   #           endif
 #       endif  #       endif
     }      }
   
       kill(pid, SIGALRM);
   
     return(0);      return(0);
 }  }
   
Line 2664  envoi_signal_thread(pthread_t tid, enum Line 2664  envoi_signal_thread(pthread_t tid, enum
         return(1);          return(1);
     }      }
   
       pthread_kill(tid, SIGALRM);
   
     return(0);      return(0);
 }  }
   
Line 2680  envoi_signal_contexte(struct_processus * Line 2682  envoi_signal_contexte(struct_processus *
             % LONGUEUR_QUEUE_SIGNAUX;              % LONGUEUR_QUEUE_SIGNAUX;
     pthread_mutex_unlock(&mutex_interruptions);      pthread_mutex_unlock(&mutex_interruptions);
   
       pthread_kill((*s_etat_processus_a_signaler).tid, SIGALRM);
   
     return(0);      return(0);
 }  }
   
Line 2831  creation_queue_signaux(struct_processus Line 2835  creation_queue_signaux(struct_processus
                 return;                  return;
             }              }
   
             if (DosAllocSharedMem(&ptr_os2, nom, nombre_queues *              if (DosAllocSharedMem((PVOID) &s_queue_signaux, nom,
                     ((2 * longueur_queue) + 4) * sizeof(int),                      sizeof(struct_queue_signaux),
                     PAG_WRITE | PAG_READ | PAG_COMMIT) != 0)                      PAG_WRITE | PAG_READ | PAG_COMMIT) != 0)
             {              {
                 free(nom);                  free(nom);
Line 2841  creation_queue_signaux(struct_processus Line 2845  creation_queue_signaux(struct_processus
             }              }
   
             free(nom);              free(nom);
             fifos = ptr_os2;  
               sem_init(&((*s_queue_signaux).semaphore), 1, 1);
               (*s_queue_signaux).pointeur_lecture = 0;
               (*s_queue_signaux).pointeur_ecriture = 0;
 #       endif  #       endif
 #   endif  #   endif
   
Line 2910  liberation_queue_signaux(struct_processu Line 2917  liberation_queue_signaux(struct_processu
 void  void
 destruction_queue_signaux(struct_processus *s_etat_processus)  destruction_queue_signaux(struct_processus *s_etat_processus)
 {  {
     unsigned char       *nom;  #   ifndef OS2
           unsigned char       *nom;
   #   endif
   
 #   ifdef IPCS_SYSV // SystemV  #   ifdef IPCS_SYSV // SystemV
 #       ifndef OS2  #       ifndef OS2
Line 2946  destruction_queue_signaux(struct_process Line 2955  destruction_queue_signaux(struct_process
             unlink(nom);              unlink(nom);
             free(nom);              free(nom);
 #       else  #       else
             if (DosFreeMem(fifos) != 0)              sem_close(&((*s_queue_signaux).semaphore));
               sem_destroy(&((*s_queue_signaux).semaphore));
   
               if (DosFreeMem(s_queue_signaux) != 0)
             {              {
                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;                  (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
                 return;                  return;
             }              }
   
         // FERMER LE FICHIER  
   
 #       endif  #       endif
 #   else // POSIX  #   else // POSIX
 #       ifndef SEMAPHORES_NOMMES  #       ifndef SEMAPHORES_NOMMES
Removed from v.1.81  
changed lines
  Added in v.1.89

CVSweb interface <joel.bertrand@systella.fr>