[D7][Mutex]Exclusion inter application

Version imprimable

12/10/2006, 16h16
jbat

[D7][Mutex]Exclusion inter application

Hello,

Contexte :

Deux applications sur un même PC.

Ma première application crée un mutex (CreateMutex) avec le nom d'objet "Toto". Le resultat du CreateMutex est le handle du mutex crée et vaut par exemple : 1724.

Ma seconde application crée un mutex (CreateMutex) avec le nom d'objet "Toto". La création est censé échouer car le mutex a déjà été crée. La seconde application change alors de tactique et récupère le handle du mutex "Toto" (OpenMutex). Le resultat du OpenMutex est le handle du mutex récupéré et vaut par exemple : 2628.

Question1 :
Le handle du mutex crée/récupéré dans les deux applications ne devraient-il pas être le même ? par exemple 1724 dans les deux applications ?

Question2 :
En utilisant ce mutex dans mes deux application avec les fonction WaitForSingleObject et ReleaseMutex, vais-je réussir à éviter un accès concurent à une même ressources par les deux applications ?

Vos lumières sur ces deux questions me seraient bien utiles... Si j'ai dit des bétises, n'hésitez pas non plus à me rectifier. ;)
13/10/2006, 13h00
jbat

Personne ne saurai me répondre ? :|
13/10/2006, 13h02
Jipété

Mets-nous un bout de code, on pourra tester !
--
jp

Pour tester si le mutex existe déjà: [FAQ]

Code:

1
2
3
4
 
  SetLastError(NO_ERROR);
  CreateMutex (nil, False, PChar(MonNomDeMutex));
  if GetLastError = ERROR_ALREADY_EXISTS then

13/10/2006, 13h52
PadawanDuDelphi

Citation:

Question2 :
En utilisant ce mutex dans mes deux application avec les fonction WaitForSingleObject et ReleaseMutex, vais-je réussir à éviter un accès concurent à une même ressources par les deux applications ?

Si tu récupère le même identifiant de mutex, alors oui. Les mutex ont étés crés pour ça: gérer les accès au ressources entre des threads qui s'execute séparemment. Attention quand même de na pas bloquer ton appli ou à creer des situations de famines.

@+.

Voici en simplifié ce que je fait... Je vous l'épure un peu sinon, personne ne voudra s'y plonger ;)

J'ai développé la fonction TraceMessage qui ajoute dans un fichier une chaine passée en paramètre.
Chaque programme dans lequel j'ai inclue l'unité contenant TraceMessage peut ainsi espionner son fonctionnement interne... Le fichier "espion" est généré dans le même path que l'application qui espionne.
Ainsi, si deux applications du même répertoire espionnent, elles écrivent dans le même fichier. Je tente de mettre en place un système de mutex afin d'éviter les conflits d'accès à l'espion, sachant que dans le pire des cas, l'espion ne doit pas planter le programme qui espionne.

Voici mon pseudo code :

Deux variables globales :

Code:

1
2
    g_ThreadGestionEspion : TThreadGestionEspion ; //* Thread permettant de gérer les accès concurents a l'espion au sein d'une même application.
    g_SpyMutex : THandle = 0 ; //* Handle du mutex.

Pseudo-code de la fonction TraceMessage

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
procedure TraceMessage(sMessage : string);
    begin
        // Création ou récupération du mutex d'accès au fichier lstmess.csv
        SetLastError(NO_ERROR);
        if(g_SpyMutex = 0)then
        begin
            g_SpyMutex := CreateMutex(nil, false, PChar(sNomMutex)); // <= Création du mutex
        end;
        if (GetLastError=ERROR_ALREADY_EXISTS) then
        begin
            g_SpyMutex := OpenMutex(MUTEX_ALL_ACCESS , false, PChar(sNomMutex)); // <= Recuperation du mutex si déjà existant
        end;

        // Réservation du mutex
        WaitForSingleObject(g_SpyMutex,INFINITE); // <= Utilisation du mutex
        try
            // Création de l'objet à tracer dans l'espion
	    SpyMessage := TSpyMessage.create(...);
            // Création ou réutilisation du thread de gestion de l'espion.
            if(not(Assigned(g_ThreadGestionEspion)))then
	    begin
	    	g_ThreadGestionEspion := TThreadGestionEspion.create(false,true);
	    end;
	    // Dépot de l'objet à tracer dans l'espion sur le dessus de la pile des objets à tracer.
            g_ThreadGestionEspion.Addmessage(SpyMessage);
        Finally
            // Libération du mutex d'accès au fichier lstmess.scv
            ReleaseMutex(g_SpyMutex);// <= Liberation du mutex
        end;
    end;

Et maintenant, voici le pseudo code du thread qui dépile les messages et qui, lui seul, est autorisé à écrire dans le fichier espion. Evidemment, Si deux applications espionnent dans le même répertoire, chaque appli aura son thread d'écriture dans l'espion. C'est pourquoi les threads utilisent le mutex "g_SpyMutex" créé dans TraceMessage.

