Forum | HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop

1064 connectés

FORUM HardWare.fr

C

[C] POSIX message queues : #define MQ_MAXMSG 10 ???

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : [C] POSIX message queues : #define MQ_MAXMSG 10 ???

n°1817208

kaloskagatos

Bonjour à tous,

J'ai écrit un bout de code dans mon appli en utilisant les messages queues fournies par la lib real time (librt) du système sous linux, je teste le bouzin et ça ne marche pas. Je tâtonne, je cherche un peu sur le net, et finalement je découvre que l'API n'autorise l'utilisation que de 10 messages par queue...

Code :

#define MQ_MAXMSG 10

La structure mq_attr permet de définir mq_maxmsg le nombre de message de la queue, si par malheur on en définit plus de 10 mq_open échoue avec un "invalid argument"...

Le #define MQ_MAXMSG n'est documenté nulle part, ce n'est qu'en cherchant sur le net que j'ai trouvé d'autres personnes qui ont rencontré le problème. Le plus étonnant c'est qu'on trouve sur le net d'autres version de la lib qui définissent MQ_MAXMSG à 40, ou à 100. Pourquoi cela n'est-il pas normalisé? Pour ma part mon système possède la librt-2.3.4.so, mais mon appli doit fonctionner sur d'autres machines. Je vais partir sur une autre solution mais j'aurais aimé comprendre cette aberration de fixer un paramètre aussi important dans une lib aussi commune...

Message cité 1 fois

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

mood

Publicité

n°1817464

kaloskagatos

up

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817484

Taz

bisounours-codeur

Attention, ça ne marche que mq_open de changer mq_maxmsg.

Message cité 1 fois

n°1817487

Taz

bisounours-codeur

kaloskagatos a écrit :

Le #define MQ_MAXMSG n'est documenté nulle part, ce n'est qu'en cherchant sur le net que j'ai trouvé d'autres personnes qui ont rencontré le problème. Le plus étonnant c'est qu'on trouve sur le net d'autres version de la lib qui définissent MQ_MAXMSG à 40, ou à 100. Pourquoi cela n'est-il pas normalisé?

Parce que c'est une valeur par défaut sans grande importance ? Si tu veux plus, demande plus.

T'as tout dans le man, y compris le sysctl /proc pour avoir une valeur supérieure à 10.

Message cité 1 fois

n°1817498

kaloskagatos

Taz a écrit :

Attention, ça ne marche que mq_open de changer mq_maxmsg.

Je comprends pas la phrase mq_open plante avec invalid argument :

Code :

struct mq_attr atr;
atr.mq_maxmsg = 11;
atr.mq_msgsize = 1024;
mq_open("/dawa", O_CREAT | O_RDWR , S_IRWXO, &atr);

Taz a écrit :

Parce que c'est une valeur par défaut sans grande importance ? Si tu veux plus, demande plus.

T'as tout dans le man, y compris le sysctl /proc pour avoir une valeur supérieure à 10.

Ok je check baby

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817499

kaloskagatos

Je sais que t'as raison, laisse moi chercher.

Mais en fait ça me fait chier si je dois régler le nombre max de messages depuis le système, en root à tous les coups, c'est pas très user compliant Comment je fais si je veux distribuer mon appli et être sûr que ça plantera pas à l'exécution?

Patapay je cherche toujours le sysctl /proc

Message édité par kaloskagatos le 27-11-2008 à 11:12:16

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817501

Taz

bisounours-codeur

minable ta non-initialisation de struct ... soit fais un memset, soit fais un simple "attr = { 0, 1, 2, 3 };" pour être sur que tous les membres que tu n'initilises pas sont à 0 plutôt qu'à des valeurs délirantes.

Si t'as besoin d'une taille plus grande:
- tu peux la vérifier en lisant /proc ou quand tu crées ta file, tu vois bien si ton open marche avec la valeur que tu demandes ou pas
- quand la file est pleine, ça bloque, à moins que tu mettes un flag pour que ça ne bloque pas, auquel cas, tu peux ressayer plus tard.

