forked from Imagelibrary/rtems
6a0898bba3
PR 1291/cpukit * itron/inline/rtems/itron/semaphore.inl, itron/src/twai_sem.c, posix/include/mqueue.h, posix/include/rtems/posix/mqueue.h, posix/include/rtems/posix/semaphore.h, posix/include/rtems/posix/time.h, posix/src/condtimedwait.c, posix/src/mqueuereceive.c, posix/src/mqueuerecvsupp.c, posix/src/mqueuesend.c, posix/src/mqueuesendsupp.c, posix/src/mqueuetimedreceive.c, posix/src/mqueuetimedsend.c, posix/src/mutextimedlock.c, posix/src/mutextranslatereturncode.c, posix/src/posixtimespecabsolutetimeout.c, posix/src/prwlocktimedrdlock.c, posix/src/prwlocktimedwrlock.c, posix/src/semaphoretranslatereturncode.c, posix/src/semaphorewaitsupp.c, posix/src/semtimedwait.c, posix/src/semtrywait.c, posix/src/semwait.c, posix/src/sigtimedwait.c, posix/src/timersettime.c, posix/src/ualarm.c, rtems/src/semobtain.c, rtems/src/semtranslatereturncode.c, score/include/rtems/score/coremutex.h, score/include/rtems/score/coresem.h, score/src/coresemseize.c: This patch addresses issues on implementation of the timeout on the following POSIX services. Some of these services incorrectly took a timeout as a relative time. Others would compute a 0 delta to timeout if the absolute time and the current time were equal and thus incorrectly block the caller forever. The root of the confusion is that POSIX specifies that if the timeout is incorrect (e.g. in the past, is now, or is numerically invalid), that it does not matter if the call would succeed without blocking. This is in contrast to RTEMS programming style where all errors are checked before any critical sections are entered. This fix implemented a more uniform way of handling POSIX absolute time timeouts. + pthread_cond_timedwait - could block forever + mq_timedreceive - used relative not absolute time + mq_timedsend - used relative not absolute time + pthread_mutex_timedlock - used relative not absolute time + pthread_rwlock_timedrdlock- used relative not absolute time + pthread_rwlock_timedwrlock- used relative not absolute time + sem_timedwait - could block forever
170 lines
3.0 KiB
C
170 lines
3.0 KiB
C
/**
|
|
* @file mqueue.h
|
|
*/
|
|
|
|
/*
|
|
* COPYRIGHT (c) 1989-2008.
|
|
* 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
|
|
*/
|
|
|
|
/**
|
|
* Message queue id type
|
|
*/
|
|
typedef Objects_Id mqd_t;
|
|
|
|
/**
|
|
* This is the message queue attributes structure.
|
|
*/
|
|
struct mq_attr {
|
|
/** This is the message queue flags */
|
|
long mq_flags;
|
|
/** This is the maximum number of messages */
|
|
long mq_maxmsg;
|
|
/** This is the maximum message size */
|
|
long mq_msgsize;
|
|
/** This is the mumber of messages currently queued */
|
|
long mq_curmsgs;
|
|
};
|
|
|
|
/**
|
|
* 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 *abstime
|
|
);
|
|
|
|
#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 *abstime
|
|
);
|
|
|
|
#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 */
|