include/native/mutex.h

Go to the documentation of this file.

#ifndef _XENO_MUTEX_H
#define _XENO_MUTEX_H

#include <nucleus/synch.h>
#include <native/types.h>

struct rt_task;

typedef struct rt_mutex_info {

        int lockcnt;            /* !< Lock nesting level (> 0 means "locked"). */

        int nwaiters;           /* !< Number of pending tasks. */

        char name[XNOBJECT_NAME_LEN]; /* !< Symbolic name. */

} RT_MUTEX_INFO;

typedef struct rt_mutex_placeholder {
        xnhandle_t opaque;
} RT_MUTEX_PLACEHOLDER;

#if defined(__KERNEL__) || defined(__XENO_SIM__)

#define XENO_MUTEX_MAGIC 0x55550505

typedef struct __rt_mutex {

        unsigned magic;         /* !< Magic code - must be first */

        xnsynch_t synch_base;   /* !< Base synchronization object. */

        xnhandle_t handle;      /* !< Handle in registry -- zero if unregistered. */

        struct rt_task *owner;  /* !< Current mutex owner. */

        int lockcnt;            /* !< Lock nesting level (> 0 means "locked"). */
        
        char name[XNOBJECT_NAME_LEN]; /* !< Symbolic name. */

#if defined(__KERNEL__) && defined(CONFIG_XENO_OPT_PERVASIVE)
        pid_t cpid;             /* !< Creator's pid. */
#endif /* __KERNEL__ && CONFIG_XENO_OPT_PERVASIVE */

} RT_MUTEX;

#ifdef __cplusplus
extern "C" {
#endif

int __native_mutex_pkg_init(void);

void __native_mutex_pkg_cleanup(void);

#ifdef __cplusplus
}
#endif

#else /* !(__KERNEL__ || __XENO_SIM__) */

typedef RT_MUTEX_PLACEHOLDER RT_MUTEX;

#ifdef __cplusplus
extern "C" {
#endif

int rt_mutex_bind(RT_MUTEX *mutex,
                  const char *name,
                  RTIME timeout);

static inline int rt_mutex_unbind (RT_MUTEX *mutex)

{
        mutex->opaque = XN_NO_HANDLE;
        return 0;
}

#ifdef __cplusplus
}
#endif

#endif /* __KERNEL__ || __XENO_SIM__ */

#ifdef __cplusplus
extern "C" {
#endif

/* Public interface. */

int rt_mutex_create(RT_MUTEX *mutex,
                    const char *name);

int rt_mutex_delete(RT_MUTEX *mutex);

int rt_mutex_acquire(RT_MUTEX *mutex,
                     RTIME timeout);

int rt_mutex_release(RT_MUTEX *mutex);

int rt_mutex_inquire(RT_MUTEX *mutex,
                     RT_MUTEX_INFO *info);

#ifdef __KERNEL__
#if LINUX_VERSION_CODE < KERNEL_VERSION(2,6,18)
static inline int __deprecated_call__ rt_mutex_lock(RT_MUTEX *mutex, RTIME timeout)
{
        return rt_mutex_acquire(mutex, timeout);
}

static inline int __deprecated_call__ rt_mutex_unlock(RT_MUTEX *mutex)
{
        return rt_mutex_release(mutex);
}
#endif /* LINUX_VERSION_CODE < KERNEL_VERSION(2,6,18) */
#else /* !__KERNEL__ */

int rt_mutex_lock(RT_MUTEX *mutex,
                  RTIME timeout);

int rt_mutex_unlock(RT_MUTEX *mutex);

#endif /* __KERNEL__ */

#ifdef __cplusplus
}
#endif

#endif /* !_XENO_MUTEX_H */

---