forked from Imagelibrary/rtems
feaa007839
* posix/preinstall.am, posix/include/aio.h, posix/include/devctl.h, posix/include/mqueue.h, posix/include/sched.h, posix/include/semaphore.h, posix/include/rtems/posix/cancel.h, posix/include/rtems/posix/priority.h, posix/include/rtems/posix/psignal.h, posix/include/rtems/posix/threadsup.h, posix/include/rtems/posix/timer.h, posix/inline/rtems/posix/priority.inl, posix/src/barrierattrdestroy.c, posix/src/barrierattrgetpshared.c, posix/src/barrierattrinit.c, posix/src/barrierattrsetpshared.c, posix/src/cancel.c, posix/src/cancelrun.c, posix/src/cleanuppop.c, posix/src/cleanuppush.c, posix/src/cond.c, posix/src/condattrdestroy.c, posix/src/condattrgetpshared.c, posix/src/condattrinit.c, posix/src/condattrsetpshared.c, posix/src/condbroadcast.c, posix/src/conddefaultattributes.c, posix/src/conddestroy.c, posix/src/condinit.c, posix/src/condsignal.c, posix/src/condsignalsupp.c, posix/src/condwait.c, posix/src/condwaitsupp.c, posix/src/key.c, posix/src/keycreate.c, posix/src/keydelete.c, posix/src/keygetspecific.c, posix/src/keyrundestructors.c, posix/src/keysetspecific.c, posix/src/mqueue.c, posix/src/mqueueclose.c, posix/src/mqueuecreatesupp.c, posix/src/mqueuedeletesupp.c, posix/src/mqueuegetattr.c, posix/src/mqueuenametoid.c, posix/src/mqueuenotify.c, posix/src/mqueueopen.c, posix/src/mqueuereceive.c, posix/src/mqueuerecvsupp.c, posix/src/mqueuesend.c, posix/src/mqueuesendsupp.c, posix/src/mqueuesetattr.c, posix/src/mqueueunlink.c, posix/src/mutex.c, posix/src/mutexattrdestroy.c, posix/src/mutexattrgetprioceiling.c, posix/src/mutexattrgetprotocol.c, posix/src/mutexattrgetpshared.c, posix/src/mutexattrinit.c, posix/src/mutexattrsetprioceiling.c, posix/src/mutexattrsetprotocol.c, posix/src/mutexattrsetpshared.c, posix/src/mutexdefaultattributes.c, posix/src/mutexdestroy.c, posix/src/mutexgetprioceiling.c, posix/src/mutexlock.c, posix/src/mutexlocksupp.c, posix/src/mutexsetprioceiling.c, posix/src/mutextrylock.c, posix/src/mutexunlock.c, posix/src/psignal.c, posix/src/psignalchecksignal.c, posix/src/psignalclearprocesssignals.c, posix/src/psignalclearsignals.c, posix/src/psignalsetprocesssignals.c, posix/src/psignalunblockthread.c, posix/src/ptimer.c, posix/src/rwlockattrdestroy.c, posix/src/rwlockattrgetpshared.c, posix/src/rwlockattrinit.c, posix/src/rwlockattrsetpshared.c, posix/src/semaphore.c, posix/src/semaphoredeletesupp.c, posix/src/semaphorenametoid.c, posix/src/semaphorewaitsupp.c, posix/src/semclose.c, posix/src/semdestroy.c, posix/src/semgetvalue.c, posix/src/seminit.c, posix/src/semopen.c, posix/src/sempost.c, posix/src/semtrywait.c, posix/src/semunlink.c, posix/src/semwait.c, posix/src/setcancelstate.c, posix/src/setcanceltype.c, posix/src/sysconf.c, posix/src/testcancel.c: Add missing copyright statements.
164 lines
2.8 KiB
C
164 lines
2.8 KiB
C
/**
|
|
* @file mqueue.h
|
|
*/
|
|
|
|
/*
|
|
* COPYRIGHT (c) 1989-2007.
|
|
* On-Line Applications Research Corporation (OAR).
|
|
*
|
|
* The license and distribution terms for this file may be
|
|
* found in the file LICENSE in this distribution or at
|
|
* http://www.rtems.com/license/LICENSE.
|
|
*
|
|
* $Id$
|
|
*/
|
|
|
|
#ifndef _MQUEUE_H
|
|
#define _MQUEUE_H
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
#include <unistd.h>
|
|
|
|
#if defined(_POSIX_MESSAGE_PASSING)
|
|
|
|
#include <sys/types.h>
|
|
|
|
#include <rtems/system.h>
|
|
#include <rtems/score/object.h>
|
|
|
|
/*
|
|
* 15.1.1 Data Structures, P1003.1b-1993, p. 271
|
|
*/
|
|
|
|
typedef Objects_Id mqd_t;
|
|
|
|
struct mq_attr {
|
|
long mq_flags; /* Message queue flags */
|
|
long mq_maxmsg; /* Maximum number of messages */
|
|
long mq_msgsize; /* Maximum message size */
|
|
long mq_curmsgs; /* Number of messages currently queued */
|
|
};
|
|
|
|
/*
|
|
* 15.2.2 Open a Message Queue, P1003.1b-1993, p. 272
|
|
*/
|
|
|
|
mqd_t mq_open(
|
|
const char *name,
|
|
int oflag,
|
|
...
|
|
);
|
|
|
|
/*
|
|
* 15.2.2 Close a Message Queue, P1003.1b-1993, p. 275
|
|
*/
|
|
|
|
int mq_close(
|
|
mqd_t mqdes
|
|
);
|
|
|
|
/*
|
|
* 15.2.2 Remove a Message Queue, P1003.1b-1993, p. 276
|
|
*/
|
|
|
|
int mq_unlink(
|
|
const char *name
|
|
);
|
|
|
|
/*
|
|
* 15.2.4 Send a Message to a Message Queue, P1003.1b-1993, p. 277
|
|
*
|
|
* NOTE: P1003.4b/D8, p. 45 adds mq_timedsend().
|
|
*/
|
|
|
|
int mq_send(
|
|
mqd_t mqdes,
|
|
const char *msg_ptr,
|
|
size_t msg_len,
|
|
unsigned int msg_prio
|
|
);
|
|
|
|
#if defined(_POSIX_TIMEOUTS)
|
|
|
|
#include <time.h>
|
|
|
|
int mq_timedsend(
|
|
mqd_t mqdes,
|
|
const char *msg_ptr,
|
|
size_t msg_len,
|
|
unsigned int msg_prio,
|
|
const struct timespec *timeout
|
|
);
|
|
|
|
#endif /* _POSIX_TIMEOUTS */
|
|
|
|
/*
|
|
* 15.2.5 Receive a Message From a Message Queue, P1003.1b-1993, p. 279
|
|
*
|
|
* NOTE: P1003.4b/D8, p. 45 adds mq_timedreceive().
|
|
*/
|
|
|
|
ssize_t mq_receive(
|
|
mqd_t mqdes,
|
|
char *msg_ptr,
|
|
size_t msg_len,
|
|
unsigned int *msg_prio
|
|
);
|
|
|
|
#if defined(_POSIX_TIMEOUTS)
|
|
|
|
ssize_t mq_timedreceive(
|
|
mqd_t mqdes,
|
|
char *msg_ptr,
|
|
size_t msg_len,
|
|
unsigned int *msg_prio,
|
|
const struct timespec *timeout
|
|
);
|
|
|
|
#endif /* _POSIX_TIMEOUTS */
|
|
|
|
#if defined(_POSIX_REALTIME_SIGNALS)
|
|
|
|
/*
|
|
* 15.2.6 Notify Process that a Message is Available on a Queue,
|
|
* P1003.1b-1993, p. 280
|
|
*/
|
|
|
|
int mq_notify(
|
|
mqd_t mqdes,
|
|
const struct sigevent *notification
|
|
);
|
|
|
|
#endif /* _POSIX_REALTIME_SIGNALS */
|
|
|
|
/*
|
|
* 15.2.7 Set Message Queue Attributes, P1003.1b-1993, p. 281
|
|
*/
|
|
|
|
int mq_setattr(
|
|
mqd_t mqdes,
|
|
const struct mq_attr *mqstat,
|
|
struct mq_attr *omqstat
|
|
);
|
|
|
|
/*
|
|
* 15.2.8 Get Message Queue Attributes, P1003.1b-1993, p. 283
|
|
*/
|
|
|
|
int mq_getattr(
|
|
mqd_t mqdes,
|
|
struct mq_attr *mqstat
|
|
);
|
|
|
|
#endif /* _POSIX_MESSAGE_PASSING */
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
#endif
|
|
/* end of include file */
|