sendtask.c

来自「软件简介 1.vxworks中有关posix消息队列的一个例子 2.本软件基于c」· C语言 代码 · 共 32 行

/* sendTask.c - mq sending example */ 
 
/* includes */ 
#include "vxWorks.h" 
#include "mqueue.h" 
#include "fcntl.h" 
#include "mqEx.h"
 
/* defines */ 
#define MSG   "greetings" 
#define HI_PRIO 30
 
void sendTask (void) 
    { 
    mqd_t    mqPXId;          /* msg queue descriptor */
 
    /* open msg queue; should already exist with default attributes */ 
    if ((mqPXId = mq_open (MQ_NAME, O_RDWR, 0, NULL)) == (mqd_t) -1) 
        { 
        printf ("sendTask: mq_open failed\n"); 
        return; 
        }
 
    /* try writing to queue */ 
    if (mq_send (mqPXId, MSG, sizeof (MSG), HI_PRIO) == -1) 
        { 
        printf ("sendTask: mq_send failed\n"); 
        return; 
        } 
    else 
        printf ("sendTask: mq_send succeeded\n"); 
    }