Message cité 1 fois

n°1817502

kaloskagatos

>>T'as tout dans le man, y compris le sysctl /proc pour avoir une valeur supérieure à 10.

ok bon ça j'ai pas trouvé où tu l'avais vu dans le man de mq_

sysctl on peut le faire depuis le code, mais bon toucher au noyau c'est pas très à propos dans mon appli, je pense que j'avais fait fausse route en utilisant ça.

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817506

kaloskagatos

Taz a écrit :

minable ta non-initialisation de struct ... soit fais un memset, soit fais un simple "attr = { 0, 1, 2, 3 };" pour être sur que tous les membres que tu n'initilises pas sont à 0 plutôt qu'à des valeurs délirantes.

C'est toi t'es minable [:masklinn]

Taz a écrit :

Si t'as besoin d'une taille plus grande:
- tu peux la vérifier en lisant /proc ou quand tu crées ta file, tu vois bien si ton open marche avec la valeur que tu demandes ou pas
- quand la file est pleine, ça bloque, à moins que tu mettes un flag pour que ça ne bloque pas, auquel cas, tu peux ressayer plus tard.

- Je veux pas vérifier si ma valeur >10 que je demande marche, je veux que ça marche avec 100 messages par file
- HS

Mais merci pour ton intervention, j'y vois plus clair, et je me sens un peu plus crétin :jap:

Message édité par kaloskagatos le 27-11-2008 à 11:23:57

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817510

Taz

bisounours-codeur

Nan mais je pense que ton erreur, c'est juste un bug de données pas initialisée ...

10 ou 100, c'est le même problème, si tu ne gères pas le cas où la file est pleine, ça fera tot ou tard des surprises. C'est dans le manuel, 100 ça ne marchera pas avec les valeurs par défaut système. La taille totale de la file faut pas l'oublier non plus.

mood

Publicité

n°1817513

kaloskagatos

Je vois pas de bug dans mon initialisation :

Code :

struct mq_attr {
long mq_flags; /* Flags: 0 or O_NONBLOCK */
long mq_maxmsg; /* Max. # of messages on queue */
long mq_msgsize; /* Max. message size (bytes) */
long mq_curmsgs; /* # of messages currently in queue */
};

mq_flags ça va changer quelque chose au moment d'envoyer/lire des messages, moi ça plante quand je fais un mq_open avec mq_maxmsg = 11.

mq_curmsgs faut pas l'initialiser si je ne m'abuse.

Je poste mon de code de test

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817520

Taz

bisounours-codeur

Code :

# struct mq_attr atr;
atr.mq_maxmsg = 11;
atr.mq_msgsize = 1024;

Et les autres membres, ils valent quoi ? UB.

Message cité 1 fois

n°1817522

kaloskagatos

avec #define MAXMSG 11 ça plante avec "Ca plante à l'ouverture: Invalid argument"
avec 10 ça passe.
Mon code est beau.

gcc -Wall -pedantic -ansi -lrt mqueue.c

Code :

