diff options
Diffstat (limited to 'PACE/pace/posix/mqueue.inl')
| -rw-r--r-- | PACE/pace/posix/mqueue.inl | 62 |
1 files changed, 38 insertions, 24 deletions
diff --git a/PACE/pace/posix/mqueue.inl b/PACE/pace/posix/mqueue.inl index 2459563e9b3..aaa951c0863 100644 --- a/PACE/pace/posix/mqueue.inl +++ b/PACE/pace/posix/mqueue.inl @@ -13,75 +13,89 @@ * * ============================================================================= */ -#if (PACE_HAS_POSIX_NONUOF_FUNCS) PACE_INLINE int -pace_mq_close (pace_mqd_t mqdes) +pace_mq_close (mqd_t mqdes) { +# if defined (PACE_HAS_RT) return mq_close (mqdes); +# else /* !PACE_HAS_RT */ + PACE_RETURN_NO_SUPPORT (PACE_ERRNO_LACKS_RT); +# endif /* !PACE_HAS_RT */ } -#endif /* PACE_HAS_POSIX_NONUOF_FUNCS */ -#if (PACE_HAS_POSIX_NONUOF_FUNCS) PACE_INLINE int -pace_mq_getattr (pace_mqd_t mqdes, - pace_mq_attr * mqstat) +pace_mq_getattr (mqd_t mqdes, + struct mq_attr * mqstat) { +# if defined (PACE_HAS_RT) return mq_getattr (mqdes, mqstat); +# else /* !PACE_HAS_RT */ + PACE_RETURN_NO_SUPPORT (PACE_ERRNO_LACKS_RT); +# endif /* !PACE_HAS_RT */ } -#endif /* PACE_HAS_POSIX_NONUOF_FUNCS */ -#if (PACE_HAS_POSIX_NONUOF_FUNCS) PACE_INLINE int -pace_mq_notify (pace_mqd_t mqdes, - const pace_sigevent * notification) +pace_mq_notify (mqd_t mqdes, + const struct sigevent * notification) { +# if defined (PACE_HAS_RT) return mq_notify (mqdes, notification); +# else /* !PACE_HAS_RT */ + PACE_RETURN_NO_SUPPORT (PACE_ERRNO_LACKS_RT); +# endif /* !PACE_HAS_RT */ } -#endif /* PACE_HAS_POSIX_NONUOF_FUNCS */ -#if (PACE_HAS_POSIX_NONUOF_FUNCS) PACE_INLINE ssize_t -pace_mq_receive (pace_mqd_t mqdes, +pace_mq_receive (mqd_t mqdes, char * msg_ptr, size_t msg_len, unsigned int * msg_prio) { +# if defined (PACE_HAS_RT) return mq_receive (mqdes, msg_ptr, msg_len, msg_prio); +# else /* !PACE_HAS_RT */ + PACE_RETURN_NO_SUPPORT (PACE_ERRNO_LACKS_RT); +# endif /* !PACE_HAS_RT */ } -#endif /* PACE_HAS_POSIX_NONUOF_FUNCS */ -#if (PACE_HAS_POSIX_NONUOF_FUNCS) PACE_INLINE int -pace_mq_send (pace_mqd_t mqdes, +pace_mq_send (mqd_t mqdes, const char * msg_ptr, size_t msg_len, unsigned int msg_prio) { +# if defined (PACE_HAS_RT) return mq_send (mqdes, msg_ptr, msg_len, msg_prio); +# else /* !PACE_HAS_RT */ + PACE_RETURN_NO_SUPPORT (PACE_ERRNO_LACKS_RT); +# endif /* !PACE_HAS_RT */ } -#endif /* PACE_HAS_POSIX_NONUOF_FUNCS */ -#if (PACE_HAS_POSIX_NONUOF_FUNCS) PACE_INLINE int -pace_mq_setattr (pace_mqd_t mqdes, - const pace_mq_attr * mqstat, - pace_mq_attr * omqstat) +pace_mq_setattr (mqd_t mqdes, + const struct mq_attr * mqstat, + struct mq_attr * omqstat) { +# if defined (PACE_HAS_RT) return mq_setattr (mqdes, mqstat, omqstat); +# else /* !PACE_HAS_RT */ + PACE_RETURN_NO_SUPPORT (PACE_ERRNO_LACKS_RT); +# endif /* !PACE_HAS_RT */ } -#endif /* PACE_HAS_POSIX_NONUOF_FUNCS */ -#if (PACE_HAS_POSIX_NONUOF_FUNCS) PACE_INLINE int pace_mq_unlink (const char * name) { +# if defined (PACE_HAS_RT) return mq_unlink (name); +# else /* !PACE_HAS_RT */ + PACE_RETURN_NO_SUPPORT (PACE_ERRNO_LACKS_RT); +# endif /* !PACE_HAS_RT */ } -#endif /* PACE_HAS_POSIX_NONUOF_FUNCS */ |