Vous êtes dans : GNU/Linux Astuces / Pages man [Section3 - Sous-fonctions]

MQ_NOTIFY

Index

1. NOM
2. SYNOPSIS
3. DESCRIPTION
4. VALEUR RENVOYÉE
5. ERREURS
6. CONFORMITÉ À
7. EXEMPLE
8. VOIR AUSSI
9. TRADUCTION

NOM

SYNOPSIS

#include <mqueue.h>

mqd_t mq_notify(mqd_t mqdes, const struct sigevent *notification);

DESCRIPTION

union sigval {                /* Données passées avec la notification */
    int     sival_int;        /* Entier */
    void   *sival_ptr;        /* Pointeur */
};

struct sigevent {
    int    sigev_notify;      /* Notification method */
    int    sigev_signo;       /* Notification signal */
    union sigval sigev_value; /* Data passed with notification */
    void (*sigev_notify_function) (union sigval);
                              /* Function for thread notification */
    void  *sigev_notify_attributes;
                              /* Thread function attributes */
};

SIGEV_NONE

Une notification « null » : le processus appelant est enregistré comme destinataire des notifications, mais aucune notification n'est envoyée lorsqu'un message arrive.

SIGEV_SIGNAL

Notifier le processus en envoyant le signal spécifié dans sigev_signo. Si le signal est attrapé par un gestionnaire de signaux qui a été enregistré avec sigaction(2) et le drapeau SA_SIGINFO, alors les champs suivants sont définis dans la structure siginfo_t qui est passée en second argument du gestionnaire : si_code est défini à SI_MESGQ ; si_signo est défini au numéro du signal ; si_pid est défini au pid du processus qui a envoyé le message ; et si_uid est défini à l'uid du processus qui a envoyé le message. Les mêmes informations sont disponibles si le signal est accepté avec sigwaitinfo(2).

SIGEV_THREAD

Délivrer des notifications en invoquant <notification->sigev_thread_function> comme fonction de démarrage d'un nouveau thread. La fonction est invoquée avec notification->sigev_value comme seul argument. Si notification->sigev_notify_attributes est non NULL, alors elle doit pointer vers une structure pthread_attr_t qui définit les attributs du thread.

VALEUR RENVOYÉE

ERREURS

EBADF

Le descripteur spécifié dans mqdes n'est pas valable.

EBUSY

Un autre processus est déjà enregistré pour recevoir les notifications de cette file de messages.

EINVAL

notification->sigev_notify n'est pas l'une des valeurs permises ; ou notification->sigev_notify vaut SIGEV_SIGNAL et notification->sigev_signo n'est pas un numéro de signal valable.

ENOMEM

Pas assez de mémoire.

CONFORMITÉ À

EXEMPLE

#include <pthread.h>
#include <mqueue.h>
#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

#define die(msg) { perror(msg); exit(EXIT_FAILURE); }

static void                     /* Thread start function */
tfunc(union sigval sv)
{
    struct mq_attr attr;
    ssize_t nr;
    void *buf;
    mqd_t mqdes = *((mqd_t *) sv.sival_ptr);

    /* Determine max. msg size; allocate buffer to receive msg */

    if (mq_getattr(mqdes, &attr) == -1) die("mq_getattr");
    buf = malloc(attr.mq_msgsize);
    if (buf == NULL) die("malloc");

    nr = mq_receive(mqdes, buf, attr.mq_msgsize, NULL);
    if (nr == -1) die("mq_receive");

    printf("Read %ld bytes from MQ, (long) nr);
    free(buf);
    exit(EXIT_SUCCESS);         /* Terminate the process */
}

int
main(int argc, char *argv[])
{
    mqd_t mqdes;
    struct sigevent not;

    assert(argc == 2);

    mqdes = mq_open(argv[1], O_RDONLY);
    if (mqdes == (mqd_t) -1) die("mq_open");

    not.sigev_notify = SIGEV_THREAD;
    not.sigev_notify_function = tfunc;
    not.sigev_notify_attributes = NULL;
    not.sigev_value.sival_ptr = &mqdes; /* Arg. vers la fonction du proc. */
    if (mq_notify(mqdes, &not) == -1) die("mq_notify");

    pause();    /* Le processus sera terminé par la fonction du proc. */
}

VOIR AUSSI

TRADUCTION