Délivrance de signaux et processus blogué par un sémaphore

Délivrance de signaux et processus blogué par un sémaphore - C++ - Programmation

Marsh Posté le 20-09-2002 à 15:33:48    

J'ai mis un handle sur le signal SIGINT (ctrl+c) de tous mes processus.
Pour les synchroniser j'utilise un sémaphore.
Mais j'ai l'impression que quand un processus est bloqué, il ne reçoit plus du tout les signaux, meme aprés avoir repris la main.
Y a-t-il une option à la con que je n'ai pas encore trouvé qui permette aux processus bloqués d'etre débloqués pour recevoir les signaux ? ou qu'il les exécute dés qu'il reprend la main ?
 
Voici un exemple qui devrait se compiler à coup sur avec un gcc sur une station Sun solaris 9.
Pour les autres, je ne sais pas.  mais y'a que des fork, des printf, et des manips de sémaphores.
En espérant que c'est clair ...
 

Code :
  1. #include <stdio.h>
  2. #include <unistd.h>
  3. #include <signal.h>
  4. #include <sys/types.h>
  5. #include <sys/ipc.h>
  6. #include <sys/sem.h>
  7. #define forever for(;;)
  9. // Déclaration des prototypes des fonctions
  10. void gerer_pere(void);
  11. void gerer_fils(void);
  12. void gerer_sigint(int sig);
  14. // Déclaration des variables globales
  15. int pidf=0;
  17. // Initialisation pour les sémaphores
  18. union semun
  19. {
  20. int val;
  21. struct semid_ds *buf;
  22. ushort *array;
  23. };
  24. union semun arg;
  25. int semid;
  26. struct sembuf prendre={0,1,0},liberer={0,-1,0},attendre={0,0,0};
  27. struct sembuf attente_prise[2]={{0,0,0},{0,1,0}},liberer_sem1={1,-1,0};
  28. ushort sem_val_init[2]={0,1};
  30. int main(int argc,char *argv[])
  31. {
  32. //initialisations spécifiques aux sémaphores
  33. key_t cle;   // Clé unique du syteme IPC
  35. // Création de la clé
  36. if ((cle=ftok(argv[0],'0'))==-1)
  37. {
  38. printf("Probleme sur ftok\n" );
  39. exit(-1);
  40. }
  41. //obtention d'un identificateur pour les sémaphore, ouvert à tout le monde
  42. // sem 0 : pour gérer la réservation de la ressource
  43. // sem 1 : pour que dernier processus sache qu'il doit détruire les sémaphores
  44. if ((semid=semget(cle,2, IPC_CREAT|0666))==-1)
  45. {
  46. printf("impossible d'obtenir une clé\n" );
  47. exit(-1);
  48. }
  49. //initialisation du sémphore
  50. arg.array=sem_val_init;
  51. if (semctl(semid,2,SETALL,arg)==-1)
  52. {
  53. printf("Erreur à l'initialisation\n" );
  54. semctl(semid,IPC_RMID,NULL);  // Effacement du sémaphore
  55. exit(-1);
  56. }
  57. // FIN des initialisations spécifiques aux sémaphores  
  59. switch(pidf=fork())
  60. {
  61. case -1: //fork a renvoyé -1, c'est au père, il n'y a pas de fils car c'est un code d'échec
  62.  {
  63.  printf("Création du filsl impossible\n" );
  64.  exit(-1);
  65.  break;
  66.  }
  67. case 0:  // fork a renvoyé 0 : on est donc dans le processus fils processus fils  
  68.  {
  69.  gerer_fils();
  70.  break;
  71.  }
  72. default: gerer_pere(); // fork a renvoyé une autre valeur : c'est le PID du fils pour le processus du père
  73. }
  75. raise(SIGINT);
  77. }
  80. void gerer_pere(void)
  81. {
  82. int i=0;
  83. signal(SIGINT,gerer_sigint);
  84. sleep(srand(getpid())%5);
  86. semop(semid,attente_prise,2); // Attente de libération de l'écran et prise s'il est libre
  88. printf("Pere actif: PID= %d\n",getpid());
  89. for (i=0;i<10;i++)
  90. {
  91. printf("Père\n" );
  92. sleep(1);
  93. }
  94. semop(semid,&liberer,1);  // Libération de la ressource
  95. }
  98. void gerer_fils(void)
  99. {
  100. int i=0;
  101. signal(SIGINT,gerer_sigint);
  102. sleep(srand(getpid())%5);
  104. semop(semid,attente_prise,2); // Attente de libération de l'écran et prise s'il est libre
  105. printf("Fils actif: PID= %d\n",getpid());
  106. for (i=0;i<10;i++)
  107. {
  108. printf("Fils\n" );
  109. sleep(1);
  110. }
  111. semop(semid,&liberer,1);  // Libération de la ressource
  112. }
  114. void gerer_sigint(int sig)
  115. {
  117. // Effacement du sémaphore : il faut le lire, mais sans bloquer le processus
  118. if (semctl(semid,1,GETVAL)==1) semop(semid,&liberer_sem1,1); //c'est le premier processus qui passe qui décrémente
  119. else semctl(semid,IPC_RMID,NULL); // Effacement des sémaphores
  121. exit(0);
  122. }


Message édité par Bon_sang le 20-09-2002 à 15:39:25
Reply

Marsh Posté le 20-09-2002 à 15:33:48   

Reply

Marsh Posté le 27-09-2002 à 11:31:33    

Et y a-t-il d'autres endoits où chercher sur le web sur ce sujet ?
 
 

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed