File de messages

Version imprimable

File de messages

Bonjour,
j'ai besoin d'échanger entre deux processus (1 writer, 1 reader), je teste les files de messages.
Le code du writer:

Code:

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
 
struct Msgbuf {
    long mtype;       /* message type, must be > 0 */
    char mtext[128];    /* message data */
};
 
int main()
{
    int msgq;   //message queue identifier
    key_t cle;
 
    cle = ftok(PATH, PROJ_ID);
    if(cle < 0) {
        perror("ftok");
        exit(EXIT_FAILURE);
    }
 
    msgq = msgget(cle, 0660 | IPC_CREAT);
    if(msgq < 0) {
        perror("msgget");
        exit(EXIT_FAILURE);
    }
 
    struct Msgbuf msgbuf;
    msgbuf.mtype = 1;
 
    strcpy(msgbuf.mtext, "Hello");
    msgsnd(msgq, &msgbuf, sizeof(struct Msgbuf), 0);
    printf("Sent %s\n", msgbuf.mtext);
    usleep(1000000);
 
    msgbuf.mtype = 2;
    strcpy(msgbuf.mtext, "You !!!");
    msgsnd(msgq, &msgbuf, sizeof(struct Msgbuf), 0);
    printf("Sent %s\n", msgbuf.mtext);
 
    printf("Enter key to continue: ");
    getchar();
    msgctl(msgq, IPC_RMID, NULL);
    exit(EXIT_SUCCESS);
}

Le code du reader:

Code:

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
 
struct Msgbuf {
    long mtype;       /* message type, must be > 0 */
    char mtext[128];    /* message data */
};
 
int main()
{
    int msgq;   //message queue identifier
    key_t cle;
    struct Msgbuf msgbuf;
    int nb_octets;
 
    cle = ftok(PATH, PROJ_ID);
    if(cle < 0) {
        perror("ftok");
        exit(EXIT_FAILURE);
    }
 
    msgq = msgget(cle, 0660 | IPC_CREAT);
    if(msgq < 0) {
        perror("msgget");
        exit(EXIT_FAILURE);
    }
 
    printf("Waiting for message...\n");
    do {
        nb_octets = 0;
        nb_octets = msgrcv(msgq, &msgbuf, sizeof(struct Msgbuf), 0, MSG_NOERROR);
        printf("%d %s\n", nb_octets, msgbuf.mtext);
        if(nb_octets < 0) {
            perror("msgrcv");
            break;
        }
    }while(msgbuf.mtype > 0);
 
    printf("Fin du lecteur.\n");
    exit(EXIT_SUCCESS);
}

Côté reader, 136 "Hello" est affiché puis plus rien jusqu'à ce que côté writer on appuie sur une touche du clavier.
Le reader répond par -1 "Hello" encore une fois. Apparemment "You !!!" n'arrive jamais puis "msgrcv: Identifier removed" puisque le reader clôt la file.
Que manque t-il à mon code?
Merci pour votre aide...

19/02/2020, 21h54
Sve@r

Bonjour

Citation:

Envoyé par rdtech

Que manque t-il à mon code?

La taille passée en second paramètre de msgsnd() ne doit pas inclure celle de "mtype". En demandant à envoyer plus d'octets que nécessaire, la fonction va chercher plus d'octets et dépasse la zone réservée à Msgbuf => comportement indéterminé.
Remplace msgsnd(msgq, &msgbuf, sizeof(struct Msgbuf), 0) par msgsnd(msgq, &msgbuf, sizeof(msgbuf.mtext), 0). Mis à part ce détail, chez-moi ton code fonctionne (il fonctionne aussi tel que tu l'as écrit à l'origine mais justement c'est ça un comportement indéterminé => parfois ça marche).
Pour msgrcv() c'est moins grave car la fonction récupère "au plus" la taille demandée donc s'il y a moins que demandé c'est pas grave. Mais bon si tu peux faire les choses bien ici aussi...
20/02/2020, 11h51
rdtech

Bonjour Sve@r et merci.
C'était bien l'erreur et ça fonctionne maintenant.
Mais il me reste une interrogation:
côté msgrcv(), la page de man dit: "Si msgtyp est supérieur à 0, alors le premier message de type msgtyp est extrait de la file". msgsnd ne transmet pas le type du message, comment peut elle extraire le message correspondant dans la file?

Si tu as une réponse, je suis intéressé.
Merci.
20/02/2020, 16h52
Sve@r

Citation:

Envoyé par rdtech

Mais il me reste une interrogation:
côté msgrcv(), la page de man dit: "Si msgtyp est supérieur à 0, alors le premier message de type msgtyp est extrait de la file". msgsnd ne transmet pas le type du message, comment peut elle extraire le message correspondant dans la file?

La partie rouge de ta phrase est incorrecte. msgsnd() reçoit en paramètre un pointeur de type msgbuf donc elle a accès à tout msgbuf. Il n'y a aucune raison qu'elle n'envoie pas mtype à la msq.
Ce n'est pas parce que dans la taille tu ne prends pas en compte la taille "mtype" que cette info n'est pas intégrée automatiquement par msgsnd()...
24/02/2020, 18h01
rdtech

Ok, good !! C'est clair maintenant.
C'est le sizeof() dans msgsnd() qui m'a induis en erreur.
Merci Sve@r pour tes explications.