#include <mqueue.h>
#include <sys/stat.h>
#include <stdio.h>
#include <string.h>
#define MAXMSG 11 /* Nombre maximal de message dans la file */
#define MSGSIZE 256 /* Taille maximale des messages */
#define QNAME "/dawa" /* nom de la file */
#define NBSEND 10 /* Nombre de messages effectifs */
#define SUPERGRAND 1000000 /* taille de buffer */
/* -------------------------------------------------------------------------- */
/* Creation de la queue */
/* -------------------------------------------------------------------------- */
mqd_t init()
{
struct mq_attr mqattr ;
mqd_t qid ;
/* Parametre de l'ouverture de la file */
mqattr.mq_flags = 0;
mqattr.mq_maxmsg = MAXMSG ;
mqattr.mq_msgsize = MSGSIZE ;
mqattr.mq_curmsgs = 0;
/* Suppression d'une eventuelle queue */
if( mq_unlink( QNAME ) == 0 )
printf( "Warning : La file %s a été supprimée.\n", QNAME ) ;
/* Creation de la file */
qid = mq_open( QNAME, O_RDWR | O_CREAT | O_NONBLOCK , S_IRWXO, &mqattr ) ;
if( qid == (mqd_t) -1 )
perror( "Ca plante à l'ouverture" ) ;
return qid ;
}
/* -------------------------------------------------------------------------- */
/* Suppression de la queue */
/* -------------------------------------------------------------------------- */
int close( mqd_t qid )
{
/* Abandon du descripteur */
if( mq_close( qid ) )
{
perror( "Ca plante à la fermeture, mais c'est pas vrai !" ) ;
return 1 ;
}
/* Suppression effective de la queue */
if( mq_unlink( QNAME ) )
{
perror( "Ca plante à la destruction de la queue" ) ;
return 1 ;
}
return 0 ;
}
/* -------------------------------------------------------------------------- */
/* Envoi */
/* -------------------------------------------------------------------------- */
int send( mqd_t id )
{
char *msg = "Ceci est un texte toujours plus long que lg" ;
if( mq_send( id, msg, strlen(msg), 0 ) )
{
perror( "Ca plante à l'envoi nondidiou" ) ;
return 1 ;
}
return 0 ;
}
/* -------------------------------------------------------------------------- */
/* Reception */
/* -------------------------------------------------------------------------- */
int receive( mqd_t qid )
{
char buffer[SUPERGRAND] ;
mqd_t retVal ;
/* Reception d'un message */
retVal = mq_receive( qid, buffer, SUPERGRAND, NULL ) ;
if( retVal < 1 )
{
perror( "Nous avons rencontré un problème sérieux." ) ;
printf( "ben ouais, on a lu %d octets\n", retVal ) ;
return 1 ;
}
printf( "On a lu %d octets sans problème\n", retVal ) ;
return 0 ;
}
/* -------------------------------------------------------------------------- */
/* Main ! */
/* -------------------------------------------------------------------------- */
int main( int argc, char **argv )
{
mqd_t qid ;
unsigned i ;
/* Ouverture de la mqueue de m... */
qid = init() ;
if( qid == (mqd_t) -1 )
return 1 ;
printf( "Init Ok. En attente du feu vert go ouais.\n" ) ;
getchar() ;
/* Envoi effectif */
for( i=0; i < NBSEND ; ++i )
{
if( send( qid ) )
{
printf( "La foirage arrive à l'envoi %u\n", i ) ;
return 1 ;
}
}
printf( "Send Ok. En attente du feu vert go ouais.\n" ) ;
getchar() ;
for( i=0; i < NBSEND ; ++i )
{
if( receive( qid ) )
{
printf( "La foirage arrive à la récepcheune %u\n", i ) ;
return 1 ;
}
}
printf( "Receive Ok. En attente du feu vert go ouais.\n" ) ;
getchar() ;
/* Fermeture qui plante ou pas */
return close( qid ) ;
}

Message édité par kaloskagatos le 27-11-2008 à 11:44:07

n°1817523

Taz

bisounours-codeur

1) et le flag, il prend quelle valeur ?
2) voir premier message. Il faut augmenter la limite système.

Message cité 1 fois

n°1817526

Taz

bisounours-codeur

'tain t'es chaud de créer ta propre fonction send ... man 2 send

Message cité 1 fois

n°1817527

kaloskagatos

J'ai tout initialisé mais sans succès

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817530

Taz

bisounours-codeur

Et quand je te parlais de taille de file.

SUPERGRAND 1000000

ça fait du bon bourrage de pile par la suite. Etant donné que la taille des messages/files est bien plus petite que ça

Message cité 1 fois

n°1817531

kaloskagatos

Taz a écrit :

1) et le flag, il prend quelle valeur ?
2) voir premier message. Il faut augmenter la limite système.

