[SIGNAL] threads et processus

Version imprimable

20/12/2004, 21h59
beLz

[SIGNAL] threads et processus
Salut,

j'ai une question concernant les signaux dans les threads et fork. Je cherche en fait a voir qu'est ce qui est hérité et qu'est ce qui ne l'est pas. Je fais en fait
Code:

1 2 signal(SIGINT, myfunc);
dans mon processus pere. Mon processus pere fork d'abord plusieurs fois pui s crée 2 threads. J'ai donc un certain nombre de fils et 2 threads. Je cherche lorsque je fais ctrl-c a quitter proprement cad a vider mes sémaphores. Le probleme est qu'en définissant comme ca et dans mon pere seuls les processus fils captent le signal et lance myfunc. Mais il y a donc x tentatives de suppression de sémaphores => ca foire !

Ce que je voudrais c'est juste effacer une seule fois mes sémaphores. J'ai donc pensé à capter le signal ctrl-c dans un seul thread du pere mais il capte rien du tout.

Comment faire???

merci de vos éclaircissements :)
20/12/2004, 22h33
Pouic
Salut,

La, comme ca, je dirais que l'utilisation d'une variable globale serait une bonne solution (si on ne veut pas se compliquer la vie :wink: )

en global:
Code:

1 2 int check = 0;
et dans ton handler de signaux:
Code:

1 2 3 4 5 6 7 8 9 void sighandler(int s){ .... if ( !check){ /* on arrive ici pour la premiere fois: on supprime ce qu'il y a à supprimer */ check = 1; } ..... }
=> il faut proteger la portion de code avec le test par des semaphores si plusieurs processus sont susceptibles d'acceder a ce handler en même temps...

++
Pouic
20/12/2004, 22h47
beLz

J'ai plusieurs remarques :

la premiere est que jpeux me tromper mais l'handler est pour définir les SIGUSR nan ?
La seconde est que tout mon probleme est que c'est obligé le pere qui doit faire le nettoyage. Donc je sais pas comment les threads vont entre eux se répartir le captage du signal. si je fais

Code:

signal(SIGINT, myfunc)

avant de faire mes threads j'aurai le signal définit pour tous mes threads. Donc logiquement 3 appels de myfunc duquel je ne dois faire qu'une fois la routine de nettoyage. Ce que j'avais fait a l'origine c'est de laisser mes fils mourir avec le ctrl-c mais capter le signal dans 1 seul des threads... mais évidement ca fonctionne pas il capte rien du tout...
20/12/2004, 23h04
Pouic

Citation:

Envoyé par beLz

J'ai plusieurs remarques :

la premiere est que jpeux me tromper mais l'handler est pour définir les SIGUSR nan ?

Non. Tu peux redefinir le traitement de presque tous les signaux (sauf deux, mais je ne m'en rapelle jamais).

Citation:

Code:

signal(SIGINT, myfunc)

il me semble que l'utilisation de la fonction signal est desuet: il faut utiliser a la place sigaction (mais bon, ce n'est pas très important dans le contexte)

et enfin, je ne comprend pas ce qui te pose probleme dans ma solution ?

++
Pouic
20/12/2004, 23h07
beLz

mon probleme est que seul mes fils répondent au signal que je catche. Le pere n'a pas l'air de s'en soucier. Alors que je voudrai que ce soit le pere qui attrape le signal.

Je vais continuer a chercher je continuerai de t'ennuyer si ca fonctionne pas ;)

merci quand meme :p
20/12/2004, 23h13
Pouic

Citation:

Envoyé par beLz

mon probleme est que seul mes fils répondent au signal que je catche. Le pere n'a pas l'air de s'en soucier. Alors que je voudrai que ce soit le pere qui attrape le signal.

Tiens.... Ce n'est pas normal, ça.... Tu peux montrer ton code s'il n'est pas trop long ? (ou l'uploader sur un ftp sinon)

Et quant à m'ennuyer, il n'y a pas de problemes: j'espere que tu trouvera rapidemment ta reponse ! :wink: :lol:

++
Pouic

bon jte poste en gros un code raccourcis :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
int main(int argc, char *argv) {
 
// Un tas d'opérations
 
for (i=0; i < max; i++) {
PIDS[i]=fork();
if (PIDS[i]==0) { break; }
}
 
if (PIDS[current] == 0) {
// on est dans un fils
startFils(current);
}
else {
signal(SIGINT, cleanAll);
if (pthead_create(&mythread1, NULL, funmythread1, NULL)  < 0) {
cleanAll();
}
if (pthead_create(&mythread2, NULL, funmythread2, NULL)  < 0) {
cleanAll();
}
// création de shmem
 
while(TRUE) {
downmutex(mymutex);
//ops
}
}
}
void cleanAll() {
// enlever les semaphores et les sh mem
exit(EXIT_SUCCESS);
}
 
void *funmythread1() {
signal(SIGINT, NULL);
// ops
}
void *funmythread2() {
signal(SIGINT, NULL);
// ops
}

Voila j'espere que c'est plus clair comme ca :)

