Discussion :

[d'Oursse]

J'ai utilise un pipe anonyme pour faire de la redirection standard entrée / sortie et, naïf que je suis, j'ai utilisé WaitForMultipleObjects pour attendre l'arrivee de donnée avec le HANDLE du pipe

Le code marchait plus ou moins bien (l'attente est aléatoire).

Après quelques recherches, il semble que WaitForMultipleObjects ne fonctionne pas avec les pipes (en tout cas, la doc mentionne les HANDLE qui sont gérés par cette fonction, et les pipes ne sont pas mentionnés, ce qui au passage me semble vraiment stupide).

Apparemment, les pipes nommés peuvent être gérés par cette fonction (en utilisant le mode overlap et un event). Je voulais savoir si il est possible de faire en sorte que les pipes anonymes puissent être gérés par WaitForMultipleObjects, par un moyen détournés (un event, ou tout autre moyen)

Au passage, je dois utiliser WaitForMultipleObjects (utilisé dans un framework, pour un lancement de callback quand une donnée arrive dans le pipe).

merci

[Melem]

Si tu veux attendre l'arrivée de données t'as qu'à faire un simple ReadFile ! ReadFile est déjà par défaut bloquante, je ne vois pas pourquoi tu es allé chercher des complications de ce genre.

[d'Oursse]

je me cite :

Au passage, je dois utiliser WaitForMultipleObjects (utilisé dans un framework, pour un lancement de callback quand une donnée arrive dans le pipe).

en gros, je n'ai pas le choix... Il faut que j'utilise WaitForMultipleObjects, qui est utilise dans la main loop de notre bibliotheque

[Melem]

Désolé, c'est vrai que je n'ai pas bien compris le problème. Dans ce cas on change un peu : ReadFile asynchrone (overlapped) sur chaque pipe et passer les handles d'event à WaitForMultipleObject.

[d'Oursse]

Je ne connais pas très bien tout ce système d'event / overlap. Est-ce que je dois faire ceci :

1) ev <-- CreateEvent
2) overlapped.hEvent <-- ev
3) je passe ev à WaitForMultipleObjects
4) une fois que WaitForMultipleObjects a retourné, je fais un while (1) { ReadFile(pipe, overlapped) } ?

ou bien

a) ev <-- CreateEvent
b) overlapped.hEvent <-- ev
c) je fais un ReadFile(pipe, overlapped) et je stocke ce qui est lu s'il y a des données
d) je passe ev à WaitForMultipleObjects
e) une fois que WaitForMultipleObjects a retourné, je fais un while (1) { ReadFile(pipe, overlapped) + realloc avec ce qui a été stocké précédemment} ?

Ce qui me gêne dans le premier cas, c'est qu'il n'y a aucun lien entre ev passé à WaitForMultipleObjects, et le ReadFile ou le pipe.

[Melem]

La 2, sauf que c) doit être placé dans une boucle et dans e) un GetOverlappedResult doit immédiatement suivre le WaitForMultipleObjects pour connaître le résultat du dernier ReadFile. après tu fais ce que tu veux.

[d'Oursse]

pour le c), une boucle du style

Code :

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

1
2
3
4
5
6
7
8
while (1)
{
  char buf[BUFSIZE];

  if (ReadFile(pipe, buf, sizeof(buf), NULL, overlapped))
    break ;
}

?

Si oui, c'est gênant car elle est bloquante.

[Melem]

Oui mais là buf n'existe plus dès que tu quittes la boucle, tu devras arranger de ce côté. T'as qu'à mettre la boucle dans un thread à part entière et il n'y a plus le problème de blocage.

[d'Oursse]

dans un autre thread qui est lié à celui ci :

http://www.developpez.net/forums/m5005077-3/

mon edit me laisse perplexe quant l'utilisation des tubes anonymes et GetOverlappedResult().

Edit: d'ailleurs la doc de cette fonction mentionne "Retrieves the results of an overlapped operation on the specified file, named pipe, or communications device."

Edit2 : pas le choix, je fais du synchrone... Résolu pour moi.