1) on s'en fout du flag, il sert pas à l'ouverture mais à l'envoi
2) c'est bien ce que j'avais compris, je veux pas toucher au système donc c'est DMC.

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817534

Taz

bisounours-codeur

Et manie le perror/strerror/errno pour pouvoir qualifier les -1 retournés, sinon tu peux pas savoir pourquoi ça ne marche pas.

Message cité 1 fois

n°1817536

kaloskagatos

Taz a écrit :

Et quand je te parlais de taille de file.

SUPERGRAND 1000000

ça fait du bon bourrage de pile par la suite. Etant donné que la taille des messages/files est bien plus petite que ça

On s'en fout aussi, c'était pour mes tests perso, bien évidemment ceci n'est pas le logiciel que je développe professionnellement pour mon employeur.

Message cité 1 fois

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817538

Taz

bisounours-codeur

1) ok j'avais pas lu. Ca reste pas idiot d'utiliser généralement la syntaxe d'initialisation.

Je comprends pas pourquoi tu bloques vraiment sur la taille de la file. Si elle est pleine, bah tu bloques dessus jusqu'à qu'un autre processus la vide.

Message cité 1 fois

n°1817539

kaloskagatos

Taz a écrit :

'tain t'es chaud de créer ta propre fonction send ... man 2 send

je rêve ou tu me parles de socket là? J'ai pas écrit de fonction send, y'a rien dedans.

Taz a écrit :

Et manie le perror/strerror/errno pour pouvoir qualifier les -1 retournés, sinon tu peux pas savoir pourquoi ça ne marche pas.

Comme je l'ai dit mon code est magnifique

Message cité 1 fois

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817541

Taz

bisounours-codeur

kaloskagatos a écrit :

On s'en fout aussi, c'était pour mes tests perso, bien évidemment ceci n'est pas le logiciel que je développe professionnellement pour mon employeur.

Bah on s'en fout oui et non, à force de faire des trucs foireux/baclés pour tester, ça devient dur de savoir si ton test marche ou pas.

n°1817543

kaloskagatos

Taz a écrit :

1) ok j'avais pas lu. Ca reste pas idiot d'utiliser généralement la syntaxe d'initialisation.

Je comprends pas pourquoi tu bloques vraiment sur la taille de la file. Si elle est pleine, bah tu bloques dessus jusqu'à qu'un autre processus la vide.

Parce que je bosse sur un simulateur temps réel qui n'a pas le temps d'attendre que la file se vide. Donc j'en reviens à la conclusion que cette API n'est pas faite pour moi.

Message cité 1 fois

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817547

Taz

bisounours-codeur

kaloskagatos a écrit :

je rêve ou tu me parles de socket là? J'ai pas écrit de fonction send, y'a rien dedans.

(T'as aussi écrit une close. C'est des mauvaises habitudes à ne pas prendre sinon un jour tu le feras vraiment et tu comprendras jamais pourquoi ça marche pas).

Message cité 1 fois

n°1817549

Taz

bisounours-codeur

kaloskagatos a écrit :

Parce que je bosse sur un simulateur temps réel qui n'a pas le temps d'attendre que la file se vide. Donc j'en reviens à la conclusion que cette API n'est pas faite pour moi.

Bah t'as le flag d'open et le flag de receives/send qui te permet de ne pas attendre

Message cité 1 fois
Message édité par Taz le 27-11-2008 à 11:53:45

n°1817551

kaloskagatos

Taz a écrit :

(T'as aussi écrit une close. C'est des mauvaises habitudes à ne pas prendre sinon un jour tu le feras vraiment et tu comprendras jamais pourquoi ça marche pas).

J'ai pas compris, qu'est-ce que j'ai fait ?

Taz a écrit :

Bah t'as le flag d'open et le flag de receives/send qui te permet de ne pas attendre

