Discussion :

[DrTank]

Bonjour,

J'éssai désespérément de créer un file de messages. Bon la créer ce n'est pas le problème, sauf que j'ai l'impression qu'elle ne reçoit aucun message.. D'ailleurs je specifie un nombre max de messages pourtant je peux lui en envoyer plus..Idem avec la taille d'un message. il me semblait que ca devait provoquer une erreur non ?

Je laisse le code au cas ou quelqu'un est assez familier avec ca

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
 
#include <unistd.h>
#include <mqueue.h>
#include <stdio.h>
#include <signal.h>
#include <string.h>
#include <sys/types.h>
#include <stdlib.h>
 
int main(int argc, char ** argv){
	int i=0;
	mqd_t mq;
 
	struct mq_attr attr;
	struct mq_attr live_attr;
	//struct sigaction sa;
 
	attr.mq_maxmsg = 5;
	attr.mq_msgsize = 30;
	attr.mq_flags = 0;
	attr.mq_curmsgs = 0;
 
	char buff[100];
	strcpy(buff, "TRANX");
	int msgsize = 100;
 
 
 
	if (mq = mq_open("/queue", O_CREAT | O_RDWR | O_EXCL, 0666, attr) == -1){
		perror("Error : message queue ");
		mq_unlink("/queue");
		exit(1);
	}
 
 
	while(i!=10){
		mq_send(mq, buff, msgsize, 1);
		mq_getattr(mq, &attr);
		printf("nbre msg : %d\n",attr.mq_curmsgs);
		printf("max msg : %d\n",attr.mq_maxmsg);
		printf("%d \n",i);
		i++;
	}
	mq_unlink("/queue");
}

[mchk0123]

Qu'est ce que entend par erreur ?

Tu ne vérifie même pas si mq_send et mq_get_attr renvoi un code d'erreur !
Donc surement que si car msgsize utilisé dans mq_send >>> à msgsize utilisé dans mq_open

[DrTank]

ah exact, j'ai donc fait la modif et l'erreur générée par le mq_send est 'Bad file descriptor' pourtant le mq_open ne me renvoie pas d'erreur ..

[Foobar1329]

Hello,

Bonjour,

J'éssai désespérément de créer un file de messages. Bon la créer ce n'est pas le problème, sauf que j'ai l'impression qu'elle ne reçoit aucun message.. D'ailleurs je specifie un nombre max de messages pourtant je peux lui en envoyer plus..Idem avec la taille d'un message. il me semblait que ca devait provoquer une erreur non ?

Je laisse le code au cas ou quelqu'un est assez familier avec ca

Code :

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

1
2
3
4
 
	char buff[100];
	strcpy(buff, "TRANX");
	int msgsize = 100;

msgsize ne sert à rien, sizeof(buff)/sizeof(*buff) serait plus propre au cas où tu déciderais de changer de taille de buffer.

Code :

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

1
2
 
	if (mq = mq_open("/queue", O_CREAT | O_RDWR | O_EXCL, 0666, attr) == -1){

Belle, belle !! Faut arrêter de programmer trop tar le soir, la bad file descriptor est potentiellement justifié ici. Il ne manque pas des parenthèses ?

Tu affectes à mq le résultat de la comparason entre le retour de mq_open et -1 et non le retour de mq_open.

Code :

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

1
2
if ( (mq = mq_open("/queue", O_CREAT | O_RDWR | O_EXCL, 0666, attr)) == (mqd_t)-1)

Et voilà, tu dois bien avoir un bad file descriptor et il ne te reste plus qu'à scruter errno pour voir pourquoi.

A+

[DrTank]

Ahhh bien vu c'était effictivement ca... tout fonctionne maintenant, merci


edit : En revanche quand je fais un printf de attr.mq_maxmsg il m'affiche 10 alors que ce n'est pas ce que je lui ai spécifié. Meme apres un mq_setattr avec une valeur differente il m'affiche 10, c'est à n'y rien comprendre..

[DrTank]

up

[mchk0123]

Merci de cliquer sur le bouton quand on à trouvé la solution.

[DrTank]

bah oui mais il reste un petit probleme que je n'arrive pas a résoudre..