merci bcp de ton aide :)

21/12/2004, 00h11
Pouic
hmmm, etrange....
Deja, moi, je sortirais ceci des fonctions associees aux thread: ce n'est pas necessaire.
Code:

1 2 signal(SIGINT, cleanAll);
J ai fais un test rapidemment sur un programme semblable au tiens (au niveau de la structure), et pour moi, , il n'y a que le pere qui capte le signal...
Je dois t'avouer que je ne vois pas trop ce qui se passe.... :?
Si c'est trop long pour que ce soit lisible sur le forum, tu peux m'envoyer ton code complet par mp (si tu ne peux pas l'uploader)?
21/12/2004, 00h22
beLz

je t'ai envoyé ca en mp.

merci de ton aide :roll:
21/12/2004, 00h39
Emmanuel Delahaye

Citation:

Envoyé par Pouic

La, comme ca, je dirais que l'utilisation d'une variable globale serait une bonne solution (si on ne veut pas se compliquer la vie :wink: )

en global:

Code:

int check = 0;

En toute rigueur:

Code:

sig_atomic_t check = 0;

Ce type est défini dans <signal.h>
21/12/2004, 00h44
beLz

euuuuh oui :)

le sig_atomic_t n'est pas un typedef int ?

si oui alors qu'est ce que ca change ?
Juste pour la beauté d'utiliser les bons types ?

Citation:

Envoyé par beLz

le sig_atomic_t n'est pas un typedef int ?

Sur ton implémentation, peut être...

Code:

1
2
3
4
5
6
7
8
9
 
d:\Program Files\Microsoft Visual Studio\VC98\Include\SIGNAL.H(59): typedef int sig_atomic_t;
d:\Program Files\Microsoft Visual Studio\VC98\CRT\SRC\SIGNAL.H(73): typedef int sig_atomic_t;
d:\BC\INCLUDE\SIGNAL.H(16): typedef int sig_atomic_t;   /* Atomic entity type (ANSI) */
d:\BCC55\INCLUDE\SIGNAL.H(49): typedef int sig_atomic_t;   /* Atomic entity type (ANSI) */
d:\DJGPP.NEW\include\signal.h(31): typedef int sig_atomic_t;
d:\TC\INCLUDE\SIGNAL.H(19): typedef int	sig_atomic_t; 	/* Atomic entity type (ANSI) */
d:\Djgpp_\include\signal.h(31): typedef int sig_atomic_t;
d:\Djgpp_\rsxntdj\include\sys\signal.h(10): typedef int sig_atomic_t;

Citation:

si oui alors qu'est ce que ca change ?
Juste pour la beauté d'utiliser les bons types ?

A écrire du code portable.

21/12/2004, 00h55
Pouic
Citation:

Envoyé par Emmanuel Delahaye

En toute rigueur:

Code:

sig_atomic_t check = 0;

Ce type est défini dans <signal.h>

Arf, oui, en plus tu me l'as déja dis... desolé...

@beLz:
8O effectivement, tu ne pouvais pas le poster ici :wink:
Comme je n'avais pas les .h pour tester tout ca... :roll:
Mais je pense que ton probleme vient du fait que tu n'utilises pas les bonnes fonctions de signaux:
Ce que tu devrais faire (a mon avis):
Dans le pere (au tout debut):
Code:

1 2 3 4 5 6 struct sigaction action; sigemptyset(&action.sa_mask); action.sa_flags = 0; action.sa_handler = exitCleanly; sigaction (SIGINT, &action, NULL); /* on redefinit le traitement */
Dans les fils:
Code:

1 2 3 4 sigset_t mask; sigaddset(&mask, SIGINT); sigprocmask(SIG_SETMASK, &mask, NULL); /* les fils ne voient plus SIGINT */
et dans les threads:
Code:

1 2 3 4 sigset_t mask_thread; sigaddset(&mask_thread, SIGINT); pthread_sigmask(SIG_SETMASK, &mask_thread, NULL); /* les thread non plus ! */
Avec ca, si quelqu'un d'autre que le pere capte le signal SIGINT, je ne comprends vraiment plus rien .....
21/12/2004, 01h14
beLz

ben voila ca fonctionne nickel :)

visiblement l'appel de sigaction, sigmask et tout et tout est bcp plus fiable que signal()...

Un énorme merci a toi :)

ps : quand un probleme disparait, un autre surgit ^^ mais jsuis pas sur qu'il attendra pas demain.. on verra ;)
ps2 : simple précision t'as juste fait une erreur de frappe au sigsmask :) jdis ca si qq cherchait a utiliser le code :)
21/12/2004, 01h28
Pouic

hop, édité !
Sinon, la fonction signal peut sembler bien pratique parcequ'il y a moins de parametres a mettre en place, mais elle est deprecated (enfin il me semble)
Je recommande l'utilisation de la fonction sigaction a la place (ainsi que les fonctions associées: sigfillset, sigaddset, sigprocmask, sigismember, etc....)

En tout cas, content que ton probleme soit résolu :D

++
Pouic