Select et list/FIFO.

**Baradhur** · 28/01/2011, 13h23

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** · 28/01/2011, 17h17

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.

Envoyé par man 7 mq_overview

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** · 31/01/2011, 14h18

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** · 31/01/2011, 14h39

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** · 01/02/2011, 17h35

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** · 01/02/2011, 18h55

Envoyé par 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.

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).

**Baradhur** · 02/02/2011, 15h18

Merci pour toutes ces precisions! Je pense que j'ai tout ce qu'il me faut maintenant

**Baradhur** · 03/02/2011, 11h18

Je me permet de poser une derniere question, j'ai du mal a trouver la reponse en cherchant sur le net.

Dans le cas des MQ du system 5, il faut detruire les MQ avec une fonction specifique, sinon elle reste ouverte meme apres etre sorti du programme. Pour les MQ POSIX, il existe mq_close, mais il ne fait que fermer le file descriptor.

Est ce qu'il faut comprendre qu'il detruit par la meme la message queue precedement creer? Ou est ce qu'il existe une autre fonction qui permet de definitivement supprimer l'ensemble?

Merci d'avance!

edit: J'ai fini par trouver a force de chercher, il faut utiliser mq_unlink pour la fermer definitivement. ^^

**Emmanuel Deloget** · 03/02/2011, 11h36

Normallement, fermer tous les descripteurs de fichiers sur la MQ détruit également cette MQ. mq_unlink() a un effet différent en fait : elle supprime le nom de la MQ, mais ne la ferme pas - il est possible de continuer à l'utiliser, à moins que je ne me trompe.

A noter que mon exemple ne gère pas les permissions sur la MQ lors de l'appel à mq_open(). Il peut être utile de les spécifier de manière explicite.

**Baradhur** · 03/02/2011, 11h51

Je viens de finir mon programme de test qui marche tout bien avec cette nouvelle version des mq. Malheureusement, je suis toujours bloquer sur mon select...

Dans mon programme principale, je cree ma mq, je pose 3 messages dessus, ensuite je fork. Dans le fils, je fais un exec, et a l'interieur, je recupere les 3 messages sans problemes. Ensuite je fais un send a l'interieur de mon exec. Dans le pere, a la fin du wait, je fais un mq_receive, je recois bien le message, pas de probleme.

Mais quand j'essaye de rajouter un select sur mon FD de mq, ben il bloque et rien ne se passe. j'ai mis un sleep pour etre sur qu'on arrive pas sur l'envoie avant que le pere bloque sur le select. Mais rien ne se passe, le programme ne bouge pas sur le select... Peut etre aussi que j'utilise mal ledit select?

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
 
int main()
{
  struct mq_attr attr;
  mqd_t mq;
 
  attr.mq_maxmsg = 20;
  attr.mq_msgsize = 64;
  attr.mq_flags = 0;
  attr.mq_curmsgs = 0;
 
 mq = mq_open("/ma_queue", (O_RDWR | O_CREAT | O_NONBLOCK), 00666, &attr);
  memset(&attr, 0, sizeof(attr));
  mq_getattr(mq, &attr);
 
  string buf = "TEST TRANSFER";
  mq_send(mq, buf.c_str(), attr.mq_msgsize, 0);
  mq_send(mq, "TEST 2 OMG", (sizeof(char)*64), 0);
  mq_send(mq, "TEST 3 OMFG", (sizeof(char)*64), 0);
 
 
  int rc, i;
  rc = fork();
  if (rc == 0)
    {
      cout << "debut du fils" << endl;
      execv("/home/baradhur/test/thread/thread", NULL);
    }
  else
    {
 
      fd_set read;
      FD_ZERO(&read);
      FD_SET(mq, &read);
      std::cout << "juste avant le select" << std::endl;
      select (mq, &read, NULL, NULL, NULL);
      wait(&i);
      std::cout << "juste apres le wait" << std::endl;
      char *buffer = new char[64];
      mq_receive(mq, buffer, 64, NULL);
      perror("mq_receive apres select");
      cout << "recu de elsewhere : " << buffer << endl;
     }
}

Voici le code dans le exec:

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
 
int main()
{ 
  mqd_t mq;                                                          
  struct mq_attr attr;
  sleep(1);                                
 
  mq = mq_open("/ma_queue", (O_RDWR | O_CREAT), 00666, NULL);
 
  memset(&attr, 0, sizeof(attr));
  mq_getattr(mq, &attr);
 
  char *buffer = new char[64];
  int r = mq_receive(mq, buffer, 64, NULL);
  cout << "test IPC 1: " << buffer << endl;
  r = mq_receive(mq, buffer, 64, NULL);
  cout << "test IPC 2: " << buffer << endl;
  r = mq_receive(mq, buffer, 64, NULL);
  cout << "test IPC 3: " << buffer << endl;
 
  mq_send(mq, "TEST RENVOIE", (sizeof(char)*64), 0);
  perror("send from elsewhere");
  mq_close(mq);
  return (0);
}

Je me sentirais bete si ca marchais pas pour debloquer le select dans ce cas la aussi

edit: Je suis un boulet

j'avais pas bien fait mon appel au select!
select (mq + 1, &read, NULL, NULL, NULL);
Manquait le petit +1... Ca a l'air de marcher tout bien maintenant! Une petite confirmation du meme resultat chez quelqu'un d'autre serait pas de refus

**Emmanuel Deloget** · 03/02/2011, 14h49

Code :

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

1
2
select (mq + 1, &read, NULL, NULL, NULL);

Il faut comprendre que select() construit un tableau dont les indices sont les fd qui sont renseignés dans les sets qui lui sont en paramètre. Le premier paramètre est la taille du plus grand des tableaux (donc équal au max(fd1,...,fdn) + 1).

En outre, à chaque fois que tu attends un message, tu dois attendre au moins attr.mq_msgsize bytes, qui n'est pas nécessairement ce que tu as souhaité (une fois débloqués tes appels à mq_receive, tout se passent beaucoup mieux). Sur mon système, je demande une taille de message de 64 bytes, mais le système me donne une taille de message de 8192 bytes (donc attendre 64 bytes va nécessairement échouer).

J'ai corrigé tes erreurs, voici l'archive contenant les programmes et un script pour les builder. Il suffit de lancer ./build.sh && ./pere pour voir le résultat.

**Baradhur** · 03/02/2011, 16h07

Hey ben, on peut dire que ca c'est du coup de main o_O Merci beaucoup lol Jamais ete aussi bien accompagne

J'ai bien regarder ce que tu m'avais passer, j'ai bien compris l'ensemble des choses que tu m'a expliquer, j'ai fini l'implémentation dans mon programme, et je suis en phase de test pour vérifier que tout va bien

Merci encore pour ton aide précieuse!

Select et list/FIFO.

Langage C++

Discussions similaires

Partager

Partager