Discussion :

[Baradhur]

Bonjour a tous!

Je viens vers vous pour un probleme de select. En effet, j'ai un programme qui fait communiquer different processus entre eux a travers des IPC. Des messages queues pour etre precis. (Ca peut s'apparenter a des listes).

Ma question est: Est il possible d'utiliser un select pour savoir quand des elements ont ete rajouter sur cette FIFO? Et plus généralement avec les list de la STL?


Si ca fonctionnait, ca me permettrait de faire un truc vachement plus propre! A moins que vous ayez une solution plus classe a proposer, je suis aussi preneur

Merci d'avance pour vos reponses!

edit: Petit precision de taille, je suis sous linux pour coder ^^

[Emmanuel Deloget]

Si ce sont des message queue POSIX et non pas des messages queues System V, et que tu es bien sous Linux, alors oui, les messages queues sont pollables.

On Linux, a message queue descriptor is actually a file descriptor, and can be monitored using select(2), poll(2), or epoll(7). This is not portable.

(le gras est de moi)

[Baradhur]

Ben j'ai essaye de faire un programme de test. Dans un programme pere, je creer ma message queue, je push dessus, je fork un autre programme avec un exec, ou je recois les message. Et donc dans le pere je fais un select sur le fd de la MQ, et je push dans mon autre programme. Et ca ne debloque pas le select.. Je sais pas d'ou ca vient!

Aurais tu un exemple de code qui fonctionne? a tout hazard ^^

[Emmanuel Deloget]

Non, je n'ai pas de code, mais ça devrait parcher tout seul. Peux tu poster ton code à toi ?

Edit: confirme quand même un point : tu utilises bien une MQ Linux (mq_open(), mq_receive()...), et pas une MQ System V (msgget,...)

[Baradhur]

Hey bien j'ai utiliser le system V avec les msgget etc. Je ne comprend pas pourquoi ca ne fonctionne pas avec un le fd d'un system V. En plus, dans ts les exemples que j'avais pu trouver (tu me dira j'avais ptet pas assez chercher), c'etait avec le system V, et aucun avec mq_open etc. J'en avais meme jamais entendu parler,c'est pour dire...

Il faut que je refasse mon truc avec des mq_open alors? Ca marche de la meme facon que le system V? (Si tu a un site avec des exemples, je suis preneur)

en tout cas, merci de tes interventions, tu m'aide beaucoup! Je comprend vraiment pas pourquoi les fd des msgget ne fonctionne pas avec le select.

[Emmanuel Deloget]

Hey bien j'ai utiliser le system V avec les msgget etc. Je ne comprend pas pourquoi ca ne fonctionne pas avec un le fd d'un system V. En plus, dans ts les exemples que j'avais pu trouver (tu me dira j'avais ptet pas assez chercher), c'etait avec le system V, et aucun avec mq_open etc. J'en avais meme jamais entendu parler,c'est pour dire...

Il faut que je refasse mon truc avec des mq_open alors? Ca marche de la meme facon que le system V? (Si tu a un site avec des exemples, je suis preneur)

en tout cas, merci de tes interventions, tu m'aide beaucoup! Je comprend vraiment pas pourquoi les fd des msgget ne fonctionne pas avec le select.

Il me semble que les IPC System V ne renvoient pas des fd, mais des identifiants - qui ne sont pas partagés avec les processus fils. Je ne suis pas sûr à 100% de ça (sauf en ce qui concerne la partie "pas partagé" )

Pour récupérer une mq ouverte dans un processus père, il faut refaire un msgctl() avec la clef spécifiée dans le père.

Sinon, man 7 mq_overview

Une MQ ouverte avec mq_open pointe bien sur un fd, lui, et ce fd est hérité par tous les processus fils.

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
48
49
50
51
52
53
54
55
56
57
58
59
60
 
#include <fcntl.h>
#include <sys/stat.h>
#include <mqueue.h>
#include <unistd.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
 
// link avec -lrt
 
int main()
{
  char *buffer;
  mqd_t mq;
  pid_t pid;
  int r;
  struct mq_attr attr;
 
  mq = mq_open("/ma_message_queue", O_RDWR|O_CREAT);
  if (mq == (mqd_t)(-1)) { perror("mq_open"); exit(-1); }
  memset(&attr, 0, sizeof(attr));
  mq_getattr(mq, &attr);
  pid = fork();
  if (pid < 0)
  {
    mq_close(mq);
    perror("fork");
    exit(-2);
  }
  else if (pid == 0)
  {
    // child process
    mq_send(mq, "test", 5, 0);
    exit(0);
  }
  else
  {
    waitpid(pid,NULL,0);
 	buffer = malloc(attr.mq_msgsize);
    r = mq_receive(mq, buffer, attr.mq_msgsize, NULL);
    if (r > 0)
    {
    	printf("message = %s\n", buffer);
    }
    else if (r == 0)
    {
    	printf("no message received\n");
    }
    else
    {
    	perror("mq_receive");
    }
    free(buffer);
    mq_close(mq);
    return 0;
  }
}

C'est écrit en C, mais on peut écrire de même en C++ (en beaucoup plus court, en fait).