Un morceau de la déclaration de la classe TThreadGestionEspion :

Code:

1
2
3
4
5
  TThreadGestionEspion = class(TThread)
  private
    { Déclarations privées }
    m_slMessages : tstringList ;
   [...etc...]

Pseudo-code de la fonction Execute du TThreadGestionEspion :

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
44
45
46
47
48
49
50
51
52
53
54
procedure TThreadGestionEspion.Execute;
	var
	sMessage : string ;
	slListeErreurs : tstringList ;
    begin
        repeat
            sleep(10);
            Application.ProcessMessages();
            // Réservation du mutex
            WaitForSingleObject(g_SpyMutex,INFINITE);// <= Utilisation du mutex
            try
                if(m_slMessages.count>0)then
                begin
                    // Récupération du plus vieux SpyMessage en attente d'insertion dans le fichier lstmess.csv
                    m_slMessages := Liste.strings[0];
                    
                    slListeErreurs.Clear ;
                    if(FileExists(ExtractFilePath(sModuleName)+'lstMess.csv')=true)then
                    begin
	                    try
	                        slListeErreurs.LoadFromFile(ExtractFilePath(sModuleName)+'lstMess.csv');
	                        Except on E:exception do
	                        begin
	                            // Rien du tout, ce n'est pas grave.
	                            Continue ;
	                        end;
	                    end;
                        // On teste la capacité du fichier pour éviter les débordements
                    end;
                    slListeErreurs.Insert(0,sMessage);
                    try
                        slListeErreurs.SaveToFile(ExtractFilePath(sModuleName)+'lstMess.csv');
                        bSuccesSpy := true ;
                        except on E : exception do
                        begin
                            // Rien du tout, ce n'est pas grave.
                            Continue ;
                        end;
                    end;
                    if(bSuccesSpy)then
                    begin
                        // Suppression du SpyMessage que l'on viens de réussir à insérer dans le fichier lstmess.csv
                        TSpyMessage(m_slMessages.Objects[0]).free ;
                        m_slMessages.Delete(0);
                    end;
                end;
            Finally
                // Libération du mutex d'accès au fichier lstmess.scv
                ReleaseMutex(g_SpyMutex);// <= Liberation du mutex
            end;
        until (terminated) ;
        slListeErreurs.Free ;
        slListeErreurs := nil ;
    end;

13/10/2006, 15h50
PadawanDuDelphi

J'voue que j'ai vraiment la flemme de me lancer dans un code à base de Mutex.... ;) .
Pourrais-tu simplement indiqué la ligne de création avec son handle et celles qui récupèrent un mauvais handle?

J'aurais quand même deux questions:
1) Est-ce que ton programme fonctionne si la récupération du mutex appartient à la même application que celle de sa création?
2)Est-ce que un second mutex est crée (c'est envisagle puisque tu as deux handle différents)?

@+.

Voilà, j'ai mis un peu de gras dans mon pseudo-code pour vous en faciliter la lecture.

Comme j'espionne également l'utilisation des mutex afin de comprendre où ça pourrait clocher, voici un extrait de ma trace révélateur du problème :

Une dll de mon cru utilise l'espion via la fonction TraceMessage
Le programme chargé de tester cette même dll utilise la même fonction pour s'espionner lui même.
Code:

1 2 3 4 5 6 7 8 9 Le plus récent Date Application NomFonction Opération réalisée N°Hdle utilisé Nom Mutex utilisé pour le CreateMutex ou le OpenMutex 16/10/2006 09:32:56 Dtt.dll (2.2.0.0) TraceMessageV02() ReleaseMutex 3728 16/10/2006 09:32:56 Dtt.dll (2.2.0.0) TraceMessageV02() WaitForSingleObject 3728 16/10/2006 09:32:56 Dtt.dll (2.2.0.0) TraceMessageV02() OpenMutex 3728 SPYMUTEXDDOCUMENTSANDSETTINGSAWATREJMYDOCUMENTSPROGMKSSOURCESDTT2 16/10/2006 09:32:56 Testeur_Dtt () TraceMessageV02() ReleaseMutex 3772 16/10/2006 09:32:56 Testeur_Dtt () TraceMessageV02() WaitForSingleObject 3772 16/10/2006 09:32:56 Testeur_Dtt () TraceMessageV02() CreateMutex 3772 SPYMUTEXDDOCUMENTSANDSETTINGSAWATREJMYDOCUMENTSPROGMKSSOURCESDTT2 Le plus vieux
Je n'ai mis que le début de la trace, mais par la suite, chacune des app continue à utiliser son mutex dans son coin...
Je n'utilise jamais CloseHandle() sur le mutex qui nous intéresse car je n'ai pas moyen de savoir si le mutex est encore où non utilisé par une application externe.

Je rappèle mon problème : Je m'étonne que le numéro du Handle ne soit pas le même dans mes deux app et je me demande donc si ma protection par mutex est efficace...