Discussion :

[robux]

Salut,

J'utilise cette fonction pour synchroniser des evenements sur des fonctions en récupérant l'index de l'évenement en retour.

Ces evenements proviennent de processus clients qui demandent l'instance d'un pipe d'un processus serveur pour lui ecrire un message

ça marche pas mal mais le premier client qui écrit n'est jamais detecté. Le deuxième oui. etc..

Une idée? ça me trotte je trouve pas!

Merci
Robux

[Médinoc]

Es-tu sûr que tu n'as pas une attente avant ta boucle d'attente principale, ou un problème du genre?

[robux]

Salut,

Je traite mon WaitForMultipleObject dans un thread. En pas à pas j'entre dans le thread comme suit :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
void DispatcherRoot::run()
{
	bool lwait = false;

	DWORD i,dwWait,cbRet;
	bool fSuccess;
	while( !mStop )
	{
		dwWait = WaitForMultipleObjects(
			kPipeCount,
			mPlatformSpecificData->hEvent,
			FALSE, // no wait for all 
			INFINITE);
		
		i = dwWait - WAIT_OBJECT_0; // determines which pipes
		
		if (i < 0 || i > (kPipeCount - 1))
		{
			LCTrace("Index pipe out of Range.\n");
			continue;
		}
		
		// Je connais i donc je connais l'event et je traite dans une fonction
}

}

puis l'attente est infini sur la fonction Wait. Je lance mon premier client il ne se passe rien. j'en lance un deuxième le debug commence et je passe à la ligne suivante où i est défini

Donc le premier client est ignoré par le serveur. c'est génant.

Comme il s'agit de pipe voici le code des evenements et pipes créés :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
struct DispatcherRoot::DispatcherRootPlatformSpecificData
{
	char buffer[kMessageBufferSize];	// buffer to store client requests
	
	struct 
	{
		HANDLE hPipe;
		bool fPending;
		DWORD dwState;
	} hPipeStruct[kPipeCount];
	
	OVERLAPPED ovr[kPipeCount];
	HANDLE hEvent[kPipeCount];
	CString pipeName;		//The name of server pipe

};


// Create pipes
	for(int i = 0; i < kPipeCount; i++)
	{
		mPlatformSpecificData->hEvent[i] = 
			CreateEvent(
			NULL,
			TRUE,
			TRUE,
			NULL);
		if(mPlatformSpecificData->hEvent[i] == NULL) 
		{
			LCTrace("Should not happend : CreateEvent failed with %d.\n", GetLastError()); 
			return ;
		}
		mPlatformSpecificData->ovr[i].hEvent = mPlatformSpecificData->hEvent[i]; // je garde les event dans ma structure

		mPlatformSpecificData->hPipeStruct[i].hPipe = CreateNamedPipe( mPlatformSpecificData->pipeName,
		  PIPE_ACCESS_INBOUND | FILE_FLAG_OVERLAPPED,
		  PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
		  kPipeCount, kMessageBufferSize, kMessageBufferSize,
		  0, NULL);

		mPlatformSpecificData->hPipeStruct[i].fPending = ConnectToNewClient(mPlatformSpecificData->hPipeStruct[i].hPipe,&mPlatformSpecificData->ovr[i]);
		if(!mPlatformSpecificData->hPipeStruct[i].fPending)// ConnectNamedPipe should return 0 for an OVERLAPPED pipe
		{
			LCTrace("ConnectNamedPipe has failed");
		}
		mPlatformSpecificData->hPipeStruct[i].dwState = mPlatformSpecificData->hPipeStruct[i].fPending ? CONNECTING_STATE : READING_STATE;
	}

Robux

[Médinoc]

Tes événements sont créés signalés. À quel moment les resettes-tu ?
Que se passe-t-il si un client se connecte entre le moment où tu crées l'event et celui où tu le resettes ? (race condition)

[robux]

Oui je reset les evenements dans la fonction ConnectToNewClient comme suit :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
bool ConnectToNewClient(HANDLE hPipe, LPOVERLAPPED lpo) 
{ 
   BOOL fConnected, fPendingIO = FALSE; 
 
// Start an overlapped connection for this pipe instance. 
   fConnected = ConnectNamedPipe(hPipe, lpo); 
 
// Overlapped ConnectNamedPipe should return zero. 
   if (fConnected) 
   {
      printf("ConnectNamedPipe failed with %d.\n", GetLastError()); 
      return 0;
   }


  switch (GetLastError()) 
   { 
   // The overlapped connection in progress. 
      case ERROR_IO_PENDING: 
         fPendingIO = TRUE; 
         break; 
 
   // Client is already connected, so signal an event. 
 
      case ERROR_PIPE_CONNECTED: 
         if (SetEvent(lpo->hEvent)) 
            break; 
 
   // If an error occurs during the connect operation... 
      default: 
      {
         printf("ConnectNamedPipe failed with %d.\n", GetLastError());
         return 0;
      }
   } 
 
   return fPendingIO; 
}

En testant pas à pas quand j'instancie tout mes pipe par le code du précedent message (CreateNamedPipe) puis ConnectToNewClient, J'arrive dans le code cidessus.

Ce qu'il se passe c'est que je passe systématiquement dans le cas : ERROR_PIPE_PENDING. Le setEvent se fait lui dans ERROR_PIPE_CONNECTED donc les resets ne se font que si les pipe sont coneectés donc occupés. logique non?

Je ne fais pas de SetEvent ou ResetEvent avant ça et j'ai testé avec les deux mon premier client n'est jamais detecté (ignoré par le service).

D'autre part, les exemple dans msdn font des createEvent sans faire ResetEvent ou SetEvent derrière. Je vois pas?

Merci!!

Robux

[Médinoc]

Je pense que tu ne fais pas tes ResetEvent() au bon endroit, et que tu as une race condition à cause de ça.

PS: Ça me parait bizarre ton truc: C'est le serveur qui se connecte aux clients?