Oui mais ne pas attendre signifie que le send échoue et qu'il faut revenir poster les messages qui ne sont pas passés, moi j'aimerais poster tous mes messages pis continuer à faire autre chose quoi.

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817567

Taz

bisounours-codeur

Je comprends, mais si tu penses comme ça, tu vas avoir le problème tous les appels systèmes et fonctions qui se sont pas async (à commencer par le moindre read ou write).

Soit tu gères dans une boucle le fait que la file soit pleine, soit tu le traites dans un autre thread ou dans un sous-programme chargé de poster.

C'est sans fin comme problème.

Empiler encore et encore côté envoyeur, ça ne résout pas forcément ton problème puisque y a forcément une limite à un moment et c'est un peu inquiétant que ça ne vide pas au bon rythme en face ?

C'est du producteur/consommateur de base en IPC: mq, pipe ou autre le système est pas là pour stocker tous tes messages. Il te donne de tuyaux de taille fixe, si tu veux bufferiser plus, il faut que tu le fasses toi même côté utilisateur.

n°1817583

kaloskagatos

J'ai compris ce que tu m'expliques, mais dans mon cas le nombre de messages envoyés a une limite max, c'est dans la spec.

De plus je ne suis pas rentré dans le détail dans mon post mais pour le moment je n'ai qu'un seul processus, l'envoi se fait à t0 et la réception se fait à t1 dans un callback appelé par un échéancier. En bref je me suis fourvoyé avec cette lib, je vais utiliser un buffer circulaire et pis ça ira tout seul.

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817589

Taz

bisounours-codeur

Ca c'est sur que si c'est pas threadé ni multiprocessé, c'est pas bien la peine de sortir faire de l'IPC. Si ça se trouve, t'as peut-être meme pas besoin de synchronisation.

Comme tu dis, un pauvre buffer, de la synchro comme il faut, et ça doit se faire tout seul. Réfléchi bien à la synchro si c'est 2 thread qui communiquent pour faire quelque chose d'intelligent

n°1817595

kaloskagatos

Bein c'est parce que potentiellement un jour ce sera multithreadé que j'ai utilisé ça, donc je voulais déjà le valider.

Bon bein thx

Message cité 1 fois

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1817599

Taz

bisounours-codeur

kaloskagatos a écrit :

Bein c'est parce que potentiellement un jour ce sera multithreadé que j'ai utilisé ça, donc je voulais déjà le valider.

Bon bein thx

c'est pour de la comme entre processus ça.

n°1817751

kaloskagatos

c'est ce que je voulais dire

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1818228

kaloskagatos

Taz a écrit :

Code :

# struct mq_attr atr;
atr.mq_maxmsg = 11;
atr.mq_msgsize = 1024;

Et les autres membres, ils valent quoi ? UB.

Au fait ça veut dire quoi UB? Tu m'as insulté? :fou:

---------------
« Le hasard, c’est différent de la chance. Parce que la chance, je n'en ai jamais. »

n°1818230

babarpapa

Tu te fous de la gueule de mon pote?

Message cité 1 fois

n°1818268

Taz

bisounours-codeur

babarpapa a écrit :

Tu te fous de la gueule de mon pote?

suce moi papa!

mood

Publicité

Ajouter une réponse

FORUM HardWare.fr

C

[C] POSIX message queues : #define MQ_MAXMSG 10 ???

Sujets relatifs
Préprocesseur C	[C] J'essaye de me faire une petite bibliothèques de fonction avec SDL
tri fusion en C	Listing des différences avec le C++
[C] Problème de lecture dans un fichier en C : fscanf	[C] Bataille navale, sauvegarde/restauration.
[C] Comment faire un getchar() sans pause après	[débutant][questionalacon] scanf et chaîne de caractères
[C] Opérations avec des matrices	[Résolu] Problème pour lire et écrire des fichiers pgm en C++
Plus de sujets relatifs à : [C] POSIX message queues : #define MQ_MAXMSG 10 ???

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo

Page générée en 0.083 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR